文档建议反馈控制台
首页
学习
活动
专区
圈层
工具
MCP广场
文章/答案/技术大牛
发布
社区首页 >问答首页 >IBM-MQ PCF用于获取特定主题的订阅者计数

问IBM-MQ PCF用于获取特定主题的订阅者计数
EN

Stack Overflow用户
提问于 2020-09-15 17:15:58
回答 1查看 112关注 0票数 0

我正在使用IBM-MQ，并希望使用PCFMessage获取特定主题的订阅者数量

代码语言：javascript
复制
    MQQueueManager qmgr = null;
    PCFMessageAgent agent = null;
    
    Hashtable<String, Object> hashtable = new Hashtable<String,Object>();
    hashtable.put(MQConstants.HOST_NAME_PROPERTY,"HOST NAME");
    hashtable.put(MQConstants.PORT_PROPERTY,1414);
    hashtable.put(MQConstants.CHANNEL_PROPERTY,"CHANNEL NAME");
    hashtable.put(MQConstants.USER_ID_PROPERTY, "USER_ID");
    hashtable.put(MQConstants.PASSWORD_PROPERTY, "PASSWORD");
    
    agent = new PCFMessageAgent(qmgr);
    PCFMessage request = new PCFMessage(MQConstants.MQCMD_INQUIRE_TOPIC_STATUS);
    request.addParameter(MQConstants.MQCA_TOPIC_STRING, groupTopic);

这样的结果是

代码语言：javascript
复制
    MQCFH (com.ibm.mq.headers.internal.store.ByteStore [encoding: 0x00000001, ccsid: 1208, size: 36] @813045649)
        MQLONG Type: 2 (0x00000002)
        MQLONG StrucLength: 36 (0x00000024)
        MQLONG Version: 3 (0x00000003)
        MQLONG Command: 183 (0x000000b7)
        MQLONG MsgSeqNumber: 1 (0x00000001)
        MQLONG Control: 1 (0x00000001)
        MQLONG CompCode: 0 (0x00000000)
        MQLONG Reason: 0 (0x00000000)
        MQLONG ParameterCount: 22 (0x00000016)
MQCFST (com.ibm.mq.headers.internal.ReflectingStore [encoding: 0x00000001, ccsid: 1208])
        MQLONG Type: 4 (0x00000004)
        MQLONG StrucLength: 40 (0x00000028)
        MQLONG Parameter: 2094 (MQCA_TOPIC_STRING)
        MQLONG CodedCharSetId: 1208 (0x000004b8)
        MQLONG StringLength: 19 (0x00000013)
        MQCHAR[] String: "{grouplist}"
MQCFST (com.ibm.mq.headers.internal.ReflectingStore [encoding: 0x00000001, ccsid: 1208])
        MQLONG Type: 4 (0x00000004)
        MQLONG StrucLength: 68 (0x00000044)
        MQLONG Parameter: 2105 (MQCA_ADMIN_TOPIC_NAME)
        MQLONG CodedCharSetId: 1208 (0x000004b8)
        MQLONG StringLength: 48 (0x00000030)
        MQCHAR[] String: "                                                "
MQCFST (com.ibm.mq.headers.internal.ReflectingStore [encoding: 0x00000001, ccsid: 1208])
        MQLONG Type: 4 (0x00000004)
        MQLONG StrucLength: 20 (0x00000014)
        MQLONG Parameter: 2029 (MQCA_CLUSTER_NAME)
        MQLONG CodedCharSetId: 1208 (0x000004b8)
        MQLONG StringLength: 0 (0x00000000)
        MQCHAR[] String: ""
MQCFST (com.ibm.mq.headers.internal.ReflectingStore [encoding: 0x00000001, ccsid: 1208])
        MQLONG Type: 4 (0x00000004)
        MQLONG StrucLength: 68 (0x00000044)
        MQLONG Parameter: 2110 (MQCA_COMM_INFO_NAME)
        MQLONG CodedCharSetId: 1208 (0x000004b8)
        MQLONG StringLength: 48 (0x00000030)
        MQCHAR[] String: "SYSTEM.DEFAULT.COMMINFO.MULTICAST               "
MQCFST (com.ibm.mq.headers.internal.ReflectingStore [encoding: 0x00000001, ccsid: 1208])
        MQLONG Type: 4 (0x00000004)
        MQLONG StrucLength: 68 (0x00000044)
        MQLONG Parameter: 2096 (MQCA_MODEL_DURABLE_Q)
        MQLONG CodedCharSetId: 1208 (0x000004b8)
        MQLONG StringLength: 48 (0x00000030)
        MQCHAR[] String: "SYSTEM.DURABLE.MODEL.QUEUE                      "
MQCFST (com.ibm.mq.headers.internal.ReflectingStore [encoding: 0x00000001, ccsid: 1208])
        MQLONG Type: 4 (0x00000004)
        MQLONG StrucLength: 68 (0x00000044)
        MQLONG Parameter: 2097 (MQCA_MODEL_NON_DURABLE_Q)
        MQLONG CodedCharSetId: 1208 (0x000004b8)
        MQLONG StringLength: 48 (0x00000030)
        MQCHAR[] String: "SYSTEM.NDURABLE.MODEL.QUEUE                     "
MQCFIN (com.ibm.mq.headers.internal.ReflectingStore [encoding: 0x00000001, ccsid: 1208])
        MQLONG Type: 3 (0x00000003)
        MQLONG StrucLength: 16 (0x00000010)
        MQLONG Parameter: 255 (MQIA_CLUSTER_PUB_ROUTE)
        MQLONG Value: 2 (0x00000002)
MQCFIN (com.ibm.mq.headers.internal.ReflectingStore [encoding: 0x00000001, ccsid: 1208])
        MQLONG Type: 3 (0x00000003)
        MQLONG StrucLength: 16 (0x00000010)
        MQLONG Parameter: 185 (MQIA_TOPIC_DEF_PERSISTENCE)
        MQLONG Value: 0 (0x00000000)
MQCFIN (com.ibm.mq.headers.internal.ReflectingStore [encoding: 0x00000001, ccsid: 1208])
        MQLONG Type: 3 (0x00000003)
        MQLONG StrucLength: 16 (0x00000010)
        MQLONG Parameter: 6 (MQIA_DEF_PRIORITY)
        MQLONG Value: 0 (0x00000000)
MQCFIN (com.ibm.mq.headers.internal.ReflectingStore [encoding: 0x00000001, ccsid: 1208])
        MQLONG Type: 3 (0x00000003)
        MQLONG StrucLength: 16 (0x00000010)
        MQLONG Parameter: 184 (MQIA_DEF_PUT_RESPONSE_TYPE)
        MQLONG Value: 1 (0x00000001)
MQCFIN (com.ibm.mq.headers.internal.ReflectingStore [encoding: 0x00000001, ccsid: 1208])
        MQLONG Type: 3 (0x00000003)
        MQLONG StrucLength: 16 (0x00000010)
        MQLONG Parameter: 175 (MQIA_DURABLE_SUB)
        MQLONG Value: 1 (0x00000001)
MQCFIN (com.ibm.mq.headers.internal.ReflectingStore [encoding: 0x00000001, ccsid: 1208])
        MQLONG Type: 3 (0x00000003)
        MQLONG StrucLength: 16 (0x00000010)
        MQLONG Parameter: 181 (MQIA_INHIBIT_PUB)
        MQLONG Value: 2 (0x00000002)
MQCFIN (com.ibm.mq.headers.internal.ReflectingStore [encoding: 0x00000001, ccsid: 1208])
        MQLONG Type: 3 (0x00000003)
        MQLONG StrucLength: 16 (0x00000010)
        MQLONG Parameter: 182 (MQIA_INHIBIT_SUB)
        MQLONG Value: 2 (0x00000002)
MQCFIN (com.ibm.mq.headers.internal.ReflectingStore [encoding: 0x00000001, ccsid: 1208])
        MQLONG Type: 3 (0x00000003)
        MQLONG StrucLength: 16 (0x00000010)
        MQLONG Parameter: 195 (MQIA_PM_DELIVERY)
        MQLONG Value: 2 (0x00000002)
MQCFIN (com.ibm.mq.headers.internal.ReflectingStore [encoding: 0x00000001, ccsid: 1208])
        MQLONG Type: 3 (0x00000003)
        MQLONG StrucLength: 16 (0x00000010)
        MQLONG Parameter: 196 (MQIA_NPM_DELIVERY)
        MQLONG Value: 3 (0x00000003)
MQCFIN (com.ibm.mq.headers.internal.ReflectingStore [encoding: 0x00000001, ccsid: 1208])
        MQLONG Type: 3 (0x00000003)
        MQLONG StrucLength: 16 (0x00000010)
        MQLONG Parameter: 1300 (MQIACF_RETAINED_PUBLICATION)
        MQLONG Value: 0 (0x00000000)
MQCFIN (com.ibm.mq.headers.internal.ReflectingStore [encoding: 0x00000001, ccsid: 1208])
        MQLONG Type: 3 (0x00000003)
        MQLONG StrucLength: 16 (0x00000010)
        MQLONG Parameter: 176 (MQIA_MULTICAST)
        MQLONG Value: 2 (0x00000002)
MQCFIN (com.ibm.mq.headers.internal.ReflectingStore [encoding: 0x00000001, ccsid: 1208])
        MQLONG Type: 3 (0x00000003)
        MQLONG StrucLength: 16 (0x00000010)
        MQLONG Parameter: 215 (MQIA_PUB_COUNT)
        MQLONG Value: 1 (0x00000001)
MQCFIN (com.ibm.mq.headers.internal.ReflectingStore [encoding: 0x00000001, ccsid: 1208])
        MQLONG Type: 3 (0x00000003)
        MQLONG StrucLength: 16 (0x00000010)
        MQLONG Parameter: 204 (MQIA_SUB_COUNT)
        MQLONG Value: 48 (0x00000030)
MQCFIN (com.ibm.mq.headers.internal.ReflectingStore [encoding: 0x00000001, ccsid: 1208])
        MQLONG Type: 3 (0x00000003)
        MQLONG StrucLength: 16 (0x00000010)
        MQLONG Parameter: 219 (MQIA_PUB_SCOPE)
        MQLONG Value: 0 (0x00000000)
MQCFIN (com.ibm.mq.headers.internal.ReflectingStore [encoding: 0x00000001, ccsid: 1208])
        MQLONG Type: 3 (0x00000003)
        MQLONG StrucLength: 16 (0x00000010)
        MQLONG Parameter: 218 (MQIA_SUB_SCOPE)
        MQLONG Value: 0 (0x00000000)
MQCFIN (com.ibm.mq.headers.internal.ReflectingStore [encoding: 0x00000001, ccsid: 1208])
        MQLONG Type: 3 (0x00000003)
        MQLONG StrucLength: 16 (0x00000010)
        MQLONG Parameter: 234 (MQIA_USE_DEAD_LETTER_Q)
        MQLONG Value: 2 (0x00000002)

我期望的是通过上面的代码获得groupTopic的用户数量。但MQConstants.MQIA_SUB_COUNT的值始终固定为48。我想知道我是不是错误地使用了PCFMessage，或者是否有其他方法可以获得主题的订阅者数量。

java
ibm-mq
EN

回答 1

Stack Overflow用户

回答已采纳

发布于 2020-09-15 23:49:20

正如马克在他的评论中所说的，您应该执行MQSC命令DISPLAY TPSTATUS(xxxx) TYPE(TOPIC)。我更喜欢显式地设置PCF参数，这样我就知道将返回什么。

对MQCMD_INQUIRE_TOPIC_STATUS的PCF命令进行编码，遵循MQ KnowLedge Center中的规则

因此，代码应该是：

代码语言：javascript
复制
request = new PCFMessage(CMQCFC.MQCMD_INQUIRE_TOPIC_STATUS); 
request.addParameter(CMQC.MQCA_TOPIC_STRING, groupTopic);
request.addParameter(CMQCFC.MQIACF_TOPIC_STATUS_TYPE, CMQCFC.MQIACF_TOPIC_STATUS);
request.addParameter(CMQCFC.MQIACF_TOPIC_STATUS_ATTRS, new int [] { CMQCFC.MQIACF_ALL });

responses = agent.send(request);

for (int i = 0; i < responses.length; i++)
{
   // Make sure that each response is ok
   if ((responses[i]).getCompCode() == CMQC.MQCC_OK)
   {
      topicStr = responses[i].getStringParameterValue(CMQC.MQCA_TOPIC_STRING);
      topicName= responses[i].getStringParameterValue(CMQC.MQCA_ADMIN_TOPIC_NAME);
      durable  = responses[i].getIntParameterValue(CMQC.MQIA_DURABLE_SUB);
      persist  = responses[i].getIntParameterValue(CMQC.MQIA_TOPIC_DEF_PERSISTENCE);
      inh_Pub  = responses[i].getIntParameterValue(CMQC.MQIA_INHIBIT_PUB);
      inh_Sub  = responses[i].getIntParameterValue(CMQC.MQIA_INHIBIT_SUB);
      pubCount = responses[i].getIntParameterValue(CMQC.MQIA_PUB_COUNT);
      subCount = responses[i].getIntParameterValue(CMQC.MQIA_SUB_COUNT);
   }
}

因此，上述PCF代码相当于以下MQSC命令：

代码语言：javascript
复制
DISPLAY TPSTATUS(xxxx) TYPE(TOPIC) ALL
票数 2
EN
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接：

https://stackoverflow.com/questions/63898748

复制
相关文章

相似问题

领券

腾讯云开发者

扫码关注腾讯云开发者

扫码关注腾讯云开发者

领取腾讯云代金券

热门产品

热门推荐

更多推荐

Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有 

深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 粤公网安备44030502008569号

腾讯云计算（北京）有限责任公司 京ICP证150476号 |  京ICP备11018762号

问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档