如何在Ruby和Java之间序列化/解析protobuf对象?

cro*_*cha 5 ruby java protocol-buffers rabbitmq

在Ruby中序列化protobuf对象和在Java中解析的正确方法是什么?这是为了自动化测试,我们正在Rabbit队列中侦听此消息.

发布者(Ruby):

protoNew = Protobuf::Request.new
protoNew.request = request
protoNew.id = id.to_i
protoNew.authentication = authentication

return protoNew.serialize_to_string
Run Code Online (Sandbox Code Playgroud)

消费者(Java):

    @Override
    public void onMessage(Message message, Channel channel) 
    {
        ProtoRequest protoRequest;
        try {
            protoRequest = ProtoRequest.parseFrom(message.getBody());
        } catch (InvalidProtocolBufferException e1) {
            logger.error("Error parsing protobuf", e1);
        } 
Run Code Online (Sandbox Code Playgroud)

这是我看到的错误:

解析protobuf时出错:com.google.protobuf.InvalidProtocolBufferException:协议消息end-group标记与期望标记不匹配.at com.google.protobuf.InvalidProtocolBufferException.invalidEndTag(InvalidProtocolBufferException.java:94)[protobuf-java-2.6.1.jar:] at com.google.protobuf.CodedInputStream.checkLastTagWas(CodedInputStream.java:174)[protobuf-java -2.6.1.jar:] com.google.protobuf.AbstractParser.parsePartialFrom(AbstractParser.java:139)[protobuf-java-2.6.1.jar:] at com.google.protobuf.AbstractParser.parseFrom(AbstractParser. java:168)[protobuf-java-2.6.1.jar:] com.google上的com.google.protobuf.AbstractParser.parseFrom(AbstractParser.java:180)[protobuf-java-2.6.1.jar:]. protobuf.AbstractParser.parseFrom(AbstractParser.java:185)[protobuf-java-2.6.1.jar:

Wan*_*ker 1

目前尚不清楚如何打包输出,protoNew.serialize_to_string使其成为 Java 代码的 JMS 消息的内容。我猜想由于字符编码,有些事情变得混乱了。

作为解决方法,您可以对 的二进制输出进行 Base 64 编码protoNew.serialize_to_string,并在 Java 端进行 Base 64 解码。

require "base64"
...
return Base64.encode64 protoNew.serialize_to_string
Run Code Online (Sandbox Code Playgroud)

在Java端,

import org.apache.commons.codec.binary.Base64;
...
protoRequest = ProtoRequest.parseFrom(Base64.decodeBase64(message.getBody()))
Run Code Online (Sandbox Code Playgroud)

上述解决方案的一个缺点是,与纯二进制形式相比,它会导致更大的有效负载大小。

PS:请注意,如果我将输出写入person.serialize_to_stringRuby 端的文件,并在 Java 上读取该文件,它似乎工作正常

f = File.open("data.dat", "wb")
f << person.serialize_to_string
f.close
Run Code Online (Sandbox Code Playgroud)