gRPC中间件通过拦截器实现通用逻辑复用，Go语言中使用Unary和Stream Interceptor分别处理一元和流式RPC；可通过grpc.UnaryInterceptor注册日志、认证等中间件，结合go-grpc-middleware库链式组合多个拦截器，提升可维护性；认证中间件可校验metadata中的token，流式拦截器则封装ServerStream实现日志记录等功能，增强服务可观测性与安全性。
在Go语言中使用gRPC中间件，主要是通过拦截请求和响应来实现通用逻辑的复用，比如日志记录、身份验证、超时控制、限流等。gRPC本身不直接提供中间件机制，但可以通过拦截器（Interceptor）实现类似功能。gRPC Go库支持两种类型的拦截器：Unary Interceptor（用于普通RPC）和Streaming Interceptor（用于流式RPC）。
一、什么是gRPC中间件（拦截器）
gRPC中间件本质上是函数钩子，在请求被处理前或响应返回后执行。它们可以嵌套组合，形成处理链。在Go中，中间件被称为Interceptor。
两种主要类型：
- Unary Interceptor：作用于一元RPC（即普通的请求-响应模式）
- Stream Interceptor：作用于客户端流、服务器流或双向流
二、定义并使用一元中间件
一元拦截器的类型定义如下：
立即学习“go语言免费学习笔记（深入）”；
// Unary Server Interceptortype UnaryServerInterceptor func(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, handler grpc.UnaryHandler) (resp interface{}, err error)
下面是一个简单的日志中间件示例：
func LoggingInterceptor(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, handler grpc.UnaryHandler) (interface{}, error) {log.Printf("Received request: %s", info.FullMethod)
resp, err := handler(ctx, req)
if err != nil {
log.Printf("Error handling request: %v", err)
} else {
log.Printf("Request processed successfully")
}
return resp, err
}
注册到gRPC服务器：
server := grpc.NewServer(grpc.UnaryInterceptor(LoggingInterceptor),
)
三、链式中间件与第三方库
实际项目中通常需要多个中间件，如认证、恢复、日志、监控等。可以手动嵌套，但更推荐使用go-grpc-middleware库进行管理。
安装：
go get github.com/grpc-ecosystem/go-grpc-middleware
使用多个中间件：
import "github.com/grpc-ecosystem/go-grpc-middleware"var opts = []grpc.ServerOption{
grpc.UnaryInterceptor(grpc_middleware.ChainUnaryServer(
LoggingInterceptor,
AuthInterceptor,
RecoveryInterceptor,
)),
}
server := grpc.NewServer(opts...)
这样可以清晰地组合多个行为，提升可维护性。
四、实现一个认证中间件
常见需求是验证每个请求的Token。以下是一个简单的Auth中间件示例：
func AuthInterceptor(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, handler grpc.UnaryHandler) (interface{}, error) {// 排除健康检查等公开接口
if info.FullMethod == "/UserService/Login" {
return handler(ctx, req)
}
md, ok := metadata.FromIncomingContext(ctx)
if !ok {
return nil, status.Errorf(codes.Unauthenticated, "missing metadata")
}
tokens := md["token"]
if len(tokens) == 0 {
return nil, status.Errorf(codes.Unauthenticated, "missing token")
}
if !validateToken(tokens[0]) {
return nil, status.Errorf(codes.Unauthenticated, "invalid token")
}
return handler(ctx, req)
}
其中validateToken可根据业务使用JWT、Redis会话等方式校验。
五、流式中间件（Stream Interceptor）
流式RPC的拦截器更复杂，因为涉及流的封装。定义如下：
type StreamServerInterceptor func(srv interface{}, ss grpc.ServerStream, info *grpc.StreamServerInfo, handler grpc.StreamHandler) error例如，实现一个流式日志拦截器：
func LoggingStreamInterceptor(srv interface{}, stream grpc.ServerStream, info *grpc.StreamServerInfo, handler grpc.StreamHandler) error {log.Printf("Stream started: %s", info.FullMethod)
err := handler(srv, stream)
log.Printf("Stream finished: %s, error: %v", info.FullMethod, err)
return err
}
注册方式类似：
grpc.StreamInterceptor(LoggingStreamInterceptor)基本上就这些。gRPC中间件是构建健壮服务的关键组件，合理使用能显著提升代码复用性和系统可观测性。掌握拦截器原理和常用模式，对Go微服务开发非常有帮助。
