如何在保留原始值的同时优雅链式调用Mono方法？

我有以下四个返回Mono类型的方法：

Mono<A> tearUp();
Mono<B> doB(A a);
Mono<C> doC(B b);
Mono<D> shutDown(A a);

最简单的工作流实现如下：

tearUp()
    .flatMap(a -> shutDown(a))
    .block();

现在我需要依次调用tearUp、doB、doC、shutDown这四个方法，我知道可以通过多次调用block()实现：

A a = tearUp().block();
B b = doB(a).block();
C c = doC(b).block();
D d = shutDown(a).block();

请问如何优雅地用Mono实现这个调用流程？我尝试了下面这段代码，是否正确？

tearUp()
    .flatMap(a -> doB(a).flatMap(b -> doC(b)).thenReturn(a))
    .flatMap(a -> shutDown(a))
    .block();

你的代码是正确的，它能按顺序执行所有方法：先调用tearUp()获取A，接着用A调用doB()得到B，再用B调用doC()，最后用最初的A调用shutDown()，整个流程是异步非阻塞的（仅最后的block()会阻塞）。

不过可以优化写法，让逻辑更清晰：

tearUp()
    .flatMap(a -> 
        doB(a)
            .flatMap(b -> doC(b))
            .then(shutDown(a))
    )
    .block();

这里用then()替代原写法中的thenReturn(a).flatMap(...)，因为我们不需要doC()的返回值C，只需要确保它执行完成后再调用shutDown(a)，语义上更贴合“等待前序操作完成后执行收尾逻辑”的需求。

如果后续需要用到C的结果，也可以调整为：

tearUp()
    .flatMap(a -> 
        doB(a)
            .flatMap(b -> doC(b))
            .flatMap(c -> shutDown(a)) // 此处可直接使用c的值
    )
    .block();

这种嵌套flatMap的方式既保证了操作的顺序执行，又全程保持Reactive的异步特性，比多次调用block()更符合Reactor的设计理念，避免了不必要的线程阻塞和上下文切换。

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