publish-subscribe - 如何在 gcloud pubsub 中为主题添加 protobuf 文件？

Question

在谷歌云的 pubsub 中，我可以看到在创建新主题时，我必须创建一条新消息。我可以在那里存储一个 protobuf 文件，而不必在键值对中编写整个消息结构吗？对于应该编写的 protobuf 代码，我的意思是 this .如果 protobuf 不打算放在 gcloud pubsub 上，我如何将它与 grpc 客户端一起使用？

Answer 1

如果您想通过 Publish API 发送 ProtoBuf 消息，您应该将其序列化为 ByteString，然后将其设置为消息的 数据 字段。例如，如果您使用 Java client library你有一个 Publisher和某些 ProtoBuf 类型的 obj，那么您可以执行以下操作:

PubsubMessage message = PubsubMessage.newBuilder()
    .setData(obj.toByteString())
    .build();
ApiFuture<String> response = publisher.publish(message);
...

在订阅端，您将解码 MessageReceiver 中的消息:

public void receiveMessage(PubsubMessage message, AckReplyConsumer consumer) {
  ProtoBufMessage obj;
  try {
    obj = ProtoBufMessage.parseFrom(message.getData());
  } catch (Exception e) {
    // Handle improperly encoded message
  }
  ...
}