Vertx事件总线拦截器阻止请求调用

Question

我试图通过事件总线发送数据，当从客户端接到呼叫并响应回客户端。

一切正常，直到我在事件总线上添加拦截器...

以下是代码：-

public class TestVerticle extends AbstractVerticle {

    @Override
    public void start(Promise<Void> promise) {

        Router router = Router.router(vertx);

        vertx.exceptionHandler(globalExceptionHandler -> {
            System.out.println("Exception not handled in application  : " + globalExceptionHandler.getCause());
        });

        vertx.eventBus().consumer("test", handler -> {
            System.out.println("Message receive form event bus : " + handler.body().toString());
            handler.reply(handler.body().toString());
        });

        router.get().handler(this::rootHandler);
        vertx.createHttpServer().requestHandler(router).listen(8080, resultHandler -> {
            if (resultHandler.succeeded()) {
                promise.complete();
            } else {
                promise.fail(resultHandler.cause());
            }
        });

        vertx.eventBus().addOutboundInterceptor(handler -> {
            System.out.println("Outbound data : "+handler.body().toString());
        });

//        vertx.eventBus().addInboundInterceptor(handler -> {
//            System.out.println("Inbound data : " + handler.body().toString());
//        });
    }

    private void rootHandler(RoutingContext routingContext) {
        JsonObject msg = new JsonObject().put("path", routingContext.request().path());
        vertx.eventBus().request("test","Hello from Application",reply -> this.replyHandler(routingContext,reply));
    }

    private void replyHandler(RoutingContext ctx, AsyncResult<Message<Object>> reply) {
        HttpServerResponse response = ctx.response()
                .putHeader("Content-Type", "application/json");
        System.out.println("Reply from event bus : " +reply.result().body().toString());
        if (reply.succeeded()) {
            response.setStatusCode(200)
                    .setStatusMessage("OK")
                    .end(reply.result().body().toString());
        } else {
            response.setStatusCode(500)
                    .setStatusMessage("Server Error")
                    .end(new JsonObject().put("error", reply.cause().getLocalizedMessage()).encodePrettily());
        }
    }

    public static void main(String[] args) {
        Vertx.vertx().deployVerticle(new TestVerticle(), deploymenHandler -> {
            if (deploymenHandler.succeeded()) {
                System.out.println("verticle deplyed");
            } else {
                System.out.println("failed");
            }
        });

    }

    @Override
    public void stop(Promise<Void> promise) {
        System.out.println("Exiting verticle");
        promise.complete()
    }
}

还有一个疑问是，当我从IDE停止应用程序时，不会调用stop方法，但是如果我从另一个正常工作的垂直程序中取消部署这个垂直程序。

Answer 1

当您使用eventbus拦截器时，必须调用处理程序中的next（）方法，否则您会被卡住。

vertx.eventBus().addOutboundInterceptor(handler -> {
  System.out.println("Outbound data : "+handler.body().toString());
  handler.next();
});

vertx.eventBus().addInboundInterceptor(handler -> {
  System.out.println("Inbound data : "+handler.body().toString());
  handler.next();
});