Spring5中的WebClient使用方法详解

Spring5中的WebClient是一个非常强大的用于建立HTTP请求和处理响应的库。它提供了一套基于响应式流的API，可以帮助我们更简单、高效地完成Web请求的处理和响应。

1. Maven依赖

为了使用Spring5中的WebClient，我们需要在项目中加入如下的Maven依赖：

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-webflux</artifactId>
</dependency>

这个依赖中已经包含了WebFlux和Reactive Netty，是进行响应式编程和建立WebClient请求所必须的库。

2. 创建WebClient

下面是创建WebClient的方法。我们需要指定服务端的URL地址，然后调用build()即可完成WebClient的创建。

WebClient webClient = WebClient.create("http://localhost:8080");

3. 发送HTTP请求

3.1. 发送GET请求

使用WebClient发送GET请求，可以通过get()方法实现：

Mono<String> result = webClient.get().uri("/api/user").retrieve().bodyToMono(String.class);

以上代码中：

• get()：表示构建GET请求。
• uri()：指定请求的URI路径。
• retrieve()：在非阻塞的情况下执行HTTP请求。
• bodyToMono()：将响应体转换为Mono表示的流，支持参数化类型。

3.2. 发送POST请求

使用WebClient发送POST请求，可以通过post()方法实现：

User user = new User();
user.setName("test");
user.setAge(18);
Mono<User> userMono = Mono.just(user);
Mono<User> resultMono = webClient.post().uri("/api/user").contentType(MediaType.APPLICATION_JSON).body(userMono, User.class).retrieve().bodyToMono(User.class);

以上代码中：

• post()：表示构建POST请求。
• uri()：指定请求的URI路径。
• contentType()：指定请求的Content-Type。
• body()：设置请求体。
• bodyToMono()：将响应体转换为Mono表示的流，支持参数化类型。

4. 示例

下面是一个完整的使用WebClient发送HTTP请求的示例代码，可以GET、POST、PUT、DELETE：

@Component
public class WebClientExample {

    @Autowired
    WebClient webClient;

    public void example() {
        // GET请求
        Mono<String> getMono = webClient.get().uri("/api/user").retrieve().bodyToMono(String.class);

        // POST请求
        User user = new User();
        user.setName("test");
        user.setAge(18);
        Mono<User> userMono = Mono.just(user);
        Mono<User> postMono = webClient.post().uri("/api/user").contentType(MediaType.APPLICATION_JSON).body(userMono, User.class).retrieve().bodyToMono(User.class);

        // PUT请求
        User updateUser = new User();
        updateUser.setName("update");
        updateUser.setAge(20);
        Mono<User> updateMono = Mono.just(updateUser);
        Mono<User> putMono = webClient.put().uri("/api/user/{id}", 1).contentType(MediaType.APPLICATION_JSON).body(updateMono, User.class).retrieve().bodyToMono(User.class);

        // DELETE请求
        Mono<Void> deleteMono = webClient.delete().uri("/api/user/{id}", 1).retrieve().bodyToMono(Void.class);
    }
}

以上代码中，我们可以很容易地通过WebClient发送各种HTTP请求，并处理其响应。通过Mono和Flux等响应式类型，我们可以实现非阻塞的Web请求处理和响应，提高系统性能和可扩展性。