Spring WebFlux中.then(Mono{})执行顺序困惑及原因咨询

你遇到的问题核心在于Mono的「创建」和「订阅」是完全分离的两个阶段，而then操作符的行为和你预期的有差异，本质是没搞清楚这两个阶段的时机。

原代码的问题 #

你的原代码：

fun storeIfValid(x): Mono<Long> =
    doSomeChecksThatMightFail().then(repo.save(x))

这里的repo.save(x)是在调用storeIfValid方法时就立即执行了，它会直接生成一个Mono实例——如果你的Repository实现（比如Spring Data Reactive MongoDB）在调用save时就触发了实际的数据库操作（而非等到Mono被订阅才执行），那不管前面的doSomeChecksThatMightFail()是否失败，这个save操作已经跑起来了。

then操作符的真实作用是：忽略上游Mono的结果，仅当上游Mono成功发出onComplete信号时，才去「订阅」下游的Mono。但它不会管下游Mono是不是已经提前创建、甚至提前执行了副作用。

为什么Mono.defer能解决 #

Mono.defer { ... }是一个延迟创建Mono的操作符：它不会在一开始就执行lambda里的代码，而是等到下游被订阅时才会执行lambda，生成真正的Mono实例。

修改后的代码：

fun storeIfValid(x): Mono<Long> =
    doSomeChecksThatMightFail().then(Mono.defer { repo.save(x) })

此时的执行流程是：

1. 调用storeIfValid时，仅创建上游的检查Mono，defer里的repo.save(x)完全没执行
2. 当整个Mono被订阅后：
   • 先执行上游的检查逻辑
   • 如果检查成功（发出onComplete），才会执行defer的lambda，调用repo.save(x)生成Mono并订阅，此时才触发数据库操作
   • 如果检查失败（发出onError），defer的lambda不会执行，自然不会有save操作

为什么flatMap也能解决 #

flatMap的逻辑类似：它只会在上游Mono成功发出元素时，才执行lambda生成下游的Mono。也就是说，只有检查通过，才会调用repo.save(x)并订阅它，同样延迟了副作用的执行时机：

fun storeIfValid(x): Mono<Long> =
    doSomeChecksThatMightFail().flatMap { repo.save(x) }

这里因为上游的检查Mono可能是一个Mono<Void>（如果doSomeChecksThatMightFail()不返回数据），flatMap依然能工作——只要上游成功完成，就会执行lambda生成save的Mono。

关键总结 #

在Reactor中：

• 像repo.save(x)这种直接创建Mono的方式，属于** eager（急切）创建**，副作用（比如数据库操作）可能在创建阶段就触发
• defer、flatMap、concatMap这类操作符属于** lazy（延迟）创建**，只有当上游信号触发时，才会生成下游的Mono/Flux，从而精准控制副作用的执行时机

如果你需要确保下游操作仅在上游成功后才执行，必须用延迟创建的方式包裹下游的Mono/Flux。

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