Spring WebFlux for Java：响应式编程完整指南

1. 什么是 Spring WebFlux 及其用途

Spring WebFlux 是一个响应式 Web 框架，属于 Spring Framework 5+ 生态系统，为传统的 Spring MVC 提供了替代方案。与每个 HTTP 请求由单独线程处理的阻塞（blocking）方法不同，WebFlux 基于异步、非阻塞（non-blocking）的输入输出模型。这使得它能够用最少的线程处理数千个并发连接，这对于高负载系统、微服务和实时应用程序至关重要。

为什么需要 Spring WebFlux？在当今用户和设备数量呈指数级增长的世界中，传统的 Servlet 容器（Tomcat、Jetty）面临着“C10K”问题（处理 10,000 个并发连接）。每个线程都会消耗内存（通常每个栈约 1 MB），当有 10,000 个线程时，仅栈内存就需要 10 GB。WebFlux 通过使用响应式流（Reactive Streams）模型解决了这个问题，在该模型中，单个线程可以处理多个请求，并在数据准备好时在它们之间切换。

WebFlux 支持两种类型的服务器：Netty（推荐，非阻塞）和 Servlet 3.1+（Tomcat、Jetty、Undertow）。它与 Reactor 项目（Mono 和 Flux）完全集成，并且除了 @Controller 注解外，还可以使用函数式路由风格（Router Functions）。这使其成为构建高性能 API、服务器发送事件（SSE）服务器、WebSocket 应用程序以及使用响应式数据库（MongoDB Reactive、R2DBC）的微服务的理想选择。

2. 安装

Spring WebFlux 不能通过 pip 或 npm 安装，因为它是一个 Java 库。要使用它，您需要在项目中添加依赖项。以下是 Maven 和 Gradle 的具体命令。

Maven (pom.xml)

<dependency>\n    <groupId>org.springframework.boot</groupId>\n    <artifactId>spring-boot-starter-webflux</artifactId>\n    <version>3.2.0</version> <!-- 请使用最新版本 -->\n</dependency>\n

Gradle (build.gradle)

implementation 'org.springframework.boot:spring-boot-starter-webflux:3.2.0'\n

如果您使用 Spring Initializr (start.spring.io)，只需在依赖项部分选择“Spring Reactive Web”。为了实现与数据库的非阻塞操作，请同时添加：

<dependency>\n    <groupId>org.springframework.boot</groupId>\n    <artifactId>spring-boot-starter-data-mongodb-reactive</artifactId>\n</dependency>\n

3. 快速入门 — 最小工作示例

创建一个简单的响应式 REST 控制器，返回问候语。此示例演示了使用注解的 WebFlux 基本配置。

// MainApplication.java\nimport org.springframework.boot.SpringApplication;\nimport org.springframework.boot.autoconfigure.SpringBootApplication;\n\n@SpringBootApplication\npublic class MainApplication {\n    public static void main(String[] args) {\n        SpringApplication.run(MainApplication.class, args);\n    }\n}\n\n// GreetingController.java\nimport org.springframework.web.bind.annotation.GetMapping;\nimport org.springframework.web.bind.annotation.RestController;\nimport reactor.core.publisher.Mono;\n\n@RestController\npublic class GreetingController {\n\n    @GetMapping("/hello")\n    public Mono<String> sayHello() {\n        return Mono.just("Hello from Spring WebFlux!");\n    }\n}\n

启动应用程序并打开 http://localhost:8080/hello。您将看到字符串“Hello from Spring WebFlux!”。请注意