我的应用程序向需要某种后台处理的作业的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队列中删除消息，或者更好地将它们标记为已完成？
当您收到来自SQS队列的消息时，该消息将（默认情况下）在30秒后返回队列。这是为了处理消息处理崩溃并且需要再次处理消息的情况。
成功处理邮件后，请使用deleteMessage删除该邮件。当您从receiveMessage收到消息时，您需要消息中的receiptHandle值才能删除该消息。
如果消息的典型处理可能需要30秒以上，那么您可以配置队列以增加"返回队列"的时间。这在SQS队列配置中被称为"默认可见性超时"。
还要注意，亚马逊SQS的工作方式如下：
- 与消息被添加到队列的方式相比，消息可能被无序接收
- 消息可能会被接收两次，因此允许您的消息处理器处理这些情况
您确实需要在处理消息后删除消息，这将被视为"标记消息已完成"；但是，如果某个下游需要对此"已完成"操作执行操作，则我会向另一个SQS队列发布一条"完成"消息，然后从传入队列中删除该消息。通过这种方式，另一个过程，无论是现在还是将来，都可以在第一个工人完成工作时采取需要完成的行动，即以解耦的方式将这些过程链接在一起。
如果下游没有什么需要做的，那么简单地删除它就足够了。