在Eclipse中停止vertx顶点

Question

我正在关注Jenkov关于vertx的教程。这里有两个文件：

MyVerticle.java：

import io.vertx.core.AbstractVerticle;
import io.vertx.core.Future;

public class MyVerticle extends AbstractVerticle {

    @Override
    public void start(Future<Void> startFuture) {
        System.out.println("MyVerticle started!");
    }

    @Override
    public void stop(Future stopFuture) throws Exception {
        System.out.println("MyVerticle stopped!");
    }
}

和VertxVerticleMain。爪哇：

import io.vertx.core.Vertx;

public class VertxVerticleMain {

    public static void main(String[] args) {
        Vertx vertx = Vertx.vertx();

        vertx.deployVerticle(new MyVerticle());
    }
}

运行VertxVerticleMain后。java，我看到“MyVerticle启动了！”在Eclipse的控制台中，但不知道如何在MyVerticle中调用stop。

Jenkov说，当Vert. x关闭并且你的顶点需要停止时，会调用Stop（）方法。我如何关闭我的Vert. x并停止这个顶点？我想看到我的版本停止！在控制台中。

Answer 1

你的代码应该添加super。停下来，超级棒。start（）函数如下：

public class MyVerticle extends AbstractVerticle {

    @Override
    public void start(Future<Void> startFuture) {
        //must call super.start() or call startFuture.complete()
        super.start(startFuture); 
        System.out.println("MyVerticle started!");
        System.out.println("Verticle_stopFuture.start(): deployId=" + context.deploymentID());
    }

    @Override
    public void stop(Future stopFuture) throws Exception {
        //must call super.stop() or call stopFuture.complete()
        super.stop(stopFuture);
        System.out.println("MyVerticle stopped!");
    }
}

和VertxVerticleMain。爪哇：

public class VertxVerticleMain {
    static String verticle_deployId;

    public static void main(String[] args) throws InterruptedException {
        System.out.println("start main(): thread="+Thread.currentThread().getId());


        Vertx vertx = Vertx.vertx();

        vertx.deployVerticle(new MyVerticle(), new Handler<AsyncResult<String>>(){

            @Override
            public void handle(AsyncResult<String> asyncResult) {

                if (asyncResult.succeeded()) { // khi startFuture.complete() đc gọi
                    System.out.println("asyncResult = DeployId =" + asyncResult.result());

                    verticle_deployId = asyncResult.result();
                } else { //khi startFuture.fail() đc gọi
                    System.out.println("Deployment failed!");  //vì chưa đc cấp id
                }
            }
        });

        // waiting for Verticle context is allocate by Vertx
        Thread.currentThread().sleep(500);

        Set<String> deploymentIDs = vertx.deploymentIDs();
        System.out.println("==============  (sleeped 500ms wait for Context allocated), list of deploymentIDs: number Deployments =" + deploymentIDs.size());
        for(String depId: deploymentIDs){
            //
            System.out.println(depId);
        }

        //close verticle here
        vertx.undeploy(verticle_deployId);


    }

}

Answer 2

从垂直方向。x文档：

Vert.x calls this method when un-deploying the instance. You do not call it yourself. 

如果你跑Vert。从主方法中选择x，然后终止JVM进程（例如，通过在Eclipse中单击“停止”按钮），Vert。x可能没有被通知取消部署Verticle，或者JVM在Vert之前终止。x有时间解除垂直线的部署。

您可以做很多事情来确保verticle将被取消部署，并且stop（）方法将被调用：

>

vertx.deploymentIDs().forEach(vertx::undeploy);

你可以通过编程告诉Vert。要停止：

vertx.close();

您可以添加一个关闭钩子来确保上面的选项之一在JVM终止时执行：

Runtime.getRuntime().addShutdownHook(new Thread() {
    public void run() {
        vertx.close();
    }
});

您可以通过调用Vert以编程方式取消垂直部署。或者直接停止Java进程，这在术语上会触发Vert。x进程停止。

顺便说一句，值得问问自己，当运行verticle的进程停止时，是否真的有必要始终调用stop（）方法。你永远无法确定这会发生；当进程被迫停止或终止时，可能不会调用stop（）方法。