Vertx |群集中垂直线的全局状态

Question

新手警报。

我正在尝试在Vertx中编写一个简单的模块，它每10秒轮询一次数据库（PostGres）并将结果推送给客户端。我正在考虑将阻塞代码（通过JDBC查询数据库）限制在工作垂直中，上面的其余层是完全非阻塞和异步的。

此模块将打包为一个jar，并分发到不同的应用程序（通常是webapps），这些应用程序可以通过javascript桥订阅事件总线。

我这里的问题是在集群环境中，我有5个运行vertx模块的webapp进程，我如何确保只有一个vertx垂直查询数据库。我不希望所有的顶点都在查询数据库并增加更多负载。或者有没有不同的方法来解决这个问题。我使用的是Vertx版本3.4.1

Answer 1

我在这里给出了我天真的解决方案，我不知道它是否能完全解决你的问题，但这是我的思考过程。

1） 轮询位，是的，确实可以为每10秒部分设置一个用于阻止调用的工作线程垂直路径[或者您也可以在这里使用异步位，因为您已经有了异步Postgress JDBC客户端]。这样的代码片段可以帮助您

vertx.setPeriodic(10000, id -> {
  // This handler will get called every 10 seconds
  JsonObject jdbcObject = fetchFromJdbc();
  eventBus.publish("INTRESTED_PARTIES", jdbcObject); 
});

2） 对于侦听部分，所有其他垂直站点都可以订阅事件总线并侦听该地址，并且在任何情况下都可以获取消息

3）这是为了确保并非您的jar的所有运行实例都开始轮询数据库，为此我认为最好的处理方法是不要在任何jar中部署垂直，并使用运行时vertx命令以独立方式运行垂直

vertx run DatabasePoller.java -cluster

如果你真的想变得非常花哨，你可以加入服务发现来确保如果垂直的服务已经注册，那么没有其他部署会触发注册。

但是我想在考虑事件时给你竖起大拇指，以便更好地处理系统间通信。

Answer 2

因此，有两种方法可以让你的垂直度成倍增加：

1. 如果在部署verticle时实例化多个实例
2. 如果你开始集群你的顶点。不同jvm或不同主机中的x个实例

您可以尝试控制执行查询的verticle的实例数。意味着您要确保竖线只存在于一个顶点中。x个实例，您的verticle只部署了一个实例。

但这有几个缺点：

• 您的部署是不透明的，这意味着您的集群节点在部署结构上有所不同
• 如果集群节点在运行查询垂直链接的地方死亡，那么就没有回退

因此，最好的做法是在所有实例上部署verticle并对其进行同步。

我认为有3种可能性：

>

将数据库用作同步点。您可以添加一个以毫秒为单位存储上次执行时间的简单表。轮询模块将首先检查是否到了执行下一次轮询的时间。如果轮询模块执行轮询，它也会更新时间。这必须在一个事务中完成，并在时间表上显式锁定。

您可以将redis与https://redis.io/commands/getset功能。您可以将时间以毫秒为单位存储在密钥中，并使用getset方法确保时间的升级是原子的。因此，只有能够在redis中设置密钥的轮询模块才会执行轮询。