答案：golang中gRPC中间件通过拦截器实现，主要使用一元拦截器处理请求前后逻辑，如日志、认证、恢复、监控等；自定义拦截器需符合特定函数签名，并通过grpc.UnaryInterceptor注册，多个中间件可借助grpc-middleware库链式组合，常见顺序为recovery→auth→Logging→metrics，确保context传递和错误处理正确。
在golang中使用gRPC中间件，主要通过拦截器（Interceptor）实现。gRPC本身不直接提供“中间件”概念，但拦截器起到了类似作用，可以在请求处理前后执行通用逻辑，比如日志、认证、超时、监控等。
1. 理解gRPC拦截器类型
gRPC Go支持两种拦截器：
- Unary Interceptor：用于处理一元调用（普通请求-响应模式）
- stream Interceptor：用于处理流式调用（客户端流、服务端流、双向流）
大多数中间件场景使用一元拦截器即可。
2. 编写自定义一元拦截器
一元拦截器是一个函数，签名为：
立即学习“go语言免费学习笔记（深入）”；
func(ctx context.Context, req Interface{}, info *grpc.UnaryServerInfo, handler grpc.UnaryHandler) (resp interface{}, err Error)
示例：实现一个简单日志中间件
func loggingMiddleware(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, handler grpc.UnaryHandler) (interface{}, error) { fmt.printf(“Received request to %sn”, info.FullMethod) // 调用实际的处理函数 resp, err := handler(ctx, req) fmt.Printf(“Finished handling %s with error: %vn”, info.FullMethod, err) return resp, err }
3. 在gRPC服务器中注册拦截器
使用 grpc.UnaryInterceptor 选项注册中间件：
server := grpc.NewServer(grpc.UnaryInterceptor(loggingMiddleware))
如果需要多个中间件，可以使用 grpc-middleware 库组合：
import “github.com/grpc-ecosystem/go-grpc-middleware” server := grpc.NewServer( grpc.UnaryInterceptor(grpc_middleware.ChainUnaryServer( loggingMiddleware, authMiddleware, recoveryMiddleware, )), )
4. 常见中间件实践
以下是一些实用的中间件示例思路：
- 认证中间件：从metadata中提取Token，验证合法性
- 恢复中间件（Recovery）：捕获panic，防止服务崩溃
- 监控中间件：记录请求延迟，上报prometheus
- 限流中间件：基于IP或Token限制请求频率
例如，一个基础的auth中间件：
func authMiddleware(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, handler grpc.UnaryHandler) (interface{}, error) { md, ok := metadata.FromIncomingContext(ctx) if !ok { return nil, status.Errorf(codes.Unauthenticated, “missing metadata”) } tokens := md[“authorization”] if len(tokens) == 0 { return nil, status.Errorf(codes.Unauthenticated, “missing token”) } if tokens[0] != “secret-token” { // 实际应使用JWT等机制 return nil, status.Errorf(codes.Unauthenticated, “invalid token”) } return handler(ctx, req) }
基本上就这些。通过拦截器，你可以将横切关注点统一处理，保持业务逻辑干净。中间件顺序很重要，一般建议按 recovery → auth → logging → metrics 的顺序链式注册。不复杂但容易忽略细节，比如context传递和错误映射。