Java中如何通过单JmsTemplate连接多台不同配置的IBM队列管理器并清理队列

不行，单个JmsTemplate无法通过单一MQQueueConnectionFactory连接多个队列管理器（QM）。原因很简单：MQQueueConnectionFactory是为单个QM实例设计的，每个QM都有独立的主机地址、端口、通道、队列管理器名称等配置参数，无法在一个Factory实例中同时配置多套连接信息。

解决方案：配置多套ConnectionFactory与JmsTemplate #

最直接可靠的方式是为每台QM分别配置独立的MQQueueConnectionFactory和对应的JmsTemplate，然后批量执行队列清理操作。以下是Spring环境下的实现示例：

1. 配置多套ConnectionFactory和JmsTemplate

import com.ibm.mq.jms.MQQueueConnectionFactory;
import com.ibm.msg.client.wmq.WMQConstants;
import org.springframework.context.annotation.Bean;
import org.springframework.jms.core.JmsTemplate;
import org.springframework.stereotype.Component;
import org.springframework.beans.factory.annotation.Qualifier;

@Component
public class MQConfig {
    // 第一台QM的连接配置
    @Bean("qm1ConnectionFactory")
    public MQQueueConnectionFactory qm1ConnectionFactory() {
        MQQueueConnectionFactory factory = new MQQueueConnectionFactory();
        factory.setHostName("host1.example.com");
        factory.setPort(1414);
        factory.setQueueManager("QMGR1");
        factory.setChannel("SYSTEM.DEF.SVRCONN"); // 根据实际通道名修改
        factory.setTransportType(WMQConstants.WMQ_CM_CLIENT);
        // 如需认证，添加以下配置
        // factory.setStringProperty(WMQConstants.USERID, "mquser");
        // factory.setStringProperty(WMQConstants.PASSWORD, "mqpass");
        return factory;
    }

    @Bean("qm1JmsTemplate")
    public JmsTemplate qm1JmsTemplate(@Qualifier("qm1ConnectionFactory") MQQueueConnectionFactory factory) {
        JmsTemplate template = new JmsTemplate(factory);
        template.setDefaultDestinationName("YOUR_TARGET_QUEUE"); // 统一目标队列名
        return template;
    }

    // 第二台QM的连接配置
    @Bean("qm2ConnectionFactory")
    public MQQueueConnectionFactory qm2ConnectionFactory() {
        MQQueueConnectionFactory factory = new MQQueueConnectionFactory();
        factory.setHostName("host2.example.com");
        factory.setPort(1415);
        factory.setQueueManager("QMGR2");
        factory.setChannel("SYSTEM.DEF.SVRCONN");
        factory.setTransportType(WMQConstants.WMQ_CM_CLIENT);
        return factory;
    }

    @Bean("qm2JmsTemplate")
    public JmsTemplate qm2JmsTemplate(@Qualifier("qm2ConnectionFactory") MQQueueConnectionFactory factory) {
        JmsTemplate template = new JmsTemplate(factory);
        template.setDefaultDestinationName("YOUR_TARGET_QUEUE");
        return template;
    }

    // 第三台QM的连接配置
    @Bean("qm3ConnectionFactory")
    public MQQueueConnectionFactory qm3ConnectionFactory() {
        MQQueueConnectionFactory factory = new MQQueueConnectionFactory();
        factory.setHostName("host3.example.com");
        factory.setPort(1416);
        factory.setQueueManager("QMGR3");
        factory.setChannel("SYSTEM.DEF.SVRCONN");
        factory.setTransportType(WMQConstants.WMQ_CM_CLIENT);
        return factory;
    }

    @Bean("qm3JmsTemplate")
    public JmsTemplate qm3JmsTemplate(@Qualifier("qm3ConnectionFactory") MQQueueConnectionFactory factory) {
        JmsTemplate template = new JmsTemplate(factory);
        template.setDefaultDestinationName("YOUR_TARGET_QUEUE");
        return template;
    }
}

2. 批量清理队列数据

import org.springframework.jms.core.JmsTemplate;
import org.springframework.stereotype.Service;
import javax.jms.Message;
import javax.jms.JMSException;
import org.springframework.beans.factory.annotation.Qualifier;

@Service
public class QueueCleanupService {
    private final JmsTemplate qm1JmsTemplate;
    private final JmsTemplate qm2JmsTemplate;
    private final JmsTemplate qm3JmsTemplate;

    // 构造注入（Spring 4.3+支持）
    public QueueCleanupService(@Qualifier("qm1JmsTemplate") JmsTemplate qm1JmsTemplate,
                               @Qualifier("qm2JmsTemplate") JmsTemplate qm2JmsTemplate,
                               @Qualifier("qm3JmsTemplate") JmsTemplate qm3JmsTemplate) {
        this.qm1JmsTemplate = qm1JmsTemplate;
        this.qm2JmsTemplate = qm2JmsTemplate;
        this.qm3JmsTemplate = qm3JmsTemplate;
    }

    public void clearAllTargetQueues() {
        clearSingleQueue(qm1JmsTemplate);
        clearSingleQueue(qm2JmsTemplate);
        clearSingleQueue(qm3JmsTemplate);
    }

    private void clearSingleQueue(JmsTemplate template) {
        // 循环接收消息，直到超时（1秒）无消息返回，说明队列已空
        while (true) {
            Message message = template.receive(1000);
            if (message == null) {
                break;
            }
            // 可选：记录被清理的消息ID或内容
            try {
                System.out.println("清理消息：" + message.getJMSMessageID());
            } catch (JMSException e) {
                e.printStackTrace();
            }
        }
    }
}

补充说明 #

如果你的三台QM属于同一个MQ集群，且目标队列是集群共享队列，那么清理其中一个节点的队列数据会同步到集群其他节点，这种情况下只需配置一套ConnectionFactory即可。但如果是独立队列（每个QM上都有同名的本地队列），则必须按上述方案分别连接清理。

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