Netty ChannelFuture如何工作？

Question

我读过《网络指南》，它在ChannelFuture上解释得不多。我发现ChannelFuture在应用时是一个复杂的想法。

我试图做的是在初始响应之后将消息写入上下文。与典型的请求/响应流不同。我需要这样的流程：

1. 客户端发送请求 -

问题是，如果我这样做，第二次写入将不会发出：

ctx.writeAndFlush(response);
Message newMsg = createMessage();
ctx.writeAndFlush(newMsg);   //will not send to client

然后我尝试使用频道未来，它的工作原理，但我不确定我在逻辑上是否正确：

ChannelFuture msgIsSent = ctx.writeAndFlush(response);
if(msgIsSent.isDone())
{
    Message newMsg = createMessage();
    ctx.writeAndFlush(newMsg);   //this works
}

或者我应该使用ChannelFutureListener（）代替？

ChannelFuture msgIsSent = ctx.writeAndFlush(response);
msgIsSent.addListener(new ChannelFutureListener(){
@Override
public void operationComplete(ChannelFuture future)
    {
       Message newMsg = createMessage();
       ctx.writeAndFlush(newMsg);
    }
});

这也行得通吗？

哪一种是最佳实践方法？使用方法2是否有任何潜在问题？

Answer 1

#2看起来更好，但一定要测试操作是否成功。如果没有，请使用未来.getCause（） 访问异常。这并不是说它会改变功能，但是你可以通过在写调用的结果上直接添加侦听器来缩短代码，也就是说，你不需要声明未来本身，因为它将在回调中提供。

Answer 2

试试这个：

    ctx.channel().writeAndFlush(response);
    Message newMsg = createMessage();
    ctx.channel().writeAndFlush(newMsg);

Channel.write（）总是从ChannelPipeline的尾部开始。

ChannelHandlerContext（频道句柄上下文）。write（）从ChannelHandler的当前位置开始。

Answer 3

当然，这也取决于您的“协议”(例如，如果您使用HTTP，HTTP协议不支持为同一个请求发送两个应答)。但是，假设您的协议允许您发送多个响应部分:

Netty根据顺序添加要发送到管道的消息。

所以在你的第一个例子中，我有点惊讶它不起作用：

ctx.writeAndFlush(response);
Message newMsg = createMessage();
ctx.writeAndFlush(newMsg); // should send the message

但是，它可能由您的协议领导。例如，可能会发生这种情况：

response in message queue to send
flush not yet done
newMsg in message queue to send
flush now come but protocol does not support 2 messages so only send first one

因此，如果您的协议必须承认已经发送了第一条消息，那么您必须等待第一条消息，因此执行以下操作：

ctx.writeAndFlush(response).addListener(new ChannelFutureListener() {
  @Override
  public void operationComplete(ChannelFuture future) {
    if (future.isDone()) {
      Message newMsg = createMessage();
      ctx.writeAndFlush(newMsg);
    } else { // an error occurs, do perhaps something else
    }
  }
});

因此，您的上一个建议（我只是没有创建ChannelFuture，而是直接使用了writeAndFlush的结果，但两者都是相等的）。只要注意operationComplete并不意味着它成功的情况。