Amazon SQS消息接收后未删除是否会被重复消费？如何规避？

我刚接触Amazon SQS，但有使用Azure Service Bus的经验。我记得从队列中‘pop’消息后，该消息就不再存在于队列中，无需担心多个消费者获取到同一条消息（若我的记忆有误，敬请谅解）。

我正在遵循Amazon .NET SDK的‘接收并删除’消息示例，这让我产生疑问：在消息被删除前，其他消费者是否有可能获取到它？这种理解是否正确？有没有办法在接收消息的同时将其从队列中移除，或者通过其他方式避免重复消费？

附带代码示例：

// 从队列接收单条消息
var receiveMessageRequest = new ReceiveMessageRequest
{
    AttributeNames = { "GlobalTransactionId", "Amount", "TransactionDate" },
    MaxNumberOfMessages = 1,
    MessageAttributeNames = { "All" },
    QueueUrl = queueUrl,
    VisibilityTimeout = 0,
    WaitTimeSeconds = 0,
};

var receiveMessageResponse = await client.ReceiveMessageAsync(receiveMessageRequest);

// 从队列中删除已接收的消息
var deleteMessageRequest = new DeleteMessageRequest
{
    QueueUrl = queueUrl,
    ReceiptHandle = receiveMessageResponse.Messages[0].ReceiptHandle,
};

var deleteMessageResponse = await client.DeleteMessageAsync(deleteMessageRequest);

解答 #

1. 当前场景确实存在重复消费风险 #

你代码里把VisibilityTimeout设为0，这意味着消息被接收后不会对其他消费者隐藏。在你调用DeleteMessageAsync完成删除操作前，其他消费者完全有可能获取到同一条消息，你的这个理解是正确的。

2. 近似实现“接收即删除”的方式 #

Amazon SQS没有原生的“接收时直接删除”API，但可以通过以下方式接近这个效果：

• 设置合理的可见性超时：把VisibilityTimeout设为比你处理消息所需时间更长的值（比如30秒）。这样在你处理并删除消息的时间段内，这条消息对其他消费者不可见。如果消费进程意外崩溃，超时后消息会重新回到队列，避免丢失。
• 接收后立即执行删除：像你现在的代码这样，接收消息后马上调用删除接口，但要注意处理接收成功但删除失败的异常（比如网络波动），这种情况下消息可能会被其他消费者再次获取。

3. 彻底避免重复消费的核心方案 #

分布式系统中无法完全杜绝重复消息，最可靠的解决方式是让消费逻辑实现幂等性：

• 利用消息自带的唯一标识（比如你代码里的GlobalTransactionId），处理前先检查该ID是否已被处理过（可存在数据库或缓存中），若已处理则直接跳过。
• 确保业务操作本身是幂等的（比如重复执行扣款操作不会导致多扣钱）。

内容的提问来源于stack exchange，提问作者Yohancef Chin