英文:
How to make a variable available to all gRPC request handlers on a gRPC server?
问题
你可以通过将变量添加到gRPC请求上下文中来实现在所有请求处理程序中使用它。在Run()函数中，你可以使用context.WithValue()函数将foo变量添加到gRPC服务器的上下文中。然后，在请求处理程序中，你可以使用ctx.Value()函数来获取该变量的值。
下面是修改后的代码示例：
func Run(...) ... {
// this is variable I want to add to all my request handler's context
foo := "bar"
grpcServer := grpc.NewServer()
grpc_health_v1.RegisterHealthServer(grpcServer, health.NewServer())
pb.RegisterMyServer(grpcServer, newServer())
signal.Notify(sigChan, syscall.SIGTERM, syscall.SIGINT)
go func() {
if err := grpcServer.Serve(lis); err != nil {
errChan <- err
}
}()
return grpcServer, nil
}
func (s *myServer) Ping(
ctx context.Context,
pingRequest *pb.PingRequest,
) (*pb.PingResponse, error) {
// 获取foo变量的值
foo := ctx.Value("foo").(string)
// 使用foo变量进行处理
// ...
return &pb.PingResponse{}, nil
}
在Run()函数中，你可以使用context.WithValue()函数将foo变量添加到gRPC服务器的上下文中：
ctx := context.WithValue(context.Background(), "foo", foo)
然后，在请求处理程序中，你可以使用ctx.Value()函数来获取该变量的值：
foo := ctx.Value("foo").(string)
这样，你就可以在所有请求处理程序中使用foo变量了。
英文:
I'm starting my gRPC server like this:
func Run(...) ... {
// this is variable I want to add to all my request handler's context
foo := "bar"
grpcServer := grpc.NewServer()
grpc_health_v1.RegisterHealthServer(grpcServer, health.NewServer())
pb.RegisterMyServer(grpcServer, newServer())
signal.Notify(sigChan, syscall.SIGTERM, syscall.SIGINT)
go func() {
if err := grpcServer.Serve(lis); err != nil {
errChan <- err
}
}()
return grpcServer, nil
}
And here's an example of a handler for a "ping" request:
func (s *myServer) Ping(
ctx context.Context,
pingRequest *pb.PingRequest,
) (*pb.PingResponse, error) {
return &pb.PingResponse{}, nil
}
You can see in Run() that I have a variable foo that I would somehow like to be available to all my request handlers. This variable does not depend on the client's request in any way, it just needs to be available in the request handlers.
What is the best way to achieve this?
- Use a singleton
- Use a global
- Somehow add it to the gRPC request contexts?
答案1
得分: 2
使用您的自定义实现来创建GRPC服务器。
type GrpcServer struct {
Foo string
}
func (g *GrpcServer) Ping(ctx context.Context, pingRequest *pb.PingRequest) (*pb.PingResponse, error) {
fmt.Println(g.Foo)
return &pb.PingResponse{}, nil
}
并注册您的自定义实现到GRPC服务器。
func Run() {
foo := "bar"
grpcServer := grpc.NewServer()
grpc_health_v1.RegisterHealthServer(grpcServer, health.NewServer())
pb.RegisterMyServer(grpcServer, &GrpcServer{Foo: foo})
signal.Notify(sigChan, syscall.SIGTERM, syscall.SIGINT)
go func() {
if err := grpcServer.Serve(lis); err != nil {
errChan <- err
}
}()
return grpcServer, nil
}
英文:
Use your custom implementation to GRPC server.
type GrpcServer struct {
Foo string
}
func (g *GrpcServer) Ping(ctx context.Context, pingRequest *pb.PingRequest, ) (*pb.PingResponse, error) {
fmt.Println(g.Foo)
return &pb.PingResponse{}, nil
}
And register your custom implementation of grpc server.
func Run() {
foo := "bar"
grpcServer := grpc.NewServer()
grpc_health_v1.RegisterHealthServer(grpcServer, health.NewServer())
pb.RegisterMyServer(grpcServer, &GrpcServer{Foo: foo})
signal.Notify(sigChan, syscall.SIGTERM, syscall.SIGINT)
go func() {
if err := grpcServer.Serve(lis); err != nil {
errChan <- err
}
}()
return grpcServer, nil
}
通过集体智慧和协作来改善编程学习和解决问题的方式。致力于成为全球开发者共同参与的知识库，让每个人都能够通过互相帮助和分享经验来进步。
评论