如何在不使用block()或subscribe()时将Mono<Mono<Something>>转为Mono<Something>

在Reactor框架中，你可以直接使用flatMap操作符实现嵌套Mono的扁平化，全程不需要调用block()或subscribe()这类阻塞/触发订阅的方法。

核心实现方式 #

flatMap的作用是将上层Mono发射的元素（此处为内部的Mono<Something>）转换为新的Publisher，并将其结果合并到外层流中，整个过程保持异步非阻塞。

示例代码：

// 假设你已有一个嵌套结构的Mono<Mono<Something>>
Mono<Mono<Something>> nestedMono = ...;

// 转换为单层的Mono<Something>
Mono<Something> flattenedMono = nestedMono.flatMap(innerMono -> innerMono);

更简洁的写法 #

如果不需要对内部Mono做额外处理，可直接用Function.identity()简化代码：

Mono<Something> flattenedMono = nestedMono.flatMap(Function.identity());

补充说明 #

• 若需要严格保证内部Mono的执行顺序（单元素场景下无差异），也可以用concatMap操作符，效果与flatMap一致；但多元素场景下flatMap会并行处理，concatMap是串行处理。
• 这种方式完全遵循Reactor响应式流规范，不会破坏异步非阻塞特性，避免了block()带来的线程阻塞问题。

内容的提问来源于stack exchange，提问作者user1354825