java - 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;
  }
 }

因此，如果发送的第一个命令以及正在发生的事情，我想中断下一个事件总线发送。

谢谢

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() 将阻塞，直到知道回复为止。