从 java 代码中获取队列深度

Question

任何人都可以帮助在 java 中编写获取队列深度的代码。我们在 IBM WebSphere MQ 中有 4 个队列，其中有消息。

我想编写一个 jsp 来在运行报告时读取队列名称及其深度。我怎么做？ 任何人都可以帮助获得完整的解决方案，因为我不知道该怎么做

Answer 1

我认为没有办法使用 JMS 检索队列深度。但是，您可以使用 MQ 系列特定的 Java API 来检索此信息。这是示例代码。关注int openOptions = MQC.MQOO_INQUIRE;

这里是reference guide

int depth = 0;
MQQueueManager qMgr; // define a queue manager object
String mqHost = "";
String mqPort = "";
String mqChannel = "";
String mqQMgr = "";
String mqQueue = "";
try {
    // Set up MQSeries environment
   MQEnvironment.hostname = mqHost;
   MQEnvironment.port = Integer.valueOf(mqPort).intValue();
   MQEnvironment.channel = mqChannel;
   MQEnvironment.properties.put(MQC.TRANSPORT_PROPERTY,
   MQC.TRANSPORT_MQSERIES);
   qMgr = new MQQueueManager(mqQMgr);
   int openOptions = MQC.MQOO_INQUIRE;
   MQQueue destQueue = qMgr.accessQueue(mqQueue, openOptions);
   depth = destQueue.getCurrentDepth();
   destQueue.close();
   qMgr.disconnect();
} catch (Exception err) {
   err.printStackTrace();
}

Answer 2

如果您从 IBM 下载安装 WMQ 客户端（而不是仅从 QMgr 安装中获取类库），您将获得示例代码。提供的示例中有几个列出队列名称、查询对象属性和创建对象。在 Win 7 上的默认安装中，这些可以在 C:\Program Files (x86)\IBM\WebSphere MQ\tools\pcf\samples 找到。

在此处下载 WMQ 客户端库：

• WMQ v6.0 为 SupportPac MQC6（生命周期结束于 2012 年 9 月）
• WMQ v7.0 为SupportPac MQC7
• WMQ v7.1 是SupportPac MQC71
• SupportPac 登录页面是 here。

强烈建议您使用最新的 WMQ 客户端进行任何新的开发。它适用于目标 QMgr 提供的任何功能级别的所有先前版本的 WMQ。请参阅信息中心的Compatibility & Interop statement。您可以从WMQ Library landing page 找到您正在使用的 WMQ 版本的服务器或客户端的信息中心。

Answer 3

其中一些函数在 IIB 中已被弃用，因此我粘贴了更新后的代码。它有效:)

享受

从 Java 获取 MQ 队列深度：

try {
        int depth = 0;
        MQQueueManager qMgr; // define a queue manager object
        String mqHost = "";
        String mqPort = "";
        String mqChannel = "";
        String mqQMgr = "";
        String mqQueue = "";
        try {
            // Set up MQSeries environment
           MQEnvironment.hostname = mqHost;
           MQEnvironment.port = Integer.valueOf(mqPort).intValue();
           MQEnvironment.channel = mqChannel;
           //MQEnvironment.properties.put(MQC.TRANSPORT_PROPERTY,MQC.TRANSPORT_MQSERIES);
           qMgr = new MQQueueManager(mqQMgr);
           //int openOptions = 1;//MQC.MQOO_INQUIRE;



           int openOptions = CMQC.MQOO_INQUIRE + CMQC.MQOO_FAIL_IF_QUIESCING + CMQC.MQOO_INPUT_SHARED;


           MQQueue destQueue = qMgr.accessQueue(mqQueue, openOptions);
           depth = destQueue.getCurrentDepth();
           destQueue.close();
           qMgr.disconnect();


            MbMessage outMessage = new MbMessage();
            outAssembly = new MbMessageAssembly(inAssembly, outMessage);
            MbElement root = outMessage.getRootElement();
            MbElement outXmlRoot =  root.createElementAsLastChild(MbXMLNSC.PARSER_NAME);
            MbElement Appointment = outXmlRoot.createElementAsLastChild(MbElement.TYPE_NAME, "RootElementXMLName", null);
            Appointment.createElementAsLastChild(MbElement.TYPE_NAME_VALUE, "Q_DepthFromServer", depth);        
            out.propagate(outAssembly);    
        }