等待所有Mono响应从下游API返回的正确方法是什么

Question

我对Mono和Flux很陌生。我正在尝试加入几个下游API响应。这是一个传统的阻塞应用程序。我不想收集Mono的列表，我想要一个从下游API返回的有效负载列表，我从Mono获取。然而，有时返回给控制器的“结果”只有部分或没有下游API响应。正确的方法是什么？我读过几篇关于如何迭代通量和混合单态的帖子

您不应该在web应用程序中的任何位置调用subscribe。如果这是绑定到HTTP请求的，则基本上是触发反应性管道，而不保证资源或完成。调用subscribe会触发管道，但不会等到它完成

我应该使用CompletableFuture吗？

在我的服务中，我尝试

var result = new ArrayList<List<>>();
List<Mono<X>> monoList = apiCall();
Flux.fromIterable(monoList)
            .flatMap(m -> m.doOnSuccess(
                        x -> {  
                            result.add(x.getData());
                        }
        )).subscribe();

我还尝试在controller中执行以下操作，但该方法返回时不等待subscribe完成

var result = new ArrayList<List<X>>();
        Flux.concat(
                this.service.callApis(result, ...)
        ).subscribe();
        return result;

在我的服务中

public Mono<Void> callApis(List<List<x>> result, ..) {
...
return Flux.fromIterable(monoList)
                .flatMap(m -> m.doOnSuccess(
                        x -> {  
                            result.add(x.getData()...);
                        }
                )).then();

Answer 1

项目反应器留档（这是非常好的）有一个部分，称为我需要哪个运算符？。您需要从您的API调用中创建一个Flux，组合结果，然后返回同步世界。

在您的情况下，您的所有下游服务似乎都有相同的API，因此它们都返回相同的类型，并且这些响应在应用程序中的显示顺序并不重要。此外，我假设apiCall（）返回一个列表

Flux.fromIterable(apiCall()) // Flux<Mono<Response>>
    .flatMap(mono -> mono) // Flux<Response>
    .map(response -> response.getData()) // Flux<List<X>>
    .collectList() // Mono<List<List<X>>>
    .block(); // List<List<X>>

fromIterable（...）。平面图（x-

map（）用于提取响应的数据部分。

collectList（）创建一个等待流量完成的单声道，并给出一个包含所有数据列表的结果。

block（）订阅上一个操作符返回的单声道，并一直阻塞到它完成为止，在这种情况下，将在apiCall（）返回的所有单声道完成时执行。

这里有许多可能的替代方案，哪个最合适将取决于您的确切用例。