Webflux中如何在首个Mono执行成功后调用第二个Mono并返回其结果

你的代码无法触发WebClient调用的核心原因是Reactor的惰性执行特性：

• service.operation2() 基于WebClient实现，返回值必然是Mono/Flux类型的响应式流，你在flatMap中调用方法后没有把返回的流纳入整个响应式链路，这个流不会被订阅，自然不会触发实际的HTTP请求。
• 手动调用subscribe()触发op2是错误写法：这会让op2脱离当前请求的响应式上下文和生命周期管理，不仅可能出现上下文丢失、请求提前返回中断op2执行的问题，也无法保证op2执行完成后再返回op1的结果。
• 直接用then()方法不符合需求：then()会丢弃上游流的元素，只返回后续流的完成信号，拿不到op1的返回结果。

直接在flatMap中组装op2的流，用thenReturn在op2完成后返回op1的结果即可：

public Mono<ResponseEntity<Resource>> callOperations(){
   return service.operation1()
          // op1执行成功拿到Resource后才会触发flatMap内逻辑
          .flatMap(resource -> service.operation2()
                  // 等待op2执行完成后，返回op1的结果
                  .thenReturn(resource)
          )
          .map(ResponseEntity::ok);
}

• 执行顺序符合要求：只有op1成功返回、没有抛出异常时，才会触发op2的WebClient调用，op1失败时整个流直接传播错误，不会执行op2。
• WebClient可正常发起调用：op2返回的响应式流被纳入主链路，会被Webflux框架统一订阅调度，不存在流不执行的问题。
• 返回值符合要求：thenReturn会等待op2完全执行完成（包括WebClient请求发送、响应接收、后续逻辑处理完毕），才会把op1拿到的resource传给下游，不会提前返回结果。

如果习惯用then写法，也可以用下面的等价实现，效果完全一致：

public Mono<ResponseEntity<Resource>> callOperations(){
   return service.operation1()
          .flatMap(resource -> Mono.when(service.operation2())
                  .then(Mono.just(resource))
          )
          .map(ResponseEntity::ok);
}

注意：不要在Webflux请求处理的主响应式流中手动调用subscribe()，手动订阅会脱离框架的生命周期管理，会引发请求提前返回、上下文丢失、资源泄漏等不可预期的问题。

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