单线程Vert.x事件循环

Question

我正在使用vert。x 2.1.5版本。我试图在我的项目中使用事件循环。下面给出了示例代码

JsonObject result = null;
//loop starting
for (int i=0;i<length;i++)
{

 final JsonObject jsonObject1 = jsonObject.getArray("result").get(i);                                                           
 int x = jsonObject1.getInteger("X");
 String Data = "X="+x+"&Y="+y;  
 //calling another event 
vertx.eventBus().send("event1", Data,new Handler<Message<String>() {public void   handle(Message<String>response) 
{
JsonObject jsonObject = new JsonObject(response.body());
result_arry.addArray(jsonObject.getArray("details"));
                                            }
});
} // loop end
result = resultJson("Ok",result_arry ); 
//it will create one json object with proper format 
message.reply(result.toString());

在此代码中，我的事件总线在执行事件循环之前返回值。我需要根据事件循环输出填充我的输出 如何实现

Answer 1

基本上，问题在于你没有等待消息的到来。为了让我的例子更加清晰，我删除了大部分Json逻辑。

Vertx vertx = Vertx.vertx();
int messages = 10;

// First register your consumer
MessageConsumer<JsonObject> consumer = vertx.eventBus().consumer("event1");
consumer.handler(o -> {
    System.out.println("Got message" + o.body());

    // Consumer replies to sender with the same message
    o.reply(o.body());
});

// Now send your messages
for (int i=0;i<messages;i++) {
    JsonObject data = new JsonObject();
    data.put("value", i);

    vertx.eventBus().send("event1", data, response -> {
        if (response.succeeded()) {
            // Each time consumer replies, print it
            System.out.println("Consumer replied: " + response.result().body());
        }
    });
}

请注意，回复在处理程序体中，发送方在访问它之前必须检查响应是否成功。