Spring Boot使用jmsTemplate异步发AMQ消息时broker宕机无响应问题

• ActiveMQ客户端默认开启故障转移无限重连机制，Broker下线后客户端会持续尝试重连，不会抛出连接异常，导致jmsTemplate.send方法一直处于阻塞等待状态。
• 默认JmsTemplate未配置发送超时，没有主动中断阻塞逻辑的触发条件。
• @Async只是将整个sendMessage方法提交到异步线程池执行，并没有改变jmsTemplate.send本身的同步阻塞特性，方法卡死后对应异步线程会被直接挂起，不会进入后续catch、finally代码块。
• 当前代码仅捕获Exception类型异常，若阻塞过程中抛出Error类型的异常，也会无法触发异常处理逻辑。

1. 配置JmsTemplate发送超时
   在Spring配置中为JmsTemplate添加全局发送超时限制，示例代码如下：

@Bean
public JmsTemplate jmsTemplate(ConnectionFactory connectionFactory) {
    JmsTemplate jmsTemplate = new JmsTemplate(connectionFactory);
    // 配置发送超时时间为3000毫秒，超时后自动中断抛出异常
    jmsTemplate.setDeliveryTimeout(3000);
    return jmsTemplate;
}

2. 限制ActiveMQ客户端重连策略
   修改ActiveMQ连接的Broker URL，添加重连次数、超时限制，关闭无限重连：
   原URL格式tcp://127.0.0.1:61616，调整为带参数的failover格式：

failover:(tcp://127.0.0.1:61616)?maxReconnectAttempts=2&startupMaxReconnectAttempts=1&timeout=3000

参数说明：

• maxReconnectAttempts：运行中断线后的最大重连次数，负数代表无限重连
• startupMaxReconnectAttempts：应用启动时的最大重连次数
• timeout：单次重连请求的超时时间

3. 扩大异常捕获范围（可选）
   将原有Exception捕获调整为Throwable，确保所有错误场景都能触发失败兜底逻辑：

try {
    // 原有消息发送逻辑
} catch (Throwable e) {
    saveToPubTable(messageId, messageType, messageVersion, pubDate, CodeTypeConstants.FAILURE, text);
}

4. 异步方法超时兜底（可选）
   可将异步方法返回值改为CompletableFuture，配合调用端超时配置，避免异步线程长期被阻塞占用：

@Async
public CompletableFuture<Void> sendMessage(String text, String eventName, long entityPk, String messageId, String messageType, long messageVersion, String destinationQueue) {
    // 原有业务逻辑
    return CompletableFuture.completedFuture(null);
}

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