Windows环境下Redis客户端创建报错ClientClosedError的解决方法

错误原因 #

你遇到的ClientClosedError: The client is closed错误，本质是Redis客户端还没完成连接初始化，就执行了publish/subscribe这类命令。从redis@v4版本开始，redis.createClient()默认采用异步连接模式，不会自动阻塞等待连接建立，直接调用命令就会触发客户端未打开的错误。

解决方案 #

方法1：使用async/await等待连接完成 #

利用异步函数等待客户端连接建立后，再执行订阅和发布操作：

const redis = require("redis");
const CHANNELS = { TEST: "TEST" };

class Pubsub {
    constructor() {
        this.publisher = redis.createClient();
        this.subscriber = redis.createClient();
        
        // 异步初始化连接与订阅
        (async () => {
            await this.publisher.connect();
            await this.subscriber.connect();
            
            // v4版本subscribe方法支持回调参数
            await this.subscriber.subscribe(CHANNELS.TEST, (message, channel) => {
                this.handleMessage(channel, message);
            });
        })();
    }
    
    handleMessage(channel, message) {
        console.log(`message recieved. channel: ${channel}. message: ${message}`);
    }
}

// 异步执行发布逻辑，确保客户端已连接
(async () => {
    const testPubsub = new Pubsub();
    // 短暂延迟确保订阅端完成订阅（更严谨的方式是监听订阅成功事件）
    setTimeout(() => {
        testPubsub.publisher.publish(CHANNELS.TEST, "this is a message that published");
    }, 100);
})();

方法2：监听ready事件触发命令 #

通过监听客户端的ready事件，在连接完成后再执行对应操作：

const redis = require("redis");
const CHANNELS = { TEST: "TEST" };

class Pubsub {
    constructor() {
        this.publisher = redis.createClient();
        this.subscriber = redis.createClient();
        
        // 订阅端连接就绪后执行订阅
        this.subscriber.on("ready", () => {
            this.subscriber.subscribe(CHANNELS.TEST);
        });
        
        this.subscriber.on("message", (channel, message) => {
            this.handleMessage(channel, message);
        });
        
        // 主动触发连接
        this.publisher.connect();
        this.subscriber.connect();
    }
    
    handleMessage(channel, message) {
        console.log(`message recieved. channel: ${channel}. message: ${message}`);
    }
}

const testPubsub = new Pubsub();

// 发布端就绪后发送消息
testPubsub.publisher.on("ready", () => {
    testPubsub.publisher.publish(CHANNELS.TEST, "this is a message that published");
});

额外注意事项 #

• 如果你之前用的是redis@v3及更早版本，自动连接的逻辑在v4中被移除，必须显式调用connect()，这是版本升级后最容易踩的坑。
• 订阅场景下，建议确保订阅端先完成订阅再发送消息，避免丢失初始消息（可以通过监听subscribe事件替代setTimeout，更可靠）。
• 生产环境中，建议添加客户端的error事件监听，便于排查连接失败等问题：

  this.publisher.on("error", (err) => console.error("Publisher error:", err));
  this.subscriber.on("error", (err) => console.error("Subscriber error:", err));
  

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