Java Spring+AWS Auto Scaling下如何控制TaskProtection避免SQS任务中断？

Spring 完全支持应对这种任务终止场景的处理，核心围绕消息不丢失和优雅关闭两个关键点，下面分机制说明和最佳实践展开：

一、Spring SQS 的消息确认机制 #

默认情况下，@SqsListener 采用自动确认模式：当消息处理方法正常返回时，Spring 会自动向 SQS 发送确认请求；如果方法抛出未捕获异常，消息会被放回队列（遵循队列重试机制）。但如果任务是被强制终止（比如进程被 kill），此时 Spring 来不及发送确认，SQS 会在消息可见性超时到期后，将消息重新放回队列，保证消息不会丢失。

你也可以开启手动确认来获得更精细的控制，比如处理到关键阶段后再确认：

@SqsListener(value = "your-queue-name")
public void processMessage(String messageBody, Acknowledgment acknowledgment) {
    try {
        // 执行消息处理逻辑
        // ...
        // 处理完成后手动确认
        acknowledgment.acknowledge();
    } catch (Exception e) {
        // 异常场景下不确认，让消息自动重试
        // 或根据业务逻辑决定是否转入死信队列
    }
}

二、Spring Boot 优雅关闭配置 #

为了避免任务终止时直接打断正在处理的消息，你需要配置 Spring Boot 的优雅关闭：

1. 在 application.properties 或 application.yml 中添加：

server.shutdown=graceful
spring.lifecycle.timeout-per-shutdown-phase=30s

这里的 timeout-per-shutdown-phase 要设置为你的消息最长处理时间，确保正在处理的消息有足够时间完成。

2. Spring Cloud AWS 的 SQS Listener 会自动响应优雅关闭：停止接收新消息，等待所有正在处理的消息完成后再退出进程。

三、关键最佳实践 #

• 合理设置可见性超时：将队列的可见性超时设置为消息最长处理时间的 1.5~2 倍，避免正常处理过程中消息因超时被重新放回队列。可以通过 @SqsListener 的 visibilityTimeout 属性配置，或在 SQS 队列层面设置默认值：

@SqsListener(value = "your-queue", visibilityTimeout = 20) // 单位：秒

• 配置死信队列（DLQ）：为业务队列绑定死信队列，当消息重试次数达到阈值后，自动转入 DLQ，避免无效重试占用资源，同时方便后续排查异常消息。

• 保证消息处理的幂等性：由于任务终止可能导致消息被重新投递，你的处理逻辑必须是幂等的。比如用消息的唯一 ID 作为数据库主键或缓存键，处理前先检查是否已处理过该消息，避免重复执行带来的数据不一致问题。

• 集群启停的优雅触发：在根据队列深度启停任务时，不要直接强制终止进程。比如在 K8s 环境中配置 preStop 钩子，给应用预留足够的优雅关闭时间；在自定义启停脚本中，先发送信号让应用停止接收新消息，等待配置的超时时间后再终止进程。

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