使用Node.js AWS SDK从SQS仅接收一条消息的问题排查

原因 #

默认创建的是标准SQS队列，它的消息分发机制是概率性的：为了保证分布式系统的高可用和低延迟，ReceiveMessage调用不会严格返回MaxNumberOfMessages指定的数量，哪怕队列中有足够的消息。AWS会根据队列负载、分布式节点状态等因素动态返回部分消息，这是标准队列的设计特性，并非代码问题。

如果是FIFO队列（非默认配置），若消息属于同一个消息组ID，ReceiveMessage每次只能返回该组的一条消息，以此保证消息顺序性——但你使用的是默认配置，所以大概率是标准队列的特性导致。

解决方法 #

要一次性取回目标数量的消息，需要循环调用ReceiveMessage，直到获取到足够消息或达到预设的重试次数/超时时间。以下是修改后的代码：

const sqsClient = new SQSClient({ region: REGION });

async function fetchTargetMessages(queueUrl, targetCount = 2) {
  const collectedMessages = [];
  const params = {
    AttributeNames: ["SentTimestamp"],
    MaxNumberOfMessages: Math.min(targetCount, 10), // SQS单次最多返回10条消息
    MessageAttributeNames: ["All"],
    QueueUrl: queueUrl,
    WaitTimeSeconds: 5, // 长轮询减少空响应次数
  };

  while (collectedMessages.length < targetCount) {
    const data = await sqsClient.send(new ReceiveMessageCommand(params));
    const messages = data.Messages ?? [];
    if (messages.length === 0) break; // 队列已无更多消息，终止循环
    collectedMessages.push(...messages);
  }

  return collectedMessages;
}

// 使用示例
const messages = await fetchTargetMessages(queueURL, 2);
console.log(messages.length);

补充说明 #

• 长轮询（WaitTimeSeconds>0）已经在你的代码中配置，它能有效减少空响应的概率，提升批量获取效率。
• SQS单次ReceiveMessage调用最多返回10条消息，所以设置MaxNumberOfMessages时无需超过这个值。
• 如果业务需要严格的批量消息获取且对吞吐量要求不高，可以改用SQS FIFO队列，但需注意消息组ID、顺序性等限制。

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