使用Apache Camel与ActiveMQ的Spring项目JMS连接无法自动刷新问题求助

我来帮你搞定这个问题——其实核心原因很简单：Spring Boot的ActiveMQ starter已经默认帮我们配置了连接自动重试和恢复的机制，但传统Spring项目需要手动添加这些配置项。下面一步步给你讲怎么操作：

1. 确保使用ActiveMQ的Failover连接URL #

首先要把你的ActiveMQ连接URL改成failover模式，这是实现连接自动恢复的基础。你给出的配置里已经有failover，重点确认这几个关键参数：

broker:
  host: localhost
  port: 61616
  protocol: tcp
  endpoint: ${broker.protocol}://${broker.host}:${broker.port}
  url: failover:(${broker.endpoint}?wireFormat.maxInactivityDurationInitalDelay=30000)?timeout=3000&jms.useCompression=true&startupMaxReconnectAttempts=0&jms.redeliveryPolicy.maximumRedeliveries=${maxConsumers}

关键参数说明：

• startupMaxReconnectAttempts=0：表示启动阶段无限重试连接，不会因为broker一开始不可用就放弃
• wireFormat.maxInactivityDurationInitalDelay=30000：延长初始无活动检测的时长，避免过早判定连接断开

2. 配置DefaultJmsMessageListenerContainer的重试策略 #

在传统Spring项目中，你需要显式配置DefaultJmsMessageListenerContainer的恢复参数，让它在连接失败后定期重试。

XML配置方式 #

<bean id="jmsListenerContainer" class="org.apache.camel.component.jms.DefaultJmsMessageListenerContainer">
    <property name="connectionFactory" ref="jmsConnectionFactory"/>
    <property name="destinationName" value="test.events.topic"/>
    <property name="subscriptionDurable" value="true"/>
    <!-- 每5秒重试一次连接 -->
    <property name="recoveryInterval" value="5000"/>
    <!-- 配置无限重试的固定间隔策略 -->
    <property name="backOff">
        <bean class="org.springframework.util.backoff.FixedBackOff">
            <property name="interval" value="5000"/>
            <property name="maxAttempts" value="0"/> <!-- 0表示无限重试 -->
        </bean>
    </property>
</bean>

Java配置方式 #

@Configuration
public class JmsConfig {
    @Bean
    public DefaultJmsMessageListenerContainer jmsListenerContainer(ConnectionFactory connectionFactory) {
        DefaultJmsMessageListenerContainer container = new DefaultJmsMessageListenerContainer();
        container.setConnectionFactory(connectionFactory);
        container.setDestinationName("test.events.topic");
        container.setSubscriptionDurable(true);
        // 设置重试间隔为5秒
        container.setRecoveryInterval(5000);
        
        // 配置无限重试的BackOff策略
        FixedBackOff backOff = new FixedBackOff();
        backOff.setInterval(5000);
        backOff.setMaxAttempts(0); // 0代表无限次重试
        container.setBackOff(backOff);
        
        return container;
    }
}

3. 配置Apache Camel JMS组件的重试参数 #

确保你的Camel路由使用的JMS组件也开启了无限重试，比如在路由定义中添加相关参数：

@Component
public class EventRoute extends RouteBuilder {
    @Override
    public void configure() throws Exception {
        from("jms:topic:test.events.topic?connectionFactory=#jmsConnectionFactory&connectionRetryMaxAttempts=-1&connectionRetryInterval=5000")
            .log("Received event: ${body}")
            .to("bean:eventProcessor");
    }
}

这里的connectionRetryMaxAttempts=-1表示无限重试连接，connectionRetryInterval=5000是每次重试的间隔。

验证效果 #

配置完成后，你可以再测试一遍：

1. 先启动你的Spring应用（此时ActiveMQ broker未启动），会看到类似你提供的日志：

org.apache.camel.component.jms.DefaultJmsMessageListenerContainer: Could not refresh JMS Connection for destination 'test.events.topic' - retrying using FixedBackOff{interval=5000, currentAttempts=1, maxAttempts=unlimited}. Cause: Could not connect to broker URL: tcp://activemq:61616. Reason: java.net.UnknownHostException: activemq

2. 然后启动ActiveMQ broker，稍等几秒，应该就能看到类似Spring Boot里的日志：

Successfully refreshed JMS Connection

这就说明连接已经自动恢复了。

为什么Spring Boot可以自动恢复？ #

因为Spring Boot的spring-boot-starter-activemq自动配置类已经默认帮我们做了这些配置：

• 自动启用Failover连接URL
• 默认配置了DefaultJmsMessageListenerContainer的重试策略
• 预设了合理的连接重试参数

而传统Spring项目没有这些默认配置，所以需要我们手动补上。

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