bytebuf在netty中的重用

Question

我和Netty有一个http服务。对于一组请求，在http正文中只有“{}”的相同答复。我有一个想法，可以避免为每个这样的请求创建新的缓冲区，所以我使用了：

private static final ByteBuf EMPTY_REPLY = Unpooled.copiedBuffer("{}", CharsetUtil.UTF_8);

在我的SimpleChannelInboundHandler中。它只适用于第一个查询，之后我开始有

WARNING: Failed to mark a promise as success because it has failed already: DefaultChannelPromise@48c81b24(failure: io.netty.handler.codec.EncoderException: io.netty.util.IllegalReferenceCountException: refCnt: 0, decrement: 1), unnotified cause:
io.netty.handler.codec.EncoderException: io.netty.util.IllegalReferenceCountException: refCnt: 0, decrement: 1
    at io.netty.handler.codec.MessageToMessageEncoder.write(MessageToMessageEncoder.java:106)
    at io.netty.channel.AbstractChannelHandlerContext.invokeWrite0(AbstractChannelHandlerContext.java:738)
    at io.netty.channel.AbstractChannelHandlerContext.invokeWriteAndFlush(AbstractChannelHandlerContext.java:801)
    at io.netty.channel.AbstractChannelHandlerContext.write(AbstractChannelHandlerContext.java:814)
    at io.netty.channel.AbstractChannelHandlerContext.writeAndFlush(AbstractChannelHandlerContext.java:794)
    at io.netty.channel.AbstractChannelHandlerContext.writeAndFlush(AbstractChannelHandlerContext.java:831)
    at travel.ServerHandler.writeResult(ServerHandler.java:475)

所以看起来缓冲区在第一次回复后会自动释放。有这样的缓冲的正确方法是什么？

Answer 1

共享Netty缓冲区时，需要遵循基本引用计数规则，而不是基本垃圾收集的简单规则。

这些规则基本上可以归结为：

• 当从类中发送bytebuf时，调用reate()
• 如果使用bytebuf，请调用release()

在调用.reate()之后，您还需要执行一个技巧，即调用.duplicate()，因为这样可以防止对读取器索引的修改传递到您的基副本，如果不这样做，就会出现第一次写入成功的问题，但是在此之后，所有后续的写入都将写入一个空缓冲区。