在 node.js 中使用 redis 时，应为发布/订阅（pub/sub）和键值读写（如 get/set）分别创建独立的客户端实例，而非共用同一连接——因为 pub/sub 连接具有特殊行为（如无法执行普通命令），混用会导致错误或阻塞。
在 node.js 中使用 redis 时，应为发布/订阅（pub/sub）和键值读写（如 get/set）分别创建独立的客户端实例，而非共用同一连接——因为 pub/sub 连接具有特殊行为（如无法执行普通命令），混用会导致错误或阻塞。
Redis 的 Pub/Sub 机制与常规数据库操作在协议层和连接语义上存在本质差异：
- Pub/Sub 连接是单向事件驱动的：一旦调用 SUBSCRIBE，该连接即进入“订阅模式”，此后只能接收消息，不能再执行 GET、SET、DEL 等普通命令；否则会触发 ERR only (P)SUBSCRIBE / (P)UNSUBSCRIBE / PING / QUIT allowed in this context 错误。
- 普通数据操作需专用连接：GET、SET、HSET、EXPIRE 等命令必须在非订阅状态的连接上执行，这类连接支持完整 Redis 命令集，且可复用连接池提升性能。
✅ 正确做法：创建两个独立客户端实例
Redis Skill - 高性能缓存管理
下载
Redis 缓存和数据结构管理技能。通过自然语言操作 Redis，支持 String、Hash、List、Set、ZSet、Stream 等数据结构操作。当用户提到 Redis、缓存、消息队列、会话存储时使用此技能。
// 专用 Pub/Sub 客户端（仅用于 subscribe/publish）
const subscriber = redis.createClient({ url: process.env.REDIS_URL });
const publisher = redis.createClient({ url: process.env.REDIS_URL }); // publish 可复用 subscriber 实例，但推荐分离以明确职责
// 专用数据操作客户端（仅用于 CRUD 和业务逻辑）
const dataStore = redis.createClient({ url: process.env.REDIS_URL });
// 初始化连接
await Promise.all([
subscriber.connect(),
publisher.connect(),
dataStore.connect()
]);
// 订阅示例
subscriber.subscribe('app-updates', (message) => {
console.log('Received update:', message);
});
// 发布示例
await publisher.publish('app-updates', JSON.stringify({ event: 'user_updated', id: 123 }));
// 数据库操作示例
await dataStore.set('last_update_ts', Date.now().toString(), { EX: 3600 });
const ts = await dataStore.get('last_update_ts');⚠️ 注意事项：
- 不要尝试在 subscriber 实例上调用 dataStore.set() —— 即使尚未 subscribe，只要连接被用于订阅流程（尤其是 redis@4+），其内部状态可能已锁定；
- publisher 可复用 subscriber 实例（因 PUBLISH 是普通命令），但强烈建议分离：避免状态污染、便于监控、利于错误隔离；
- 所有客户端均需显式调用 .connect()（v4+），并在应用退出前调用 .quit() 释放资源；
- 生产环境应配置重连策略、超时、密码认证及 TLS（若 Redis 启用 SSL）。
? 总结：
一个 Redis 应用中，两个客户端是黄金标准——一个专责 Pub/Sub（含独立 subscriber + publisher 实例），另一个专责数据存取。这既符合 Redis 协议设计，也保障了稳定性、可观测性与可维护性。三实例（subscriber/publisher/dataHandler）虽可行，但 dataHandler 与 publisher 完全可合并为同一数据客户端，无需额外开销。
