Netty ByteBuf到Byte[]解码器

Question

我希望将传入的Netty的Butebuf消息转换为我的类的MyBuffer实例。为此，我使用以下MessageTomessageDecoder:

class ByteArrayDecoder extends MessageToMessageDecoder<ByteBuf> {
  @Override
  protected void decode(ChannelHandlerContext ctx, ByteBuf msg, List<Object> out) throws Exception {
    int length = msg.readableBytes();
    if (msg.hasArray()) {
      out.add(new MyBuffer(msg.array(), msg.arrayOffset(), length));

    } else {
      byte[] bytes = new byte[length];
      msg.getBytes(msg.readerIndex(), bytes);
      out.add(new MyBuffer(bytes, 0, length));
    }
  }
}

现在，由于bytebuf消息是引用计数的，我们必须在处理完它之后释放它。这是由我们正在扩展的MessageTomessageDecoder自动完成的。

现在，既然ButeBuf已经发布，这难道不意味着支持阵列处于危险之中吗？它将被回收，我不确定我会在我的MyBuffer的数组中看到什么。

这个解码器可以安全使用吗？这是正确的编写方式吗？

Answer 1

根据@FerryBig的建议，我正在回答我的评论！

bytebuf.array（）返回您指定的实际支持数组...

一旦您放弃了对它的句柄/引用，并且引用计数随后下降到0（立即或当其他一切都放弃它的声明时），所有的赌注都取消了。