本文属于机器翻译版本。若本译文内容与英语原文存在差异,则一律以英文原文为准。
Amazon SQS 可见性超时
当使用者接收并处理来自某个队列的消息时,消息将保留在该队列中。Amazon SQS 不会自动删除消息。因为 Amazon SQS 是分布式系统,所以无法保证使用者实际收到消息(例如,由于连接问题或由于使用者应用程序问题)。因此,使用者在接收和处理消息后必须从队列中删除该消息。

在收到消息后,消息将立即保留在队列中。为防止其他用户再次处理消息,Amazon SQS 会设置可见性超时,Amazon SQS 阻止其他用户接收并处理消息的一段时间。消息的默认可见性超时为 30 秒。最少为 0 秒。最长时间为 12 个小时。有关使用控制台配置队列可见性超时的信息,请参阅配置队列参数(控制台).
对于标准队列,可见性超时无法保证不会接收消息两次。有关更多信息,请参阅 至少一次传递。
FIFO 队列允许生产者或消费者尝试多次重试:
-
如果生产者检测到失败
SendMessage
操作时,它可以使用相同的消息重复数据消除 ID,根据需要多次重试发送。假设生产者在重复数据消除间隔到期之前至少收到一个确认,则多次重试既不影响消息的顺序,也不会引入重复项。 -
如果消费者检测到失败
ReceiveMessage
操作,它可以根据需要使用相同的接收请求尝试 ID 重试多次。假设消费者在可见性超时到期之前至少收到一个确认,则多次重试不会影响消息的顺序。 -
当您收到带有消息组 ID 的消息时,除非删除消息或变为可见消息,否则不再返回同一消息组 ID 的消息。
传输中的消息
Amazon SQS 消息有三个基本状态:
-
由制作人发送到队列。
-
消费者从队列中收到。
-
从队列中删除。
一条消息被认为是已存储在生产者将其发送到队列之后,但是消费者尚未从队列中收到(即在状态 1 和 2 之间)。存储的消息数量没有配额。一条消息被认为是在飞行中在消费者从队列中接收,但尚未从队列中删除(即在状态 2 和 3 之间)之后。对于传输中的消息数量有配额。
适用于机上消息的配额与无限的存储的消息数量。
对于大多数标准队列(取决于队列流量和消息积压),最多可能有 120000 个传输中的消息(由使用者从队列中接收,但尚未从队列中删除)。如果您在使用时达到此配额短轮询,Amazon SQS 返回OverLimit
错误消息。如果您使用长轮询,Amazon SQS 不返回错误消息。为避免达到此配额,您应该在处理消息后将其从队列中删除。您还可以增加用来处理消息的队列的数量。要申请提高配额,请提交支持请求
对于 FIFO 队列,最多可能有 20,000 个传输中的消息(使用者从队列中收到但尚未从队列中删除)。如果您达到此配额,Amazon SQS 将不返回任何错误消息。
使用 FIFO 队列时,DeleteMessage
如果在可见性超时窗口之外收到请求,操作将失败。如果可见性超时为 0 秒,则必须在发送的同一毫秒内删除消息,否则该消息被视为已放弃。这可能会导致 Amazon SQS 在对ReceiveMessage
如果您将MaxNumberOfMessages
参数大于 1。有关其他详细信息,Amazon SQS FIFO API 的工作原理
设置可见性超时
可见性超时从 Amazon SQS 返回消息时开始。在这段时间里,使用者可以处理和删除消息。但是,如果使用者在删除消息之前失败,并且您的系统没有在可见性超时结束之前对该消息调用 DeleteMessage
操作,则其他使用者将可以看到该消息并且再次接收该消息。如果某条消息只能被接收一次,则您的使用者应在可见性超时期间内删除该消息。
每个 Amazon SQS 队列都具有 30 秒的默认可见性超时设置。您可以为整个队列更改此设置。通常,您应将可见性超时设置为您的应用程序处理消息并从队列中删除消息所需的最长时间。此外,在接收消息时,您还可以为返回的消息设置特殊的可见性超时,而无需更改整个队列的超时。有关更多信息,请参阅及时处理消息部分中的最佳实践。
如果您不知道处理消息需要多长时间,请创建心跳对于你的消费者流程:指定初始可见性超时(例如 2 分钟),然后,只要您的消费者仍在处理消息,就可以每分钟将可见性超时延长 2 分钟。
最大可见性超时为 Amazon SQS 收到ReceiveMessage
请求. 延长可见性超时不会重置 12 小时的最大值。
此外,您可能无法将单条消息的超时设置为整整 12 小时(例如 43,200 秒),因为ReceiveMessage
请求启动计时器。例如,如果您收到消息并立即通过发送ChangeMessageVisibility
使用调用VisibilityTimeout
等于 43,200 秒,它可能会失败。但是,使用值 43,195 秒将起作用,除非通过以下方式请求消息之间存在显著延迟。ReceiveMessage
并更新可见性超时。如果您的使用者需要超过 12 小时,请考虑使用 Step Functions。
更改消息的可见性超时
当您收到来自队列的消息并开始处理该消息时,队列的可见性超时可能不够 (例如,您可能需要处理和删除消息)。可通过使用 ChangeMessageVisibility
操作指定新的超时值来缩短或延长消息的可见性。
例如,如果队列的默认超时值为 60 秒,在您接收消息后 15 秒时,您发送了 ChangeMessageVisibility
调用并将 VisibilityTimeout
设为 10 秒,则这 10 秒从您进行 ChangeMessageVisibility
调用时开始计时。因此,自您最初更改可见性超时后 10 秒 (共 25 秒) 起,任何更改可见性超时或删除此消息的尝试都可能导致错误。
新的超时期限自您调用 ChangeMessageVisibility
操作起生效。此外,新的超时期限仅应用于消息的特定接收。ChangeMessageVisibility
不会影响消息的后续接收或后续队列的超时。
终止消息的可见性超时
收到来自某个队列的某条消息时,您可能会发现,您实际上不想处理并删除该消息。Amazon SQS 允许您终止特定消息的可见性超时。这将使该消息对系统中的其他组件立即可见并且可用于处理。
要在调用 ReceiveMessage
后终止消息的可见性超时,请调用 ChangeMessageVisibility
并将 VisibilityTimeout
设置为 0 秒。