Node.js Redis客户端异步Set循环后连接提前关闭问题求助

嘿，作为Node.js新手碰到这个异步问题太正常啦！我来帮你把这个问题理清楚，以及给出具体的解决办法～

问题根源先搞懂 #

你已经猜到原因啦：forEach是同步执行的循环，它不会等待每一次Redis set的异步Promise完成。所以循环刚跑完（只是发起了所有set请求，但这些请求还在后台执行），代码就直接跳到关闭连接的步骤了，导致Redis操作还没做完，连接就先断了。

具体解决办法 #

核心思路就是：收集所有Redis set操作的Promise，等所有Promise都执行完成后，再关闭Redis连接。下面分两种客户端版本给你示例：

情况1：使用旧版Node Redis客户端（v3及以下） #

旧版客户端的方法默认是回调式的，需要先把set转成Promise版本：

const redis = require('redis');
const { promisify } = require('util');

// 创建客户端并把set方法转成Promise
const client = redis.createClient();
const setAsync = promisify(client.set).bind(client);

// 假设你的待存储数据数组是这样的
const dataList = [
  ['user:1', '{"name":"Shashank"}'],
  ['user:2', '{"name":"Alice"}'],
  ['user:3', '{"name":"Bob"}']
];

async function saveDataAndClose() {
  try {
    // 用map代替forEach，收集所有set操作的Promise
    const savePromises = dataList.map(([key, value]) => {
      return setAsync(key, value);
    });

    // 等待所有set操作全部完成
    await Promise.all(savePromises);
    console.log('所有数据都存到Redis啦！');

    // 现在安全关闭连接
    client.quit();
  } catch (err) {
    console.error('存储数据时出错了:', err);
    // 就算出错也要记得关闭连接
    client.quit();
  }
}

// 执行函数
saveDataAndClose();

情况2：使用新版Node Redis客户端（v4+） #

新版客户端本身就支持Promise，不用额外转译，更简洁：

const { createClient } = require('redis');

async function saveDataAndClose() {
  const client = createClient();
  
  try {
    // 新版需要先建立连接
    await client.connect();

    const dataList = [
      ['user:1', '{"name":"Shashank"}'],
      ['user:2', '{"name":"Alice"}']
    ];

    // 收集所有set操作的Promise
    const savePromises = dataList.map(([key, value]) => {
      return client.set(key, value);
    });

    // 等待所有操作完成
    await Promise.all(savePromises);
    console.log('所有存储操作完成！');

    // 关闭连接
    await client.quit();
  } catch (err) {
    console.error('出错了:', err);
    await client.quit();
  }
}

saveDataAndClose();

为啥forEach不行？ #

再给你补个反面例子，帮你加深理解：

// ❌ 错误写法：forEach不会等待内部的异步操作
dataList.forEach(async ([key, value]) => {
  await setAsync(key, value);
});
// 这行代码会立刻执行，完全不等上面的await完成
client.quit();

这里的async回调是每个迭代里的异步函数，但forEach本身是同步的，它不会等待这些异步函数执行完毕，所以client.quit()会抢先执行，导致连接提前关闭。

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