ruby-on-rails - 如何动态分配正确的消息来解码协议缓冲区消息？

Question

嗨，我有一个适用于“事件”的数据流管道。这些事件是简单的协议缓冲区消息，例如：

message OrderCoffee {
    int32 id = 1;
}

message CancelOrder {
    int32 id = 1;
}

然后客户端对这些消息进行序列化/编码并将它们推送到消息代理（例如Google Pub/Sub）。订阅者使用一条消息并尝试解码/反序列化（伪代码）：

decoded_message = OrderCoffe.decode(encoded_message)
decoded_message = CancelOrder.decode(encoded_message)

这些线路中的哪一条有效？两者，至少在我的 Ruby 代码中。我不知道我是否对如何使用协议缓冲区有概念上的误解，或者那是一个 ruby 错误。

如果这是预期的行为，我怎么知道在运行时我应该对收到的消息进行解码？

编辑：

虽然我无法理解。有人可以提供一个如何在 ruby 中实现它的例子吗？

score 2 · Accepted Answer

基本上，你不能从那里。Protobuf 消息不是自描述的。如果是我，我会添加一个包装器：

message SomeType {
    oneof the_thing {
        OrderCoffee order = 1;
        CancelOrder cancel = 2;
    }
}

当您反序列化 athe_thing时，您可以测试分配了哪个内部对象。

1 回答 1