Node AWS SDK中等待SQS消息的正确方式是什么？

问题根源 #

默认情况下，receiveMessage 采用短轮询模式：不管队列里有没有消息，请求都会立刻返回，无消息时就会返回不含 Messages 键的对象。

正确方案：使用SQS长轮询 #

SQS原生支持长轮询，这是官方推荐的等待消息的方式，无需自己实现定时轮询逻辑。它的核心是让请求在队列无消息时保持连接，直到有消息到达或超时。

1. 单次请求启用长轮询 #

调用 receiveMessage 时，通过 WaitTimeSeconds 参数设置最长等待时间（最大20秒）：

const response = await this.sqs.receiveMessage({
  QueueUrl: url,
  WaitTimeSeconds: 20, // 最多等待20秒，期间有消息会立即返回
  MaxNumberOfMessages: 1 // 可选，指定单次最多接收的消息数量
}).promise();

if (response.Messages) {
  // 处理收到的消息
}

• 若等待期间队列有消息，请求会立刻返回结果；
• 若超时仍无消息，才会返回不含 Messages 的空响应。

2. 队列级别默认启用长轮询 #

如果希望所有针对该队列的接收请求都默认使用长轮询，可以在创建队列时配置持久化属性，或修改现有队列：

// 创建队列时配置
await this.sqs.createQueue({
  QueueName: "your-queue-name",
  Attributes: {
    "ReceiveMessageWaitTimeSeconds": "20" // 全局默认长轮询超时20秒
  }
}).promise();

// 修改现有队列配置
await this.sqs.setQueueAttributes({
  QueueUrl: url,
  Attributes: {
    "ReceiveMessageWaitTimeSeconds": "20"
  }
}).promise();

配置后，后续调用 receiveMessage 无需再指定 WaitTimeSeconds，自动使用长轮询。

3. 持续监听队列的实现 #

如果需要持续监听队列处理消息，可以结合循环和长轮询：

async function startQueueListener(url) {
  while (true) {
    const response = await this.sqs.receiveMessage({
      QueueUrl: url,
      WaitTimeSeconds: 20,
      MaxNumberOfMessages: 10 // 单次最多接收10条消息
    }).promise();

    if (response.Messages) {
      // 批量处理消息
      for (const message of response.Messages) {
        // 执行你的消息处理逻辑
        console.log("处理消息:", message.Body);

        // 处理完成后删除消息（避免重复消费）
        await this.sqs.deleteMessage({
          QueueUrl: url,
          ReceiptHandle: message.ReceiptHandle
        }).promise();
      }
    }
    // 无消息时，循环会自动发起下一次长轮询，无需额外延时
  }
}

// 启动监听
startQueueListener(yourQueueUrl);

这种方式比手动定时轮询更高效，能减少空请求的次数，降低API调用成本。

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