Node.js项目实现数组元素分步输出至Facebook Messenger（带延迟）

我来帮你搞定这个需求！根据你描述的逻辑，咱们可以用异步函数结合setTimeout来实现这个逐个发送带延迟的功能，还能根据每条消息的单词数动态调整等待时间，让用户有足够时间读完每条内容。

核心实现思路 #

1. 第一个消息直接发送，无需延迟
2. 后续每条消息发送前，根据上一条消息的单词数计算延迟时间
3. 用async/await保证消息发送的顺序性，避免乱序

完整代码示例 #

// 计算延迟时间：按单词数分配阅读时间，这里设每个单词1.5秒（可自定义）
const calculateDelay = (text) => {
  // 处理空文本或纯空格的情况
  if (!text.trim()) return 2000; // 默认给2秒延迟
  const wordCount = text.trim().split(/\s+/).length;
  return wordCount * 1500;
};

// 核心函数：逐个发送消息到Facebook Messenger
async function sendMessagesWithDelay(messagesArray, recipientId) {
  for (let index = 0; index < messagesArray.length; index++) {
    const currentMessage = messagesArray[index];
    
    // 发送当前消息（这里替换成你的Messenger实际发送逻辑）
    await sendMessengerMessage(recipientId, currentMessage);
    
    // 不是最后一条消息的话，等待计算好的延迟
    if (index !== messagesArray.length - 1) {
      const delayTime = calculateDelay(currentMessage);
      // 用Promise包装setTimeout，让async/await能正确等待
      await new Promise(resolve => setTimeout(resolve, delayTime));
    }
  }
}

// 示例：Facebook Messenger消息发送函数（需要替换成你的实际API调用）
async function sendMessengerMessage(recipientId, text) {
  // 这里调用Facebook Messenger的发送API，比如用axios/fetch
  // 示例代码（仅作参考，需替换成你的token和实际逻辑）：
  /*
  const messengerApiUrl = `https://graph.facebook.com/v18.0/me/messages`;
  const accessToken = process.env.MESSENGER_BOT_TOKEN;
  
  await fetch(messengerApiUrl, {
    method: 'POST',
    headers: {
      'Content-Type': 'application/json',
      'Authorization': `Bearer ${accessToken}`
    },
    body: JSON.stringify({
      recipient: { id: recipientId },
      message: { text: text }
    })
  });
  */
  // 测试用的控制台输出，实际开发时删掉
  console.log(`已发送消息给用户${recipientId}: ${text}`);
}

使用示例 #

// 待发送的消息数组
const conversationMessages = [
  "嗨！欢迎使用我们的Messenger机器人😉",
  "接下来我会慢慢给你发送每条内容，你有足够时间阅读",
  "这是第三条消息，你看延迟是不是刚好？",
  "所有消息发送完毕啦！"
];

// 用户的Messenger ID
const targetUserId = "USER_MESSENGER_UNIQUE_ID";

// 调用发送函数
sendMessagesWithDelay(conversationMessages, targetUserId)
  .then(() => console.log("全部消息发送完成"))
  .catch(error => console.error("发送过程出错:", error));

注意事项 #

• 延迟时间调整：你可以修改calculateDelay里的1500（毫秒）来调整每单词的阅读时间，比如改成1000即1秒/单词
• API限流：Facebook Messenger有调用频率限制，不要设置过短的延迟，避免触发限流
• 错误处理：可以在sendMessengerMessage里添加错误捕获，或者在sendMessagesWithDelay的循环里加try/catch，处理发送失败的情况
• 异步保证：确保你的sendMessengerMessage函数返回Promise，这样await才能正确等待发送完成

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