|
此版本仍在开发中,尚未被视为稳定版本。如需最新稳定版本,请使用 Spring Boot 4.0.4! |
调用 REST 服务
Spring Boot 提供了多种方便的方式来调用远程 REST 服务。
如果您正在开发非阻塞的响应式应用程序并且使用 Spring WebFlux,那么可以使用 WebClient。
如果您更喜欢命令式 API,那么可以使用 RestClient 或 RestTemplate。
WebClient
如果您的类路径上有 Spring WebFlux,我们建议您使用 WebClient 来调用远程 REST 服务。
WebClient 接口提供了一种函数式风格的 API,并且是完全响应式的。
您可以在 Spring Framework 文档的专用 章节 中了解更多关于 WebClient 的信息。
如果你不是在编写响应式 Spring WebFlux 应用程序,可以使用 RestClient 而不是 WebClient。
这提供了一个类似的函数式 API,但它是命令式的而不是响应式的。 |
Spring Boot 会为您创建并预配置一个原型 WebClient.Builder Bean。
强烈建议您将其注入到您的组件中,并使用它来创建 WebClient 实例。
Spring Boot 正在配置该构建器以共享 HTTP 资源,并以与服务器端相同的方式反映编解码器设置(请参阅 WebFlux HTTP 编解码器自动配置)等。
以下代码展示了一个典型的示例:
-
Java
-
Kotlin
import reactor.core.publisher.Mono;
import org.springframework.stereotype.Service;
import org.springframework.web.reactive.function.client.WebClient;
@Service
public class MyService {
private final WebClient webClient;
public MyService(WebClient.Builder webClientBuilder) {
this.webClient = webClientBuilder.baseUrl("https://example.org").build();
}
public Mono<Details> someRestCall(String name) {
return this.webClient.get().uri("/{name}/details", name).retrieve().bodyToMono(Details.class);
}
}
import org.springframework.stereotype.Service
import org.springframework.web.reactive.function.client.WebClient
import reactor.core.publisher.Mono
@Service
class MyService(webClientBuilder: WebClient.Builder) {
private val webClient: WebClient
init {
webClient = webClientBuilder.baseUrl("https://example.org").build()
}
fun someRestCall(name: String): Mono<Details> {
return webClient.get().uri("/{name}/details", name)
.retrieve().bodyToMono(Details::class.java)
}
}
WebClient 运行时
Spring Boot 将根据应用程序类路径上可用的库,自动检测要使用哪个 ClientHttpConnector 来驱动 WebClient。
按优先顺序,支持以下客户端:
-
Reactor Netty
-
Jetty RS 客户端
-
Apache HttpClient
-
JDK HttpClient
如果类路径上存在多个客户端,将使用优先级最高的客户端。
spring-boot-starter-webflux starter 默认依赖于 io.projectreactor.netty:reactor-netty,后者同时提供了服务器端和客户端的实现。
如果你选择使用 Jetty 作为响应式服务器,则应添加对 Jetty 响应式 HTTP 客户端库 org.eclipse.jetty:jetty-reactive-httpclient 的依赖。
对服务器端和客户端使用相同的技术具有优势,因为它会自动在客户端和服务器之间共享 HTTP 资源。
开发人员可以通过提供自定义的 ReactorResourceFactory 或 JettyResourceFactory Bean 来覆盖 Jetty 和 Reactor Netty 的资源配置 - 这将应用于客户端和服务器端。
如果您希望为客户端覆盖该选择,您可以定义自己的 ClientHttpConnector bean,并完全控制客户端配置。
您可以从Spring框架参考文档中了解更多关于<a t="C1"><code>0</code>配置选项的信息</a>。
全局 HTTP 连接器配置
如果自动检测到的 ClientHttpConnector 不符合您的需求,您可以使用 spring.http.clients.reactive.connector 属性来选择特定的连接器。
例如,如果您的类路径上有 Reactor Netty,但您更喜欢 Jetty 的 HttpClient,则可以添加以下内容:
-
Properties
-
YAML
spring.http.clients.reactive.connector=jetty
spring:
http:
clients:
reactive:
connector: jetty
| 你也可以使用 全局配置属性,这些属性适用于所有 HTTP 客户端。 |
对于更复杂的自定义,您可以使用 ClientHttpConnectorBuilderCustomizer 或声明您自己的 ClientHttpConnectorBuilder bean,这将导致自动配置回退。
当您需要自定义底层 HTTP 库的某些内部组件时,这非常有用。
例如,以下代码将使用配置了特定 ProxySelector 的 JDK 客户端:
-
Java
-
Kotlin
import java.net.ProxySelector;
import org.springframework.boot.http.client.reactive.ClientHttpConnectorBuilder;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
@Configuration(proxyBeanMethods = false)
public class MyConnectorHttpConfiguration {
@Bean
ClientHttpConnectorBuilder<?> clientHttpConnectorBuilder(ProxySelector proxySelector) {
return ClientHttpConnectorBuilder.jdk().withHttpClientCustomizer((builder) -> builder.proxy(proxySelector));
}
}
import org.springframework.boot.http.client.reactive.ClientHttpConnectorBuilder
import org.springframework.context.annotation.Bean
import org.springframework.context.annotation.Configuration
import java.net.ProxySelector
@Configuration(proxyBeanMethods = false)
class MyConnectorHttpConfiguration {
@Bean
fun clientHttpConnectorBuilder(proxySelector: ProxySelector): ClientHttpConnectorBuilder<*> {
return ClientHttpConnectorBuilder.jdk().withHttpClientCustomizer { builder -> builder.proxy(proxySelector) }
}
}
WebClient 自定义
根据您希望自定义应用的广泛程度,主要有三种WebClient自定义方法。
为了尽可能缩小自定义的范围,请注入自动配置的 WebClient.Builder,然后根据需要调用其方法。
WebClient.Builder 实例是有状态的:对构建器的任何更改都会反映在随后使用它创建的所有客户端中。
如果您想使用同一个构建器创建多个客户端,还可以考虑使用 WebClient.Builder other = builder.clone(); 克隆该构建器。
要对所有 WebClient.Builder 实例进行应用程序范围的附加自定义,您可以声明 WebClientCustomizer bean,并在注入点本地更改 WebClient.Builder。
最后,您可以回退到原始 API 并使用 WebClient.create()。
在这种情况下,不会应用任何自动配置或 WebClientCustomizer。
WebClient SSL 支持
如果您需要在 ClientHttpConnector 上使用自定义 SSL 配置,可以注入一个可以与构建器的 apply 方法一起使用的 WebClientSsl 实例。
WebClientSsl 接口提供对您已在 application.properties 或 application.yaml 文件中定义的任何 SSL bundles 的访问。
以下代码展示了一个典型的示例:
-
Java
-
Kotlin
import reactor.core.publisher.Mono;
import org.springframework.boot.webclient.autoconfigure.WebClientSsl;
import org.springframework.stereotype.Service;
import org.springframework.web.reactive.function.client.WebClient;
@Service
public class MyService {
private final WebClient webClient;
public MyService(WebClient.Builder webClientBuilder, WebClientSsl ssl) {
this.webClient = webClientBuilder.baseUrl("https://example.org").apply(ssl.fromBundle("mybundle")).build();
}
public Mono<Details> someRestCall(String name) {
return this.webClient.get().uri("/{name}/details", name).retrieve().bodyToMono(Details.class);
}
}
import org.springframework.boot.webclient.autoconfigure.WebClientSsl
import org.springframework.stereotype.Service
import org.springframework.web.reactive.function.client.WebClient
import reactor.core.publisher.Mono
@Service
class MyService(webClientBuilder: WebClient.Builder, ssl: WebClientSsl) {
private val webClient: WebClient
init {
webClient = webClientBuilder.baseUrl("https://example.org")
.apply(ssl.fromBundle("mybundle")).build()
}
fun someRestCall(name: String): Mono<Details> {
return webClient.get().uri("/{name}/details", name)
.retrieve().bodyToMono(Details::class.java)
}
}
RestClient
如果您的应用程序未使用 Spring WebFlux 或 Project Reactor,我们建议您使用 RestClient 来调用远程 REST 服务。
RestClient 接口提供了一种函数式风格的命令式 API。
Spring Boot 会为您创建并预配置一个原型 RestClient.Builder Bean。
强烈建议您将其注入到您的组件中,并使用它来创建 RestClient 实例。
Spring Boot 会使用 HttpMessageConverters 和适当的 ClientHttpRequestFactory 来配置该构建器。
以下代码展示了一个典型的示例:
-
Java
-
Kotlin
import org.springframework.stereotype.Service;
import org.springframework.web.client.RestClient;
@Service
public class MyService {
private final RestClient restClient;
public MyService(RestClient.Builder restClientBuilder) {
this.restClient = restClientBuilder.baseUrl("https://example.org").build();
}
public Details someRestCall(String name) {
return this.restClient.get().uri("/{name}/details", name).retrieve().body(Details.class);
}
}
import org.springframework.boot.docs.io.restclient.restclient.ssl.Details
import org.springframework.stereotype.Service
import org.springframework.web.client.RestClient
@Service
class MyService(restClientBuilder: RestClient.Builder) {
private val restClient: RestClient
init {
restClient = restClientBuilder.baseUrl("https://example.org").build()
}
fun someRestCall(name: String): Details {
return restClient.get().uri("/{name}/details", name)
.retrieve().body(Details::class.java)!!
}
}
RestClient 自定义
根据您希望自定义应用的广泛程度,主要有三种RestClient自定义方法。
为了尽可能缩小自定义的范围,请注入自动配置的 RestClient.Builder,然后根据需要调用其方法。
RestClient.Builder 实例是有状态的:对构建器的任何更改都会反映在随后使用它创建的所有客户端中。
如果您想使用同一个构建器创建多个客户端,还可以考虑使用 RestClient.Builder other = builder.clone(); 克隆该构建器。
要对所有 RestClient.Builder 实例进行应用程序范围的附加自定义,您可以声明 RestClientCustomizer bean,并在注入点本地更改 RestClient.Builder。
最后,您可以回退到原始 API 并使用 RestClient.create()。
在这种情况下,不会应用任何自动配置或 RestClientCustomizer。
| 您可以更改 全局 HTTP 客户端配置。 |
RestClient SSL 支持
如果您需要在 ClientHttpRequestFactory 上使用自定义 SSL 配置,可以注入一个可以与构建器的 apply 方法一起使用的 RestClientSsl 实例。
RestClientSsl 接口提供对您已在 application.properties 或 application.yaml 文件中定义的任何 SSL bundles 的访问。
以下代码展示了一个典型的示例:
-
Java
-
Kotlin
import org.springframework.boot.restclient.autoconfigure.RestClientSsl;
import org.springframework.stereotype.Service;
import org.springframework.web.client.RestClient;
@Service
public class MyService {
private final RestClient restClient;
public MyService(RestClient.Builder restClientBuilder, RestClientSsl ssl) {
this.restClient = restClientBuilder.baseUrl("https://example.org").apply(ssl.fromBundle("mybundle")).build();
}
public Details someRestCall(String name) {
return this.restClient.get().uri("/{name}/details", name).retrieve().body(Details.class);
}
}
import org.springframework.boot.docs.io.restclient.restclient.ssl.settings.Details
import org.springframework.boot.restclient.autoconfigure.RestClientSsl
import org.springframework.stereotype.Service
import org.springframework.web.client.RestClient
@Service
class MyService(restClientBuilder: RestClient.Builder, ssl: RestClientSsl) {
private val restClient: RestClient
init {
restClient = restClientBuilder.baseUrl("https://example.org")
.apply(ssl.fromBundle("mybundle")).build()
}
fun someRestCall(name: String): Details {
return restClient.get().uri("/{name}/details", name)
.retrieve().body(Details::class.java)!!
}
}
如果除了 SSL 捆绑包之外,您还需要应用其他自定义配置,可以将 HttpClientSettings 类与 ClientHttpRequestFactoryBuilder 结合使用:
-
Java
-
Kotlin
import java.time.Duration;
import org.springframework.boot.http.client.ClientHttpRequestFactoryBuilder;
import org.springframework.boot.http.client.HttpClientSettings;
import org.springframework.boot.ssl.SslBundles;
import org.springframework.http.client.ClientHttpRequestFactory;
import org.springframework.stereotype.Service;
import org.springframework.web.client.RestClient;
@Service
public class MyService {
private final RestClient restClient;
public MyService(RestClient.Builder restClientBuilder, SslBundles sslBundles) {
HttpClientSettings settings = HttpClientSettings.ofSslBundle(sslBundles.getBundle("mybundle"))
.withReadTimeout(Duration.ofMinutes(2));
ClientHttpRequestFactory requestFactory = ClientHttpRequestFactoryBuilder.detect().build(settings);
this.restClient = restClientBuilder.baseUrl("https://example.org").requestFactory(requestFactory).build();
}
public Details someRestCall(String name) {
return this.restClient.get().uri("/{name}/details", name).retrieve().body(Details.class);
}
}
import org.springframework.boot.http.client.ClientHttpRequestFactoryBuilder;
import org.springframework.boot.http.client.HttpClientSettings
import org.springframework.boot.ssl.SslBundles
import org.springframework.stereotype.Service
import org.springframework.web.client.RestClient
import java.time.Duration
@Service
class MyService(restClientBuilder: RestClient.Builder, sslBundles: SslBundles) {
private val restClient: RestClient
init {
val settings = HttpClientSettings.defaults()
.withReadTimeout(Duration.ofMinutes(2))
.withSslBundle(sslBundles.getBundle("mybundle"))
val requestFactory = ClientHttpRequestFactoryBuilder.detect().build(settings);
restClient = restClientBuilder
.baseUrl("https://example.org")
.requestFactory(requestFactory).build()
}
fun someRestCall(name: String): Details {
return restClient.get().uri("/{name}/details", name).retrieve().body(Details::class.java)!!
}
}
RestTemplate
Spring Framework 的 RestTemplate 类在 RestClient 之前就已存在,是许多应用程序调用远程 REST 服务的经典方式。
当您有不需要迁移到 RestTemplate 的现有代码,或者因为您已经熟悉 RestClient API 时,可以选择使用 RestTemplate。
由于 RestTemplate 实例在使用前通常需要进行自定义,Spring Boot 不提供任何单一自动配置的 RestTemplate bean。
不过,它会自动配置一个 RestTemplateBuilder,可用于在需要时创建 RestTemplate 实例。
自动配置的 RestTemplateBuilder 确保将合理的 HttpMessageConverters 和适当的 ClientHttpRequestFactory 应用于 RestTemplate 实例。
以下代码展示了一个典型的示例:
-
Java
-
Kotlin
import org.springframework.boot.restclient.RestTemplateBuilder;
import org.springframework.stereotype.Service;
import org.springframework.web.client.RestTemplate;
@Service
public class MyService {
private final RestTemplate restTemplate;
public MyService(RestTemplateBuilder restTemplateBuilder) {
this.restTemplate = restTemplateBuilder.build();
}
public Details someRestCall(String name) {
return this.restTemplate.getForObject("/{name}/details", Details.class, name);
}
}
import org.springframework.boot.restclient.RestTemplateBuilder
import org.springframework.stereotype.Service
import org.springframework.web.client.RestTemplate
@Service
class MyService(restTemplateBuilder: RestTemplateBuilder) {
private val restTemplate: RestTemplate
init {
restTemplate = restTemplateBuilder.build()
}
fun someRestCall(name: String): Details {
return restTemplate.getForObject("/{name}/details", Details::class.java, name)!!
}
}
RestTemplateBuilder 包含许多有用的方法,可用于快速配置 RestTemplate。
例如,要添加 BASIC 身份验证支持,您可以使用 builder.basicAuthentication("user", "password").build()。
RestTemplate 自定义
根据您希望自定义应用的广泛程度,主要有三种RestTemplate自定义方法。
为了将任何自定义的范围尽可能缩小,请注入自动配置的 RestTemplateBuilder,然后根据需要调用其方法。
每次方法调用都会返回一个新的 RestTemplateBuilder 实例,因此自定义仅影响此构建器的此次使用。
要进行应用程序范围的附加自定义,请使用 RestTemplateCustomizer bean。
所有此类 bean 都会自动注册到自动配置的 RestTemplateBuilder 中,并应用于使用它构建的任何模板。
以下示例展示了一个自定义器,它配置为除 192.168.0.5 之外的所有主机都使用代理:
-
Java
-
Kotlin
import org.apache.hc.client5.http.classic.HttpClient;
import org.apache.hc.client5.http.impl.classic.HttpClientBuilder;
import org.apache.hc.client5.http.impl.routing.DefaultProxyRoutePlanner;
import org.apache.hc.client5.http.routing.HttpRoutePlanner;
import org.apache.hc.core5.http.HttpException;
import org.apache.hc.core5.http.HttpHost;
import org.apache.hc.core5.http.protocol.HttpContext;
import org.springframework.boot.restclient.RestTemplateCustomizer;
import org.springframework.http.client.HttpComponentsClientHttpRequestFactory;
import org.springframework.web.client.RestTemplate;
public class MyRestTemplateCustomizer implements RestTemplateCustomizer {
@Override
public void customize(RestTemplate restTemplate) {
HttpRoutePlanner routePlanner = new CustomRoutePlanner(new HttpHost("proxy.example.com"));
HttpClient httpClient = HttpClientBuilder.create().setRoutePlanner(routePlanner).build();
restTemplate.setRequestFactory(new HttpComponentsClientHttpRequestFactory(httpClient));
}
static class CustomRoutePlanner extends DefaultProxyRoutePlanner {
CustomRoutePlanner(HttpHost proxy) {
super(proxy);
}
@Override
protected HttpHost determineProxy(HttpHost target, HttpContext context) throws HttpException {
if (target.getHostName().equals("192.168.0.5")) {
return null;
}
return super.determineProxy(target, context);
}
}
}
import org.apache.hc.client5.http.classic.HttpClient
import org.apache.hc.client5.http.impl.classic.HttpClientBuilder
import org.apache.hc.client5.http.impl.routing.DefaultProxyRoutePlanner
import org.apache.hc.client5.http.routing.HttpRoutePlanner
import org.apache.hc.core5.http.HttpException
import org.apache.hc.core5.http.HttpHost
import org.apache.hc.core5.http.protocol.HttpContext
import org.springframework.boot.restclient.RestTemplateCustomizer
import org.springframework.http.client.HttpComponentsClientHttpRequestFactory
import org.springframework.web.client.RestTemplate
class MyRestTemplateCustomizer : RestTemplateCustomizer {
override fun customize(restTemplate: RestTemplate) {
val routePlanner: HttpRoutePlanner = CustomRoutePlanner(HttpHost("proxy.example.com"))
val httpClient: HttpClient = HttpClientBuilder.create().setRoutePlanner(routePlanner).build()
restTemplate.requestFactory = HttpComponentsClientHttpRequestFactory(httpClient)
}
internal class CustomRoutePlanner(proxy: HttpHost?) : DefaultProxyRoutePlanner(proxy) {
@Throws(HttpException::class)
public override fun determineProxy(target: HttpHost, context: HttpContext): HttpHost? {
if (target.hostName == "192.168.0.5") {
return null
}
return super.determineProxy(target, context)
}
}
}
最后,您可以定义自己的 RestTemplateBuilder bean。
这样做将替换自动配置的构建器。
如果您希望任何 RestTemplateCustomizer bean 应用于您的自定义构建器(如同自动配置所做的那样),请使用 RestTemplateBuilderConfigurer 进行配置。
以下示例公开了一个 RestTemplateBuilder,其与 Spring Boot 的自动配置所执行的操作相匹配,不同之处在于还指定了自定义的连接和读取超时:
-
Java
-
Kotlin
import java.time.Duration;
import org.springframework.boot.restclient.RestTemplateBuilder;
import org.springframework.boot.restclient.autoconfigure.RestTemplateBuilderConfigurer;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
@Configuration(proxyBeanMethods = false)
public class MyRestTemplateBuilderConfiguration {
@Bean
public RestTemplateBuilder restTemplateBuilder(RestTemplateBuilderConfigurer configurer) {
return configurer.configure(new RestTemplateBuilder())
.connectTimeout(Duration.ofSeconds(5))
.readTimeout(Duration.ofSeconds(2));
}
}
import org.springframework.boot.restclient.autoconfigure.RestTemplateBuilderConfigurer
import org.springframework.boot.restclient.RestTemplateBuilder
import org.springframework.context.annotation.Bean
import org.springframework.context.annotation.Configuration
import java.time.Duration
@Configuration(proxyBeanMethods = false)
class MyRestTemplateBuilderConfiguration {
@Bean
fun restTemplateBuilder(configurer: RestTemplateBuilderConfigurer): RestTemplateBuilder {
return configurer.configure(RestTemplateBuilder()).connectTimeout(Duration.ofSeconds(5))
.readTimeout(Duration.ofSeconds(2))
}
}
最极端(且很少使用)的选项是在不使用配置器的情况下创建您自己的 RestTemplateBuilder bean。
除了替换自动配置的构建器之外,这还会阻止使用任何 RestTemplateCustomizer bean。
| 您可以更改 全局 HTTP 客户端配置。 |
RestTemplate SSL 支持
如果您需要在 RestTemplate 上配置自定义 SSL,可以将 SSL 捆绑包 应用于 RestTemplateBuilder,如下例所示:
-
Java
-
Kotlin
import org.springframework.boot.docs.io.restclient.resttemplate.Details;
import org.springframework.boot.restclient.RestTemplateBuilder;
import org.springframework.boot.ssl.SslBundles;
import org.springframework.stereotype.Service;
import org.springframework.web.client.RestTemplate;
@Service
public class MyService {
private final RestTemplate restTemplate;
public MyService(RestTemplateBuilder restTemplateBuilder, SslBundles sslBundles) {
this.restTemplate = restTemplateBuilder.sslBundle(sslBundles.getBundle("mybundle")).build();
}
public Details someRestCall(String name) {
return this.restTemplate.getForObject("/{name}/details", Details.class, name);
}
}
import org.springframework.boot.docs.io.restclient.resttemplate.Details
import org.springframework.boot.ssl.SslBundles
import org.springframework.boot.restclient.RestTemplateBuilder
import org.springframework.stereotype.Service
import org.springframework.web.client.RestTemplate
@Service
class MyService(restTemplateBuilder: RestTemplateBuilder, sslBundles: SslBundles) {
private val restTemplate: RestTemplate
init {
restTemplate = restTemplateBuilder.sslBundle(sslBundles.getBundle("mybundle")).build()
}
fun someRestCall(name: String): Details {
return restTemplate.getForObject("/{name}/details", Details::class.java, name)!!
}
}
RestClient 和 RestTemplate 的 HTTP 客户端检测
Spring Boot 将根据应用程序类路径上可用的库,通过 RestClient 和 RestTemplate 自动检测要使用的 HTTP 客户端。
按优先顺序,支持以下客户端:
-
Apache HttpClient
-
Jetty HttpClient
-
Reactor Netty HttpClient
-
JDK 客户端 (
java.net.http.HttpClient) -
简单 JDK 客户端 (
java.net.HttpURLConnection)
如果类路径上有多个客户端可用,并且没有提供全局配置,则将使用首选的客户端。
全局 HTTP 客户端配置
如果自动检测到的 HTTP 客户端不符合您的需求,您可以使用 spring.http.clients.imperative.factory 属性来选择特定的工厂。
例如,如果您的类路径上有 Apache HttpClient,但您更倾向于使用 Jetty 的 HttpClient,则可以添加以下内容:
-
Properties
-
YAML
spring.http.clients.imperative.factory=jetty
spring:
http:
clients:
imperative:
factory: jetty
| 你也可以使用 全局配置属性,这些属性适用于所有 HTTP 客户端。 |
对于更复杂的自定义,您可以使用 ClientHttpRequestFactoryBuilderCustomizer 或声明您自己的 ClientHttpRequestFactoryBuilder bean,这将导致自动配置回退。
当您需要自定义底层 HTTP 库的某些内部组件时,这非常有用。
例如,以下代码将使用配置了特定 ProxySelector 的 JDK 客户端:
-
Java
-
Kotlin
import java.net.ProxySelector;
import org.springframework.boot.http.client.ClientHttpRequestFactoryBuilder;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
@Configuration(proxyBeanMethods = false)
public class MyClientHttpConfiguration {
@Bean
ClientHttpRequestFactoryBuilder<?> clientHttpRequestFactoryBuilder(ProxySelector proxySelector) {
return ClientHttpRequestFactoryBuilder.jdk()
.withHttpClientCustomizer((builder) -> builder.proxy(proxySelector));
}
}
import org.springframework.boot.http.client.ClientHttpRequestFactoryBuilder
import org.springframework.context.annotation.Bean
import org.springframework.context.annotation.Configuration
import java.net.ProxySelector
@Configuration(proxyBeanMethods = false)
class MyClientHttpConfiguration {
@Bean
fun clientHttpRequestFactoryBuilder(proxySelector: ProxySelector): ClientHttpRequestFactoryBuilder<*> {
return ClientHttpRequestFactoryBuilder.jdk()
.withHttpClientCustomizer { builder -> builder.proxy(proxySelector) }
}
}
API 版本控制
WebClient 和 RestClient 都支持进行带版本的远程 HTTP 调用,这样可以在不破坏现有功能的情况下逐步演进 API。
通常这涉及发送一个 HTTP 请求头、查询参数或 URL 路径段,以指示应使用的 API 版本。
您可以使用 WebClient.Builder 或 RestClient.Builder 上的方法配置 API 版本控制。
| API版本控制也支持在服务器端。 请参阅 Spring MVC 和 Spring WebFlux 部分以获取详细信息。 |
| 服务器端API版本控制配置不会被用来自动配置客户端。 应使用API版本控制策略的客户端,通常用于测试,需要显式进行配置。 |
HTTP 服务接口客户端
而不是直接使用 RestClient 或 WebClient 来调用HTTP服务,也可以使用带注解的Java接口来调用它们。
HTTP服务接口通过使用带有@HttpExchange注解的方法来定义服务契约,或者更常见的是方法特定的变体(@GetExchange、@PostExchange、@DeleteExchange等)。
例如,以下代码为一个“echo” API 定义了一个 HTTP 服务,该服务将返回一个包含请求回声的 JSON 对象。
-
Java
-
Kotlin
import java.util.Map;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.service.annotation.HttpExchange;
import org.springframework.web.service.annotation.PostExchange;
@HttpExchange(url = "https://echo.zuplo.io")
public interface EchoService {
@PostExchange
Map<?, ?> echo(@RequestBody Map<String, String> message);
}
import org.springframework.web.bind.annotation.RequestBody
import org.springframework.web.service.annotation.HttpExchange
import org.springframework.web.service.annotation.PostExchange
@HttpExchange(url = "https://echo.zuplo.io")
interface EchoService {
@PostExchange
fun echo(@RequestBody message: Map<String, String>): Map<*, *>
}
有关如何开发HTTP服务接口客户端的更多详细信息,请参阅 Spring框架参考文档。
导入HTTP服务
要将HTTP服务接口用作客户端,您需要导入它。
一种实现此目的的方法是使用 @ImportHttpServices 注解,通常在您的主应用程序类上使用。
您可以使用该注解来导入特定的类,或从特定包中扫描要导入的类。
例如,以下配置将在 com.example.myclients 包中扫描 HTTP 服务接口:
-
Java
-
Kotlin
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.web.service.registry.ImportHttpServices;
@SpringBootApplication
@ImportHttpServices(basePackages = "com.example.myclients")
public class MyApplication {
public static void main(String[] args) {
SpringApplication.run(MyApplication.class, args);
}
}
import org.springframework.boot.autoconfigure.SpringBootApplication
import org.springframework.boot.runApplication
import org.springframework.web.service.registry.ImportHttpServices
@SpringBootApplication
@ImportHttpServices(basePackages = ["com.example.myclients"])
class MyApplication
fun main(args: Array<String>) {
runApplication<MyApplication>(*args)
}
服务客户组
在 @HttpExchange 注释中硬编码绝对 URL 在生产应用程序中通常不是理想的做法。
相反,您通常希望在代码中为 HTTP 服务客户端提供一个逻辑名称,然后根据该名称从属性中查找 URL。
HTTP服务客户端通过将它们注册到命名组中来实现这一点。 HTTP服务组是一组共享共同特性的HTTP服务接口。
例如,我们可能需要定义一个“回显”组,用于调用 https://echo.zuplo.io 的 HTTP 服务客户端。
| HTTP 服务组可以用于定义不仅仅是 URL 的内容。 例如,您的组可以定义连接超时时间和 SSL 设置。 您还可以将客户端自定义逻辑与一个组关联,例如添加代码以插入所需的授权标头。 |
当使用 @ImportHttpServices 时,可以使用 group 属性将 HTTP 服务接口与组相关联。
例如,假设我们上面的示例是这样组织的,即所有在 com.example.myclients 包中的 HTTP 服务接口都属于 echo 组。
我们首先从服务接口中删除硬编码的 URL:
-
Java
-
Kotlin
import java.util.Map;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.service.annotation.PostExchange;
public interface EchoService {
@PostExchange
Map<?, ?> echo(@RequestBody Map<String, String> message);
}
import org.springframework.web.bind.annotation.RequestBody
import org.springframework.web.service.annotation.HttpExchange
import org.springframework.web.service.annotation.PostExchange
interface EchoService {
@PostExchange
fun echo(@RequestBody message: Map<String, String>): Map<*, *>
}
我们可以接着写:
-
Java
-
Kotlin
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.web.service.registry.ImportHttpServices;
@SpringBootApplication
@ImportHttpServices(group = "echo", basePackages = "com.example.myclients")
public class MyApplication {
public static void main(String[] args) {
SpringApplication.run(MyApplication.class, args);
}
}
import org.springframework.boot.autoconfigure.SpringBootApplication
import org.springframework.boot.runApplication
import org.springframework.web.service.registry.ImportHttpServices
@SpringBootApplication
@ImportHttpServices(group = "echo", basePackages = ["com.example.myclients"])
class MyApplication
fun main(args: Array<String>) {
runApplication<MyApplication>(*args)
}
最后,我们可以使用一个 base-url 属性将 echo 组链接到实际的 URL:
-
Properties
-
YAML
spring.http.serviceclient.echo.base-url=https://echo.zuplo.io
spring:
http:
serviceclient:
echo:
base-url: "https://echo.zuplo.io"
| 如果未指定分组,则HTTP服务客户端将与名为“default”的分组相关联。 |
|
如果您在同一包中有多个需要与不同组相关联的HTTP服务接口,可以分别列出它们。
例如:
|
配置属性
HTTP 服务的配置属性可以在 spring.http.serviceclient.<group-name> 下指定:
你可以使用属性来配置以下方面:
-
基础URL。
-
任何应该发送的默认头信息。
-
API版本控制配置。
-
重定向设置。
-
连接和读取超时。
-
SSL 用于的捆绑包。
| 你也可以使用 全局配置属性,这些属性适用于所有 HTTP 客户端。 |
例如,以下属性将:
-
将所有HTTP客户端配置为使用一秒的连接超时(除非另有覆盖)。
-
在“echo”组中配置HTTP服务客户端以:
-
使用特定的基 URL。
-
设置两秒的读取超时。
-
使用
X-Version标头插入API版本信息。
-
-
Properties
-
YAML
spring.http.clients.connect-timeout=1s
spring.http.serviceclient.echo.base-url=https://echo.zuplo.io
spring.http.serviceclient.echo.read-timeout=2s
spring.http.serviceclient.echo.apiversion.default=1.0.0
spring.http.serviceclient.echo.apiversion.insert.header=X-Version
spring:
http:
clients:
connect-timeout: 1s
serviceclient:
echo:
base-url: "https://echo.zuplo.io"
read-timeout: 2s
apiversion:
default: 1.0.0
insert:
header: X-Version
自定义
如果您需要在基本属性之外自定义HTTP服务客户端,可以使用HTTP服务组配置器。
对于RestClient支持的HTTP服务客户端,您可以声明一个实现RestClientHttpServiceGroupConfigurer的bean。
对于WebClient支持的HTTP服务客户端,您可以声明一个实现WebClientHttpServiceGroupConfigurer的bean。
两者的工作方式相同,并将由 Spring Boot 的自动配置自动应用。
例如,以下配置将添加一个组自定义器,该自定义器会将包含组名称的 HTTP 头部添加到每个传出请求中:
-
Java
-
Kotlin
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.client.support.RestClientHttpServiceGroupConfigurer;
@Configuration(proxyBeanMethods = false)
public class MyHttpServiceGroupConfiguration {
@Bean
RestClientHttpServiceGroupConfigurer myHttpServiceGroupConfigurer() {
return (groups) -> groups.forEachClient((group, clientBuilder) -> {
String groupName = group.name();
clientBuilder.defaultHeader("service-group", groupName);
});
}
}
import org.springframework.context.annotation.Bean
import org.springframework.context.annotation.Configuration
import org.springframework.web.client.support.RestClientHttpServiceGroupConfigurer
@Configuration(proxyBeanMethods = false)
class MyHttpServiceGroupConfiguration {
@Bean
fun myHttpServiceGroupConfigurer(): RestClientHttpServiceGroupConfigurer {
return RestClientHttpServiceGroupConfigurer { groups ->
groups.forEachClient { group, clientBuilder ->
val groupName = group.name()
clientBuilder.defaultHeader("service-group", groupName)
}
}
}
}
高级配置
除了 @ImportHttpServices 注解之外,Spring Framework 还提供了一个 AbstractHttpServiceRegistrar 类。
您可以 @Import 该类的自定义扩展以执行编程配置。
有关更多详细信息,请参阅 Spring Framework 参考文档。
无论您使用哪种方法注册HTTP服务客户端,Spring Boot的支持都相同。
将全局配置应用于所有 HTTP 客户端
无论使用何种底层技术,所有HTTP客户端都有可以配置的公共设置。
这些包括:
-
连接超时。
-
读取超时。
-
HTTP 重定向应如何处理。
-
连接时应使用哪个 SSL 证书包。
这些常用设置由 HttpClientSettings 类表示,可以传递到 build(…) 方法中的 ClientHttpConnectorBuilder 和 ClientHttpRequestFactoryBuilder。
如果您希望将相同的配置应用于所有自动配置的客户端,可以使用 spring.http.clients 属性来实现:
-
Properties
-
YAML
spring.http.clients.connect-timeout=2s
spring.http.clients.read-timeout=1s
spring.http.clients.redirects=dont-follow
spring:
http:
clients:
connect-timeout: 2s
read-timeout: 1s
redirects: dont-follow