Spring JmsListener退避策略失效问题求助

你混淆了容器连接恢复的BackOff和消息消费重试的退避策略——你配置的FixedBackOff是给DefaultJmsListenerContainerFactory用来恢复连接的，不是控制消息消费失败后的重试逻辑的，所以你的maxAttempts和interval完全没作用在消息重试上。

开启sessionTransacted=true后，消费失败会触发事务回滚，MQ Series会不断重新投递这条消息，导致无限循环，而JMSXDeliveryCount递增只是MQ自身的投递计数，和Spring的配置无关。

正确实现消息退避重试的两种方案 #

方案一：用Spring Retry实现消费端重试退避 #

1. 引入Spring Retry依赖（Maven示例）：

<dependency>
    <groupId>org.springframework.retry</groupId>
    <artifactId>spring-retry</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-aop</artifactId>
</dependency>

2. 在配置类上开启重试开关：

@Configuration
@EnableRetry // 新增该注解
public class Jmsconfig implements JmsListenerConfigurer {
    // 原有代码保持不变
}

3. 在JmsListener方法上配置重试规则：

@Component
public class MqConsumer {

    @Autowired
    private JmsTemplate jmsTemplate;
    @Value("${mqueue.error}")
    private String mqError;

    @JmsListener(destination = "${your.queue.name}", containerFactory = "jmsListenerContainerFactory")
    @Retryable(
            value = {Exception.class}, // 指定触发重试的异常类型
            maxAttempts = 3, // 最大重试次数
            backoff = @Backoff(delay = 5000) // 每次重试间隔5秒
    )
    public void consumeMessage(YourMessage message) {
        // 你的消息消费逻辑，抛出异常时会触发重试
    }

    // 重试耗尽后的兜底处理方法
    @Recover
    public void recover(Exception e, YourMessage message) {
        // 例如将消息转发到死信队列
        jmsTemplate.convertAndSend(mqError, message);
    }
}

方案二：利用MQ Series自身的重试机制 #

直接在MQ队列上配置重试参数，达到次数后自动转发到死信队列：

• 设置队列的BackoutThreshold（最大重试次数，如3）
• 设置BackoutRetryInterval（重试间隔，如5秒）
• 配置DeadLetterQueue（重试耗尽后转发的死信队列）

这种方案无需在Spring代码中额外配置，完全由MQ管控重试逻辑，适合依赖中间件能力的场景。

关于你原有配置的说明 #

你代码里的factory.setBackOff(fbo)和factory.setRecoveryInterval(3000L)是用来处理容器连接断开后的重连逻辑的，比如MQ服务重启后，容器每隔3秒尝试重新建立连接，和消息消费的重试没有关系，别再搞混了。

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