Vertx Eventbus发送节点间失败

Question

我有一个小演示，演示了Vertx如何使用Hazelcast Cluster Manager通过Eventbus在节点之间发送消息。

到目前为止，我已经成功地使节点相互识别。

Members [2] {
    Member [192.168.150.193]:5701 - 0c8120d8-73dc-4fc2-af6d-16288dbd707a
    Member [192.168.130.41]:5701 - 19239bb1-e7e8-4990-a389-817d6a7d128a this
}

但是，我在集群成员之间的EventBus通信中遇到了一个问题。根据Vertx手册页面。

集群管理器不处理事件总线节点间传输，这是由Vert直接完成的。x与TCP连接。

但是，即使我事先通过以下方式从群集管理器获得群集事件总线：

public static EventBus clusterEB = null;
...
Vertx.clusteredVertx(options, res -> {
        if (res.succeeded()) {
            Vertx vertx = res.result();
            clusterEB = vertx.eventBus();
            vertx.deployVerticle(new DemoVerticle());
        }
    });

当本地节点的主顶点使用该静态事件总线对象向远程节点发送消息时。

eb.send("worker.count", request_count, res -> {
                if (res.succeeded()) {
                    System.out.println("Received reply No." + res.result().body());
                    worker_busy--;
                    System.out.println("WORKER_BUSY = " + worker_busy);
                }
            });

抛出了一个异常：

io.netty.channel.AbstractChannel$AnnotatedConnectException: Connection refused: localhost/127.0.0.1:50509

使用netstat，我发现50509是远程节点eventbus正在监听的端口。因此，我猜测我的配置错过了一些导致Vertx错误的地址，如果我错了，请纠正我。

这些信息是我目前为止研究的，我真的很期待听到你们对这个问题的任何建议。如果您需要更多信息，请随时问我。

p/s：本地节点之间的事件总线通信仍然良好。在Ubuntu上运行的代码（禁用UFW），远程机器是关闭防火墙的Windows（我认为防火墙在这里不是问题，因为节点之间仍然存在tcp连接，可以列出网络中的所有集群成员）

Answer 1

对于遇到同样问题的人，希望我的回答能对你有所帮助。

多亏了@Paulo_Lopes的建议，我的问题稍微调一下就解决了。

我必须以编程方式设置群集主机，如下所示：

VertxOptions options = new VertxOptions().setClusterManager(mgr).setClusterHost("192.168.130.21");

Vertex Hazelcast的文件中也有关于此的简要信息：

当运行垂直时。如果x处于群集模式，还应确保垂直。x知道正确的接口。在命令行上运行时，这是通过指定群集主机选项来完成的。。。

但老实说，我认为他们应该把它更容易理解的方式。简而言之，您必须将您的机器IP指定为群集主机，因为群集事件总线将使用该IP并注册一个套接字用于节点间通信。如果没有设置群集主机配置，Vertx将以您的localhost（127.0.0.1）作为IP，通过Vertx发送的每条消息只能到达本地节点。

这就是全部。“希望它能帮助有需要的人，谢谢你，”保罗说。

Answer 2

看起来是垂直的。x为您的主机（127.0.0.1）选择了错误的IP地址，而实际上它们是：

• 192.168。150.193
• 192.168。130.41

您可能希望通过添加以下额外的命令行参数来强制每个节点选择正确的IP地址：

-cluster-host 192.168.150.193

对于另一个节点也是如此，具有：

-cluster-host 192.168.130.41