标签：project-reactor spring-webflux spring

我有一个简单的Java程序,它使用Spring WebClient发送多个请求.每个都返回一个单声道,我使用response.subscribe()来检查结果.

但是,我的主要执行线程在处理所有请求之前完成,除非我添加一个长的Thread.sleep().

使用CompletableFutures,您可以使用：CompletableFuture.allOf(期货).join();

有没有办法等待所有Mono完成？

解决方法:

如the Project Reactor documentation中所述,在您订阅发布者之前没有任何反应.该操作返回Disposable的实例,这意味着此时操作可能仍在进行中.

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

您的问题并没有真正解释“检查回复”的含义.在这里,我们将获得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();

标签：project-reactor,spring-webflux,spring
来源： https://codeday.me/bug/20190910/1799280.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。