Vertx 中发送的同步 EventBus 消息

Question

我想通过 Vertx 中的 EventBus 但同步发送多条消息。我想发送一条消息，等待它，然后发送下一条消息。地址是一样的。默认情况下我是怎么做的？或者有必要使用，也许，一个 executeBlocking 代码？这是我的代码。public class EventBusSync {    private Vertx vertx = Vertx.vertx();    private static final String SERVICE_ADDRESS =  "service.worker";  public void sentViaEvBus() {    String message1 = "message1";    String message2 = "message2";    String reply1 = sendCommand(SERVICE_ADDRESS,message1);    String reply2 = sendCommand(SERVICE_ADDRESS,message2);  }  private String sendCommand(String address, String command) {   String message;   vertx.eventBus().send(address,command, handler -> {    if(handler.succeeded()) {     log.info("success");   } else {     log.error("error",handler.cause());     throw new RuntimeException("ERROR");    }    message = handler.result.body();    }); return message;  } }所以在这里，如果它发送了第一个命令并且正在发生某些事情，我想中断下一个 eventbus 发送。

Answer 1

用 CompleteFuture

  private String sendCommand(String address, String command) {

    CompletableFuture<String> completableFuture = new CompletableFuture<>();

    vertx.eventBus().<String>send(address, command, asyncResult -> {

      if (asyncResult.succeeded()) {

        completableFuture.complete(asyncResult.result().body());

      } else {

        completableFuture.completeExceptionally(asyncResult.cause());

      }

    });

    try {

      return completableFuture.get();

    } catch (Exception e) {

      throw new RuntimeException(e);

    }

  }

请确保此代码不会在 Vert.x 事件循环上调用，因为get()在知道答复之前会阻塞。

Answer 2

的EventBus是为异步消息传递（发布/订阅消息，点对点和请求响应消息）制成。强制同步动作没有意义。

如果您想要同步响应，如果您在同一个 JVM 中，只需调用另一个 java 类中的方法。

Answer 3

Vert.x-sync 示例

在这里，您将找到演示 Vert.x-Sync 实际应用的示例。

[...]

这演示了使用 awaitResult 来同步发送事件总线消息并获取回复。