处理后从 SQS 队列中删除消息

Question

我的应用程序为需要某种后台处理的作业向 AWS SQS 队列发送消息。我的处理守护进程接收并处理这样的消息：

$result = $sqsClient->receiveMessage([
    'QueueUrl' => \Myapp\Config::get('sqs.queue'),
    'WaitTimeSeconds' => 20,
    'MaxNumberOfMessages' => 1
]);

if (isset($result['Messages'])) {
    foreach ($result->getPath('Messages/*/Body') as $messageBody) {
        $handler = new \Myapp\Handler();
        $handler->dispatch($messageBody);
    }
}

这很好用，但是我可以从 SQS 控制台看到我的脚本检索到的消息被放入“正在运行的消息”类别中，然后过一段时间它们又被放回“可用消息”中，并且我的脚本最终又把它们捡起来了。

如何从 SQS 队列中删除消息，或者更好地将它们标记为已完成？

Answer 1

当您收到来自 SQS 队列的消息时，该消息将（默认情况下）在 30 秒后返回到队列。这是为了处理消息处理崩溃并且需要再次处理消息的情况。

成功处理您的消息后，使用deleteMessage 删除该消息。当您从 receiveMessage 收到邮件时，您需要邮件中的 receiptHandle 值才能删除邮件。

如果您的消息的典型处理时间可能超过 30 秒，那么您可以配置您的队列以增加“返回队列”时间。这在 SQS 队列配置中称为“默认可见性超时”。

另请注意，Amazon SQS 的工作方式是：

1. 与将消息添加到队列的方式相比，消息可能被无序接收
2. 可能会收到两次消息，因此请让您的消息处理器处理这些情况

Answer 2

您确实需要在处理完消息后删除它们 - 这将被视为“将它们标记为已完成”；但是，如果下游需要对此“完成”操作采取行动，我将“完成”消息发布到另一个 SQS 队列，然后从传入队列中删除该消息并不少见。这样，另一个进程，无论是现在还是未来，都可以在第一个工作人员完成其工作时采取需要执行的操作，即将这些进程以解耦的方式链接在一起。

如果下游没有什么需要做的，只需删除它就足够了。