本文详解如何在 node.js 中高效、安全地批量读取 redis 中多个以 user:gxxxx 格式命名的有序列表（list），并精准将每条数据绑定其对应的员工 id，避免异步并发导致的连接关闭错误。
在构建高并发调度类应用（如排班系统）时，常需根据员工身份快速拉取其全部排班记录。Redis 的 List 结构天然适合按时间顺序存储日程（如 lpush user:G1257 "{...}"），但若对每个员工发起独立 lRange 请求，不仅会因大量并发回调耗尽连接资源，更易触发 ClientClosedError —— 正如原始代码中 forEach + 回调 方式所遭遇的问题：Node.js 事件循环未等待 Redis 命令完成即提前释放连接，导致后续命令失败。
根本解法是避免并发回调，改用原子化批量执行。Redis 官方推荐方案是 MULTI/EXEC 事务或更轻量的 Pipeline；在 @redis/client（v4+）中，multi() 实例天然支持命令队列与 Promise 化执行，兼具性能与语义清晰性。
以下为生产就绪的实现步骤：
✅ 步骤一：使用 multi().exec() 批量提交所有 lRange 请求
const { createClient } = require('redis');
const client = createClient();
await client.connect(); // 确保连接已建立
// 示例路由逻辑（Express）
router.get('/scheduler', async (req, res) => {
try {
// 1. 查询目标员工列表（例如按职级筛选）
const personnelList = await Personnel.findAll({
where: { mgr_wrkpersonnels_designation: req.query.mgr_wrkpersonnels_designation }
});
// 2. 构建 MULTI 批量命令
const multi = client.multi();
personnelList.forEach(person => {
const empId = person.dataValues.mgr_wrkpersonnels_empid;
multi.lRange(`user:${empId}`, 0, -1); // 不带回调，仅入队
});
// 3. 一次性执行所有命令，返回扁平化结果数组
const results = await multi.exec(); // 类型：Array<[error, reply] | null>
// 4. 解析结果并注入 empId 上下文
const allSchedules = results.map((result, idx) => {
if (!result || result[0]) {
console.warn(`Failed to fetch list for ${personnelList[idx].dataValues.mgr_wrkpersonnels_empid}:`, result?.[0]);
return [];
}
const empId = personnelList[idx].dataValues.mgr_wrkpersonnels_empid;
return result[1] // lRange 返回的字符串数组
.map(str => JSON.parse(str))
.map(item => ({ ...item, resource: empId })); // 绑定员工标识
});
res.json(allSchedules);
} catch (err) {
console.error('Scheduler fetch error:', err);
res.status(500).json({ error: 'Failed to load schedules' });
}
});⚠️ 关键注意事项
- 勿在 forEach 中直接调用异步 Redis 方法：原始错误源于 client.lRange(..., callback) 在未确保连接存活时被多次调用，而 multi() 将所有命令序列化至服务端，彻底规避连接竞争。
- multi.exec() 返回二维数组：每个元素为 [error, reply] 元组，需显式判空与错误处理（如示例中的 if (!result || result[0])）。
- JSON 解析需防御性编程：Redis 存储的是字符串，JSON.parse() 可能抛异常，建议包裹 try/catch 或使用 safeParse 工具函数。
- 连接生命周期管理：确保 client.connect() 在应用启动时调用，并在进程退出前调用 client.quit()（可在 process.on('SIGTERM') 中处理）。
? 性能与扩展提示
- 单次 multi.exec() 可轻松处理数百个 lRange，实测响应稳定在 ~6ms（见原文日志），远优于串行请求（O(n) 网络往返）或无序并发（O(1) 但风险高）。
- 若未来需支持分页或条件过滤，可结合 LRANGE 起始索引与 LLEN 预估总量，或改用 Sorted Set（ZSET）按时间戳排序，启用 ZRANGEBYSCORE。
- 对于超大规模员工（>10k），建议增加 Redis 连接池（如 redis.createCluster()）或引入缓存降级策略（如本地 LRU Cache + TTL）。
通过 MULTI/EXEC 批量读取，你不仅解决了 ClientClosedError，更获得了一致、可预测、低延迟的数据加载能力——这是构建实时调度系统的底层基石。
