编写IBM MQ异步消费进程时如何查询队列消息大小与数量

标准JMS规范本身未定义队列消息总数、消息大小这类运行态元数据的查询接口，你代码中使用的QueueReceiver属于标准JMS接口实现，因此不提供对应查询能力，需要调用IBM MQ原生扩展能力获取统计信息，可根据业务场景选择以下三种实现方式：

方案1：轻量基础统计 - 读取MQQueue原生属性 #

你代码中实例化的MQQueue是IBM对JMS Queue接口的原生实现，自带队列基础统计属性，不需要额外创建管理连接，直接在现有代码基础上即可调用，适合只需要队列总消息数的轻量场景：

• 注意：该方式只能获取队列整体统计值，无法获取单条消息的明细属性

import com.ibm.mq.constants.CMQC;
// 将JMS Queue对象强转为IBM原生MQQueue类型
MQQueue mqQueue = (MQQueue) queue;
// 获取当前队列内的消息总数（当前队列深度）
int currentMsgCount = mqQueue.getIntProperty(CMQC.MQIA_CURRENT_Q_DEPTH);
// 获取队列配置的最大允许消息数
int maxMsgCount = mqQueue.getIntProperty(CMQC.MQIA_MAX_Q_DEPTH);
// 获取队列自启动以来达到过的最大消息数
int historyMaxDepth = mqQueue.getIntProperty(CMQC.MQIA_HIGH_Q_DEPTH);

方案2：高性能全量统计 - 使用PCF管理接口 #

如果需要获取消息总大小、队列配置参数等更全的统计字段，且队列深度较大（万级以上），推荐使用IBM MQ官方提供的PCF（可编程命令格式）接口查询，该方式直接从队列管理器读取统计值，不需要遍历队列消息，性能最高：

import com.ibm.mq.pcf.*;
import com.ibm.mq.MQQueueConnection;
import com.ibm.mq.MQQueueManager;

// 从现有JMS连接中获取原生队列管理器实例
MQQueueManager qMgr = ((MQQueueConnection)con).getMQQueueManager();
PCFMessageAgent agent = new PCFMessageAgent(qMgr);

// 构造队列查询请求
PCFMessage request = new PCFMessage(CMQCFC.MQCMD_INQUIRE_Q);
request.addParameter(CMQC.MQCA_Q_NAME, "myQueue");
request.addParameter(CMQC.MQIA_Q_TYPE, CMQC.MQQT_LOCAL);
// 指定需要返回的统计字段
request.addParameter(CMQCFC.MQIACF_Q_ATTRS, new int[] {
    CMQC.MQIA_CURRENT_Q_DEPTH,
    CMQC.MQIA_MAX_MSG_LENGTH,
    CMQC.MQIA_HIGH_Q_DEPTH,
    CMQC.MQIA_RETENTION_INTERVAL
});

// 执行查询解析结果
PCFMessage[] responses = agent.send(request);
for (PCFMessage response : responses) {
    int currentDepth = response.getIntParameterValue(CMQC.MQIA_CURRENT_Q_DEPTH);
    int maxSupportedMsgLength = response.getIntParameterValue(CMQC.MQIA_MAX_MSG_LENGTH);
    // 其余字段按需解析即可
}
agent.disconnect();

方案3：单条消息明细查询 - 使用QueueBrowser遍历 #

如果需要获取队列内每条消息的具体大小、消息头等明细属性，且队列深度不大，可以使用JMS标准的QueueBrowser做消息浏览，该操作不会消费队列内的消息，不会影响你现有异步监听的消费逻辑：

import javax.jms.QueueBrowser;
import java.util.Enumeration;

// 复用现有session创建队列浏览器
QueueBrowser browser = session.createBrowser(queue);
Enumeration<?> msgEnum = browser.getEnumeration();
long totalMsgSize = 0;
int msgCount = 0;

while (msgEnum.hasMoreElements()) {
    javax.jms.Message msg = (javax.jms.Message) msgEnum.nextElement();
    // 获取单条消息的字节长度
    long singleMsgSize = msg.getLongProperty("JMS_IBM_MsgLength");
    totalMsgSize += singleMsgSize;
    msgCount++;
}
browser.close();

注意事项 #

• 连接MQ使用的user1账号需要拥有目标队列的查询权限，否则调用上述接口会抛出权限不足异常
• 不建议在MessageListener.onMessage消费逻辑中频繁调用统计查询，建议单独起定时任务按固定频率（如10s/次）拉取统计值，避免占用核心消费线程资源
• 队列深度超过1万时不建议使用QueueBrowser遍历统计，遍历操作会占用队列管理器资源，影响正常消费性能，优先使用PCF接口查询整体统计值

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