如何在 Netty 4 中删除拥塞的连接

Question

使用Netty 4，我如何检测到我写的数据在我这边的连接中被阻塞，如果远端跟不上，我如何关闭连接？

我在检查

频道句柄上下文.channel.outboundByteBuffer.readableBytes

但是在最新的Netty 4版本中，这给了我一个例外:

java.lang.IllegalStateException:从eventLoop外部调用nextOutboundByteBuffer（）

Answer 1

您需要从EventLoop执行此操作，否则它不是线程安全的。

大概是这样的：

ChannelHandlerContext ctx = ....
final Channel channel = ctx.channel();
channel.eventLoop().execute(new Runnable() {
    public void run() {
        if (channel.outboundByteBuffer.readableBytes() > MaxWriteBuffer) {
            // do something
        }
    }
});