如何在Golang中实现RPC服务端拦截-Golang-PHP中文网

如何在Golang中实现RPC服务端拦截

P粉602998670

发布： 2025-10-25 23:24:02

原创

240人浏览过

Golang标准库net/rpc不支持拦截器，但可通过封装ServerCodec实现日志、权限等拦截逻辑；2. 使用自定义LoggingServerCodec可在请求前后插入处理；3. gRPC-Go原生支持拦截器，提供更完整的拦截能力，适合复杂场景。

如何在golang中实现rpc服务端拦截

在Golang中实现RPC服务端拦截，主要是通过net/rpc包结合中间件思想，在请求处理前后插入自定义逻辑。虽然标准库net/rpc本身不直接支持拦截器（Interceptor）机制，但可以通过封装或使用第三方库来实现类似功能。

理解RPC拦截的作用

服务端拦截可用于：

记录请求日志
验证身份或权限
统计调用耗时
统一错误处理

尽管net/rpc没有内置拦截机制，但可以借助反射和函数包装的方式实现。

基于net/rpc的手动拦截实现

通过包装rpc.ServeCodec或注册方法前处理逻辑，可以在请求进入具体方法前执行拦截操作。

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

示例：使用自定义ServerCodec进行拦截

一种方式是实现自己的ServerCodec，在解码请求或编码响应时插入逻辑：

type LoggingServerCodec struct {
    rpc.ServerCodec
}

func (l *LoggingServerCodec) ReadRequestHeader(req *rpc.Request) error {
    log.Printf("收到请求: %s", req.ServiceMethod)
    return l.ServerCodec.ReadRequestHeader(req)
}

func (l *LoggingServerCodec) WriteResponse(resp *rpc.Response, reply interface{}) error {
    log.Printf("返回响应: %s, 成功=%v", resp.ServiceMethod, resp.Error == "")
    return l.ServerCodec.WriteResponse(resp, reply)
}

登录后复制

然后在服务端使用：

豆绘AI

豆绘AI是国内领先的AI绘图与设计平台，支持照片、设计、绘画的一键生成。

485

查看详情

conn, _ := listener.Accept()
codec := &LoggingServerCodec{
    ServerCodec: jsonrpc.NewServerCodec(conn),
}
rpc.ServeCodec(codec)

登录后复制

这样就能在每次请求/响应时打印日志，实现基本的拦截。

使用Go RPC框架（如gRPC）的拦截器

如果你使用的是gRPC-Go，它原生支持拦截器（Interceptor），更加灵活。

服务端拦截示例（gRPC）：

func loggingInterceptor(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, handler grpc.UnaryHandler) (interface{}, error) {
    log.Printf("请求方法: %s", info.FullMethod)
    // 前置处理
    resp, err := handler(ctx, req)
    // 后置处理
    log.Printf("请求完成，错误: %v", err)
    return resp, err
}

// 注册拦截器
server := grpc.NewServer(grpc.UnaryInterceptor(loggingInterceptor))

登录后复制

这种方式更标准，适合大型项目。