Spring WebFlux 是 Spring 5.0 引入的新的响应式框架，用于构建异步的、非阻塞的和事件驱动的服务。WebFlux 使用了 Reactor 作为其响应式库，该库基于 Reactive Streams 规范。
核心概念
在深入了解之前，我们需要明确几个关键概念：
- Reactor: WebFlux底层使用的响应式编程库，提供
Mono和Flux这两个核心响应式类型。Mono代表0到1个元素的异步序列，而Flux代表0到N个元素的异步序列。 - Reactive Streams: 一套流处理的标准，定义了异步处理数据流的一组接口。
WebFlux 配置
WebFlux 可以使用两种编程模型：注解式和函数式。注解式模型与Spring MVC 类似，受Spring MVC开发者欢迎。函数式模型则更为灵活，提供了路由和处理函数的定义方式。
注解式模型示例
首先，你需要在你的项目中添加对Spring Boot Starter WebFlux的依赖。
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-webflux</artifactId>
</dependency>
然后，你可以创建控制器和请求处理方法，使用@RestController和@RequestMapping注解。
@RestController
@RequestMapping("/api")
public class ReactiveController {
@GetMapping("/hello")
public Mono<String> hello() {
return Mono.just("Hello, WebFlux!");
}
}
在这个例子中，hello方法返回了一个Mono<String>，这意味着它会异步地返回一个字符串。
函数式模型示例
函数式模型使用RouterFunction和HandlerFunction来定义路由和处理逻辑。
@Configuration
public class RoutingConfig {
@Bean
public RouterFunction<ServerResponse> route(ReactiveHandler handler) {
return RouterFunctions
.route(GET("/functional/hello"), handler::hello);
}
}
@Component
public class ReactiveHandler {
public Mono<ServerResponse> hello(ServerRequest request) {
return ServerResponse.ok().body(Mono.just("Hello, WebFlux!"), String.class);
}
}
在这个例子中，RoutingConfig定义了一个路由到ReactiveHandler的hello方法。再次强调，所有的操作都是异步非阻塞的。
WebFlux 源码分析
Spring WebFlux 的内部，是基于异步和非阻塞的核心组件构建的，比如 WebHandler 接口，它是所有请求处理的核心。
当请求到达时，DispatcherHandler 负责将请求分配给适当的HandlerMapping，找到对应的Handler。然后HandlerAdapter负责实际调用请求处理方法。
在响应式栈中，Spring使用了Netty作为默认的嵌入式服务器，尽管也可以选择其他支持Reactive Streams的服务器。
性能考量
与传统的基于Servlet的Spring MVC相比，WebFlux更适合处理长时间运行的或者高并发的请求，因为它避免了每个请求一个线程的模型，减少了线程切换和内存使用。
注意事项：
- WebFlux 需要Reactor库版本与Spring框架兼容。
- WebFlux与Spring MVC不能在同一个应用中共存，因为它们的底层模型不一样。
- 不是所有的库和数据存储都支持响应式编程，因此在选择WebFlux之前需要确认整个技术栈的兼容性。
通过以上步骤和代码演示，你可以开始使用Spring WebFlux来构建响应式服务。与任何技术栈一样，选择使用WebFlux应根据应用程序的具体需求和场景来做出。
