Spring Cloud AWS @SqsListener无法监听SQS队列问题求助

1. 确认核心注解是否配置 #

检查项目的配置类或启动类上是否添加了@EnableSqs注解。这个注解是开启SQS监听功能的必要条件，若缺失，@SqsListener注解的方法不会被注册为消息监听器。

2. 验证依赖版本兼容性 #

你的Spring Boot 3.0.6搭配Spring Cloud AWS 3.0.2版本整体兼容，但需注意：

• 移除自定义的aws.java.sdk.version配置，直接使用spring-cloud-aws-dependencies中管理的AWS SDK版本，避免版本冲突导致底层API调用异常。
• 保持spring-cloud.version（2022.0.4）与Spring Cloud AWS 3.0.2的版本一致性，无需手动指定额外版本，依赖管理会自动处理兼容关系。

3. 检查AWS基础配置 #

凭证与区域配置 #

确保项目已正确配置AWS访问凭证和队列所在区域：

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

  spring:
    cloud:
      aws:
        region:
          static: us-east-1 # 替换为你的队列实际区域
        credentials:
          access-key: your-access-key
          secret-key: your-secret-key
  

  若在ECS/EKS等AWS托管服务上运行，可通过IAM角色自动获取凭证，无需手动配置。

队列权限验证 #

检查用于访问SQS的IAM用户/角色是否拥有以下核心权限：

• sqs:ReceiveMessage
• sqs:DeleteMessage
• sqs:GetQueueAttributes
  权限缺失会导致监听器无法拉取或处理消息。

4. 确认FIFO队列的消息发送规范 #

FIFO队列有强制要求：发送消息时必须指定MessageGroupId（若未开启内容去重，还需指定MessageDeduplicationId）。如果发送消息时未携带该参数，消息会被SQS拒绝，自然无法被监听到。

5. 开启DEBUG日志排查 #

将io.awspring.cloud.sqs包的日志级别设为DEBUG，查看启动时是否有监听器容器初始化日志，以及运行时是否有拉取消息的请求记录或异常信息：

logging:
  level:
    io.awspring.cloud.sqs: DEBUG

常见异常包括：队列不存在、凭证无效、权限不足、消息格式转换失败等。

6. 检查监听器方法与队列配置 #

• 确认队列名称fooQueue.fifo与AWS控制台中的实际队列名称完全一致（SQS队列名称不区分大小写，但建议完全匹配避免问题）。
• 若队列不在默认区域或需要指定队列URL，可将queueNames替换为queueUrl参数，直接指定队列的完整URL：

  @SqsListener(queueUrl = "https://sqs.us-east-1.amazonaws.com/123456789012/fooQueue.fifo")
  

• 验证监听器方法参数是否匹配：若发送的是JSON格式消息，直接用String接收是可行的，但如果是自定义对象，需确保配置了正确的消息转换器（如Jackson）。

7. 排查监听容器配置 #

若自定义了SqsListenerContainerFactory，检查是否存在以下问题：

• 并发数配置为0或负数，导致容器无法启动消费者。
• 消息可见性超时、批量拉取等配置不合理，影响消息接收。
  默认的容器配置可满足基本需求，若无需自定义，建议移除相关配置，使用默认实现。

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