IBM-MQ(9.2.2.0) Spring Boot动态监听器MQ连接过多报2537错误如何解决

存在的核心问题 #

1. 连接工厂重复创建且无连接池复用
   你在循环注册每个队列监听器的时候，都调用了mqJmsListenerContainerFactory()重新创建了一个容器工厂实例，而你的ibmConnectionFactory是未配置连接池的原生IBM MQ连接工厂，默认不会复用连接，每个容器的每个并发线程都会创建独立的MQ连接。队列数量多+并发配置较高的场景下，连接数会快速超过MQ服务端的通道最大连接数限制，触发2537错误。
2. 多余的手动事务控制
   你已经给容器工厂设置了factory.setSessionTransacted(true)，Spring JMS监听器容器本身就会自动管理事务：消息处理正常则自动提交，抛出异常则自动回滚。你在消息监听器里手动又通过jmsTransactionManager开启、提交/回滚事务，属于重复事务控制，会导致session无法正常复用，进一步加剧连接占用。
3. JMS容器缓存配置缺失
   DefaultJmsListenerContainerFactory默认的缓存级别如果没有显式配置，在无连接池的场景下会频繁销毁重建session和连接，进一步消耗连接资源。

修复方案 #

1. 改造连接工厂，增加连接池配置 #

不要直接使用原生的IBM MQ连接工厂，用CachingConnectionFactory包装实现连接复用：

@Bean
public ConnectionFactory ibmMqCachingConnectionFactory() throws JMSException {
    CachingConnectionFactory cachingFactory = new CachingConnectionFactory();
    cachingFactory.setTargetConnectionFactory(ibmConnectionFactory);
    // 按需设置缓存的session数量，根据实际并发调整
    cachingFactory.setSessionCacheSize(20);
    cachingFactory.setCacheConsumers(true);
    cachingFactory.setCacheProducers(true);
    return cachingFactory;
}

2. 容器工厂改为单例，禁止循环中重复创建 #

把mqJmsListenerContainerFactory改成Spring单例Bean，仅初始化一次：

@Bean
public DefaultJmsListenerContainerFactory mqJmsListenerContainerFactory(@Qualifier("ibmMqCachingConnectionFactory") ConnectionFactory cachingConnectionFactory) {
    DefaultJmsListenerContainerFactory factory = new DefaultJmsListenerContainerFactory();
    factory.setConnectionFactory(cachingConnectionFactory);
    factory.setDestinationResolver(new DynamicDestinationResolver());
    factory.setSessionTransacted(true);
    // 显式设置缓存级别，缓存连接和session
    factory.setCacheLevel(DefaultMessageListenerContainer.CACHE_CONNECTION);
    factory.setConcurrency(requestConcurrency);
    return factory;
}

循环注册监听器时直接注入这个单例工厂即可，不需要反复创建：

// 提前注入单例工厂
@Autowired
private DefaultJmsListenerContainerFactory mqJmsListenerContainerFactory;

// 循环内直接使用
registrar.setContainerFactory(mqJmsListenerContainerFactory);
registrar.registerEndpoint(endpoint);

3. 删除手动事务控制代码 #

容器已经开启了事务管理，直接删除手动操作事务的逻辑，简化后的监听器代码：

endpoint.setMessageListener(message -> {
    try {
        ibmmqConsumer.tradeListener(message, aTradeQueue.getTradeRequestName());
    } catch (Exception e) {
        try {
            LOG.error("Failed to publish to Active-MQ & rolled back to IBM-MQ : " + message.getJMSMessageID(), e);
        } catch (JMSException ex) {
            LOG.error("Get JMS message id error", ex);
        }
        // 抛出异常即可触发容器自动回滚
        throw new RuntimeException(e);
    }
});

4. 配合调整MQ服务端配置（可选） #

如果业务并发确实很高，可以联系MQ管理员调整对应通道的MAXINST（每个通道最大实例数）和MAXINSTC（每个客户端IP的最大通道实例数）参数，适配实际的连接需求。

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