如何配置多个IBM MQ Broker？Spring Boot 2.7.11适配方案求助

问题背景 #

参考某指南配置多MQ Broker时，发现Spring Boot 2.7.11中不存在com.ibm.mq.spring.boot.MQConnectionFactoryFactory类，需找到替代方案，创建基于自定义MQConfigurationProperties的MQConnectionFactory Bean以实现多Broker配置。

解决方案 #

1. 自定义多实例配置属性类 #

通过前缀区分不同MQ Broker，直接继承官方的MQConfigurationProperties复用已有配置项：

@ConfigurationProperties(prefix = "mq.first")
public class FirstMQProperties extends MQConfigurationProperties {
    // 无需额外字段，直接复用queueManager、host、port等原生配置项
}

@ConfigurationProperties(prefix = "mq.second")
public class SecondMQProperties extends MQConfigurationProperties {
}

2. 手动创建MQConnectionFactory实例 #

绕过已移除的MQConnectionFactoryFactory，直接基于自定义属性构建连接工厂Bean：

@Configuration
@EnableConfigurationProperties({FirstMQProperties.class, SecondMQProperties.class})
public class MultipleMQConfig {

    @Bean("firstMQConnectionFactory")
    public MQConnectionFactory firstMQConnectionFactory(FirstMQProperties properties) {
        MQConnectionFactory factory = new MQConnectionFactory();
        try {
            // 基础连接配置
            factory.setQueueManager(properties.getQueueManager());
            factory.setHostName(properties.getHost());
            factory.setPort(properties.getPort());
            factory.setChannel(properties.getChannel());
            // 认证信息配置
            if (properties.getUsername() != null) {
                factory.setStringProperty(WMQConstants.USERID, properties.getUsername());
            }
            if (properties.getPassword() != null) {
                factory.setStringProperty(WMQConstants.PASSWORD, properties.getPassword());
            }
            // 传输类型配置（客户端模式）
            factory.setTransportType(WMQConstants.WMQ_CM_CLIENT);
        } catch (MQException e) {
            throw new RuntimeException("创建第一个MQ连接工厂失败", e);
        }
        return factory;
    }

    @Bean("secondMQConnectionFactory")
    public MQConnectionFactory secondMQConnectionFactory(SecondMQProperties properties) {
        MQConnectionFactory factory = new MQConnectionFactory();
        try {
            factory.setQueueManager(properties.getQueueManager());
            factory.setHostName(properties.getHost());
            factory.setPort(properties.getPort());
            factory.setChannel(properties.getChannel());
            if (properties.getUsername() != null) {
                factory.setStringProperty(WMQConstants.USERID, properties.getUsername());
            }
            if (properties.getPassword() != null) {
                factory.setStringProperty(WMQConstants.PASSWORD, properties.getPassword());
            }
            factory.setTransportType(WMQConstants.WMQ_CM_CLIENT);
        } catch (MQException e) {
            throw new RuntimeException("创建第二个MQ连接工厂失败", e);
        }
        return factory;
    }

    // 可选：为每个Broker绑定独立的JmsTemplate
    @Bean("firstJmsTemplate")
    public JmsTemplate firstJmsTemplate(@Qualifier("firstMQConnectionFactory") MQConnectionFactory factory) {
        JmsTemplate template = new JmsTemplate();
        template.setConnectionFactory(factory);
        // 可添加默认队列、会话模式等自定义配置
        return template;
    }

    @Bean("secondJmsTemplate")
    public JmsTemplate secondJmsTemplate(@Qualifier("secondMQConnectionFactory") MQConnectionFactory factory) {
        JmsTemplate template = new JmsTemplate();
        template.setConnectionFactory(factory);
        return template;
    }
}

3. 配置文件中添加多Broker参数 #

在application.yml中配置两个MQ实例的具体参数：

mq:
  first:
    queue-manager: QM1
    host: mq-host-1
    port: 1414
    channel: CHANNEL1
    username: user1
    password: pass1
  second:
    queue-manager: QM2
    host: mq-host-2
    port: 1415
    channel: CHANNEL2
    username: user2
    password: pass2

关键说明 #

• Spring Boot 2.7.x版本的IBM MQ Starter确实移除了MQConnectionFactoryFactory，因此需手动实例化MQConnectionFactory并逐一配置属性。
• 继承MQConfigurationProperties可直接复用官方定义的所有配置项，避免重复造轮子。
• 每个Broker对应独立的MQConnectionFactory Bean，使用时通过@Qualifier注解指定具体实例即可。

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