什么时候应该删除 SQS 中的消息?

sdg*_*sdh 5 amazon-sqs amazon-web-services

我的申请包括:

  • 1 Amazon SQS 消息队列
  • n个工人

工人有以下逻辑:

 1. Wait for message from SQS queue
 2. Perform task described in message
 3. Delete the message from the SQS queue
 4. Go to (1)
Run Code Online (Sandbox Code Playgroud)

我希望每条消息只能由一名工人接收,以避免冗余工作。

是否有使用 SQS 将消息标记为“进行中”的机制,以便其他轮询器不会收到它?

或者,收到邮件后立即删除是否合适?

 1. Wait for message from SQS queue
 2. Delete the message from the SQS queue
 3. Perform task described in message
 4. Go to (1)
Run Code Online (Sandbox Code Playgroud)

如果我遵循这种方法,是否有办法恢复收到但未处理的消息,以防工作人员崩溃(步骤(3)失败)?


这个问题是针对 Spring 的,它包含了各种魔法。

Rod*_*o M 9

SQS 消息在消费者从队列中接收到但尚未从队列中删除后,就被认为是“进行中”的。这些消息对其他消费者不可见。

在 SQS 消息传递中,如果出现以下情况,消息将被视为“飞行中”:

  1. 您消费者已收到它,并且
  2. 可见性超时未过期并且
  3. 你没有删除它。

SQS 的设计使您可以调用 ReceiveMessage 并向您提供一条消息进行处理。您有一些时间(可见性超时)来处理此消息。在此“可见性”超时期间,如果您再次调用 ReceiveMessage,则不会返回您当前正在处理的消息。它是隐藏的。

一旦可见性超时到期,消息将能够返回到未来的 ReceiveMessage 调用。如果消费者以某种方式失败,则可能会发生这种情况。如果该过程成功,则您可以删除该消息。

从 ReceiveMessage 调用中隐藏的消息数是“飞行中”数。目前,SQS 队列默认设置为允许最多 120,000 条消息“进行中”。

http://docs.amazonwebservices.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/AboutVT.html