如何在Reactor中合并两个Mono订阅，单次完成双对象Couchbase保存

当然可以！在Spring WebFlux依赖的Reactor框架里，有好几个实用的操作符能帮你实现单次订阅就完成两个Mono的异步保存操作，下面给你几个常用的方案，你可以根据自己的需求选择：

方案1：用Mono.zip()并行执行+获取结果 #

如果你需要等待两个保存操作都完成，同时还想拿到它们的返回结果（虽然你的save方法返回Mono<Void>，结果可能不重要，但这个操作符依然适用），可以用zip：

// 合并两个保存操作，并行执行，等待两者都完成
Mono<Void> combinedSave = Mono.zip(
    createService.save(profile),
    createService.save(account)
).then(); // 把zip返回的Tuple转换成Mono<Void>，只关注完成状态

// 单次订阅触发所有操作
combinedSave.subscribe(
    () -> System.out.println("Profile和Account都保存成功啦！"),
    error -> System.err.println("保存过程出错：" + error.getMessage())
);

注意点： #

• zip会并行触发两个Mono的执行，但会等待两者都成功完成才会向下传递信号；
• 如果其中一个保存操作失败，整个流会立刻触发错误信号，另一个操作可能会被取消（取决于Couchbase客户端的实现）。

方案2：用Mono.when()并行执行+只关注完成状态 #

如果你完全不需要保存操作的返回结果，只关心两个操作都完成（不管结果是什么），when是更轻量的选择：

// 并行执行两个保存操作，只等待所有操作完成
Mono<Void> combinedSave = Mono.when(
    createService.save(profile),
    createService.save(account)
);

// 单次订阅触发
combinedSave.subscribe(
    () -> System.out.println("两个对象都保存完成！"),
    error -> System.err.println("保存失败：" + error.getMessage())
);

和zip的区别： #

when不会收集两个Mono的结果，只是等待所有操作完成，性能上比zip略优，适合只关心执行完成的场景。

方案3：用then()串行执行（可选） #

如果你的业务需求是先保存Profile，成功后再保存Account（串行执行），可以用then链式调用：

// 先保存Profile，成功后再保存Account
Mono<Void> sequentialSave = createService.save(profile)
    .then(createService.save(account));

sequentialSave.subscribe(...);

进阶：处理单个操作失败的情况 #

如果想让一个操作失败不影响另一个操作的执行，可以给每个Mono加上onErrorResume做容错处理：

Mono<Void> combinedSave = Mono.when(
    createService.save(profile).onErrorResume(error -> {
        // 处理Profile保存失败的逻辑，比如记录日志
        System.err.println("Profile保存失败：" + error.getMessage());
        return Mono.empty(); // 返回空Mono，让整个流继续执行
    }),
    createService.save(account).onErrorResume(error -> {
        System.err.println("Account保存失败：" + error.getMessage());
        return Mono.empty();
    })
);

这样即使其中一个保存失败，另一个依然会正常执行，整个流也不会因为单个错误而终止。

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