我正在使用 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”。我知道它们是引用计数对象,因此当我尝试像下面这样手动释放它们时:
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事件中创建新实例并不是一个好主意。
最佳答案
是的,如果你调用writeAndFlush(...)
,你基本上就转移了缓冲区的所有权。如果缓冲区已写入或写入失败,Netty 本身会释放该缓冲区。
关于java - ChannelInboundHandlerAdapter writeAndFlush(msg)方法在刷新后是否释放msg?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/43654924/