问题标签 [vertx-httpclient]

我正面临 vert.x 的问题。当触发超时时，它会生成一个响应，然后实际响应（需要 10 秒）来并尝试做出响应，所以我得到：

java.lang.IllegalStateException：响应已被写入

我是 Vert.x 的新手，我不确定所需的行为，我应该怎么做？，因为代码是异步的，我找不到检查响应是否已经发送的方法。

有没有办法正确地做到这一点？

我有这个代码：

我有一个程序，我在其中部署了一个 worker verticle（vertx 版本 3.6.3）。从这里，工人 Verticle，我正在使用 Vertx WebClient 库发出 HTTP 请求。我的 vertx 工作池大小为 20，事件循环池大小为 10。之后，发出 http 请求（在 send() 调用之后），我阻塞了使用可完成未来发出 HTTP 请求（工作线程）的工作线程。当我阻塞工作线程时，HTTP 请求永远不会响应并且总是超时。当工作线程没有被阻塞时它会响应。我想，如果我阻塞了工作线程，池中还有其他工作线程来处理 HTTP 请求。我在这里做错了什么？此外，我启用了网络日志活动，但我没有看到任何网络日志打印在日志中。

以下是我尝试过的程序，我正在运行一个示例 HTTP 服务器，该服务器在 localhost 的 8080 端口上运行，响应良好。

我想知道在指定 http 客户端超时时使用的不同时间单位的意义是什么。连接超时以毫秒为单位，空闲超时以秒为单位，读取超时以毫秒为单位。

1. vertx 是否使用不同的精度来确定应该触发超时的精度？

2. 超时是如何触发的？

我正在使用https://vertx.io/docs/apidocs/io/vertx/core/http/HttpClientRequest.html

我正在尝试为 Vertx Web 客户端编写一个包装器，以使用来自响应流的服务器加载响应正文Publisher：

此解决方案不正确，因为它通过getBytes()调用以阻塞方式读取所有正文字节。

是否可以按块从 Vertx 读取响应WebClient并将其转换为Publisher（或 Rx Flowable）？

示例响应处理程序：

我们如何通过在处理程序中模拟对象来对上述处理程序进行单元测试？

我正在尝试使用 Vertx 的 WebClient 测试我的 Post 端点，并始终将 500 作为状态代码。谁能让我知道我在这里做错了什么：-

我是 Java 新手，最近在学习 Vertx，我不明白以下代码是如何工作的：

我的问题是：为什么参数req不需要声明类型，这个 req 是从哪里来的？

所以我正在为java制作一个vertx verticle，当我在intellij中运行它时它似乎开始了，但是当我制作一个shadowjar并在我的ubuntu服务器上启动它时，我得到了这个：

它以前可以正常工作，但我无法弄清楚这是什么意思。几周前我一直在使用shadowjar来部署它，它在intellij中没有给出任何错误，这个错误给出了零信息......

在大多数 Web 应用程序中，应用程序都构建在 vertx 中，我已经看到人们在单个微服务中创建了两个 verticles。

• 一种是用于处理 HTTP 请求的 rest verticle。
• 另一种是通过dao verticle 与数据库进行通信。

每当有任何 api 请求时，HTTP verticle 通过事件总线与 dao verticle 进行通信。

但是考虑到顶点是单线程的，在这里创建两个不同的顶点有什么好处。事件总线上的通信会产生不必要的开销，而我只能创建一个处理 rest 和 i/o 的 Verticle。

我可以理解在阻塞调用的情况下有一个单独的工人 Verticle 的情况。但是在非阻塞的情况下，i/o调用的用例是什么呢？

我在 Hasura 中有一个 graphlQL 客户端（在 docker 实例上运行），我想从顶点访问它。

以下是我的代码：

但我得到以下异常：

我被卡住了，知道这里出了什么问题。