Quarkus与Vert.x的异步和并行请求

Question

我有一个Quarkus应用程序，它读取一个文件并发送请求（到另一个Quarkus微服务）。目前，我为文件的每一行发送一个请求。但这个过程花了这么长时间因为我有上千行。

我读过关于Vert.x的文章，我得到了一个对API的异步请求，这要感谢这个链接：

https://quarkus.io/blog/mutiny-concurrent-uni/

但我的问题是，我必须将请求的响应保存到一个数组中，最后保存文件。所以问题是进程结束了，而文件的结果是空的（因为请求是异步的，并且它们在那一刻被调用）

这是我用来发出异步请求的代码：

 this.client = WebClient.create(vertx,
              new WebClientOptions().setSsl(true).setTrustAll(true));
            
 client.postAbs("http://localhost:8082/myApi")
      .sendJson(myDto)
      .subscribe().with(a->this.processRecord(a.bodyAsString());        

我知道我必须等到与包含所有记录的ArrayList的异步进程完成之后，然后在所有操作完成之后保存文件。我读过关于CompletableFuture的文章，我认为它可能会起作用，但我不知道我必须在哪里等待，如何等待。

PS：也许有其他方法可以做到这一点。反正我也想知道。

多谢了。

Answer 1

使用Await().atmost（duration.ofseconds（...））或Await().indefinitely()代替subscribe。两者都将返回httpresponse。

现在，如果没有太多的上下文，很难理解您的方法是如何使用的。通常，我们不使用await()，因为调用也是异步的，因此期望接收UNI。