amazon-web-services - 我应该什么时候删除 SQS 中的消息?
问题描述
我的申请包括:
- 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 特有的,它包含了各种各样的魔法。
解决方案
SQS 消息在消费者从队列中接收到但尚未从队列中删除后被认为是“正在进行的”。这些消息对其他消费者不可见。
在 SQS 消息传递中,如果出现以下情况,则认为消息处于“飞行中”:
- 您是消费者已收到它,并且
- 可见性超时尚未到期,并且
- 你还没有删除它。
SQS 的设计目的是让您可以调用 ReceiveMessage 并将消息提供给您进行处理。您有一些时间(可见性超时)来处理此消息。在此“可见性”超时期间,如果您再次调用 ReceiveMessage,则不会向任何工作人员返回您当前正在使用的消息。它是隐藏的。
一旦可见性超时到期,消息将能够返回给未来的 ReceiveMessage 调用。如果消费者以某种方式失败,这可能会发生。如果该过程成功,则可以删除该消息。
对 ReceiveMessage 调用隐藏的消息数是“飞行中”数。目前,SQS 队列默认设置为允许最多 120,000 条消息“进行中”。
http://docs.amazonwebservices.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/AboutVT.html
推荐阅读
- javascript - 如何在画布中定位 Path2D SVG 元素?
- ruby-on-rails - 如何在选择框中显示现有数据
- vb.net - 从 DatagridView 创建 Tiff 位图文件
- graphql - AppSync 中的 GraphQL 字段级验证
- c# - 无法在选择列表中保存多个选择 - asp.net core web app razor pages
- c# - C# 8 在返回具有可空约束的可空泛型时发出警告
- ios - 尝试使用 babel-plugin-proposal-class-properties 时使用 .babelrc 的语法加倍
- mysql - 如何优化我的 Google Cloud SQL (MySQL) 数据库以与 API 一起使用
- php - 打印调试堆栈跟踪(在块内)
- swift - 如何在一个 iOS 应用中运行两种不同的 ARKit 体验