Spring6提供的四种远程接口调用神器！你知道那种？

1. 介绍

Spring 6是一个非常强大的框架，它提供了许多工具和接口来简化远程接口调用。其中，WebClient、RestTemplate、HTTP Interface和RestClient是四种方式。

WebClient是Spring 5中新引入的一个接口基于响应式，它提供了一种更简单、更灵活的方式来调用远程接口。与RestTemplate相比，WebClient更加现代化，具有更好的性能和更低的内存占用。

RestTemplate是Spring 3中引入的一个接口，它提供了一种更加简单、更加直观的方式来调用远程接口。虽然WebClient是更现代化的选择，但RestTemplate仍然是一种常用的远程接口调用方式。

HTTP Interface将 HTTP 服务定义为一个 JAVA 接口，其中包含用于 HTTP 交换的注解方法。然后，你可以生成一个实现该接口并执行交换的代理。这有助于简化 HTTP 远程访问，因为远程访问通常需要使用一个门面来封装使用底层 HTTP 客户端的细节。

RestClient是一个同步 HTTP 客户端，提供现代、流畅的 API。它为 HTTP 库提供了一个抽象，可以方便地从 Java 对象转换为 HTTP 请求，并从 HTTP 响应创建对象。

下面分别介绍4个REST接口调用的详细使用。

2. 远程接口调用

RestTemplate

RestTemplate 提供了比 HTTP 客户端库更高级别的 API。它使调用 REST 端点变得简单易行。它公开了以下几组重载方法：

• 初始化

默认构造函数使用 java.NET.HttpURLConnection 来执行请求。你可以通过 ClientHttpRequestFactory 的实现切换到不同的 HTTP 库。目前，该程序还内置了对 Apache HttpComponents 和 OkHttp 的支持。示例：

RestTemplate template = new RestTemplate(new HttpComponentsClientHttpRequestFactory());

每个 ClientHttpRequestFactory 都会公开底层 HTTP 客户端库的特定配置选项，例如，凭证、连接池和其他细节。

• URIs

许多 RestTemplate 方法都接受 URI 模板和 URI 模板变量，可以是字符串变量参数，也可以是 Map<String,String>。

String result = restTemplate.getForObject(
    "http://pack.com/users/{userId}", String.class, 666) ;

Map<String, ?>方式：

Map<String, Object> params = Collections.singletonMap("userId", 666);


String result = restTemplate.getForObject(
    "http://pack.com/users/{userId}", String.class, params) ;

• Headers

可以使用 exchange() 方法指定请求头，如下例所示：

String uriTemplate = "http://pack.com/users/{userId}";
URI uri = UriComponentsBuilder.fromUriString(uriTemplate).build(42);


RequestEntity<Void> requestEntity = RequestEntity.get(uri)
    .header("x-api-token", "aabbcc")
    .build() ;
ResponseEntity<String> response = template.exchange(requestEntity, String.class);
String responseHeader = response.getHeaders().getFirst("x-version");
String body = response.getBody() ;

• body

如果你当前CLASSPATH存在MAppingJackson2HttpMessageConverter，那么你可以直接将请求结果映射为你所需要的结果对象，如下示例所示，将目标接口返回值直接转换为User对象。

User user = restTemplate.getForObject("http://pack.com/users/{userId}", User.class, 666);

默认情况下，RestTemplate 会注册所有内置的消息转换器，这决定于你当前类路径是否有相应的转换库。你也可以显式设置要使用的消息转换器。默认构造函数如下：

public RestTemplate() {
  this.messageConverters.add(new ByteArrayHttpMessageConverter());
  this.messageConverters.add(new StringHttpMessageConverter());
  this.messageConverters.add(new ResourceHttpMessageConverter(false));
  // ...其它转换器
  if (jackson2Present) {
    this.messageConverters.add(new MappingJackson2HttpMessageConverter());
  }
  else if (gsonPresent) {
    this.messageConverters.add(new GsonHttpMessageConverter());
  }
  else if (jsonbPresent) {
    this.messageConverters.add(new JsonbHttpMessageConverter());
  }
  // ...其它转换器
  this.uriTemplateHandler = initUriTemplateHandler();
}

注意：RestTemplate 目前处于维护模式，只接受小改动和错误请求。请考虑改用 WebClient。

WebClient

WebClient 是执行 HTTP 请求的非阻塞、反应式客户端。它在 5.0 中引入，提供了 RestTemplate 的替代方案，支持同步、异步和流场景。

WebClient 支持以下功能：

1. 非阻塞 I/O。
2. 反应流反向压力
3. 用更少的硬件资源实现高并发。
4. 利用 Java 8 lambdas 的函数式流畅应用程序接口。
5. 同步和异步交互。
6. 服务器上的数据流或服务器下的数据流。

示例：

Mono<Person> result = client.get()
  .uri("/users/{userId}", id).accept(MediaType.APPLICATION_JSON)
  .retrieve()
  .bodyToMono(User.class);

HTTP Interface

Spring Framework 可让你将 HTTP 服务定义为一个 Java 接口，其中包含用于 HTTP 交换的注解方法。然后，你可以生成一个实现该接口并执行交换的代理。这有助于简化 HTTP 远程访问，因为远程访问通常需要使用一个门面来封装使用底层 HTTP 客户端的细节。

首先，声明一个带有 @HttpExchange 方法的接口：

@HttpExchange(url = "/demos")
public interface DemoInterface {


  @PostExchange("/format3/{id}")
  Users queryUser(@PathVariable Long id);


}

创建一个代理，执行所声明的 HTTP exchanges：

@Service
public class DemoService {


  private final DemoInterface demoInterface ;


  public DemoService() {
    // 基于响应式调用；你当前的环境需要引入webflux
    WebClient client = WebClient.builder().baseUrl("http://localhost:8088/").build() ;
    HttpServiceProxyFactory factory = HttpServiceProxyFactory.builder(WebClientAdapter.forClient(client)).build() ;
    this.demoInterface = factory.createClient(DemoInterface.class) ;
  }


  public Users queryUser(Long id) {
    return this.demoInterface.queryUser(id) ;
  }


}

测试接口

@Resource
private DemoService demoService ;




@GetMapping("/{id}")
public Users getUser(@PathVariable("id") Long id) {
  return this.demoService.queryUser(id) ;
}

执行结果

图片

支持的方法参数

支持的返回值

异常处理

默认情况下，WebClient为4xx和5xx HTTP状态代码引发WebClientResponseException。要自定义此项，可以注册响应状态处理程序，该处理程序应用于通过客户端执行的所有响应：

WebClient client = WebClient.builder()
    // 状态码为4xx或5xx
    .defaultStatusHandler(HttpStatusCode::isError, resp -> Mono.just(new RuntimeException(resp.statusCode().toString() + "请求错误")))
    .baseUrl("http://localhost:8088/").build() ;
HttpServiceProxyFactory factory = HttpServiceProxyFactory
    .builder(WebClientAdapter.forClient(client)).build() ;

RestClient

该接口是在Spring6.1.1版本中才有的，是一个同步 HTTP 客户端，提供现代、流畅的 API。

创建RestClientRestClient 是通过静态创建方法之一创建的。你还可以使用 builder 获取带有更多选项的生成器，例如指定要使用的 HTTP 库和要使用的消息转换器，设置默认 URI、默认路径变量、默认请求头，或注册拦截器和初始化器。

创建（或构建）后，RestClient 可由多个线程安全使用。

// 默认通过静态方法创建
RestClient restClient = RestClient.create();
// 自定义方式
RestClient restClient = RestClient.builder()
  .requestFactory(new HttpComponentsClientHttpRequestFactory())
  // 自定义消息转换器
  // .messageConverters(converters -> converters.add(new PackCustomMessageConverter()))
  .baseUrl("http://localhost:8088")
  .defaultUriVariables(Map.of("id", "888"))
  .defaultHeader("x-api-token", "aabbcc")
  .requestInterceptor(new ClientHttpRequestInterceptor() {
    @Override
    public ClientHttpResponse intercept(HttpRequest request, byte[] body, ClientHttpRequestExecution execution)
        throws IOException {
      System.out.println("我是拦截器") ;
      return execution.execute(request, body) ;
    }
  })
  .requestInitializer(new ClientHttpRequestInitializer() {
    @Override
    public void initialize(ClientHttpRequest request) {
      System.out.println("我是初始化器") ;
      request.getHeaders().add("x-version", "1.0.0") ;
    }
  })
  .build() ;

调用及处理返回值

Users users = customClient.get()
  .uri("/demos/users/{id}")
  .retrieve()
  .body(Users.class) ;

post+body请求方式

Users user = new Users();
ResponseEntity<Void> response = restClient.post() 
  .uri("/demos/users") 
  .contentType(APPLICATION_JSON) 
  .body(user) 
  .retrieve()
  .toBodilessEntity() ;

错误处理默认情况下，当返回状态代码为 4xx 或 5xx 的响应时，RestClient 会抛出 RestClientException 的子类。可以使用 onStatus.RestClientException 命令重写该行为。

Users users = customClient.get()
  .uri("/demos/users/{id}")
  .retrieve()
  // 处理返回状态码为：4xx和5xx
  .onStatus(HttpStatusCode::isError, (request, response) -> {
    throw new RuntimeException(response.getStatusCode().toString() + "请求错误") ;
  })
  .body(Users.class) ;

总结：实现远程接口调用方面的强大功能。无论是使用WebClient、RestTemplate、HTTP Interface还是直接使用RestClient，Spring都提供了丰富的工具和接口来简化开发者的操作。这些工具和接口不仅具有高性能、低内存占用的优点，而且提供了良好的可扩展性和灵活性，使得开发者可以根据实际需求进行定制化开发。