维特。x2->Vert。x 3通过事件总线进行通信

Question

我有一个很快的问题——有人试过同时运行这两个版本吗。x2和垂直。集群中的x 3应用程序，通过EventBus进行通信？

理论上这应该是可能的，但有人做过吗？；）

干杯，米莎

Answer 1

我在集群中尝试了Vert. x2和Vert. x3 EventBus。但不是同时。Vert. x2需要jdk 1.7，Vert. x3需要jdk 1.8或更高版本。我试图在jdk 1.8中运行Vert. x2，但没有成功。

因此，我认为运行两个垂直。x2和Vert。群集中不可能有x3应用程序。

Answer 2

我非常感激这个问题，因为当我决定升级我的2。x应用程序的最新版本的Vert。x、 即3。十、

我猜你暴露了这样一个问题，因为节点间/模块间通信协议至少应该在某种程度上兼容，EventBus已经是典型Vert中的模块间通信通道。x应用程序，即使是在不同的模块版本之间，也会抽象出消息传输。

同时，我不知道有哪个开源产品能在主要版本之间提供API兼容性，因为主要版本通常表示“API会改变”。维特。x应该是无一例外的，毫无疑问，不同版本开发的垂直体/模块之间的通信可能会失败，因此即使不值得测试，也应该避免这种方法。

Answer 3

对于3.3版本Vert。x正在向2添加一个新模块。x系列。这个新组件是mod-eventbus3-bridge-client。

我们的想法是，您可以将此模块部署到现有的2。x应用程序，它将连接eventbus 2。x和eventbus 3。十、

您可以在以下位置查看代码：https://github.com/vert-x/mod-eventbus3-bridge-client/tree/initial-work

所以在Vert。x3您需要执行以下操作：

public class Example {

  public static void main(String[] args) {

    Vertx vertx = Vertx.vertx();
    TcpEventBusBridge bridge = TcpEventBusBridge.create(
        vertx,
        new BridgeOptions()
            .addInboundPermitted(new PermittedOptions())
            .addOutboundPermitted(new PermittedOptions()));

    bridge.listen(7000, res -> {
      // example: vertx3 send a message to vertx2
      vertx.eventBus().send("send3", new JsonObject().put("msg", "hello send"));
    });
  }
}

在垂直方向。x2你会做相反的事情：

public class Example extends Verticle {

  @Override
  public void start() {
    final EventBus3 eb = new EventBus3(vertx, getContainer().config(), new Handler<Void>() {
      @Override
      public void handle(Void done) {
        // case #1 vertx3 send a message to vertx2
        eb.registerHandler("send3", new Handler<BridgeMessage>() {
          @Override
          public void handle(BridgeMessage msg) {
            System.out.println(msg.body());
          }
        });
      }
    });

    eb.exceptionHandler(new Handler<Throwable>() {
      @Override
      public void handle(Throwable throwable) {
        throwable.printStackTrace();
      }
    });
  }
}