java - Netty ByteBuf 首次实现

Question

我的计划是制定如下所示的消息协议(protocol):

• MessageLength:消息总长度的整数
• MessageID:具有自动递增标识符的整数
• MessageType:带有消息类型的整数(enum)
• Payload:byte[] 以及消息的有效负载(序列化 POJO)

目前，我只是想确保以正确且最佳的方式创建ByteBuf。现阶段我有以下内容:

io.netty.buffer.ByteBuf buf = Unpooled.buffer();

// Test Data Class
TestData test = new TestData("FirstName", "LastName", 40);

// Convert to Bytes is method to return the Byte Array (Serialised POJO)
byte[] payload = convertToBytes(test);

// Write 1 simulating MessageID 1
buf.writeInt(1);

// Write 2 simulating MessageType of 2
buf.writeInt(2);

// Write The Payload data<BR>
buf.writeBytes(payload);

目标是让它们传递到 LengthFieldPrepender 并沿着管道向上。

这是创建ByteBuf的正确方法吗？或者有更好的办法吗？

Answer 1

如果可能的话，您应该使用分配器来创建 ByteBuf，因为这可能会给您一个池化的 ByteBuf(取决于配置)。

类似于:

Channel channel = ...
channel.alloc().buffer(expectedSize)

另请注意，我传入了 ByteBuf 的预期大小，因为这将确保我们稍后在填充它时不需要扩展它。