使用SpringWebFlux的第一次调用的结果进行多个异步调用

Question

我需要进行异步调用，并使用其中存在的一些值对同一服务进行多次调用。将这些调用的响应与第一个调用结合起来，然后返回。

例如，当我第一次调用时，我会在JSON下面看到一个ID列表。现在，我必须使用这些ID对一个服务进行多次调用，并列出它们的响应列表，然后通过在同一个JSON中添加它们将其发送到下游。

 {“id”: 145,
    “object”:[{“id”:111}]
    }

我试过使用zipWhen和

Flux.fromIterable(userIds).parallel().runOn(Schedulers.elastic()).flatMap()

但是结果列表总是以空或空的形式出现。我们如何才能做到这一点？我是不是漏了什么？

Edit1：通过使用Flux.fromIterable解决它。阅读更多关于它的信息，最终理解了它的用途并解决了它。下面的方法占用列表中的一个项目，并将调用将调用多个API的内部方法：

return Flux.fromIterable(somelist).flatMap(listItem -> {
    return someMethodToCallAnotherAPIUsingZipWith(listItem);
    }).collectList();

内部方法：它调用第一个API，将其结果传递给zipWith，使用此结果我们可以调用另一个API，也可以简单地将其与响应一起使用。

private Mono<Object> someMethodToCallAnotherAPIUsingZipWith(String listItem) {
        return authService.getAccessToken().flatMap(accessToken ->
                webClient.get().uri(builder -> builder.path("/path").build(listItem))
                        .header(HttpHeaders.AUTHORIZATION, accessToken)
                        .retrieve()
                        .toEntity(Entity.class).log()
                        .flatMap(entity -> {
                            //manipulate your response or create new object using it
                            return Mono.just(entity);
                        }).zipWhen(consent -> webClient.get().uri(builder -> builder.path("/otherpath").build(listItem))
                        .header(HttpHeaders.AUTHORIZATION, accessToken)
                        .retrieve().bodyToMono(Entity.class).log()
                        .flatMap(entity -> {
                            //example
                            listItem = entity.getString();
                            return Mono.just(listItem);
                        }), (string1, string2) -> string1 + string2));
    }

Answer 1

private Mono<Object> someMethodToCallAnotherAPIUsingZipWith(String listItem) {
    return authService.getAccessToken().flatMap(accessToken ->
            webClient.get().uri(builder -> builder.path("/path").build(listItem))
                    .header(HttpHeaders.AUTHORIZATION, accessToken)
                    .retrieve()
                    .toEntity(Entity.class).log()
                    .flatMap(entity -> {
                        //manipulate your response or create new object using it
                        return Mono.just(entity);
                    }).zipWhen(consent -> webClient.get().uri(builder -> builder.path("/otherpath").build(listItem))
                    .header(HttpHeaders.AUTHORIZATION, accessToken)
                    .retrieve().bodyToMono(Entity.class).log()
                    .flatMap(entity -> {
                        //example
                        listItem = entity.getString();
                        return Mono.just(listItem);
                    }), (string1, string2) -> string1 + string2));
}