掌握Spring WebFlux（响应式Web开发从入门到实战）

为什么选择响应式编程Java？

传统阻塞式编程在高并发下会创建大量线程，导致资源浪费和上下文切换开销。而响应式编程Java通过事件驱动和背压机制，用少量线程即可高效处理成千上万的并发连接。这正是 WebFlux 的核心优势。

Reactor 入门：Mono 与 Flux

WebFlux 的底层依赖是 Project Reactor，它提供了两个核心发布者类型：

• Mono<T>：表示 0 或 1 个元素的异步序列。
• Flux<T>：表示 0 到 N 个元素的异步序列。

下面是一个简单的 Reactor入门 示例：

import reactor.core.publisher.Mono;import reactor.core.publisher.Flux;public class ReactorExample {    public static void main(String[] args) {        // 创建一个 Mono        Mono<String> mono = Mono.just("Hello WebFlux");        mono.subscribe(System.out::println);        // 创建一个 Flux        Flux<Integer> flux = Flux.range(1, 5);        flux.map(i -> i * 2)            .subscribe(System.out::println);    }}

Spring WebFlux 实战：构建一个响应式 REST API

下面我们通过一个完整的 Spring WebFlux实战 示例，创建一个用户管理的 RESTful 接口。

1. 添加 Maven 依赖（pom.xml）

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

2. 定义 User 实体类

public class User {    private String id;    private String name;    private String email;    // 构造函数、getter/setter 省略}

3. 创建响应式 Controller

import org.springframework.web.bind.annotation.*;import reactor.core.publisher.Flux;import reactor.core.publisher.Mono;@RestController@RequestMapping("/api/users")public class UserController {    // 模拟内存数据库    private final List<User> users = new ArrayList<>();    @GetMapping    public Flux<User> getAllUsers() {        return Flux.fromIterable(users);    }    @GetMapping("/{id}")    public Mono<User> getUserById(@PathVariable String id) {        return Mono.justOrEmpty(            users.stream().filter(u -> u.getId().equals(id)).findFirst()        );    }    @PostMapping    public Mono<User> createUser(@RequestBody User user) {        user.setId(UUID.randomUUID().toString());        users.add(user);        return Mono.just(user);    }}

启动应用后，你可以通过 Postman 或 curl 测试这些接口。你会发现，整个过程是非阻塞的，即使在高负载下也能保持高性能。

总结

通过本篇WebFlux教程，你已经掌握了响应式编程的基本思想、Reactor 核心类型（Mono/Flux），并动手实现了一个完整的 Spring WebFlux 应用。无论你是想提升系统性能，还是为未来微服务架构打基础，响应式编程Java 都是一项值得投资的技能。

记住，真正的Spring WebFlux实战才刚刚开始！建议你尝试集成 MongoDB Reactive、R2DBC 数据库，或使用 WebClient 调用其他响应式服务，进一步深化你的 Reactor入门 体验。