求助：使用回调函数实现Facebook Messenger有序消息发送

我太懂你这个痛点了！Node.js的异步特性确实会让数组遍历的速度远远快于消息发送的网络请求，结果就是消息乱序——明明数组里是按1、2、3排的，发出去却变成2、1、3这种情况。咱们用回调完全能解决这个问题，核心思路就是让下一条消息的发送必须等当前这条完全发完再触发，我给你具体的实现方案：

首先咱们需要一个基础的单条消息发送函数，它接收消息内容和回调函数，在消息发送完成（成功或失败）时调用回调。然后写一个递归处理函数，每次只处理数组里的一条消息，完成后再递归处理下一条：

// 基础单条消息发送函数，替换成你实际调用Messenger API的逻辑
function sendSingleMessage(message, callback) {
  // 这里示例用axios调用API，你可以换成自己的请求库
  axios.post('https://graph.facebook.com/v18.0/me/messages', message)
    .then(() => {
      console.log('当前消息发送成功');
      callback(null); // 成功时回调传递null表示无错误
    })
    .catch(error => {
      console.error('当前消息发送失败:', error);
      callback(error); // 失败时回调传递错误信息
    });
}

// 串行处理消息数组的核心函数
function sendMessagesInOrder(messagesArray, currentIndex, finishCallback) {
  // 终止条件：所有消息都处理完了，调用完成回调
  if (currentIndex >= messagesArray.length) {
    return finishCallback(null);
  }

  // 发送当前索引的消息
  sendSingleMessage(messagesArray[currentIndex], (error) => {
    if (error) {
      // 如果当前消息发送失败，直接终止流程并传递错误
      return finishCallback(error);
    }
    // 递归调用，处理下一条消息
    sendMessagesInOrder(messagesArray, currentIndex + 1, finishCallback);
  });
}

// 调用示例：把你的消息数组传进去
const myMessages = [
  { text: '这是第一条消息' },
  { text: '这是第二条消息' },
  { text: '这是第三条消息' }
];

sendMessagesInOrder(myMessages, 0, (error) => {
  if (error) {
    console.error('整个消息发送流程出错:', error);
  } else {
    console.log('所有消息已按顺序发送完成！');
  }
});

逻辑说明 #

这个方案用递归+回调强制实现了串行执行：每次只有当前消息的发送请求完全结束（不管成功还是失败），才会触发下一条消息的发送逻辑，这样就严格保证了消息顺序和数组里的顺序完全一致。

如果你的Node.js版本支持ES7及以上，我更推荐用async/await来实现，它本质也是串行执行，但代码结构比纯回调更直观，避免了“回调地狱”：

// 改写单条消息发送为async函数
async function sendSingleMessage(message) {
  try {
    await axios.post('https://graph.facebook.com/v18.0/me/messages', message);
    console.log('当前消息发送成功');
  } catch (error) {
    console.error('当前消息发送失败:', error);
    throw error; // 抛出错误让上层处理
  }
}

// 串行发送函数
async function sendMessagesInOrder(messagesArray) {
  // 用for...of循环配合await，自动等待当前消息发送完成再处理下一条
  for (const msg of messagesArray) {
    await sendSingleMessage(msg);
    // 可选：加个短暂延迟，避免触发Messenger API的频率限制
    // await new Promise(resolve => setTimeout(resolve, 1000));
  }
}

// 调用示例
sendMessagesInOrder(myMessages)
  .then(() => console.log('所有消息按顺序发送完成！'))
  .catch(error => console.error('发送流程出错:', error));

注意事项 #

Facebook Messenger API有请求频率限制，如果你的消息数量比较多，记得在每条消息发送后加个短暂延迟（比如1秒），避免被限流导致发送失败。

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