处理后从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删除邮件.receiptHandle收到消息后,您需要消息中的值receiveMessage才能删除消息.

如果消息的典型处理可能需要30秒以上,那么您可以配置队列以增加"返回队列"时间.这在SQS队列配置中称为"默认可见性超时".

另请注意,Amazon SQS的工作方式如下:

1. 与将它们添加到队列的方式相比,可以无序地接收消息
2. 消息可能会被接收两次,因此请允许消息处理器处理这些情况