Netty-writeAndFlush和消息排序

Question

我正在尝试实现分布式参与者模型，该模型使用Netty作为通信协议——具有TCP连接的NIO版本。

假设我们有2个节点（机器），每个节点都有Netty的服务器实例，它们将传入的消息传递给该节点上的参与者。我希望为同一对远程参与者保持消息顺序，因此我的解决方案是使用异步writeAndFlush方法将消息发送到远程节点和参与者-当在第一条消息交付之前需要向同一参与者发送另一条消息时，我会将其添加到缓冲区，并回调writeAndFlush消息，处理缓冲区中的下一个。看起来是这样的：

   channel.writeAndFlush(message).addListener(new MessageListener(mailboxOfSelector));

回调方法是：

    @Override
    public void operationComplete(ChannelFuture future) throws Exception {

        Queue<RemoteMessage> unsentToMailbox = unsentMessages.get(mailboxOfSelector);

        if (!unsentToMailbox.isEmpty()) {
            RemoteMessage message = unsentToMailbox.poll();
            channel.writeAndFlush(message).addListener(this);
        }
    }

所以，如果A和B是两个与通道连接的服务器实例，我们从A发送-

当它完成A上的最后一个处理程序时返回，还是当它被传递到B上的第一个处理程序时返回？

Answer 1

在Netty5中。alpha2版本。将数据刷新到socketchannel后，Netty然后回调operationComplete方法。在这种情况下，这并不意味着数据到达客户端。这意味着数据已发送到TCP协议栈。您可以在源代码中看到以下内容：

io.netty.channel.ChannelOutboundBuffer.java

它将调用的promise.try成功（）从删除（）方法或删除（原因原因），女巫可以触发操作完成（）方法。