如何基于@SqsListener实现SQS消息的可重试与不可重试异常处理？

针对你提到的两种异常处理需求，可以通过Spring Cloud AWS框架的内置异常类型+配置实现，无需编写额外的重试/DLQ路由逻辑，以下是具体方案：

一、永久异常直接移入DLQ #

Spring Cloud AWS提供了org.springframework.cloud.aws.messaging.listener.NonRetryableException，抛出该异常时，监听器会直接将消息移入DLQ，跳过任何重试。

实现步骤： #

1. 在消息处理器中，触发永久异常场景（如数据库未找到调用记录）时，抛出该异常：

@SqsListener("your-queue-name")
public void handleMessage(String message) {
    // 业务逻辑
    if (callRecordNotFound) {
        throw new NonRetryableException("数据库未找到调用记录，直接移入DLQ");
    }
}

2. 在配置文件（如application.yml）中指定不可重试的异常类型：

spring:
  cloud:
    aws:
      sqs:
        listener:
          non-retryable-exceptions: org.springframework.cloud.aws.messaging.listener.NonRetryableException

如果需要自定义异常类，也可以将自定义异常加入上述配置列表，同样会被视为不可重试异常。

二、瞬时异常重试3次后移入DLQ #

结合SQS本身的可见性超时机制，通过Spring Cloud AWS的重试配置即可实现“重试3次后入DLQ”的逻辑，无需额外编码。

实现步骤： #

1. 确保你的SQS队列已在AWS控制台关联了对应的DLQ（这是消息最终进入DLQ的基础配置）。
2. 在配置文件中设置重试参数：

spring:
  cloud:
    aws:
      sqs:
        listener:
          retry:
            max-attempts: 3  # 总重试次数（含第一次消费）
            back-off:
              initial-interval: 1000  # 首次重试间隔1秒
              multiplier: 2.0  # 重试间隔倍数递增

3. 在消息处理器中抛出常规异常（如服务宕机对应的ServiceUnavailableException），这类异常会被默认视为可重试异常，当重试达到3次后，消息会自动被移入DLQ。

补充说明 #

• 你提到的AWS Lambda PowerTools批量处理方案仅适用于@SqsBatch注解的批量消费场景，单条消息的@SqsListener需使用上述Spring Cloud AWS的配置方案。
• 如果使用原生AWS SDK而非Spring Cloud AWS，可以通过SqsMessageListenerContainer的异常处理器配置区分可重试/不可重试异常，仅需少量配置代码，无需编写业务逻辑层面的重试判断。

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