Redis订阅无响应求助：新手实现连接时发布订阅逻辑遇阻

刚接触Redis发布订阅踩坑很正常，我帮你梳理下代码里的问题和排查方向：

1. 先修复明显的语法与数据格式错误 #

你的publish调用里有两个关键问题：

• 字符串拼接未闭合："user has been connected from port '" + port} 这里port后面缺了单引号和右括号，直接会导致语法错误，代码可能都没正常执行；
• Redis的publish仅支持发送字符串，你直接传对象的话，会被强制转成[object Object]，完全不是你想要的内容。

修复后的代码可以改成这样：

// 先把结构化消息转成JSON字符串
const message = JSON.stringify({ 
  message: `user has been connected from port '${port}'` 
});
// 用模板字符串修正拼接逻辑，更清晰易读
client.publish('connection', message, function () { 
  console.log("client connected") 
})

接收消息时再解析回对象：

sub.on("message", (channel, message) => {
  const parsedMsg = JSON.parse(message);
  console.log("message received:", parsedMsg);
  console.log("channel:", channel);
});

2. 确保订阅成功后再发布消息 #

Redis的subscribe是异步操作，你现在刚调用sub.subscribe('connection')就立刻发消息，这时候订阅可能还没完成，消息直接就丢失了。必须等订阅确认事件触发后再执行发布：

sub.subscribe('connection');
// 监听订阅成功事件，确认订阅完成后再发消息
sub.on('subscribe', (channel, count) => {
  const message = JSON.stringify({ 
    message: `user has been connected from port '${port}'` 
  });
  client.publish('connection', message, () => console.log("client connected"));
});

3. 检查Redis客户端的连接状态 #

如果用的是Redis v4及以上版本，createClient之后必须显式调用connect()，否则客户端根本没连上Redis服务器：

// 主客户端初始化
const client = redis.createClient({ port: 6379, host: '127.0.0.1' });
client.connect().catch(err => console.error('主客户端连接失败:', err));

// 订阅客户端初始化
const sub = redis.createClient();
sub.connect().catch(err => console.error('订阅客户端连接失败:', err));

另外，一定要加上错误监听，能帮你快速定位连接或操作中的问题：

client.on('error', err => console.error('Redis主客户端错误:', err));
sub.on('error', err => console.error('Redis订阅客户端错误:', err));

4. 避免重复创建订阅客户端 #

你现在在io.on('connection')回调里每次都新建一个sub客户端，这会导致大量重复订阅，不仅浪费资源，还可能出现奇怪的异常。建议把订阅客户端的初始化移到回调外面，只创建一次：

// 全局初始化Redis客户端
const client = redis.createClient({ port: 6379, host: '127.0.0.1' });
client.connect();

const sub = redis.createClient();
sub.connect();
sub.subscribe('connection');

// 全局监听消息，无需每次连接都重新绑定
sub.on("message", (channel, message) => {
  const parsedMsg = JSON.parse(message);
  console.log("message received:", parsedMsg);
  console.log("channel:", channel);
});

io.on('connection', (socket) => {
  // 这里只处理发布逻辑即可
  const message = JSON.stringify({ 
    message: `user has been connected from port '${port}'` 
  });
  client.publish('connection', message, () => console.log("client connected"));
});

通用排查小技巧 #

• 先确认Redis服务正常：打开终端输入redis-cli ping，返回PONG说明服务没问题；
• 用redis-cli手动测试：开两个终端窗口，一个执行SUBSCRIBE connection，另一个执行PUBLISH connection "test message"，如果订阅端能收到消息，说明Redis本身没问题，问题出在你的代码；
• 仔细查看Node.js控制台的报错信息，很多时候语法错误或连接错误都会直接打印出来，只是可能没注意到。

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