发送以流方式传输的 protobuf 编码的元数据

小伙伴们对Golang编程感兴趣吗？是否正在学习相关知识点？如果是，那么本文《发送以流方式传输的 protobuf 编码的元数据》，就很适合你，本篇文章讲解的知识点主要包括。在之后的文章中也会多多分享相关知识点，希望对大家的知识积累有所帮助！

关于在启动客户端流式 grpc 时附加一段元数据（“初始”请求）的问题之前已经被问过（此处，此处），但一些答案表明这是不可能的，并建议使用 oneof ，其中对服务器的第一个请求包含相关元数据，后续请求包含要由服务器处理的实际数据。我想知道使用所选的二进制编码对元数据进行编码并将其发送到服务器是否安全，在服务器中可以从 context 对象中提取元数据并将其反序列化回有意义的数据。我相当确定，当涉及到基于文本的编码（例如 json）时，它是完全没问题的。但是 protobuf 呢？假设我们像这样定义我们的服务：

service myservice {
  rpc chitchat (stream chatmessage) returns (stream chatmessage);
}

message chatmessage {
  // ...
}

message meta {
  // ...
}

我们可以在请求中包含 meta 对象：

meta := &pb.meta{
    // ...
}
metab, err := proto.marshal(meta)
if err != nil {
    log.fatalf("marshaling error: %v", err)
}
newctx := metadata.newoutgoingcontext(context.background(), metadata.pairs("meta-bin", string(metab)))
// ...chitchat(newctx)

并在服务器端访问它：

func (s *server) ChitChat(stream pb.MyService_ChitChatServer) error {
    md, ok := metadata.FromIncomingContext(stream.Context())
    if !ok {
        return fmt.Errorf("no metadata received")
    }
    metaStr := md.Get("meta-bin")
    if len(metaStr) != 1 {
        return fmt.Errorf("expected 1 md; got: %v", len(metaStr))
    }
    meta := new(pb.Meta)
    if err := proto.Unmarshal([]byte(metaStr[0]), meta); err != nil {
        return fmt.Errorf("error during deserialization: %v", err)
    }

    // ...
    return nil
}

它似乎工作得很好 - 我错过了什么吗？这种做法很容易搬起石头砸自己的脚吗？

正确答案

是的，gRPC 支持二进制标头，因此这种方法并非无效；这是预期的不太清楚，但是：对于 oneof 方法也是如此，所以......没有太大区别。

到这里，我们也就讲完了《发送以流方式传输的 protobuf 编码的元数据》的内容了。个人认为，基础知识的学习和巩固，是为了更好的将其运用到项目中，欢迎关注golang学习网公众号，带你了解更多关于的知识点！