如何为一元 rpc 定义响应 headers
How to define response headers for unary rpc
在 Go 中,我想从我的 rpc 处理程序实现中设置一些响应 headers。具体来说,我想设置一些与缓存控制相关的headers。
但是当rpc定义为一元响应时,protoc生成的方法签名只包含请求上下文和请求消息。这与从流响应生成的代码形成对比,后者包括请求消息和 grpc.ServerStream
.
这是协议生成的示例接口:
type CmsServer interface {
GetPost(context.Context, *PostRequest) (*Post, error)
GetPosts(*GetPostsOptions, Cms_GetPostsServer) error
}
在示例中,GetPosts
包含 Cms_GetPostsServer
参数,这是一个 grpc.ServerStream
似乎包含设置自定义响应的方法 headers https://godoc.org/google.golang.org/grpc#ServerStream(我还没有尝试过,如果这是错误的请纠正我)。
同时,GetPost
似乎没有任何方法可以通过查看方法签名来设置响应 headers(context.Context 只是请求上下文,而不是响应语境)。那么如何为一元响应设置自定义响应 headers?
请求上下文具有将请求与连接相匹配的信息。您使用 grpc.SetHeader
or 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 处理程序实现中设置一些响应 headers。具体来说,我想设置一些与缓存控制相关的headers。
但是当rpc定义为一元响应时,protoc生成的方法签名只包含请求上下文和请求消息。这与从流响应生成的代码形成对比,后者包括请求消息和 grpc.ServerStream
.
这是协议生成的示例接口:
type CmsServer interface {
GetPost(context.Context, *PostRequest) (*Post, error)
GetPosts(*GetPostsOptions, Cms_GetPostsServer) error
}
在示例中,GetPosts
包含 Cms_GetPostsServer
参数,这是一个 grpc.ServerStream
似乎包含设置自定义响应的方法 headers https://godoc.org/google.golang.org/grpc#ServerStream(我还没有尝试过,如果这是错误的请纠正我)。
同时,GetPost
似乎没有任何方法可以通过查看方法签名来设置响应 headers(context.Context 只是请求上下文,而不是响应语境)。那么如何为一元响应设置自定义响应 headers?
请求上下文具有将请求与连接相匹配的信息。您使用 grpc.SetHeader
or 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)
}