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 实现请求/响应钩子，更常见做法是在业务方法内部统一调用前置/后置函数。
Audio Upload Aioz Stream Free
下载
基于 AIOZ Stream API 的免费音频上传技能，通过三步流程（Create → Upload Part → Complete）将本地音频文件上传至 AIOZ 流媒体平台。支持默认快速上传方式，使用默认编码配置，上传完成后返回 HLS 流媒体播放链接。使用 API Key (stream-publ...)进行认证。
立即学习“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
