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(); }); }); 

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