Protobuf Stream
Protobuf 流式编码将多个长度前缀的 Protobuf 消息串联,支持流式传输与逐消息解析。
用途
在 TCP/gRPC 流中传输多个 Protobuf 消息,每消息以 varint 长度前缀界定边界。
机制
每消息编码为 varint 长度前缀 + Protobuf 字节流。接收端读 varint 长度后读取对应字节解析一条消息,重复。gRPC 帧格式即此。
用例
- gRPC 流式 RPC
- Kafka Protobuf 消息
- 日志流传输
Protobuf 流式编码将多个长度前缀的 Protobuf 消息串联,支持流式传输与逐消息解析。
在 TCP/gRPC 流中传输多个 Protobuf 消息,每消息以 varint 长度前缀界定边界。
每消息编码为 varint 长度前缀 + Protobuf 字节流。接收端读 varint 长度后读取对应字节解析一条消息,重复。gRPC 帧格式即此。