webflux怎么配置和使用

WebFlux 是一个异步非阻塞的响应式编程框架，用于构建基于响应式编程的 Web 应用程序。下面是 WebFlux 的配置和使用方法：

1. 依赖配置：首先，在 Maven 或 Gradle 中添加 WebFlux 依赖：

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

2. 编写 Controller：在 Spring Boot 应用程序中创建一个或多个 Controller 类，用于处理 HTTP 请求和生成响应。可以使用注解 @RestController 标记类，@GetMapping、@PostMapping 等注解标记方法。

@RestController
public class HelloController {
    
    @GetMapping("/hello")
    public Mono<String> sayHello() {
        return Mono.just("Hello, WebFlux!");
    }
}

3. 配置路由：使用 RouterFunction 配置路由，将请求映射到对应的处理器方法。

@Configuration
public class RouterConfig {

    @Bean
    public RouterFunction<ServerResponse> route(HelloHandler helloHandler) {
        return RouterFunctions.route(RequestPredicates.GET("/hello"), helloHandler::sayHello);
    }
}

4. 编写 Handler：创建一个 Handler 类，实现处理请求的方法。

@Component
public class HelloHandler {

    public Mono<ServerResponse> sayHello(ServerRequest request) {
        return ServerResponse.ok().body(BodyInserters.fromValue("Hello, WebFlux!"));
    }
}

5. 启动应用程序：在 Spring Boot 应用程序的主类中增加 @SpringBootApplication 注解，启动应用程序。

@SpringBootApplication
public class WebfluxApplication {

    public static void main(String[] args) {
        SpringApplication.run(WebfluxApplication.class, args);
    }
}

通过以上配置和使用方法，你可以开始使用 WebFlux 构建响应式的 Web 应用程序。可以使用 Mono 和 Flux 类处理异步流式数据，提高应用程序的性能和资源利用率。