如何在 Spring Boot 中使用 WebFlux
随着互联网应用的复杂度不断增加，传统的请求响应模型已经无法满足日益增长的需求。传统的 Web 应用使用 Servlet 容器，采用同步阻塞的方式来处理请求，请求需要等待相应的处理逻辑完成后才能返回结果。这种方式的缺点是很明显的，它会阻塞线程，导致资源的浪费，同时也限制了应用的并发处理能力。
WebFlux 是 Spring Framework 5 中引入的一种新的响应式编程模型，它基于 Reactor 库，可以提供异步非阻塞的方式来处理请求，从而提高应用程序的性能和可伸缩性。在本文中，我们将介绍如何在 Spring Boot 中使用 WebFlux。
什么是 WebFlux？
WebFlux 是 Spring Framework 5 中引入的一种新的响应式编程模型，它基于 Reactor 库，可以提供异步非阻塞的方式来处理请求。WebFlux 实现了 Reactive Streams 规范，可以与其他实现了该规范的库进行交互，例如 Reactor 和 RxJava。
相比传统的 Web 应用，WebFlux 可以提供更高的吞吐量和更低的延迟，同时也可以提高应用程序的可伸缩性和容错性。WebFlux 还提供了一些有用的功能，例如响应式数据访问、响应式 Web 安全性、响应式 Web 客户端等。
在 Spring Boot 中使用 WebFlux
在 Spring Boot 中使用 WebFlux 非常简单。我们只需要添加 Spring Boot WebFlux Starter 依赖即可。Spring Boot WebFlux Starter 包含了所有必要的依赖项，可以帮助我们快速构建 WebFlux 应用程序。
首先，我们需要在项目的 pom.xml 文件中添加 Spring Boot WebFlux Starter 依赖：
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-webflux</artifactId>
</dependency>
添加完依赖后，我们可以开始编写 WebFlux 应用程序了。我们需要创建一个控制器类，该类可以处理请求并返回响应。在本文中，我们将创建一个简单的控制器类，该类可以接受 GET 请求并返回 Hello World。
首先，我们需要创建一个 HelloWorldController 类，它应该继承 AbstractController 类。AbstractController 是一个抽象类，它提供了处理请求和返回响应的方法。
package com.example.demo;
import org.springframework.http.ResponseEntity;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
import reactor.core.publisher.Mono;
@RestController
public class HelloWorldController extends AbstractController {
@GetMapping("/")
public Mono<ResponseEntity<String>> helloWorld() {
return Mono.just(ResponseEntity.ok("Hello World"));
}
}
在这个例子中，我们创建了一个 HelloWorldController 类，并在该类中定义了一个 helloWorld 方法。helloWorld 方法使用 @GetMapping 注解标记，表示它可以处理 GET 请求，并将请求的路径设置为根路径 “/”.
helloWorld 方法返回一个 Mono 对象，该对象包装了一个 ResponseEntity 对象，表示响应的状态码、头部和正文。在这个例子中，我们将响应的状态码设置为 200，表示请求成功，并将正文设置为 “Hello World”。
我们可以使用 @RestController 注解标记 HelloWorldController 类，表示它是一个控制器类。@RestController 注解相当于 @Controller 和 @ResponseBody 注解的组合。
现在，我们已经完成了 WebFlux 应用程序的编写。我们可以启动应用程序并访问 http://localhost:8080/，应该能够看到 “Hello World” 的响应。
WebFlux 的路由和处理器函数
在 WebFlux 中，我们可以使用两种不同的方式来处理请求：路由和处理器函数。
路由
路由是一种传统的方式，它将请求映射到相应的处理器方法。在 WebFlux 中，我们可以使用 RouterFunctions 类来创建路由。RouterFunctions 类提供了许多方法，可以帮助我们创建路由和处理器方法。
我们可以通过创建一个 RouterFunction 对象来定义路由。RouterFunction 对象由多个路由器函数组成，每个路由器函数都可以处理特定的请求。我们可以使用 RouterFunctions.route 方法来创建路由器函数。
package com.example.demo;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.http.MediaType;
import org.springframework.web.reactive.function.server.HandlerFunction;
import org.springframework.web.reactive.function.server.RouterFunction;
import org.springframework.web.reactive.function.server.RouterFunctions;
import org.springframework.web.reactive.function.server.ServerResponse;
import reactor.core.publisher.Mono;
@Configuration
public class RouterConfiguration {
@Bean
public RouterFunction<ServerResponse> route() {
return RouterFunctions.route()
.GET("/", request -> ServerResponse.ok()
.contentType(MediaType.TEXT_PLAIN)
.body(Mono.just("Hello World"), String.class))
.build();
}
}
在这个例子中，我们创建了一个 RouterConfiguration 类，并在该类中定义了一个 route 方法。route 方法创建了一个 RouterFunction 对象，并添加了一个路由器函数。路由器函数使用 GET 方法处理根路径 “/” 的请求，并返回一个包含 “Hello World” 字符串的 Mono 对象。
我们可以使用 @Configuration 注解来标记 RouterConfiguration 类，表示它是一个配置类。当应用程序启动时，Spring Boot 将自动扫描所有的配置类，并加载它们。
处理器函数
处理器函数是 WebFlux 中的另一种处理请求的方式。处理器函数是一组函数，它们接受请求并返回响应。在 WebFlux 中，我们可以使用 HandlerFunction 接口来定义处理器函数。
package com.example.demo;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.http.MediaType;
import org.springframework.web.reactive.function.server.HandlerFunction;
import org.springframework.web.reactive.function.server.RouterFunctions;
import org.springframework.web.reactive.function.server.ServerResponse;
import reactor.core.publisher.Mono;
@Configuration
public class HandlerConfiguration {
@Bean
public HandlerFunction<ServerResponse> helloWorld() {
return request -> ServerResponse.ok()
.contentType(MediaType.TEXT_PLAIN)
.body(Mono.just("Hello World"), String.class);
}
@Bean
public RouterFunction<ServerResponse> route() {
return RouterFunctions.route()
.GET("/", helloWorld())
.build();
}
}
在这个例子中，我们创建了一个 HandlerConfiguration 类，并在该类中定义了一个 helloWorld 方法。helloWorld 方法返回一个 HandlerFunction 对象，该对象可以处理请求并返回响应。我们还创建了一个 route 方法，该方法创建了一个 RouterFunction 对象，并将 helloWorld 方法添加为路由器函数。
我们可以使用 @Configuration 注解来标记 HandlerConfiguration 类，表示它是一个配置类。当应用程序启动时，Spring Boot 将自动扫描所有的配置类，并加载它们。
WebFlux 的异步编程模型
在 WebFlux 中，我们可以使用异步编程模型来处理请求。异步编程模型可以提供更高的并发处理能力和更低的延迟，同时也可以减少资源的浪费。
在 WebFlux 中，我们可以使用 Mono 和 Flux 类来处理异步操作。Mono 表示一个包含单个元素的响应式序列，Flux 表示一个包含多个元素的响应式序列。
下面是一个使用 Mono 和 Flux 的例子：
package com.example.demo;
import java.time.Duration;
import org.springframework.http.MediaType;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;
@RestController
public class HelloWorldController {
@GetMapping(value = "/hello", produces = MediaType.TEXT_EVENT_STREAM_VALUE)
public Flux<String> hello() {
return Flux.just("Hello", "World")
.delayElements(Duration.ofSeconds(1))
.map(String::toUpperCase);
}
@GetMapping(value= "/hello/{name}", produces = MediaType.TEXT_PLAIN_VALUE)
public Mono<String> hello(@PathVariable String name) {
return Mono.just("Hello " + name);
}
}
在这个例子中，我们创建了一个 HelloWorldController 类，并定义了两个方法：hello 和 helloWithName。hello 方法返回一个 Flux 对象，该对象表示一个包含 “Hello” 和 “World” 两个元素的响应式序列。我们使用 delayElements 方法来模拟一个异步操作，每个元素之间间隔 1 秒钟。我们还使用 map 方法将序列中的每个元素转换为大写字母。
helloWithName 方法使用 @PathVariable 注解来获取请求路径中的参数，并返回一个包含 “Hello” 和参数值的字符串的 Mono 对象。
在 WebFlux 中，我们还可以使用 Mono 和 Flux 来处理数据库查询、外部 API 调用等异步操作。在这种情况下，我们可以使用 Reactive MongoDB、Reactive Redis、WebClient 等响应式库来处理异步操作。
WebFlux 的测试
在 WebFlux 中，我们可以使用 WebTestClient 类来测试我们的应用程序。WebTestClient 类提供了一组方法，可以帮助我们发送请求并验证响应。
下面是一个使用 WebTestClient 的例子：
package com.example.demo;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.autoconfigure.web.reactive.WebFluxTest;
import org.springframework.http.MediaType;
import org.springframework.test.web.reactive.server.WebTestClient;
@WebFluxTest
public class HelloWorldControllerTest {
@Autowired
private WebTestClient webTestClient;
@Test
public void testHelloWorld() {
webTestClient.get().uri("/")
.accept(MediaType.TEXT_PLAIN)
.exchange()
.expectStatus().isOk()
.expectBody(String.class).isEqualTo("Hello World");
}
}
在这个例子中，我们创建了一个 HelloWorldControllerTest 类，并注入了一个 WebTestClient 对象。我们还定义了一个 testHelloWorld 方法，该方法使用 WebTestClient 对象发送 GET 请求，并验证响应是否正确。
在 WebFlux 中，我们还可以使用 MockServer 和 MockMvc 来测试我们的应用程序。MockServer 是一个模拟 HTTP 服务器，可以帮助我们测试应用程序的异步请求和响应。MockMvc 是一个模拟 MVC 环境的框架，可以帮助我们测试应用程序的控制器和视图。
总结
在本文中，我们介绍了如何在 Spring Boot 中使用 WebFlux。WebFlux 是一种基于 Reactor 库的响应式编程模型，可以提供异步非阻塞的方式来处理请求，从而提高应用程序的性能和可伸缩性。我们还介绍了 WebFlux 的路由和处理器函数、异步编程模型和测试方法。希望本文可以帮助你了解如何在 Spring Boot 中使用 WebFlux。
![[Orin Nx] 如何跑满GPU和CPU，观察温度和散热性能？](https://img-blog.csdnimg.cn/ea96323b6bdb4d3bb2a5bacb6385230b.png)
