无法使用事件总线与在不同机器上运行的 Verticle 进行通信答案

【问题标题】：Cannot communicate using event bus for verticles running on different machines无法使用事件总线与在不同机器上运行的 Verticle 进行通信
【发布时间】：2015-12-14 14:46:01
【问题描述】：

我们试图使用事件总线在 Verticle 之间建立通信。我们尝试了最简单的乒乓通信示例 -

public class Sender extends AbstractVerticle {
    public static void main(String[] args) {
        Vertx.clusteredVertx(new VertxOptions(),res->{
            res.result().deployVerticle(new Sender());
        });
    }
    @Override
    public void start() throws Exception {
        EventBus eb = vertx.eventBus();
        vertx.setPeriodic(1000, v -> {
            eb.send("ping-address", "ping!", reply -> {
                if (reply.succeeded()) {
                    System.out.println("Received reply: " + reply.result().body());
                } else {
                    System.out.println("No reply");
                }
           });
        });
    }
}

同样我们写了写receiver。 See the code.

如果发送方和接收方都在同一台机器上运行，则通信成功。但是当它们运行不同的机器时，通信失败。此外，这似乎不是 Hazelcast 集群管理器（我们使用的）的问题，因为 hazelcast 正确地发现了两台机器上的另一个对等点（这从 hazelcast 的控制台日志中可以明显看出）。

Members [2] {
    Member [192.168.43.12]:5701
    Member [192.168.43.84]:5701 this
}

此外，两台机器上的防火墙都没有启用，我们能够仅使用 hazelcast（不使用 vertx）在同一台机器之间建立通信，并且运行良好（例如 this）。所以问题可能出在 vert-x 上。

【问题讨论】：

标签： java event-bus vert.x vertx3

【解决方案1】：

您是否尝试在 VertxOptions 上设置 setClustered(true)？我正在测试这个示例代码，它对我来说很好：

public static void main(String[] args) {
    VertxOptions op = new VertxOptions();
    op.setClustered(true);
    Vertx.clusteredVertx(op, e -> {
        if (e.succeeded()) {
            HelloWorldVerticle hwv = new HelloWorldVerticle();
            e.result().deployVerticle(hwv);
        } else {
            e.cause().printStackTrace();
        }
    });
}

【讨论】：