等待sql i/o完成的正确方法

Question

有没有人有一个简单的代码示例来展示 netty 3.2.7 如何 应正确处理以下场景中的sql查询：

调用方法将消息传递到服务器messageReceived 方法。 messageRecieved 方法执行 sql 查询并获取 结果。调用方法不应继续处理，直到 获取sql查询的结果。

特别是 netty 等待的方式的示例 i/o（sql查询）来完成会非常有用。

Answer 1

您需要在执行 sql 查询的处理程序前面添加一个 ExecutionHandler。就是这样...

否则你会阻塞你的工作线程

Answer 2

诺曼感谢您提供额外信息。我认为这可以解决问题，但它涉及添加一个额外的处理程序，这并不是真正需要的，并且添加纯粹是为了确保 sql 查询已完成（没有功能）。

我寻找“更标准”的方式并找到了链接
“http://docs.jboss.org/netty/3.2/api/org/jboss/netty/channel/ChannelFuture.html”其中写着“提供了各种方法来让您检查I/O操作是否已完成，等待完成，并检索 I/O 操作的结果。它还允许您添加 ChannelFutureListener，以便在 I/O 操作完成时收到通知......”

它还表示 Prefer。 addListener(ChannelFutureListener) 到await() 但我不知道如何实现它。
如果有人知道如何实现它来等待 i/o sql 查询的结果完成，它将非常有用。

为了解决 sendMessage 方法中的问题，我使用了

lastWriteFuture = connector.write(message);
if (lastWriteFuture != null) {
      lastWriteFuture.awaitUninterruptibly();
}

此方法 - 它等待 sql 查询完成，然后返回给调用者。