5

我的申请包括：

  • 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)

我希望每条消息只能由一名工作人员接收，以避免多余的工作。

是否有一种机制可以使用 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)

如果我遵循这种方法，有没有办法在工作人员崩溃（步骤（3）失败）时恢复收到但未处理的消息？

这个问题是 Spring 特有的，它包含了各种各样的魔法。

4

2 回答 2

9

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

在 SQS 消息传递中，如果出现以下情况，则认为消息处于“飞行中”：

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

SQS 的设计目的是让您可以调用 ReceiveMessage 并将消息提供给您进行处理。您有一些时间（可见性超时）来处理此消息。在此“可见性”超时期间，如果您再次调用 ReceiveMessage，则不会向任何工作人员返回您当前正在使用的消息。它是隐藏的。

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

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

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

于 2019-11-15T14:19:31.917 回答
0

将有 ReciepientHandle String 将与消息一起发送。它将具有基于队列可见性超时的到期时间。

您可以使用此 ReciepientHandle 从队列中删除消息

于 2019-11-28T05:57:55.270 回答