Mono¶

引言¶

本章深入探讨了**Mono**在 Spring Reactor 中的核心设计与应用场景。作为 Reactor 模型中的关键组件，Mono 主要用于处理**单值响应式数据流**，其设计理念与 Flux（多值流）形成互补。以下从核心特性、静态方法、创建方式、与 Flux 的对比等角度展开分析。

Mono 的核心在于**仅发射一个元素**，这与 Flux 的多值特性形成鲜明对比。其设计底层通过MonoEmitter实现，采用**拉取式（Pull）**机制：当订阅者请求数据时，Mono 才会触发元素生成。这种设计避免了资源浪费，尤其适用于**延迟计算**或**异步数据获取**场景。

Mono 提供了丰富的静态工厂方法，例如：

这些方法通过**装饰器模式**实现，允许在不修改原始数据流的情况下添加日志、错误处理等横切关注点。

通过Mono.generate()方法，可以动态生成元素。例如：

Mono.generate(() -> {
    // 动态生成元素
    return "Dynamic Value";
});

此方法适用于需要根据运行时条件生成数据的场景。

Mono 支持onErrorResume、retry等操作符，例如：

Mono.just(1)
    .flatMap(value -> Mono.error(new RuntimeException()))
    .onErrorResume(e -> Mono.just(0));

这体现了**响应式编程的容错性**，允许在错误发生时无缝切换备用逻辑。

通过subscribeOn调度器，Mono 可以与阻塞式代码协同工作：

Mono.fromCallable(() -> {
    // 阻塞式操作
    return blockingMethod();
})
.subscribeOn(Schedulers.boundedElastic());

这确保了主线程不被阻塞，同时保持响应式流的特性。

将 Mono 用于封装远程 API 调用（如 RESTful 服务），结合flatMap实现链式调用：

Mono<User> userMono = WebClient.create()
    .get()
    .uri("/users/1")
    .retrieve()
    .bodyToMono(User.class);

在应用启动时，通过 Mono 动态加载配置文件：

Mono<Config> configMono = ConfigLoader.loadAsync();
configMono.subscribe(config -> {
    // 应用配置
});

利用 Reactor 的测试工具（如StepVerifier）验证 Mono 行为：

StepVerifier.create(Mono.just(42))
    .expectNext(42)
    .verifyComplete();

本章揭示了 Mono 在 Reactor 框架中的设计哲学：以单值流为切入点，通过高阶函数式操作实现复杂业务逻辑的简洁表达。其核心价值在于：