使用map+async/await批量发消息未按预期延迟执行的问题

问题根源 #

Array.map() 方法会立刻遍历整个数组，哪怕你在迭代函数里用了 async/await，map 也不会等待每个异步函数执行完成，而是一次性把所有异步任务都启动。所以所有 console.log(user, i) 会瞬间全部输出，后续的 await sendmessage(user) 虽然会在各自的任务里等待，但整体是并行执行的，完全不符合你要的“串行等待3秒发下一条”的逻辑。

解决方案：实现串行异步执行 #

要实现“等前一条发送完成（并等待3秒）再发下一条”的逻辑，你需要用串行执行的方式，替代map的并行触发。

方案1：for...of 循环（最易理解）

用 for...of 结合 async/await 可以轻松实现串行执行：

let users = [
  "user1","user2","user3","user4","user5","user6","user7"
];

async function sendMessagesInOrder() {
  for (const [index, user] of users.entries()) {
    console.log(user, index);
    // 等待当前用户的消息发送完成
    let res = await sendmessage(user);
    if (res) {
      console.log("Message Sent to: " + user);
    }
    // 等待3秒再发送下一条
    await new Promise(resolve => setTimeout(resolve, 3000));
  }
}

// 调用执行
sendMessagesInOrder();

方案2：reduce 链式调用 Promise

如果想用数组方法实现，可以用 reduce 把异步任务串成链式的 Promise：

let users = [
  "user1","user2","user3","user4","user5","user6","user7"
];

users.reduce(async (prevTask, user, index) => {
  // 等待前一个任务完成
  await prevTask;
  console.log(user, index);
  let res = await sendmessage(user);
  if (res) {
    console.log("Message Sent to: " + user);
  }
  // 等待3秒再执行下一个
  await new Promise(resolve => setTimeout(resolve, 3000));
}, Promise.resolve());

补充说明 #

• 如果你的 sendmessage 函数内部已经包含了3秒的等待逻辑，可以去掉代码里额外的 await setTimeout 部分。
• 原代码的问题核心是 map 会并行触发所有异步任务，而你需要的是串行执行的异步流程。

内容的提问来源于stack exchange，提问作者Bilal Haider