嘿，我来帮你搞定用Java获取IBM MQ队列深度及其他指标的需求！下面是一步步的实操指南，都是基于官方的IBM MQ Java客户端库来实现的。

第一步：准备依赖 #

首先得把IBM MQ的Java客户端依赖加到你的项目里。如果用Maven的话，在pom.xml里加这段：

<dependency>
    <groupId>com.ibm.mq</groupId>
    <artifactId>com.ibm.mq.allclient</artifactId>
    <version>9.3.3.0</version> <!-- 可以替换为最新稳定版 -->
</dependency>

第二步：核心实现代码 #

下面是一个完整的示例，演示如何连接MQ管理器、查询指定队列的关键指标：

import com.ibm.mq.MQException;
import com.ibm.mq.MQQueue;
import com.ibm.mq.MQQueueManager;
import com.ibm.mq.constants.CMQC;

public class MQMonitor {

    public static void main(String[] args) {
        // MQ连接参数，替换成你的实际配置
        String queueManagerName = "YOUR_QMGR_NAME";
        String channelName = "YOUR_CHANNEL_NAME";
        String host = "YOUR_MQ_HOST";
        int port = 1414; // MQ默认端口，可根据实际修改
        String queueName = "YOUR_TARGET_QUEUE";

        MQQueueManager queueManager = null;
        MQQueue queue = null;

        try {
            // 设置连接属性
            java.util.Hashtable<String, Object> props = new java.util.Hashtable<>();
            props.put(CMQC.CHANNEL_PROPERTY, channelName);
            props.put(CMQC.HOST_NAME_PROPERTY, host);
            props.put(CMQC.PORT_PROPERTY, port);
            props.put(CMQC.TRANSPORT_PROPERTY, CMQC.TRANSPORT_MQSERIES_CLIENT);

            // 连接到队列管理器
            queueManager = new MQQueueManager(queueManagerName, props);
            System.out.println("成功连接到队列管理器: " + queueManagerName);

            // 打开队列，需要INQUIRE权限
            int openOptions = CMQC.MQOO_INQUIRE;
            queue = queueManager.accessQueue(queueName, openOptions);

            // 定义要查询的队列属性ID
            int[] inquireAttrs = {
                CMQC.MQCA_Q_NAME,          // 队列名称
                CMQC.MQIA_CURRENT_Q_DEPTH, // 当前队列深度
                CMQC.MQIA_MAX_Q_DEPTH,     // 队列最大深度
                CMQC.MQIA_OPEN_INPUT_COUNT,// 打开的输入句柄数（活跃生产者数量）
                CMQC.MQIA_OPEN_OUTPUT_COUNT,// 打开的输出句柄数（活跃消费者数量）
                CMQC.MQIA_UNCOMMITTED_MSGS // 未提交的事务消息数
            };

            // 查询属性
            Object[] attrValues = queue.inquire(inquireAttrs);

            // 解析并打印结果
            String qName = (String) attrValues[0];
            int currentDepth = (Integer) attrValues[1];
            int maxDepth = (Integer) attrValues[2];
            int inputHandles = (Integer) attrValues[3];
            int outputHandles = (Integer) attrValues[4];
            int uncommittedMsgs = (Integer) attrValues[5];

            System.out.println("=== 队列 " + qName + " 指标 ===");
            System.out.println("当前队列深度: " + currentDepth);
            System.out.println("队列最大深度: " + maxDepth);
            System.out.println("活跃生产者数量: " + inputHandles);
            System.out.println("活跃消费者数量: " + outputHandles);
            System.out.println("未提交事务消息数: " + uncommittedMsgs);

        } catch (MQException e) {
            System.err.println("MQ操作异常: 原因码=" + e.reasonCode + ", 完成码=" + e.completionCode);
            e.printStackTrace();
        } finally {
            // 务必关闭资源，避免MQ资源泄漏
            try {
                if (queue != null) {
                    queue.close();
                }
                if (queueManager != null) {
                    queueManager.disconnect();
                }
            } catch (MQException e) {
                e.printStackTrace();
            }
        }
    }
}

第三步：关键指标说明 #

这里解释下代码里用到的几个核心指标：

• 当前队列深度: 队列中等待被消费的消息总数，是监控队列拥堵情况的核心指标
• 队列最大深度: 队列配置的最大消息容量，超过这个值新消息会被拒绝（除非配置了溢出队列）
• 活跃生产者数量: 当前有多少应用程序打开了队列的输入句柄，正在往队列发消息
• 活跃消费者数量: 当前有多少应用程序打开了队列的输出句柄，正在从队列消费消息
• 未提交事务消息数: 处于事务中还未提交/回滚的消息，这类消息不会被消费者读取

注意事项 #

• 权限问题: 连接MQ的用户必须拥有目标队列的INQUIRE权限，否则会抛出权限不足的异常
• 资源关闭: 一定要在finally块里关闭队列和队列管理器连接，避免MQ资源泄漏
• 异常处理: MQ操作可能抛出MQException，建议根据reasonCode做针对性处理（比如队列不存在、连接超时等）
• 批量查询: 如果需要监控多个队列，可以循环调用accessQueue和inquire方法，或者使用队列管理器的查询方法批量获取队列列表

如果还有其他细节要调整，比如监控队列管理器级别的指标（比如通道状态、连接数），或者实现定时监控，随时问哈！

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