VertX：检查数据库配置是否可用

Question

我对微服务世界非常陌生，尤其是vertX。我希望我的顶点启动无论如何，即使没有可用的数据库连接（例如，配置中缺少数据库URL）。我已经设法做到了这一点，我的顶点开始了。

现在的问题是，我希望我的verticle注意到数据库连接何时再次可用并连接到它。我该怎么做？我考虑创建另一个垂直链接“DatabaseVerticle.java”，它将在事件总线上发送当前的DB配置，我的初始垂直链接将使用此消息，并检查配置信息是否一致（回复成功）或仍然缺少一些数据（回复失败并再次进行DatabaseVerticle检查）。

这可能行得通（也可能行不通），但对我来说似乎不是最佳解决方案。

如果有人能提出更好的解决方案，我会非常高兴。谢谢你！

Answer 1

不是Vertx中的所有问题都应该由另一个顶点来解决。
在这种情况下，您可以使用。周期性（）
http://vertx.io/docs/vertx-core/java/#_don_t_call_us_we_ll_call_you

我假设您有一些函数第一次检查数据库
我们称之为checkDB（）

class PeriodicVerticle extends AbstractVerticle {

    private Long timerId;

    @Override
    public void start() {
        System.out.println("Started");
        // Should be called each time DB goes offline
        final Long timerId = this.vertx.setPeriodic(1000, (l) -> {

            final boolean result = checkDB();
            // Set some variable telling verticle that DB is back online
            if (result) {
                cancelTimer();
            }
        });

        setTimerId(timerId);

    }

    private void cancelTimer() {
        System.out.println("Cancelling");
        getVertx().cancelTimer(this.timerId);
    }

    private void setTimerId(final Long timerId) {
        this.timerId = timerId;
    }
}

在这里，我玩了一点timerId，因为我们不能马上把它传递给取消定时器（）。但除此之外，这很简单。

Answer 2

理想的方法是使用其他服务告知您的服务数据库连接。无论是通过事件总线还是HTTP，您可以做的是，当有人试图在未建立连接的情况下访问您的数据库时，只需尝试进行一些DB调用并处理异常，将布尔值返回为false。现在，当您在事件总线上获得消息时，使用它并将其保存在某个配置pojo中。现在，当有人试图访问您的数据库时，请查找config，如果可用，请建立连接。

您的消费者：

public void start(){
    EventBus eb = vertx.eventBus();
    eb.consumer("database", message -> {
        config.setConfig(message.body());
    });
}

您的数据库客户端（Mongo for this eg）：

public class MongoService{

    private MongoClient client;
    public boolean isAvailable = false;

    MongoService(Vertx vertx){
        if(config().getString("connection")){
            client = MongoClient.createShared(vertx, config().getString("connection"));
            isAvailable = true;
        }
    }
}

Answer 3

对于您的用例，我建议使用vertx配置。特别是，请查看Vert的“侦听配置更改”部分。x配置文档。

您可以创建配置检索器并为更改设置处理程序：

ConfigRetrieverOptions options = new ConfigRetrieverOptions()
  .setScanPeriod(2000)
  .addStore(myConfigStore);

ConfigRetriever retriever = ConfigRetriever.create(vertx, options);
retriever.getConfig(json -> {
  // If DB config available, start the DB client
  // Otherwise set a "dbStarted" variable to false
});

retriever.listen(change -> {
  // If "dbStarted" is still set to false
  // Check the config and start the DB client if possible
  // Set "dbStarted" to true when done
});