掌握Java响应式编程（从零开始学习Reactor框架与响应式流）

入门示例：Hello World

首先，确保你的项目已添加Reactor依赖（以Maven为例）：

<dependency>    <groupId>io.projectreactor</groupId>    <artifactId>reactor-core</artifactId>    <version>3.6.0</version></dependency>  

接下来，编写一个简单的Flux示例：

import reactor.core.publisher.Flux;public class HelloWorld {    public static void main(String[] args) {        Flux<String> flux = Flux.just("Hello", "Reactive", "World");                flux            .map(String::toUpperCase)            .subscribe(System.out::println);    }}  

运行后输出：

HELLOREACTIVEWORLD  

这里我们创建了一个包含三个字符串的 Flux，通过 map 转换为大写，最后用 subscribe 触发执行。注意：响应式流是“懒加载”的，只有订阅后才会真正执行。

处理异步操作

响应式编程的一大优势是天然支持异步。例如，模拟一个耗时操作：

import reactor.core.publisher.Mono;import reactor.core.scheduler.Schedulers;public class AsyncExample {    public static void main(String[] args) {        Mono<String> mono = Mono            .fromCallable(() -> {                // 模拟耗时任务                Thread.sleep(1000);                return "Task Completed!";            })            .subscribeOn(Schedulers.boundedElastic()) // 在后台线程执行            .doOnNext(s -> System.out.println("Processing on thread: " +                          Thread.currentThread().getName()));        System.out.println("Before subscribe");        mono.subscribe(result -> System.out.println("Result: " + result));        System.out.println("After subscribe");        // 防止主线程提前退出        try { Thread.sleep(2000); } catch (InterruptedException e) {}    }}  

输出可能如下：

Before subscribeAfter subscribeProcessing on thread: boundedElastic-1Result: Task Completed!  

这展示了如何将阻塞操作移到后台线程执行，避免阻塞主线程，体现了响应式流的非阻塞性。

错误处理与组合操作

响应式流也提供了丰富的错误处理机制：

Flux.just(1, 2, 0, 4)    .map(i -> 10 / i)    .onErrorReturn(-1) // 遇到除零错误时返回-1    .subscribe(System.out::println);  

此外，你还可以组合多个流：

Flux<String> flux1 = Flux.just("A", "B");Flux<String> flux2 = Flux.just("X", "Y");Flux.concat(flux1, flux2)    .subscribe(System.out::println); // 输出 A, B, X, Y  

总结

通过本教程，你已经掌握了Java响应式编程的基础知识，包括 Flux 与 Mono 的使用、异步调度、错误处理等核心技能。随着你深入学习Reactor教程，你会发现它在构建高性能、可扩展的现代应用中具有巨大优势。

记住：响应式不是银弹，但在I/O密集型、高并发场景下，它能显著提升系统性能。建议结合Spring WebFlux进一步实践，开启全栈响应式开发之旅！

—— 学会响应式流，让你的Java程序更高效、更优雅 ——