Vert. x：自定义启动未来处理程序总是重写

Question

垂直。xv3。5.1. 这是我定制的startVerticle方法：

@Override
public void start(Future<Void> startFuture) throws Exception {
    startFuture.setHandler(event -> {
        if (event.succeeded()) {
            logger.info("Server started on port: {}", 8080);
        } else {
            logger.warn("Failed to start: {}", event.cause());
        }
    });
    vertx.createHttpServer()
            .requestHandler(router()::accept)
            .listen(8080, event -> {
                if (event.succeeded()) {
                    startFuture.complete();
                } else {
                    startFuture.fail(event.cause());
                }
            });
}

我希望我的自定义处理程序将在将来完成时被调用。但事实并非如此！在调试模式下，我看到futureempl:：setHandler被调用了两次：一次调用我的自定义处理程序，然后在doDeploy期间调用DeploymentManager的处理程序。因此应用了最新的处理程序。

问题是：是否可以为Verticle start指定自定义回调？如果是，我怎么做？

先谢谢你。

Answer 1

首先，将你的顶点写成AbstractVerentle扩展。并且不要重写start（Future）方法。相反，使用start（）方法。它将从AbstractVerticle.start（Future）中调用，并且您可以在V中指定该未来ertx.deployVerentle-（verentle-，选项，未来）方法。

例如：

你有一些顶点。只执行初始化任务的方法：

@Override
public void start() throws Exception {
    vertx.eventbus().consume(address, m -> {
       // consumer code skipped
    });
}

和垂直配准：

final DeploymentOptions opts = new DeploymentOptions().setWorker(true);
vertx.deployVerticle(verticle, opts, event -> {
    if (event.succeeded()) {
        log.info("Verticle successfully deployed. DeploymentId: " + event.result());
    } else {
        log.error("Verticle failed to deploy. Cause: " + event.cause().getMessage(), event.cause());
    }
});

就这些：）

Answer 2

您不应该更改startFuture的处理程序，因为它属于调用方。因此，简单地说，不要这样做：）未来是用来表示你已经完成了你的开始代码，而不是定义什么应该做，一旦你完成了。

在您的具体示例中，最好在http服务器启动后编写日志，然后向startFuture指示代码执行完毕。

@Override
public void start(Future<Void> startFuture) throws Exception {
    vertx.createHttpServer()
         .requestHandler(router()::accept)
         .listen(8080, event -> {
            if (event.succeeded()) {
                logger.info("Server started on port: {}", 8080);
                startFuture.complete();
            } else {
                logger.warn("Failed to start: {}", event.cause());
                startFuture.fail(event.cause());
            }
         });
}