作者热门文章
- r - 以节省内存的方式增长 data.frame
- ruby-on-rails - ruby/ruby on rails 内存泄漏检测
- android - 无法解析导入android.support.v7.app
- UNIX 域套接字与共享内存(映射文件)
在 Go 中,我想在我的 rpc 处理程序实现中设置一些响应 header 。具体来说,我想设置一些与缓存控制相关的 header 。
但是当rpc定义为一元响应时,protoc生成的方法签名只包含请求上下文和请求消息。这与从流响应生成的代码形成对比,后者包括请求消息和 grpc.ServerStream
。
这是一个由 protoc 生成的示例接口(interface):
type CmsServer interface {
GetPost(context.Context, *PostRequest) (*Post, error)
GetPosts(*GetPostsOptions, Cms_GetPostsServer) error
}
在示例中,GetPosts
包含 Cms_GetPostsServer
参数,它是一个 grpc.ServerStream
,似乎包含设置自定义响应 header https://godoc.org/google.golang.org/grpc#ServerStream (我还没有尝试过这个,所以如果这是错误的请纠正我)。
与此同时,GetPost
似乎没有任何方法可以仅通过查看方法签名来设置响应 header (context.Context 只是请求上下文,而不是响应上下文)。那么如何为一元响应设置自定义响应 header ?
最佳答案
参见 Sending and receiving metadata - server side
请求上下文具有将请求与连接相匹配的信息。您使用 grpc.SetHeader
或 grpc.SendHeader
从服务器写入额外的元数据
func (s *server) SomeRPC(ctx context.Context, in *pb.someRequest) (*pb.someResponse, error) {
// create and send header
header := metadata.Pairs("header-key", "val")
grpc.SendHeader(ctx, header)
// create and set trailer
trailer := metadata.Pairs("trailer-key", "val")
grpc.SetTrailer(ctx, trailer)
}
关于go - 如何为一元 rpc 定义响应 header ,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/48631477/
我是一名优秀的程序员,十分优秀!