Go标准库net/rpc不支持拦截器，需手动封装或改用gRPC；gRPC原生支持UnaryInterceptor和StreamInterceptor，可统一处理日志、鉴权等；标准net/rpc可通过服务结构体封装before/after方法或HTTP中间件模拟拦截逻辑。

Go 语言标准库的 net/rpc 本身不支持拦截器（Interceptor）机制，但可以通过封装、中间件模式或结合 gRPC 实现类似功能。若你使用的是标准 net/rpc，需手动在服务端注册前/后插入逻辑；若使用 gRPC（更主流且原生支持拦截器），则可直接利用其 UnaryInterceptor 和 StreamInterceptor。

使用 gRPC 实现统一请求/响应拦截（推荐）

gRPC 是 Go 中 RPC 的事实标准，原生支持拦截器，适合统一处理日志、鉴权、指标、超时、错误包装等。

• 定义 Unary 拦截器：用于处理一元 RPC（如 GetUser）

示例：记录请求耗时与方法名

func loggingInterceptor(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, handler grpc.UnaryHandler) (interface{}, error) {
    start := time.Now()
    log.Printf("→ %s started", info.FullMethod)
    
    resp, err := handler(ctx, req)
    
    log.Printf("← %s finished in %v, error: %v", info.FullMethod, time.Since(start), err)
    return resp, err
}

• 注册拦截器启动服务

server := grpc.NewServer(
    grpc.UnaryInterceptor(loggingInterceptor),
    grpc.StreamInterceptor(streamLoggingInterceptor), // 流式拦截器可选
)
pb.RegisterUserServiceServer(server, &userServer{})

在标准 net/rpc 中模拟拦截逻辑

虽无拦截器 API，但可通过包装 rpc.Server 的 ServeCodec 或自定义 Codec 实现请求/响应钩子，更常见做法是在业务方法内部统一调用前置/后置函数。

立即学习“go语言免费学习笔记（深入）”；

• 在每个 RPC 方法开头调用 beforeRequest()，结尾调用 afterResponse()
• 提取共用逻辑为私有方法（如鉴权检查、上下文注入、结果包装）
• 用结构体字段保存通用依赖（如 logger、tracer），避免重复传参

示例：服务结构体封装

type UserService struct {
    logger *log.Logger
    tracer trace.Tracer
}

func (s *UserService) GetUser(r *GetUserRequest, res *GetUserResponse) error {
    ctx := context.Background()
    ctx = s.before(ctx, "GetUser", r)
    defer s.after(ctx, "GetUser", res)

    // 实际业务逻辑
    *res = GetUserResponse{User: &User{ID: r.ID, Name: "Alice"}}
    return nil
}

func (s *UserService) before(ctx context.Context, method string, req interface{}) context.Context {
    s.logger.Printf("→ %s with %+v", method, req)
    return context.WithValue(ctx, "start_time", time.Now())
}

func (s *UserService) after(ctx context.Context, method string, resp interface{}) {
    dur := time.Since(ctx.Value("start_time").(time.Time))
    s.logger.Printf("← %s done in %v", method, dur)
}

通过中间件函数链增强 rpc.Handler（进阶）

若你控制了服务启动流程（如用 http.Serve 托管 RPC over HTTP），可将 rpc.Server 封装为 http.Handler，再套上 HTTP 中间件：

• 用 http.HandlerFunc 包裹 rpc.Server.ServeHTTP
• 在中间件中读取/修改请求头（如提取 token）、记录 body 摘要、设置响应头
• 注意：标准 RPC over HTTP 不带完整 REST 语义，body 是二进制编码（如 JSON-RPC），解析需谨慎

关键注意事项

• 错误处理一致性：拦截器中捕获 panic，将底层错误统一转为预定义错误码（如 status.Error(codes.PermissionDenied, ...)）
• 上下文传递：始终通过 context.Context 透传截止时间、值、取消信号，勿用全局变量
• 性能开销：日志、metric 等拦截逻辑避免阻塞或高开销操作，异步上报更安全
• 流式 RPC：gRPC 流式调用需用 StreamInterceptor，它包裹整个流生命周期，不能像一元那样简单 wrap handler