Spring JMS与AWS SQS FIFO集成异常：重复轮询消息未进入处理块

我之前也碰到过类似的Spring JMS + SQS FIFO的诡异问题，结合你的描述和踩过的坑，给你梳理几个大概率的排查方向：

1. 检查FIFO队列必填属性的配置 #

SQS FIFO队列强制要求每条消息携带MessageGroupId，如果开启了显式去重还需要MessageDeduplicationId。如果发送消息时没正确设置这两个属性，或者Spring JMS客户端没正确解析这些属性，会导致消息被SQS拦截，或者客户端拿到消息后无法触发消费逻辑，表现为持续轮询但不进入处理代码。

发送消息时的正确示例：

jmsTemplate.send("your-queue-name.fifo", session -> {
    TextMessage message = session.createTextMessage("业务数据");
    // 必须设置消息组ID，同组消息按顺序消费
    message.setStringProperty("MessageGroupId", "order-group-001");
    // 显式去重ID，可选但建议设置避免重复消息
    message.setStringProperty("MessageDeduplicationId", UUID.randomUUID().toString());
    return message;
});

2. 核对监听器的注解与参数配置 #

你的监听类加了@Component，但要确认是否正确添加了@JmsListener注解，且指定的队列名必须以.fifo结尾（SQS FIFO队列的命名要求）。另外，监听器方法的参数类型要和消息类型匹配：如果发送的是TextMessage，方法参数可以是String或TextMessage；如果是对象消息，要确保配置了正确的消息转换器，类型不匹配会导致消息无法被解析，进而跳过处理逻辑。

正确的监听器示例：

@Component
public class SQSListener {
    private static final Logger LOGGER = LoggerFactory.getLogger(SQSListener.class);

    @JmsListener(destination = "your-queue-name.fifo")
    public void handleMessage(String payload) {
        LOGGER.info("开始处理消息: {}", payload);
        // 这里写你的业务逻辑
    }
}

3. 排查可见性超时与消息确认的冲突 #

你的队列可见性超时是30秒，要重点检查Spring JMS的消息确认模式：

• 如果用的是CLIENT_ACKNOWLEDGE模式，监听器里必须手动调用message.acknowledge()，如果确认逻辑遗漏或出错，消息会在可见性超时后重新回到队列，导致客户端重复轮询。
• 建议先测试切换为AUTO_ACKNOWLEDGE模式，确认是否是确认逻辑的问题：

@Bean
public DefaultJmsListenerContainerFactory jmsListenerContainerFactory(ConnectionFactory connectionFactory) {
    DefaultJmsListenerContainerFactory factory = new DefaultJmsListenerContainerFactory();
    factory.setConnectionFactory(connectionFactory);
    factory.setSessionAcknowledgeMode(Session.AUTO_ACKNOWLEDGE);
    return factory;
}

4. 检查SDK与Spring版本兼容性 #

如果使用的AWS SDK for Java（aws-java-sdk-sqs）和Spring JMS/Spring Boot版本不兼容，可能会出现协议解析异常，导致消息无法被正确处理。建议升级到稳定的最新版本，比如使用Spring Boot的starter依赖来自动管理版本兼容性：

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-activemq</artifactId>
</dependency>
<dependency>
    <groupId>com.amazonaws</groupId>
    <artifactId>aws-java-sdk-sqs</artifactId>
    <version>1.12.500</version> <!-- 或最新稳定版 -->
</dependency>

5. 开启DEBUG日志定位细节 #

把Spring JMS和AWS SQS相关的日志级别调到DEBUG，比如在application.properties中添加：

logging.level.org.springframework.jms=DEBUG
logging.level.com.amazonaws.services.sqs=DEBUG

这样能看到消息接收、解析、确认的完整流程，找到到底是哪一步卡住了——是消息没被正确解析，还是有隐藏异常被吞掉，或者确认环节出了问题。

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