在 redis 应用中，推荐为发布/订阅（pub/sub）和键值读写（如 get/set）分别创建独立的客户端连接，而非复用同一连接或为每种功能单独创建三个客户端。
在 redis 应用中，推荐为发布/订阅（pub/sub）和键值读写（如 get/set）分别创建独立的客户端连接，而非复用同一连接或为每种功能单独创建三个客户端。
Redis 的 Pub/Sub 机制与常规的数据库命令（如 GET、SET、HGETALL 等）在底层协议和连接行为上有本质区别：
- Pub/Sub 连接是单向、事件驱动的：一旦调用 SUBSCRIBE，该连接即进入“订阅模式”，此后只能接收消息，不能再执行任何非 Pub/Sub 命令（否则会报错 ERR only (P)SUBSCRIBE / (P)UNSUBSCRIBE / PING / QUIT allowed）。
- 普通命令连接需保持响应式交互：用于业务数据存取的连接需支持同步/异步请求-响应模型，必须能自由发送任意 Redis 命令。
因此，将 subscriber、publisher 和 dataStoreHandler 拆分为三个独立客户端（如问题中所示）虽可运行，但存在冗余和资源浪费；而试图让同一个客户端同时处理 Pub/Sub 和数据库操作则会导致运行时错误。
✅ 正确做法是：使用两个专用客户端
Redis Skill - 高性能缓存管理
下载
Redis 缓存和数据结构管理技能。通过自然语言操作 Redis，支持 String、Hash、List、Set、ZSet、Stream 等数据结构操作。当用户提到 Redis、缓存、消息队列、会话存储时使用此技能。
- 一个专用于 Pub/Sub（可同时 SUBSCRIBE 和 PUBLISH，因 PUBLISH 不影响订阅状态）；
- 另一个专用于数据库读写操作（GET/SET/DEL/事务等）。
示例（Node.js + redis@4.x）：
import { createClient } from 'redis';
// 1. 专用 Pub/Sub 客户端（支持 SUBSCRIBE & PUBLISH）
const pubSubClient = createClient({ url: process.env.REDIS_URL });
await pubSubClient.connect();
pubSubClient.subscribe('app-updates', (message) => {
console.log('Received update:', message);
});
// 2. 专用数据操作客户端（支持所有命令）
const dataClient = createClient({ url: process.env.REDIS_URL });
await dataClient.connect();
await dataClient.set('last_update_ts', Date.now().toString());
const ts = await dataClient.get('last_update_ts');⚠️ 注意事项：
- 不要对 pubSubClient 调用 GET 或 SET —— 这将导致连接异常或命令被忽略；
- PUBLISH 可由 pubSubClient 安全执行（它不改变订阅状态），无需额外 publisher 实例；
- 若需多频道订阅，仍只需一个 pubSubClient，多个 subscribe() 调用即可；
- 生产环境建议为两个客户端分别配置连接池参数（如 socket.maxRetriesPerRequest）、重连策略及错误监听，避免相互影响。
总结：精简连接数、职责分离、符合协议约束——双客户端模型（Pub/Sub + Data）是兼顾可靠性、性能与可维护性的标准实践。
