Protobuf v3跨语言传输长字符串遇InvalidProtocolBufferException求助

从你描述的现象来看，这个问题几乎可以确定是Protobuf变长编码（Varint）在跨语言HTTP传输时的字节流完整性问题——因为当字符串长度超过127时，Protobuf会用多字节的Varint来表示字段长度，这时候如果HTTP请求体没有完整传输，服务器就会解析到一半报错。下面是具体的排查方向和解决方法：

1. 优先检查C#客户端的HTTP发送逻辑 #

最常见的坑是没有正确处理Protobuf字节流的传输：

• 必须使用ByteArrayContent直接发送序列化后的原始字节，绝对不能用StringContent（会把字节转成字符串再编码，破坏Protobuf的二进制结构）。
• 一定要显式设置Content-Length和正确的Content-Type，避免HTTP服务器因为无法判断请求体长度而提前截断数据。

正确的C#发送示例：

var clientMsg = new CLIENT_MESSAGE { Message = "你的198字符长字符串..." };
byte[] protoBytes;

// 正确序列化Protobuf消息
using (var ms = new MemoryStream())
{
    clientMsg.WriteTo(ms);
    protoBytes = ms.ToArray();
}

// 构造HTTP请求内容
var requestContent = new ByteArrayContent(protoBytes);
requestContent.Headers.ContentType = new MediaTypeHeaderValue("application/protobuf");
requestContent.Headers.ContentLength = protoBytes.Length; // 关键：显式指定字节长度

// 发送请求
var httpClient = new HttpClient();
var response = await httpClient.PostAsync("你的Java服务器地址", requestContent);

2. 检查Java服务器的请求体读取逻辑 #

很多Java服务器端代码会犯“一次性读取流”的错误，导致长字节流被截断：

• 不要直接用request.getInputStream().read(...)单次读取，必须循环读取直到拿到Content-Length指定的所有字节。
• 如果用Spring等框架，要确保框架没有自动限制请求体大小（比如Spring的spring.servlet.multipart.max-file-size配置）。

正确的Java读取示例（Servlet环境）：

protected void doPost(HttpServletRequest request, HttpServletResponse response) throws IOException {
    int contentLength = request.getContentLength();
    byte[] protoBytes = new byte[contentLength];
    InputStream inputStream = request.getInputStream();
    
    int totalRead = 0;
    // 循环读取直到获取全部字节
    while (totalRead < contentLength) {
        int readBytes = inputStream.read(protoBytes, totalRead, contentLength - totalRead);
        if (readBytes == -1) {
            throw new IOException("请求体被截断，未读取到完整数据");
        }
        totalRead += readBytes;
    }
    
    // 解析Protobuf消息
    CLIENT_MESSAGE message = CLIENT_MESSAGE.parseFrom(protoBytes);
}

3. 验证序列化字节的一致性 #

把C#客户端序列化后的字节数组转成十六进制字符串，再把Java服务器接收的字节数组也转成十六进制，对比两者：

• 如果头部几个字节不一致，大概率是客户端发送时混入了额外字节（比如错误的HTTP头部），或者服务器少读了字节。
• 比如字符串长度198的Varint编码是0xC6 0x01（198=128+70，Varint采用小端多字节存储），如果服务器只收到第一个字节0xC6，就会触发你遇到的截断异常。

4. 排查中间件的影响 #

如果客户端和服务器之间有反向代理、负载均衡等中间件，检查这些组件是否会修改或截断HTTP请求体：

• 比如有些代理会默认开启请求体压缩，但客户端没有设置Accept-Encoding，导致代理压缩后服务器无法正确解析。
• 用Wireshark抓包，直接对比客户端发送的字节流和服务器接收的字节流，确认中间环节是否有篡改。

内容的提问来源于stack exchange，提问作者NewJ