Spring 引导 IBM 队列 - 发现所有目的地

Question

我正在编写一个小型 spring 引导应用程序，它应该监视外部 IBM Queue 安装上的队列。

我可以通过 MQXAQueueConnectionFactory 进行连接，但我还没有找到以编程方式发现该主机上所有远程 queues/destinations 的方法。我不想在我的代码中添加它们。

如何获取所有现有队列的列表以便添加侦听器？我必须提到，无法通过 REST-API 进行访问，因为该功能已被管理部门禁用。

Answer 1

可以使用IBM MQ Programmable Command Formats。如果您安装了 IBM MQ 样本，tools/pcf/samples/PCF_DisplayActiveLocalQueues.java 可以让您了解您的用例。

以下是我在单元测试中如何使用它来查找所有包含消息的队列：

import java.io.IOException;

import com.ibm.mq.MQException;
import com.ibm.mq.MQGetMessageOptions;
import com.ibm.mq.MQMessage;
import com.ibm.mq.MQQueue;
import com.ibm.mq.MQQueueManager;
import com.ibm.mq.constants.CMQC;
import com.ibm.mq.constants.CMQCFC;
import com.ibm.mq.constants.MQConstants;
import com.ibm.mq.headers.MQDataException;
import com.ibm.mq.headers.pcf.PCFMessage;
import com.ibm.mq.headers.pcf.PCFMessageAgent;

public class MqUtils {

    public static void queuesWithMessages(MQQueueManager qmgr) {
        try {
            PCFMessageAgent agent = new PCFMessageAgent(qmgr);
            try {
                PCFMessage request = new PCFMessage(CMQCFC.MQCMD_INQUIRE_Q);
                // NOTE: You can not use a queue name pattern like "FOO.*" together with
                // the "addFilterParameter" method. This is a limitation of PCF messages.
                // If you want to filter on queue names, you would have to do it in the
                // for loop after sending the PCF message.
                request.addParameter(CMQC.MQCA_Q_NAME, "*");
                request.addParameter(CMQC.MQIA_Q_TYPE, MQConstants.MQQT_LOCAL);
                request.addFilterParameter(CMQC.MQIA_CURRENT_Q_DEPTH, CMQCFC.MQCFOP_GREATER, 0);
                for (PCFMessage response : agent.send(request)) {
                    String queueName = (String) response.getParameterValue(CMQC.MQCA_Q_NAME);
                    if (queueName == null
                            || queueName.startsWith("SYSTEM")
                            || queueName.startsWith("AMQ")) {
                        continue;
                    }
                    Integer queueDepth = (Integer) response.getParameterValue(CMQC.MQIA_CURRENT_Q_DEPTH);
                    // Do something with this queue that has messages
                }
            } catch (MQException | IOException e) {
                throw new RuntimeException(e);
            } finally {
                agent.disconnect();
            }
        } catch (MQDataException e) {
            throw new RuntimeException(e);
        }
    }
}

这应该会让您了解如何配置 MQQueueManager（另请参阅 IBM docs）：

import com.ibm.mq.MQEnvironment;
import com.ibm.mq.MQException;
import com.ibm.mq.MQQueueManager;

@Configuration
static class MQConfig {

    @Bean(destroyMethod = "disconnect")
    public MQQueueManager mqQueueManager() throws MQException {
        MQEnvironment.hostname = "the.host.com";
        MQEnvironment.port = 1415;
        MQEnvironment.channel = "xxx.CL.FIX";
        return new MQQueueManager("xxx");
    }
}

第 Using with IBM MQ classes for JMS 章解释了如何在纯 JMS 中使用 PCF 消息。

Spring 引导 IBM 队列 - 发现所有目的地

Spring Boot IBM Queue - Discover all Destinations

jms

spring-boot