Node.js中如何使用gRPC服务端拦截器捕获请求与响应

首先明确两个核心结论：

• @grpc/grpc-js 库的服务端、客户端都原生支持拦截器能力，并非仅gRPC-web提供，也不是仅客户端可用
• 拦截器完全可以实现你需要的「请求预处理、响应后编辑、全局日志记录」需求

服务端拦截器实现步骤 #

你只需要在初始化gRPC Server时传入拦截器配置即可，以下是基于你提供的代码修改后的可运行示例：

1. 定义服务端拦截器 #

我们先实现一个同时支持请求日志记录、请求/响应编辑的拦截器：

// 服务端日志&编辑拦截器
const serverInterceptor = function(options, nextCall) {
  const requester = {
    // 处理请求到达业务方法前的逻辑
    start: function(metadata, listener, next) {
      // 日志记录：打印请求方法、请求到达时间
      console.log(`[请求到达] 方法名：${options.method_definition.path}，到达时间：${new Date().toISOString()}`);
      // 可以在这里编辑metadata或者请求参数
      // 比如加全局请求标识到metadata
      metadata.set('x-request-id', Math.random().toString(36).substring(2));
      
      // 自定义响应监听器，处理业务方法返回响应后的逻辑
      const newListener = {
        onReceiveMessage: function(message, next) {
          // 这里可以编辑业务方法返回的响应内容
          // 示例：给所有新闻加全局追加字段
          if (options.method_definition.path === '/NewsService/getAllNews') {
            message.news.forEach(item => item.fromInterceptor = '全局追加字段');
          }
          next(message);
        },
        onReceiveStatus: function(status, next) {
          // 记录响应完成时间，计算接口耗时
          console.log(`[请求完成] 方法名：${options.method_definition.path}，耗时：${Date.now() - start}ms`);
          next(status);
        }
      };
      const start = Date.now();
      next(metadata, newListener);
    }
  };
  return new grpc.InterceptingCall(nextCall(options), requester);
};

2. 给服务端注入拦截器 #

修改原有server.js中初始化Server的代码，传入拦截器配置即可，其余业务代码不需要改动：

// 原有代码 const server = new grpc.Server(); 替换为以下内容
const server = new grpc.Server({
  interceptors: [serverInterceptor]
});

启动服务后，每次调用getAllNews接口都会自动触发拦截器逻辑，完成日志记录、请求/响应编辑的需求。

客户端拦截器实现（可选） #

如果客户端也需要全局拦截能力，初始化客户端时传入拦截器即可，示例如下：

const clientInterceptor = function(options, nextCall) {
  const requester = {
    start: function(metadata, listener, next) {
      console.log(`[客户端发起请求] 方法：${options.method_definition.path}`);
      next(metadata, listener);
    }
  };
  return new grpc.InterceptingCall(nextCall(options), requester);
};

// 初始化客户端时传入拦截器
const client = new NewsService(
  'localhost:50051',
  grpc.credentials.createInsecure(),
  { interceptors: [clientInterceptor] }
);

拦截器常见扩展场景 #

你可以基于拦截器实现更多通用能力：

• 全局接口鉴权校验，不合法的请求直接拦截返回，不需要走到业务方法
• 统一参数格式校验，不符合规范的请求提前返回错误
• 全局错误捕获和格式化，统一返回给调用方的错误结构
• 接口耗时统计、监控数据上报

内容的提问来源于stack exchange，提问作者Mostafa Fakhraei