Node.js应用Redis客户端初始化异常：ClientClosedError问题求助

问题根源 #

你使用的 Redis 客户端是 v4+ 版本，该版本不再自动建立连接，当前的 redisClient.js 仅创建了客户端实例但未调用 connect() 方法，导致客户端处于关闭状态，执行命令时抛出 ClientClosedError。

需要修改的代码部分 #

1. 更新 redisClient.js，确保客户端正确连接并支持重连

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

let redisClient;
let isConnecting = false;

const initializeRedisClient = async () => {
    // 如果客户端已就绪，直接返回
    if (redisClient && redisClient.isReady) {
        return redisClient;
    }
    // 避免重复发起连接请求
    if (isConnecting) {
        while (isConnecting) {
            await new Promise(resolve => setTimeout(resolve, 100));
        }
        return redisClient;
    }

    isConnecting = true;
    try {
        redisClient = redis.createClient({
            // 若使用环境变量配置Redis连接，可添加此处：
            // url: process.env.REDIS_URL
        });

        // 监听客户端事件
        redisClient.on('error', (err) => console.log('Redis Client Error:', err));
        redisClient.on('connect', () => console.log('Connected to Redis'));
        redisClient.on('end', () => {
            console.log('Redis client disconnected');
            redisClient = null; // 重置客户端，下次调用时重新连接
        });
        redisClient.on('reconnecting', () => console.log('Redis client reconnecting'));

        // 显式建立连接
        await redisClient.connect();
        return redisClient;
    } catch (err) {
        console.error('Redis连接失败:', err);
        isConnecting = false;
        throw err;
    } finally {
        isConnecting = false;
    }
};

module.exports = initializeRedisClient;

2. 修改 checkBlacklist 中间件，确保使用已连接的客户端

在 adminRoutes.js 中，将中间件改为异步函数，并等待 Redis 客户端初始化完成：

// 示例checkBlacklist中间件修改
const checkBlacklist = async (req, res, next) => {
    try {
        const token = // 从请求中获取token的逻辑
        const redisClient = await initializeRedisClient();
        const isBlacklisted = await redisClient.get(`blacklist:${token}`);
        
        if (isBlacklisted) {
            return res.status(401).json({ message: 'Token已被拉黑' });
        }
        next();
    } catch (err) {
        console.error('黑名单检查失败:', err);
        res.status(500).json({ message: '服务器内部错误' });
    }
};

额外注意事项 #

• 确保本地或远程 Redis 服务正在运行
• 若 Redis 需要认证或特定配置，需在 createClient 中添加对应参数（如 password、socket 配置等）
• 所有使用 Redis 客户端的地方都需使用 await initializeRedisClient() 获取已连接的实例

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