java - 一个Netty缓冲区问题中包含多条消息

我使用netty网络库为游戏客户端构建了登录服务器。
这个游戏客户端喜欢在单个缓冲区中发送多个数据包，这带来了问题。问题在于，在网络解码类中，它只能返回一条消息。

然后，对于我来说，不可能将多个数据包读取为多个消息并以一个解码方法调用将它们返回。

我的问题是:如何最好地在一个DecoderClass.decode()方法调用中接收多个数据包？由于我只能返回一个对象，所以我很困惑。

我的初步解码类如下:

protected Object decode(ChannelHandlerContext ctx, Channel c, ChannelBuffer buf,
    VoidEnum state) throws Exception {
    short length = -1;
    short opcode = -1;
    short security = -1;

    while(buf.readableBytes() != 0 ){
        length = buf.readShort();
        opcode = buf.readShort();
        security = buf.readShort();
    }

    System.out.println("---------------------------------------");
    System.out.println("receivedLength: " + length);
    System.out.println("receivedOPCode: " + opcode);
    System.out.println("receivedSecurity: " + security);
    System.out.println("---------------------------------------");

    MessageCodec<?> codec = CodecLookupService.find(opcode);
    if (codec == null) {
        throw new IOException("Unknown op code: " + opcode + " (previous opcode: " + previousOpcode + ").");
    }


    previousOpcode = opcode;


    return codec.decode(buf);

我完整的github存储库在这里:https://github.com/desmin88/LoginServer

我希望我提供了足够的信息，以便有人可以充分理解我的问题

谢谢，

比利

最佳答案

您将需要使用FrameDecoder将接收到的数据拆分为多个“帧”，以传递给解码器。 API参考中有一些针对FrameDecoder的example code。

与其发表评论，不如做这样的事情:

实现您自己的FrameDecoder或使用现有的MyGameFrameDecoder。假设您实现了自己的ReplayingDecoder。如果您自己编写，我建议您检查 MyGameFrameDecoder (这很糟糕)。

与现有的解码器(ChannelPipeline)一起，将DecoderClass添加到服务器端的FrameDecoder中。

看起来像这样:

/* ... stuff ... */
pipeline.addLast("framer", new MyGameFrameDecoder());
pipeline.addLast("decoder", new DecoderClass());
/* ... more stuff ... */

然后，传入的数据将通过ojit_code并将流分成“帧”，然后将其发送到解码器，该解码器可以处理将数据转换为可操作的对象。