Обнаружение кластера и службы Vertx.io

Question

Я играю с vertx.io, это выглядит здорово. Теперь я создаю кластер из трех вершин (три простых jav-файла основных жирных банок). Одна вертикаль предоставляет доступ к веб-интерфейсу (API с плохим отдыхом), а две другие просто знают, что веб-вертикаль поднимается или опускается vertx.ioМеханизм обнаружения сервисов. Вот моя (соответствующая часть) простая вертикаль "не в сети":

public class FileReader extends AbstractVerticle {

  private ServiceDiscovery discovery;
  private Logger log = LogManager.getLogger(getClass());
  private Record record;

  @Override
  public void start(Future<Void> startFuture) throws Exception {
    record = EventBusService.createRecord(getServiceName(), getServiceAddress(), getClass());
    setUpRecord(record);
    discovery = ServiceDiscovery.create(vertx);
    discovery.publish(record, h -> {
        if (h.succeeded()) {
            log.info("Record published.");
        } else {
            log.info("Record not published.", h.cause());
        }
    });
    startFuture.complete();
  }
  ...
  @Override
  public void stop(Future<Void> stopFuture) throws Exception {
    log.info("Stopping verticle.");
    discovery.unpublish(record.getRegistration(), h -> {
        if (h.succeeded()) {
            log.info("Service unpublished.");
            stopFuture.complete();
        } else {
            log.error(h.cause());
            stopFuture.fail(h.cause());
        }
    });
  }
}

И вот как я развернул одну из двух "не веб" статей:

public class FileReaderApp {

private static Logger log = LogManager.getLogger(FileReaderApp.class);
private static String id;

  public static void main(String[] args) {
    ClusterManager cMgr = new HazelcastClusterManager();
    VertxOptions vOpt = new VertxOptions(new JsonObject());
    vOpt.setClusterManager(cMgr);
    Vertx.clusteredVertx(vOpt, ch -> {
        if (ch.succeeded()) {
            log.info("Deploying file reader.");
            Vertx vertx = ch.result();
            vertx.deployVerticle(new FileReader(), h -> {
                if (h.succeeded()) {
                    id = h.result();
                } else {
                    log.error(h.cause());
                }
            });
        } else {
            log.error(ch.cause());
        }
    });

    Runtime.getRuntime().addShutdownHook(new Thread() {
        public void run() {
            log.info("Undeploying " + id);
            Vertx.vertx().undeploy(id, h -> {
                if (h.succeeded()) {
                    log.info("undeployed.");
                } else {
                    log.error(h.cause());
                }
            });
        }
    });
  }
}

Когда начинаются "не-веб" вертикулы, "веб-" вертикаль уведомляется правильно. Но когда "не-сеть" отключается, я нажимаю на клавиатуру Ctrl-C, Я получил эту ошибку и вертикалка все еще думает, что все в порядке:

2017-12-01 09:08:27 INFO  FileReader:31 - Undeploying 82a8f5c2-e6a2-4fc3-84ff-4bb095b5dc43
Exception in thread "Thread-3" java.lang.IllegalStateException: Shutdown in progress
at java.lang.ApplicationShutdownHooks.add(ApplicationShutdownHooks.java:66)
at java.lang.Runtime.addShutdownHook(Runtime.java:211)
at io.vertx.core.impl.FileResolver.setupCacheDir(FileResolver.java:310)
at io.vertx.core.impl.FileResolver.<init>(FileResolver.java:92)
at io.vertx.core.impl.VertxImpl.<init>(VertxImpl.java:185)
at io.vertx.core.impl.VertxImpl.<init>(VertxImpl.java:144)
at io.vertx.core.impl.VertxImpl.<init>(VertxImpl.java:140)
at io.vertx.core.impl.VertxFactoryImpl.vertx(VertxFactoryImpl.java:34)
at io.vertx.core.Vertx.vertx(Vertx.java:82)
at edu.foo.app.FileReaderApp$1.run(FileReaderApp.java:32)

Я не до конца понимаю, что происходит. Завершение работы приложения, пока оно не развертывалось? Как это решить? Что такое подход vertx.io?

Answer 1

Есть две проблемы

1. Вы должны отменить развертывание вертикали, используя кластеризованный экземпляр Vert.x, а не просто любой экземпляр
2. undeploy это неблокирующая операция, поэтому нить крюка отключения должна ждать завершения.

Вот модифицированная версия:

Runtime.getRuntime().addShutdownHook(new Thread() {
    public void run() {
        log.info("Undeploying " + id);
        CountDownLatch latch = new CountDownLatch(1);
        theClusteredVertxInstance.undeploy(id, h -> {
            if (h.succeeded()) {
                log.info("undeployed.");

            } else {
                log.error(h.cause());
            }
            latch.countDown();
        });
        try {
            latch.await(5, TimeUnit.SECONDS);
        } catch(Exception ignored) {
        }
    }
});