Vertx发现节点但看不到消息

Question

当我启动一个新的clusteredVertx时，集群管理器找到网络上的其他节点，但是分布式eventBus看不到发布在测试地址上的消息。

例如，在启动新节点时：

VertxOptions options = new VertxOptions();

Vertx.clusteredVertx(options, res -> {
if (res.succeeded()) {
  Vertx vertx = res.result();
}

自动发现其他节点

Members [4] {
  Member [192.168.21.51]:5702
  Member [192.168.21.51]:5703
  Member [192.168.21.51]:5701
  Member [192.168.25.8]:5701 this
}

但是当一条测试消息发布到通道“JsonObject”上时，如下所示：

eventBus eB1 = vertx.eventBus()
JsonObject j = new JsonObject();
j.put("test1", "test2");
eB1.publish("test", j);

它不会被另一个节点上的接收器接收到。

EventBus eB2 = vertx.eventBus();
System.out.println("Receiver start");
MessageConsumer<JsonObject> testChannel = eB2.consumer("test");
testChannel.handler(message -> {
  System.out.println("Received: " + message.body().toString());
}

Answer 1

来自here的解决方案是将集群选项设置为本地节点。

String ipAddress = Inet4Address.getLocalHost().getHostAddress();
VertxOptions options = new VertxOptions();
options.setClusterHost(ipAddress);