flutter 下 protobuf 编解码的问题，卡好几天。

后端使用netty+protobuf 协议通过暴露 socket 端口，客户端进行 socket 连接

服务端编解码器如下：

public class SocketServerInitializer extends ChannelInitializer<Channel> {
    @Override
    protected void initChannel(Channel ch) throws Exception {
        // 31 秒没有向客户端发送消息就发生心跳
        ch.pipeline().addLast(new IdleStateHandler(31, 0, 0))
                // google Protobuf 编解码
                .addLast(new ProtobufVarint32FrameDecoder())
                .addLast(new ProtobufDecoder(WSBaseReqProtoOuterClass.WSBaseReqProto.getDefaultInstance()))
                .addLast(new ProtobufVarint32LengthFieldPrepender())
                .addLast(new ProtobufEncoder())
                .addLast(new SocketServerHandler());
    }
}

客户端使用 flutter 编写:

await Socket.connect('172.16.0.193', 9002).then((socket) {
      connectFlag = true;
      update();

      /// 创建连接鉴权
      socket.add(buildWSBaseReqProto(1, info.sid, info.uid));

      /// 开始维持心跳, 每 30s 进行一次心跳连接
      Timer.periodic(Duration(seconds: 30), (timer) {
        socket.add(buildWSBaseReqProto(0, info.sid, info.uid));
      });
      
      int HeaderLength = 2
      /// 开始监听 socket 记录
      socket.listen((event) {
        WSBaseResProto res = WSBaseResProto.fromBuffer(event.sublist(HeaderLength, event.length));
        msgList.add(res);
        update();
      });
    });

在最后监听的方法中没有做粘包、解包处理动作，所以有时候能收到消息，有时候收不到。主要是不懂怎么处理这个消息头长度的问题，希望有大佬指点一下。