ChannelInboundHandlerAdapter writeAndFlush(msg)方法是否在刷新后释放msg？

Question

我正在使用ChannelInboundHandlerAdapter类并writeAndFlush来自channelRead（）的每个消息；

public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception { 
    ByteBuf msgBuffer = (ByteBuf)msg;
    BinaryWebSocketFrame frame= new BinaryWebSocketFrame(msgBuffer);
    ctx.writeAndFlush(frame);
}

在本例中：Netty是否释放“frame”和“msg”。我知道它们是reference counted object,因此当我尝试像下面这样手动释放它们时：

public void channelRead(ChannelHandlerContext ctx, Object msg) throws  Exception { 
    ByteBuf buf = (ByteBuf)msg;
    BinaryWebSocketFrame frame= new BinaryWebSocketFrame(buf);
    ctx.writeAndFlush(frame);
    buf.release();
    frame.release();
}

但在这种情况下,我会得到refCounted对象释放错误,如下所示：

io.netty.util.IllegalReferenceCountException: refCnt: 0, decrement: 1

起初，我依赖于netty发布相关实例，但它偶尔会在运行时给我带来内存泄漏错误。

在这种情况下如何减少内存占用，因为在每个channelRead事件中创建新实例并不是一个好主意，当您不能正确释放它们时。

Answer 1

是的，如果调用writeandflush(...)，基本上就是转移缓冲区的所有权。如果缓冲区被写入或写入失败，Netty本身将释放缓冲区。