我想通過 Vertx 中的 EventBus 但同步發(fā)送多條消息。我想發(fā)送一條消息，等待它，然后發(fā)送下一條消息。地址是一樣的。默認情況下我是怎么做的？或者有必要使用，也許，一個 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; } }所以在這里，如果它發(fā)送了第一個命令并且正在發(fā)生某些事情，我想中斷下一個 eventbus 發(fā)送。
3 回答
汪汪一只貓
TA貢獻1898條經(jīng)驗 獲得超8個贊
用 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 事件循環(huán)上調(diào)用，因為get()在知道答復之前會阻塞。
LEATH
TA貢獻1936條經(jīng)驗 獲得超7個贊
的EventBus是為異步消息傳遞（發(fā)布/訂閱消息，點對點和請求響應消息）制成。強制同步動作沒有意義。
如果您想要同步響應，如果您在同一個 JVM 中，只需調(diào)用另一個 java 類中的方法。
森林海
TA貢獻2011條經(jīng)驗 獲得超2個贊
添加回答
舉報
0/150
提交
取消