WebFlux 入门指南：使用 WebFlux 构建简单 Web 应用程序

WebFlux 是 Spring Framework 5 引入的一种响应式编程模型，用于构建高性能、非阻塞的 Web 应用程序。它基于 Reactor 项目提供的反应式流技术，可以处理大量并发请求并提供高吞吐量。

以下是一个简单的示例，演示如何使用 WebFlux 构建一个简单的 Web 应用程序：

首先，确保已经添加了 Spring Boot 和 WebFlux 的相关依赖。在 Maven 或 Gradle 构建文件中，添加以下依赖项：

<dependencies>
    <!-- 其他依赖项 -->
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-webflux</artifactId>
    </dependency>
</dependencies>

创建一个处理请求的处理器类：

import org.springframework.stereotype.Component;
import org.springframework.web.reactive.function.server.RouterFunction;
import org.springframework.web.reactive.function.server.ServerResponse;
import static org.springframework.web.reactive.function.server.RequestPredicates.GET;
import static org.springframework.web.reactive.function.server.RouterFunctions.route;

@Component
public class HelloHandler {

    public RouterFunction<ServerResponse> hello() {
        return route(GET("/hello"), request -> ServerResponse.ok().bodyValue('Hello, WebFlux!'));
    }
}

在上述示例中，我们定义了一个处理器类 HelloHandler，其中的 hello() 方法返回一个 RouterFunction<ServerResponse> 对象，用于处理 /hello 路径的 GET 请求，并响应 'Hello, WebFlux!'。

创建一个启动类，并使用 @EnableWebFlux 注解启用 WebFlux：

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.annotation.Bean;
import org.springframework.web.reactive.function.server.RouterFunction;

@SpringBootApplication
@EnableWebFlux
public class Application {

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

    @Bean
    public RouterFunction<ServerResponse> routes(HelloHandler helloHandler) {
        return helloHandler.hello();
    }
}

在上述示例中，我们在启动类中定义了一个 HelloHandler 的 Bean，并使用 @Bean 注解将其注册到 Spring 容器中。然后，我们使用 @EnableWebFlux 注解来启用 WebFlux。

最后，运行应用程序并访问 http://localhost:8080/hello，您将看到 'Hello, WebFlux!' 的响应。

总结起来，WebFlux 是 Spring Framework 5 引入的一种响应式编程模型，基于 Reactor 项目。通过创建处理器类和路由函数，您可以构建非阻塞、高性能的 Web 应用程序。