在 Go 中使用 gRPC 的优雅错误处理
grpc 提供了优雅的错误处理机制,允许将自定义错误转换为 grpc 错误并从 grpc 错误中提取自定义错误,以方便在分布式系统中进行错误处理:自定义错误转换为 grpc 错误:使用 codes.new 和 errors.new 函数创建代码和错误。从 grpc 错误提取自定义错误:使用 status.fromerror 和 errors.unwrap 函数获取代码和自定义错误。
在 Go 中使用 gRPC 的优雅错误处理
在分布式系统中,优雅地处理错误非常重要。gRPC 是一个流行的用于构建分布式系统的框架,它提供了强大的错误处理机制。
gRPC 错误处理
gRPC 返回error类型的值以表示错误。gRPC 错误类型实现了github.com/golang/protobuf/ptypes/any接口,允许序列化和反序列化自定义错误。
将自定义错误转换为 gRPC 错误
要将自定义错误转换为 gRPC 错误,请使用codes.New函数创建code.Code并使用errors.New创建error:
import ( "errors" "google.golang.org/grpc/codes" "google.golang.org/grpc/status" ) func ToGRPCError(code codes.Code, err error) error { return status.Error(code, err.Error()) }
从 gRPC 错误中提取自定义错误
要从 gRPC 错误中提取自定义错误,请使用errors.Unwrap函数:
import ( "errors" ) func FromGRPCError[T any](err error) (error, bool) { grpcStatus, ok := status.FromError(err) if !ok { return nil, false } if !errors.Is(err, grpcStatus.Proto()) { return nil, false } return errors.Unwrap(grpcStatus.Proto()), true }
实战案例
示例 gRPC 服务:
package main import ( "context" "google.golang.org/grpc/codes" "google.golang.org/grpc/status" ) type GreeterService struct {} func (s *GreeterService) Greet(ctx context.Context, req *GreetRequest) (*GreetResponse, error) { if req.Name == "" { return nil, ToGRPCError(codes.InvalidArgument, errors.New("invalid")) } return &GreetResponse{Message: "Hello, " + req.Name}, nil }
示例 gRPC 客户端:
package main import ( "context" "errors" "google.golang.org/grpc/codes" ) func main() { // ... client, err := createClient() if err != nil { // Handle initialization error } req := &GreetRequest{Name: ""} resp, err := client.Greet(context.Background(), req) if err != nil { grpcStatus, ok := status.FromError(err) if ok && grpcStatus.Code() == codes.InvalidArgument { // Handle invalid name error } else { // Handle other errors } } // ... }
以上就是在 Go 中使用 gRPC 的优雅错误处理的详细内容,更多请关注其它相关文章!