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 result = restTemplate.getForObject(
    "http://pack.com/users/{userId}", String.class, 666) ;

Map方式：

Map 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 requestEntity = RequestEntity.get(uri)
    .header("x-api-token", "aabbcc")
    .build() ;
ResponseEntity 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 支持以下功能：

示例：

Mono 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) ;
}

执行结果

图片

支持的方法参数

支持的返回值

返回值	说明
void, Mono	执行给定的请求，并发布响应内容（如果有）。
HttpHeaders, Mono	执行给定的请求，释放响应内容（如果有），并返回响应标头。
, Mono	执行给定的请求，并根据声明的返回类型对响应内容进行解码。
, Flux	执行给定的请求，并将响应内容解码为已声明元素类型的数据流。
ResponseEntity, Mono	执行给定的请求，释放响应内容（如果有），并返回一个包含状态和标头的 ResponseEntity。
ResponseEntity,Mono	执行给定的请求，按照声明的返回类型解码响应内容，并返回一个包含状态、标头和解码后正文的 ResponseEntity。
Mono 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 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都提供了丰富的工具和接口来简化开发者的操作。这些工具和接口不仅具有高性能、低内存占用的优点，而且提供了良好的可扩展性和灵活性，使得开发者可以根据实际需求进行定制化开发。 张二河 接口 开发运维 0 0 上一篇 [20231130]快速删除大量文件测试(perl版本)3.txt 下一篇 Go未来演进：基于共同目标和数据驱动的决策 相关文章 JavaScript2024新功能：Object.groupBy、正则表达式v标志 PHP trim 函数对多字节字符的使用和限制 新函数 json_validate() 、randomizer 类扩展…20 个PHP 8.3 新特性全面解析 使用HTMX为WordPress增效：如何在不使用复杂框架的情况下增强平台功能 为React 19做准备：WordPress 6.6用户指南 如何删除WordPress中的所有评论 发布评论 取消回复 要发表评论，您必须先登录。 张二河 这个人很懒，什么都没有留下～ 文章8551 评论0 百度搜索：蓝易云 – Centos8部署zabbix6.4+postgresql15+PHP7.4教程 Oracle NetSuite 客户说 | 借数字化之力“轻装”出海，让中国品牌全球热卖 教授吐槽：985 高校成高级蓝翔！研究生基本废了，只为房子、票子……