java - (Java/netty) 使用 Netty 发送和接收可变大小对象的最简单方法是什么？

Question

因此，我有一个 Message 类，其中包含我要发送的所有信息。但是，其内容可能千差万别。

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

Answer 1

我们使用 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 ...