Node.js中频繁出现Redis socket closed unexpectedly警告的解决求助

问题根源 #

现有代码的几个不合理配置导致了连接不稳定：

• 重连策略太简单：固定10毫秒重试，既没做指数退避缓解服务器压力，也没限制最大重试次数，容易引发无效重试或连接震荡。
• 手动连接管理冗余：中间件每次请求都检查连接状态并手动调用connect()，但Redis客户端本身自带自动重连机制，手动干预反而容易造成连接冲突。
• Socket参数缺失：没有配置心跳、超时等关键参数，长连接容易被服务器或网络设备主动断开。

修复方案 #

1. 优化Redis客户端配置 #

修改redis-config.js，完善重连策略和Socket参数：

const config = require('./config');
const redis = require('redis');

// 自定义指数退避重连策略：重试间隔递增，最多30秒，最多重试10次
const reconnectStrategy = (retries) => {
  const delay = Math.min(retries * 500, 30000);
  if (retries > 10) {
    throw new Error('Redis max reconnection attempts reached');
  }
  return delay;
};

const cache = redis.createClient({
  url: `redis://${config.redisip}:${config.redisport}`, // 用标准URL格式更规范
  password: config.redisauth,
  socket: {
    reconnectStrategy,
    keepAlive: 30000, // 每30秒发心跳维持连接
    connectTimeout: 10000, // 连接超时10秒
    timeout: 60000, // Socket超时60秒
  }
});

cache.on('error', function (error) {
  console.error('\nRedis Error:', error); // 用error级别日志方便排查
});
cache.on('reconnecting', (delay) => {
  console.log(`Redis reconnecting, next attempt in ${delay}ms`);
});
cache.on('connect', () => {
   console.log('Redis connected');
});
cache.on('ready', () => {
   console.log('Redis ready');
});
cache.on('end', () => {
   console.log('Redis connection closed');
});

// 初始化时主动发起连接，后续交给客户端自动管理
cache.connect().catch(err => console.error('Initial Redis connection failed:', err));

module.exports = cache;

2. 简化中间件逻辑 #

修改redis-middleware.js，移除手动连接检查，依赖客户端自动重连：

const redisclient = require('./redis-config'); // 注意修正路径，原代码是redisClient，对应redis-config.js
const cache = {
  redisMiddleware: (req, res, next) => {
    // Redis客户端会自动处理重连，无需在请求层手动干预
    next();
  }
};

module.exports = cache;

3. 额外排查点 #

• 检查Redis服务器配置：确保tcp-keepalive参数已开启，避免服务器主动关闭闲置连接。
• 排查网络环境：确认Node服务和Redis服务器之间的网络稳定，没有防火墙或负载均衡器主动断开长连接。
• 升级客户端包：确保使用的redis包是最新稳定版，旧版本可能存在已知连接bug。

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