如何使用Spring5WebClient等待所有请求完成？

Question

我有一个简单的Java程序，它使用SpringWebClient发送多个请求。每个都返回一个mono，我使用的是response。subscribe（）以检查结果。

但是，我的主执行线程在处理所有请求之前完成，除非我添加一个长线程。睡眠（）。

对于CompletableFutures，您可以使用：CompletableFuture。allOf（期货）。join（）；

有没有办法等待所有单声道的完成？

Answer 1

正如Project Reactor文档中所解释的那样，在订阅发布者之前，不会发生任何事情。该操作返回一个可丢弃的实例，这意味着该操作可能仍在进行中。

如果您不在非阻塞反应性管道（例如，HTTP请求/响应交换或批处理操作）的中间，并且需要在退出VM之前等待管道的完成，那么您可以block（）。这实际上是为数不多的“允许”用例之一。

你的问题并不能真正解释你所说的“检查回答”是什么意思。在这里，我们将只获取POJO（如果HTTP响应状态不是200，或者如果我们不能反序列化响应，将发送一个错误信号）。在您的示例中，您可以有如下内容：

Mono<User> one = this.webClient...
Mono<Account> two = this.webClient...
Mono<Book> three = this.webClient...

// we want all requests to happen concurrently
Mono<Void> all = Mono.when(one, two, three);
// we subscribe and then wait for all to be done
all.block();