在Java中获取MQ队列统计信息

Question

从我的应用程序中,我需要查询一些Websphere MQ每队列统计信息(最后消息获取/放置时间,en/dequeued消息数,当前队列深度,连接客户端数).我设法通过PCFAgent获得队列深度,但我有点坚持其余,因为IBM文档相当混乱.

您是否知道可能有用的任何有用的参考(或代码示例)？

Answer 1

如果您将WMQ客户端安装在默认位置,则样本将位于:C:\Program Files (x86)\IBM\WebSphere MQ\tools\pcf\samples.

在UNIX风格上,它们最终会在/opt/mqm/samp.

如果您只是抓住了jar文件并且没有安装客户端,那么您将没有受支持的配置 - 或示例,跟踪实用程序,诊断工具等等.客户端安装媒体可以在SupportPacs中免费下载页面.目前可用的不同客户是:

• 版本6.0是SupportPac MQC6(V6是2012年9月底)
• 7.0版是SupportPac MQC7
• 版本7.1是SupportPac MQC71

确保您正在查看Infocenter以获取要连接的WebSphere MQ Server版本.另请注意,如果连接到v7 QMgr并使用v6客户端,则您使用的常量和类将限制您使用v6功能.最好使用最新的客户端,因为它总是向后兼容较旧的QMgr版本.

更新:

以下是一些代码片段,用于执行所请求的功能:

首先,您需要一个队列管理器连接(qmgr).然后你可以创建一个PCFMessageAgent:

// Create PCF Message Agent
try {
    pcfAgent = new PCFMessageAgent(qmgr);
} catch (MQException mqe) {
    System.err.println("PCF Message Agent creation ended with reason code "
                       + mqe.reasonCode);
    return mqe.reasonCode;
}

您可以使用下面的调用获得所需的大多数属性(enq/deq计数除外).请注意,为了获得最后的msg get\put时间,您需要打开队列监视(MONQ).

// Prepare PCF command to inquire queue status (status type)
inquireQueueStatus = new PCFMessage(CMQCFC.MQCMD_INQUIRE_Q_STATUS);
inquireQueueStatus.addParameter(CMQC.MQCA_Q_NAME, "name of queue to inquire");
inquireQueueStatus.addParameter(CMQCFC.MQIACF_Q_STATUS_TYPE, CMQCFC.MQIACF_Q_STATUS);
inquireQueueStatus.addParameter(CMQCFC.MQIACF_Q_STATUS_ATTRS, new int[] {
                  CMQC.MQCA_Q_NAME, CMQC.MQIA_CURRENT_Q_DEPTH,
                  CMQCFC.MQCACF_LAST_GET_DATE, CMQCFC.MQCACF_LAST_GET_TIME,
                  CMQCFC.MQCACF_LAST_PUT_DATE, CMQCFC.MQCACF_LAST_PUT_TIME,
                  CMQCFC.MQIACF_OLDEST_MSG_AGE, CMQC.MQIA_OPEN_INPUT_COUNT,
                  CMQC.MQIA_OPEN_OUTPUT_COUNT, CMQCFC.MQIACF_UNCOMMITTED_MSGS });

您可以使用以下方法检索parms:

pcfResp = pcfAgent.send(inquireQueueStatus);

对于每个单独的parms,您可以使用该getXXXXXParameterValue方法(XXXXXX是数据的类型).

对于Enq/Deq计数,您需要重置队列统计信息:

// Prepare PCF command to reset queue statistics
queueResetStats = new PCFMessage(CMQCFC.MQCMD_RESET_Q_STATS);
queueResetStats.addParameter(CMQC.MQCA_Q_NAME, queueName);

pcfResp3 = pcfAgent.send(queueResetStats);

queueMsgDeqCount = pcfResp3[0].getIntParameterValue(CMQC.MQIA_MSG_DEQ_COUNT);
queueMsgEnqCount = pcfResp3[0].getIntParameterValue(CMQC.MQIA_MSG_ENQ_COUNT);

如果您有更多问题,请与我们联系.