使用JMS+CCDT文件连接IBM MQ时的负载均衡异常求助

嘿，咱们来聊聊你遇到的这个IBM MQ负载均衡问题——这其实是用CCDT搭配Spring时的一个常见坑，先给你理清楚原因，再给几个规范的解决办法：

为什么会出现这个问题？ #

当你在Spring启动阶段一次性初始化MQ连接工厂时，IBM MQ客户端会在连接工厂初始化的瞬间就解析CCDT文件，选出一个可用的队列管理器（QMGR）并把这个选择固定下来。后续所有的连接都会复用这个已经选定的QMGR，自然就没法实现负载均衡了。

而你测试时每次请求前手动设置CCDT路径，相当于每次都触发了CCDT的重新解析和QMGR的重新选择，所以能实现负载，但这种做法确实不规范，还可能带来不必要的性能开销。

规范解决方案 #

1. 升级IBM MQ客户端版本 + 配置连接池动态选择 #

优先推荐这个方案，这是官方最认可的做法：

• 确保你使用的是IBM MQ 9.3及以上版本的客户端（包括Spring Boot Starter mq-spring-boot-starter），新版本优化了CCDT的动态解析逻辑，默认支持在创建新连接时重新选择QMGR。
• 配置连接工厂时，开启客户端重连选项，让连接池在创建新连接时重新评估可用的QMGR：

  @Bean
  public MQConnectionFactory mqConnectionFactory() throws MQException {
      MQConnectionFactory factory = new MQConnectionFactory();
      // 设置你的CCDT文件路径
      factory.setCCDTURL("file:/path/to/your/ccdt.json");
      // 开启客户端重连，允许切换到其他QMGR
      factory.setClientReconnectOptions(MQConstants.MQCLIENT_RECONNECT_Q_MGR);
      // 设置重连超时时间（单位：秒）
      factory.setClientReconnectTimeout(300);
      return factory;
  }
  

• 配合Spring的连接池（比如JmsPoolConnectionFactory）使用，设置合理的闲置超时和最大连接数，让连接池定期回收旧连接，创建新连接时自动触发QMGR的重新选择：

  @Bean
  public JmsPoolConnectionFactory jmsPoolConnectionFactory(MQConnectionFactory mqConnectionFactory) {
      JmsPoolConnectionFactory poolFactory = new JmsPoolConnectionFactory();
      poolFactory.setConnectionFactory(mqConnectionFactory);
      // 设置最大连接数，根据你的业务量调整
      poolFactory.setMaxConnections(10);
      // 设置闲置连接超时时间，超时后连接会被回收，下次获取时创建新连接
      poolFactory.setIdleTimeout(60000);
      return poolFactory;
  }
  

2. 自定义连接工厂包装类，强制触发CCDT重新解析 #

如果暂时没法升级客户端版本，可以用这个折中方案：

• 写一个包装类，在每次创建连接前，重新设置CCDT的URL（即使路径相同，也会触发客户端重新解析CCDT）：

  @Component
  public class DynamicMQConnectionWrapper {
      private final MQConnectionFactory baseFactory;
  
      // 通过构造注入原始的连接工厂
      public DynamicMQConnectionWrapper(MQConnectionFactory baseFactory) {
          this.baseFactory = baseFactory;
      }
  
      public Connection createConnection() throws JMSException {
          try {
              // 重新设置CCDTURL，触发重新解析
              baseFactory.setCCDTURL(baseFactory.getCCDTURL());
          } catch (MQException e) {
              throw new JMSException("刷新CCDT配置失败", e);
          }
          return baseFactory.createConnection();
      }
  }
  

• 发送消息时，使用这个包装类来创建连接，而不是直接用原始的连接工厂。注意：这个方式会增加每次连接的开销，建议配合连接池使用，控制重新解析的频率。

3. 检查CCDT文件的配置 #

最后别忘了确认你的CCDT文件本身配置了正确的负载均衡策略，比如在CCDT的clientConnection节点中，确保connectionNameList包含了所有要负载的QMGR，并且没有设置固定的queueManager名称（如果设置了固定值，客户端会直接连接这个QMGR，忽略其他选项）。

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