有没有办法在Mono.zip中提供事务回滚？

Question

我正在处理一个编排层微服务，其中我需要并行调用不同微服务的几个API。为此，我使用subscribeOn(Schedulers.parallel)并订阅Mono.zip中的每个响应。例如：

Mono<A> a =  service1.api().subscribeOn(Schedulers.parallel());
Mono<B> b =  service2.api().subscribeOn(Schedulers.parallel());
Mono<C> c =  service3.api().subscribeOn(Schedulers.parallel());
return Mono.zip(a,b,c);

现在，如果a、b或c中的任何一个完成时出现错误，则此压缩将失败。假设在第三个调用中出现了错误，我想以这样一种方式处理这种情况：service1.api()和service2.api()所做的任何操作都可以恢复，即像事务一样回滚。

我为我所做的任何错误的声明道歉，因为我在Spring WebFlux中还是个新手。提前感谢大家的帮助。

Answer 1

我相信没有这样的条款来回滚单个调用。您可以使用Mono.zipDelayError来完成除可能失败的调用之外的有效调用。在此之后，在错误返回时，您可以显式地实现单个事务回滚。