如何结合两个或多个参数化Monos Webflux最佳实践

Question

因此，我调用一个服务“ServiceA”，它通过webclient进行外部调用，返回一个mono，然后我想调用另一个服务“serviceB”，它也进行类似的外部调用，这次从“ServiceA”mono传递一些数据，可能还有一些其他外部参数。

Mono<ResponseA> responseAmono = serviceA.getdataA("some parameter");
Mono<ResponseB> responseBmono = serviceB.getdataB("data from responseAmono", "some parameter")

目前我有这个实现。

responseAmono
        .doOnSuccess(data -> {
            if (data.field == true) {
                serviceB.getdataB(data, "some parameter");
            }
        })
        .subscribe(x -> {}, e -> sout("serviceA Subscription Error! "+ e.getMessage()));

但是我面临线程池的挑战，因为PoolAcquirePendingLimitException

那么，将这两个单声道结合起来以获得良好性能的最佳策略是什么？

以及在调用内部mono“serviceB”时分离关注点。

笔记I订阅也在serviceB上实现。

Answer 1

doOnSuccess（）应仅针对同步副作用而不是反应性操作调用。如果您实际上是在doOnSuccess（）调用中阻塞，这可能就是您遇到线程问题的原因。

相反，flatMap（）。如果您仍然希望返回服务A的结果，而忽略服务B的结果，则可以按如下类似方式执行此操作：

responseAmono
    .flatMap(data -> {
        if (data.field == true) {
            return serviceB.getdataB(data, "some parameter").thenReturn(data);
        }
        else {
            return Mono.just(data);
        }
    })