如何找出哪条消息导致 Netty 写入异常？

Question

有一个 Java TCP-Client 使用 Netty 连接到服务器。 在断开连接的通道中写入会导致异常。哪个问题导致此问题并不重要，但对我来说重要的是哪条消息未发送并导致异常。

如何[通过使用 ChannelPromise 或 ChannelFuture] 找到它？

在这里我只得到'f.isSuccess()==true'，但这并不成功！消息未发送！

ChannelPromise promise = c.newPromise();
            promise.addListener(new ChannelFutureListener() {
                @Override
                public void operationComplete(ChannelFuture f) {
                    System.err.println("<TCPIn: promise write operationComplete.");
                    if (!f.isSuccess()) {
                        System.err.println("<TCPIn[writting]: promise write ERROR:");
                        f.cause().printStackTrace();
                        f.channel().close();
                    }
                }
            });
channel.writeAndFlush(buf,promise);

Answer 1

事情没那么简单。导致异常的原因是未能接收到从套接字发送缓冲区传输的段的确认。与特定消息的相关性可能为零。例如，它可能是一条消息的一半和下一条消息的一半，它肯定是来自先前写入的数据，而不是刚刚完成的数据。请记住，TCP 中的“写入完成”仅意味着成功缓冲套接字发送缓冲区中的数据。