JMS负载均衡环境中Connection Name List未生效问题排查

从你的配置来看，有两个核心问题导致备队列管理器的消息无法被拾取：

1. connectionNameList 参数格式错误 #

IBM MQ的MQConnectionFactory.setConnectionNameList()方法要求传入单个逗号分隔的字符串，而非两个独立参数。你当前的写法在Java中会直接触发编译错误，即便侥幸运行，也无法正确识别备节点地址。

修正写法： #

// 错误写法（语法不合法）
mqcf.setConnectionNameList(mq1.daluga.com(2171),mq2.daluga.com(2171));

// 正确写法：用逗号分隔的字符串传递节点地址
mqcf.setConnectionNameList("mq1.daluga.com(2171),mq2.daluga.com(2171)");

2. 默认是故障转移模式，而非负载均衡模式 #

默认情况下，IBM MQ的连接名列表采用故障转移（Failover）模式：客户端只会连接第一个可用的队列管理器，仅当主节点故障时才会切换到备节点。这就是你只能拾取主节点消息的根本原因。

要实现负载均衡（让客户端同时连接主备节点消费消息），需要显式开启CLIENT_BALANCED连接模式：

修正后的完整连接工厂代码： #

@Bean(name = "MQConnectionFactory")
public ConnectionFactory buildConnectionFactory() {
    try {
        MQConnectionFactory mqcf = new MQConnectionFactory();
        // 正确设置连接名列表
        mqcf.setConnectionNameList("mq1.daluga.com(2171),mq2.daluga.com(2171)");
        mqcf.setChannel(channel);
        mqcf.setTransportType(WMQConstants.WMQ_CM_CLIENT);
        // 开启负载均衡模式
        mqcf.setConnectionMode(WMQConstants.WMQ_CONNECTION_MODE_CLIENT_BALANCED);
        // 可选：配置重连参数，提升负载均衡可靠性
        mqcf.setClientReconnectOptions(WMQConstants.WMQ_CLIENT_RECONNECT);
        mqcf.setClientReconnectTimeout(300); // 重连超时时间（单位：秒）
        return mqcf;
    } catch (Exception e) {
        throw new RuntimeException("Failed to initialize MQ connection factory", e);
    }
}

3. 补充：Spring监听器容器的连接池优化 #

Spring的DefaultJmsListenerContainerFactory默认使用单连接，所有消费者共享同一个连接，可能导致负载均衡效果不佳（所有消费者绑定到同一个队列管理器）。建议引入连接池，让每个消费者获取独立连接，实现更均匀的负载分布：

整合连接池的示例代码： #

@Bean(name = "MQConnectionFactory")
public ConnectionFactory buildConnectionFactory() {
    try {
        MQConnectionFactory mqcf = new MQConnectionFactory();
        mqcf.setConnectionNameList("mq1.daluga.com(2171),mq2.daluga.com(2171)");
        mqcf.setChannel(channel);
        mqcf.setTransportType(WMQConstants.WMQ_CM_CLIENT);
        mqcf.setConnectionMode(WMQConstants.WMQ_CONNECTION_MODE_CLIENT_BALANCED);
        
        // 使用Spring的CachingConnectionFactory实现连接池
        CachingConnectionFactory cachingConnFactory = new CachingConnectionFactory(mqcf);
        // 设置会话缓存大小，与监听器并发数匹配
        cachingConnFactory.setSessionCacheSize(Integer.parseInt(numberOfListeners));
        return cachingConnFactory;
    } catch (Exception e) {
        throw new RuntimeException("Failed to initialize MQ connection factory", e);
    }
}

验证要点 #

• 确保主备队列管理器的队列配置正确：如果是集群环境，需使用集群队列；如果是独立队列，需保证两个队列同名且监听器有权访问
• 检查MQ通道是否允许来自客户端的连接请求
• 查看MQ日志，确认客户端是否成功连接到备节点

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