（爪哇/网络）使用Netty发送和接收可变大小的对象的最简单方法是什么？

Question

因此，我有一个< code>Message类，它包含了我想要发送的所有信息。然而，它的内容可以变化很大。

通过Netty通道发送和接收（特别是解码/重组部分）此类对象的最简单方法是什么？（使用Netty 3）

Answer 1

重放解码器可能是您正在寻找的：

http://docs.jboss.org/netty/3.1/api/org/jboss/netty/handler/codec/replay/ReplayingDecoder.html

如果没有足够的数据，而不是抛出错误，这将静默失败并重试decode（），直到所有数据可用。

下面是一个教程，演示了此操作的实际效果：

http://biasedbit.com/netty-tutorial-replaying-decoder/

Answer 2

我们使用4字节长度的前缀。我们在发送端使用OneToOneEncoder的子类，在接收端使用LengthFieldBasedFrameDecoder的子类。

写留言：

    private static final byte[] LENGTH_PLACEHOLDER = new byte[4];

    ChannelBufferOutputStream bout =
        new ChannelBufferOutputStream(dynamicBuffer(512, ctx.getChannel().getConfig().getBufferFactory()));
    bout.write(LENGTH_PLACEHOLDER);

    // write message contents here ...

    ChannelBuffer encoded = bout.buffer();
    encoded.setInt(0, encoded.writerIndex() - 4);
    return encoded;

LengthFieldBasedFrameDecoder的构造函数参数：

private static final int MAX_OBJECT_SIZE = 1 << 21;

public MyDecoder() 
{
    super(MAX_OBJECT_SIZE, 0, 4, 0, 4);
}

阅读消息：

    ChannelBuffer frame = (ChannelBuffer) super.decode(ctx, channel, buffer);
    if (frame == null) {
        return null;
    }

    ChannelBufferInputStream data = new ChannelBufferInputStream(frame);

    // read message here ...