Spring Framework 5.0新增的WebClient_业界新闻

发布时间:2024-08-03 06:13

阅读量:0

Spring Framework 5.0 引入了 WebClient，这是一个新的非阻塞、响应式 Web 客户端 API，旨在为构建响应式微服务提供更好的支持。WebClient 是基于 Project Reactor 的响应式流 API 构建的，它可以高效地处理大量的并发请求，非常适合现代微服务架构。

WebClient 的主要特性

响应式：WebClient 基于非阻塞 I/O，可以处理大量的并发请求而不会阻塞线程。
类型安全：API 设计为类型安全的，这有助于减少运行时错误。
可定制：可以轻松地扩展和自定义 WebClient 的行为，例如添加拦截器、过滤器或自定义转换器。
易于使用：提供了简洁的 API 来发起 HTTP 请求和处理响应。
可测试性：提供了模拟 WebClient 的工具，便于编写单元测试。

使用示例

下面是一个简单的示例，展示了如何使用 WebClient 发送一个 GET 请求并处理 JSON 响应。

import org.springframework.http.MediaType; import org.springframework.web.reactive.function.client.WebClient; import reactor.core.publisher.Mono;  public class WebClientExample {      public static void main(String[] args) {         // 创建 WebClient 实例         WebClient webClient = WebClient.create();          // 发送 GET 请求         webClient.get()                  .uri("http://example.com/api/data")                  .accept(MediaType.APPLICATION_JSON)                  .retrieve()                  .bodyToMono(Data.class) // 假设 Data 是一个 Java 类                  .subscribe(data -> {                      System.out.println("Received data: " + data);                  }, error -> {                      System.err.println("Error occurred: " + error.getMessage());                  }, () -> {                      System.out.println("Request completed.");                  });     }      // 假设这是从服务器接收的数据类     static class Data {         private String name;         private int value;          // Getters and setters         public String getName() {             return name;         }          public void setName(String name) {             this.name = name;         }          public int getValue() {             return value;         }          public void setValue(int value) {             this.value = value;         }          @Override         public String toString() {             return "Data{" +                     "name='" + name + '\'' +                     ", value=" + value +                     '}';         }     } }

WebClient 的基本用法

创建 WebClient 实例：可以使用 WebClient.create() 或者 WebClient.builder() 来创建 WebClient 实例。
构建请求：使用链式调用的方法来构建请求，例如 .get().uri("...") 或 .post().uri("...")。
处理响应：使用 retrieve() 方法来处理响应。可以通过 .bodyToMono() 或 .bodyToFlux() 方法来转换响应体为 Mono 或 Flux。
订阅响应：使用 .subscribe() 方法来订阅 Mono 或 Flux 并处理数据。

自定义 WebClient

WebClient 可以通过多种方式来定制，例如添加拦截器、自定义转换器或设置超时时间等。

添加拦截器

WebClient webClient = WebClient.builder()                                .filter((request, next) -> {                                    // 自定义逻辑                                    return next.exchange(request);                                })                                .build();

自定义转换器

WebClient webClient = WebClient.builder()                                .codecs(configurer -> configurer.defaultCodecs().maxInMemorySize(16 * 1024 * 1024))                                .build();

异常处理

WebClient 提供了内置的异常处理机制，可以使用 onStatus 方法来处理特定的状态码。

webClient.get()          .uri("http://example.com/api/data")          .retrieve()          .onStatus(HttpStatus::is4xxClientError, clientResponse -> {              // 处理 4xx 错误              return clientResponse.bodyToMono(String.class)                                   .map(body -> "Error: " + body);          })          .bodyToMono(Data.class)          .subscribe(data -> {              System.out.println("Received data: " + data);          }, error -> {              System.err.println("Error occurred: " + error.getMessage());          }, () -> {              System.out.println("Request completed.");          });