NodeJS 中使用 ioredis 时如何记录慢 Redis 操作且不影响业务性能

方案1：使用ioredis原生事件监听（零业务侵入） #

ioredis内置了命令生命周期事件，无需修改任何业务调用代码，仅在Redis实例初始化阶段添加监听逻辑即可，统计逻辑完全异步，不会阻塞业务流程。

• 实现原理：监听command事件记录命令开始时间，commandEnd事件计算耗时，超过阈值则异步记录日志，同时监听commandError事件清理计时记录避免内存泄漏。
• 代码示例：

const Redis = require('ioredis');
const redis = new Redis({
  // 你的Redis连接配置
  host: '127.0.0.1',
  port: 6379
});
// 慢查询阈值，单位ms，可根据需求调整
const SLOW_QUERY_THRESHOLD = 200;
// 存储命令ID对应开始时间
const commandStartMap = new Map();

// 命令开始执行时触发
redis.on('command', (cmd, args, queryId) => {
  commandStartMap.set(queryId, Date.now());
});

// 命令执行完成时触发
redis.on('commandEnd', (cmd, args, res, queryId) => {
  const startTime = commandStartMap.get(queryId);
  if (!startTime) return;
  const cost = Date.now() - startTime;
  if (cost > SLOW_QUERY_THRESHOLD) {
    // 此处使用异步日志库（如pino、winston）记录，禁止使用同步IO操作
    console.log(`[Redis慢查询] 命令：${cmd}，参数：${JSON.stringify(args)}，耗时：${cost}ms`);
  }
  commandStartMap.delete(queryId);
});

// 命令执行出错时触发，避免内存泄漏
redis.on('commandError', (err, cmd, args, queryId) => {
  commandStartMap.delete(queryId);
});

• 优势：完全不侵入业务代码，适配所有现有调用场景，维护成本极低。

方案2：AOP代理封装Redis实例（灵活可控） #

通过ES6 Proxy代理原始ioredis实例，对所有Redis操作方法做切面增强，计时统计逻辑放在Promise的finally回调中，不影响业务结果返回。

• 实现原理：代理Redis实例的属性读取，对操作方法做包装，调用前记录开始时间，调用完成后计算耗时，超过阈值则异步上报日志。
• 代码示例：

const Redis = require('ioredis');
const SLOW_QUERY_THRESHOLD = 200;
const rawRedis = new Redis({
  // 你的Redis连接配置
  host: '127.0.0.1',
  port: 6379
});

// 代理后的Redis实例，业务侧统一使用该实例调用
const redis = new Proxy(rawRedis, {
  get(target, prop) {
    const originVal = target[prop];
    // 非方法属性直接返回
    if (typeof originVal !== 'function') return originVal;
    // 跳过事件、连接管理等非操作方法
    if (['on', 'emit', 'connect', 'disconnect', 'quit'].includes(prop)) {
      return originVal.bind(target);
    }
    // 包装操作方法
    return async (...args) => {
      const startTime = Date.now();
      try {
        return await originVal.apply(target, args);
      } finally {
        const cost = Date.now() - startTime;
        if (cost > SLOW_QUERY_THRESHOLD) {
          // 推到下一个事件循环阶段执行，不占用当前请求处理时间
          setImmediate(() => {
            console.log(`[Redis慢查询] 命令：${prop}，参数：${JSON.stringify(args)}，耗时：${cost}ms`);
          });
        }
      }
    };
  }
});

• 优势：无需维护命令ID映射表，无内存泄漏风险，可自定义过滤不需要统计的方法，灵活性更高。

通用优化建议 #

• 所有日志、上报操作必须使用异步IO，禁止使用同步写文件、同步接口调用等阻塞事件循环的操作，推荐使用pino等低开销异步日志库。
• 若服务Redis QPS超过10万，可添加采样逻辑，例如仅统计10%的请求，进一步降低统计开销。
• 慢查询阈值支持动态配置，无需硬编码，可通过配置中心实时调整。
• 慢日志量较大时，可先写入本地内存队列，单独开异步线程批量上报，完全不占用主业务处理资源。

内容的提问来源于stack exchange，提问作者Pavneet Kaur