谷歌协议缓冲区-编码在c++，解码在Java - InvalidProtocolBufferException

Question

对不起，我想我要疯了。我在c++中有这个:

std::stringstream message;
protoMsg.SerializeToOstream(&message);
boost::system::error_code ignored_error;
std::cout << "Writing response to socket. Byte size " << protoMsg.ByteSize() << " Buffer " << message.str().length() << std::endl;
for(int i(0);i<(int)message.str().length();i++)
    std::cout << (int)message.str().at(i);
std::cout << std::endl;
boost::asio::write(socket, boost::asio::buffer(message.str()), ignored_error);
std::cout << "Done writing." << std::endl;

产生以下输出

Writing response to socket. Byte size 88 Buffer 88
1886811891161111001113278971091012500000000320400480560640730000000081000000008859621061211611110011132115121109789710910111416691201161011141109710832114101113117101115116
Done writing.

在Java中:

try {
  System.out.println("Parsing");
  int lenbytes = is.read(buffer);
  System.out.println("Read bytes " + lenbytes);
  for(int i=0;i<lenbytes;i++)
    System.out.print(Integer.toString((int)buffer[i]));
  System.out.println("");
  EnvInfoProto envInfoProto = EnvInfoProto.parseFrom(buffer);
  System.out.println("Done");
  return envInfoProto;
} catch(IOException ignore) { System.out.println("Ex: " + ignore.toString(); }

收益率

Parsing
Read bytes 88
1886811891161111001113278971091012500000000320400480560640730000000081000000008859621061211611110011132115121109789710910111416691201161011141109710832114101113117101115116
Ex: com.google.protobuf.InvalidProtocolBufferException: Protocol message contained an invalid tag (zero).

二进制数据是相同的。我检查了我使用的是正确版本的原型文件。我有点不知所措。

Answer 1

您要求从buffer的整个解析消息-我的猜测是buffer超过88字节长。

我不能立即记住parseFrom是否允许您指定要读取的最大数据量，但另一种选择是:

ByteArrayIntputStream stream = new ByteArrayInputStream(buffer, 0, lenbytes);
EnvInfoProto envInfoProto = EnvInfoProto.parseFrom(stream);

请注意，这仍然有一个问题，即您假设可以在对read的单个调用中读取流中的所有数据，这从来都不是一个好主意-但这是一个非常独立的问题。如果要在写入后关闭套接字，当然可以在Java代码中从套接字的InputStream解析流。如果您不要关闭流，我建议首先将消息长度写入套接字(作为32位整数)，以便您可以在Java中读取它，并读取正确的数据量，知道何时完成。