Azure Service Bus AMQP空闲超时致连接断开，无法自动重连求助

从你的报错信息和配置来看，核心问题有两个：Azure Service Bus因连接空闲超时强制断开链接后，Spring的CachingConnectionFactory未自动重连，以及自定义ExceptionListener未触发。下面一步步拆解原因并给出修复方案：

一、为什么会出现空闲链接断开？ #

Azure Service Bus默认的链接空闲超时是30分钟（1800000ms），你的报错里明确提到Idle link tracker...idle for 1800000ms——当链接长时间没有消息收发时，Service Bus会强制断开链接，而你的Qpid JMS客户端没有主动发送心跳来维持链接，导致后续操作时使用了已关闭的MessageProducer。

二、修复步骤 #

1. 配置Qpid客户端主动发送心跳，避免空闲断开 #

在你的Azure JMS连接URL中添加Qpid专属的AMQP参数，让客户端定期发送心跳，提前触发活动，避免Service Bus判定为空闲：

# 修改后的azure.jms.url示例，添加心跳和重连参数
azure.jms.url=amqps://your-servicebus-namespace.servicebus.windows.net?amqp.idleTimeout=1200000&amqp.tcpKeepAlive=true&amqp.reconnect.enabled=true&amqp.reconnect.initialDelay=1000&amqp.reconnect.maxDelay=30000

参数说明：

• amqp.idleTimeout=1200000：设置客户端空闲超时为20分钟（比Service Bus的30分钟短），到点自动发送心跳
• amqp.tcpKeepAlive=true：启用TCP层的心跳，进一步维持链接
• amqp.reconnect.enabled=true：开启Qpid客户端的自动重连（默认是true，但明确配置更稳妥）
• amqp.reconnect.initialDelay/maxDelay：设置重连的初始间隔和最大间隔，避免频繁重试

2. 调整CachingConnectionFactory的重连与缓存配置 #

你当前的配置存在两个冲突点：

• CachingConnectionFactory默认reconnectOnException=true，但JmsConfiguration设置了cacheLevelName="CACHE_NONE"，这会覆盖连接工厂的缓存策略，导致异常时无法正确清理旧连接并创建新连接
• 异常监听器设置在了CachingConnectionFactory上，但底层Qpid连接的异常可能没有被传递上来

修改连接工厂配置如下：

<bean id="jmsConnectionFactory" class="org.springframework.jms.connection.CachingConnectionFactory">
    <property name="targetConnectionFactory">
        <bean class="org.apache.qpid.jms.JmsConnectionFactory">
            <constructor-arg value="${azure.jms.url}" />
            <property name="username" value="${azure.jms.username}" />
            <property name="password" value="${azure.jms.password}" />
            <property name="clientID" value="AltaPay" />
            <property name="receiveLocalOnly" value="true" />
            <property name="localMessageExpiry" value="true" />
            <property name="populateJMSXUserID" value="true" />
            <!-- 把异常监听器直接设置给底层Qpid连接工厂，确保能捕获到AMQP层的异常 -->
            <property name="exceptionListener">
                <bean class="com.lauraashley.microservice.altapay.callback.exception.CustomJMSExceptionListener" />
            </property>
        </bean>
    </property>
    <property name="reconnectOnException" value="true" /> <!-- 明确开启异常重连 -->
    <property name="sessionCacheSize" value="10" />
    <property name="cacheConsumers" value="false" />
</bean>
<bean id="jmsConfig" class="org.apache.camel.component.jms.JmsConfiguration">
    <property name="connectionFactory" ref="jmsConnectionFactory" />
    <!-- 调整缓存级别为CACHE_CONNECTION，和CachingConnectionFactory的策略保持一致 -->
    <property name="cacheLevelName" value="CACHE_CONNECTION" />
    <!-- 可选：添加Camel JMS的重连配置 -->
    <property name="reconnectAttempts" value="5" />
    <property name="reconnectInterval" value="2000" />
</bean>

3. 优化自定义ExceptionListener的逻辑 #

你的监听器目前只是基础打印，可以优化一下确保能完整捕获异常上下文：

public class CustomJMSExceptionListener implements ExceptionListener {
    private static final Logger logger = LoggerFactory.getLogger(CustomJMSExceptionListener.class);
    
    @Override
    public void onException(JMSException exception) {
        logger.error("=== JMS Connection Exception Caught ===", exception);
        logger.error("Error Code: {}, Message: {}", exception.getErrorCode(), exception.getMessage());
        // 这里可以添加告警逻辑，比如发送邮件/短信通知运维人员
    }
}

注意：使用LoggerFactory确保SLF4J日志框架正常工作，并且把异常对象作为参数传入logger.error，这样能打印完整的堆栈轨迹，方便排查问题。

三、额外注意事项 #

• 避免长时间空闲的生产者/消费者：如果应用长时间没有消息收发，建议定期发送空心跳消息，或者配置Camel JMS组件自动清理空闲消费者
• 版本兼容性：你使用的azure-servicebus-spring-boot-starter版本是0.2.0，属于较旧版本，建议升级到最新稳定版（如2.x系列），新版本对Qpid客户端的集成更完善，修复了不少重连相关的bug
• 监控连接状态：通过Spring Boot Actuator添加JMS连接状态的监控指标，及时发现连接异常并告警

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