Node.js集成Redis开发聊天应用出现The client is closed错误求排查

你使用的是V4及以上版本的Node.js Redis客户端，该版本和旧版V3的核心差异是：redis.createClient()执行后不会自动建立Redis连接，必须手动调用连接方法才会初始化连接。你代码中没有执行连接操作，所以触发sendMessage事件调用client.set()时，客户端处于未连接的关闭状态，就抛出了The client is closed错误。
另外你代码中console.log(client.get('messages'))写法也存在问题，client.get是异步方法，直接打印只会输出Promise对象，无法拿到实际存储的消息值。

1. 调整Redis初始化逻辑，新增连接调用和错误监听
   修改你的Redis设置部分代码如下：

//redis setup
const redis = require('redis');
const client = redis.createClient()//默认本地配置

// 监听Redis连接异常，方便排查问题
client.on('error', err => console.log('Redis连接错误：', err));
// 手动触发Redis连接
client.connect();

2. 修正sendMessage事件中的异步调用逻辑
   给client.get添加await关键字，才能正确读取存储的消息内容：

//user generated messages
socket.on("sendMessage",  async(message, callback)=>{
  const user = getUser(socket.id);

  //存储消息到redis
  await client.set("messages",message);

  io.to(user.room).emit("message", { user: user.name, text: message });
  // 异步读取需要加await
  const savedMessage = await client.get('messages');
  console.log(savedMessage);
  callback();
});

额外优化建议 #

你当前直接用set写入messages键，每次新消息会覆盖上一条存储的内容。如果需要缓存全量聊天历史，可以按房间用Redis列表结构存储，示例写法：

// 按房间追加消息到列表
await client.lPush(`room:${user.room}:messages`, JSON.stringify({
  user: user.name,
  text: message,
  time: Date.now()
}))
// 读取最近100条历史消息
const history = await client.lRange(`room:${user.room}:messages`, 0, 99)

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