Vertx-等待redis中的数据可用

Question

我是Vertx的新手，正在探索使用事件总线的请求回复。

我想实现下面的流程

1. 用户对数据的请求
2. 控制器通过事件总线向redis处理器垂直体发送消息
3. redis处理器将等待n秒，直到redis中的值可用（将有一个后台进程持续刷新缓存，因此等待）
4. redis处理器将向控制器发送回复
5. 控制器响应用户

简而言之，我想做这样的事情：

现在我想在Vertx中实现这一点，因为Vertx可以异步运行。使用事件总线，我可以隔离控制器和处理器。因此，控制器可以接受多个用户的请求，并在html" target="_blank">负载下保持响应。（我希望我是对的！）

我在java vertx中以非常粗糙的方式实现了这一点。卡在下面的部分。

//receive request from controller
vertx.eventBus().consumer(REQUEST_PROCESSOR, evtHandler -> {
    String txnId = evtHandler.body().toString();
    LOGGER.info("Received message:: {}", txnId);

    this.redisAPI.get(txnId, result -> {          // <=====
        String value = result.result().toString();
        LOGGER.info("Value in redis : {}", value);
        evtHandler.reply(value); // reply to controller
    });
}); 

请参见箭头表示的行。如何在不阻塞事件循环的情况下等待x秒？

请帮忙。

Answer 1

正如@mohamnag所说，你可以使用Vertx计时器

下面是另一个关于如何使用计时器的示例。

请注意，计时器值的单位为ms。

作为对的改进，我建议在尝试从redisAPI获取值之前检查回调是否成功。这是使用succeed（）方法完成的。在异步环境中，由于几个问题（网络错误等），获取该结果可能会失败

 vertx.setTimer(n * 1000, id -> {
    this.redisAPI.get(txnId, result -> {
      if(result.succeeded()){  // the callback succeeded to get a value from redis
        String value = result.result().toString();
        LOGGER.info("Value in redis : {}", value);
        evtHandler.reply(value); // reply to controller
      } else {
        LOGGER.error("Value could not be gotten from redis : {}", result.cause());
        evtHandler.fail(someIntegerCode, result.cause()); // reply with failure related info
      }

    });
  });

Answer 2

这其实很简单，你需要一个计时器。有关详细信息，请参阅文档，但您或多或少需要这样的东西：

vertx.setTimer(1000, id -> {
    this.redisAPI.get(txnId, result -> {          
        String value = result.result().toString();
        LOGGER.info("Value in redis : {}", value);
        evtHandler.reply(value); // reply to controller
    });
});

您可能希望将计时器ID存储在某个地方，以便您可以取消它们，或者至少当顶点延迟关闭请求时，您知道某些内容正在运行。但这都取决于你的需求。