Netty中使用ChannelHandlerContext写入后,池化直接ByteBuf如何正确释放?
问题解答
先明确Netty中池化ByteBuf的核心规则:调用ctx.write(Object msg)时,Netty会接管ByteBuf的引用所有权,在IO操作完成(成功或失败)后自动调用release()回收池化内存,无需手动干预。
三种写法的详细分析
code 1
ctx.write(buffer); ReferenceCountUtil.release(buffer);
错误。ctx.write()刚把buffer交给Netty处理,你立刻手动释放,导致Netty后续操作时,buffer的引用计数已经为0,直接触发非法引用计数异常。
code 2
ctx.write(buffer, ctx.newPromise().addListener(f -> ReferenceCountUtil.release(buffer)));
错误,这也是你报错的原因。Netty在IO操作完成后会自动释放一次buffer,而你又在Promise监听器里手动调用release(),相当于对同一个buffer执行了两次释放操作,引用计数变为0后再次递减,触发IllegalReferenceCountException。
code 3
ctx.write(buffer);
正确。ctx.write()将buffer的所有权转移给Netty的IO线程,Netty会在写操作完成后自动完成池化ByteBuf的释放回收,不需要任何手动释放操作。
补充说明
如果需要监听写操作的结果,只需处理业务逻辑即可,不要重复释放buffer:
ChannelPromise promise = ctx.newPromise(); ctx.write(buffer, promise); promise.addListener(future -> { if (!future.isSuccess()) { // 仅做失败日志、重试等业务处理,无需手动释放buffer future.cause().printStackTrace(); } });
另外注意,ctx.write()只是将消息加入出站队列,需调用ctx.flush()才会真正发送到网络;如果使用ctx.writeAndFlush(buffer),同样遵循上述规则,无需手动释放。
内容的提问来源于stack exchange,提问作者shanfeng
相关产品推荐
相关产品推荐

