Vertx事件总线应答处理程序没有被特定调用调用

Question

我正在运行vertx的本地实例。路由器将我的请求重定向到具有以下处理程序的工作顶点：

protected Handler<Message<JsonObject>> handler1() {
    return msg -> {
        final RequestBody req = mapper.readValue(msg.body().encode(), RequestBody.class);
        processRequest(req, msg);
    }
}

processRequest函数接受请求主体，调用两个外部服务，聚合响应，然后返回给客户端。

private processRequest(RequestBody req, Message<JsonObject> msg) {
    CompletableFuture<String> service1Response = getService1ResponseAsync(req); // Make async call to service 1
    String service2Response = getService2ResponseSync(req); // Make sync call to service 2

    ResponseBody response = aggregateResult(service1Response.join(), service2Response);  // Tag1
    msg.reply(mapper.writeValueAsString(response));
}

private CompletableFuture<String> getService1ResponseAsync(RequestBody req) {
    CompletableFuture<String> result = new CompletableFuture();
    // Below handler call makes GET call to service 1 using apache HTTP client and returns the response
    vertx.eventBus().request("serviceVerticleAddr1", mapper.writeValueAsString(req), new DeliveryOptions(), reply -> { // Tag2
        if (reply.succeeded())
            result.complete(reply.result().body().toString());
        else
            result.completeExceptionally(result.cause());
    }
}

当我点击上面的API时，我的请求超时。为执行我的请求而分配的工作线程池中的线程将永远在Tag1被阻止。进一步调试后，我发现Tag2中调用的应答处理程序没有被调用。

ServiceVerticle（ServiceVerticleDDR1）[即Tag2]中的处理程序会为使用它的其他API返回正确的响应，但对我来说，它被阻止了。有人能帮我找出原因吗？当线程调用vertx时是否会形成某种死锁。eventBus（）。请求[Tag2]开始在service1Response等待将来的完成。join（）[Tag1]？

Answer 1

我想是因为消费者没有通知发送者消息已被处理，所以被阻止了。我建议您检查为ServiceVerticleDDR1地址的使用者注册的处理程序块内部，并确保正在回复（通知）发件人请求的消息已成功处理（或未成功处理）。消费者可能看起来像

vertx.eventBus().consumer("serviceVerticleAddr1", message -> {
  try{
     doSomething();
     message.reply("done");
  } catch(){
     message.fail(0, "fails");
  }
});

这样，发送方的异步处理程序将被通知消费者可以处理请求的消息