spring webflux 怎么使用

Spring WebFlux是Spring框架的一部分，它是一个基于事件驱动、非阻塞I/O模型的Web开发工具包。它专注于处理HTTP请求响应，提供了一种异步和非阻塞的方式来构建高性能的RESTful应用。

以下是使用Spring WebFlux的基本步骤：

1. **添加依赖**：在Maven或Gradle的构建文件中添加Spring WebFlux的相关依赖。例如，如果你使用的是Spring Boot，可以在`pom.xml`或`build.gradle`中加入：

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

2. **创建控制器**：使用`@RestController`和`@GetMapping`等注解来声明一个Flux处理器。比如：

   @RestController
   public class GreetingController {
       @GetMapping("/hello")
       Flux<String> greeting() {
           return Flux.just("Hello from Spring WebFlux!");
       }
   }

这里返回的是一个Flux流，表示可以持续发送数据。

3. **处理HTTP响应**：Flux支持多种响应模式，如Mono（单个值）、Flux（多个值），以及错误处理。你可以使用`block()`、`subscribe()`方法来消费Flux结果。

4. **异步处理**：由于WebFlux是非阻塞的，所以它非常适合处理IO密集型任务，如数据库查询、文件读取等。使用`WebClient`库可以从服务器发起异步GET/POST请求。

5. **错误处理**：通过`ErrorHandler`或`ReactiveExceptionHandler`来捕获和处理异常。