如何获取连接到来自Java的Websphere MQ队列的消费者数

Question

我想从Java获取特定Websphere MQ队列的消费者数量？我需要知道是否有人会在将消息放入队列之前使用这些消息。

Answer 1

首先，值得注意的是，所提出的设计是一个非常非常糟糕的设计。其效果是将异步消息传递回同步消息。这将消息生成器与消费者相结合，引入位置和解决方案依赖关系，打破集群，挫败WMQ的负载分配和平衡，将网络拓扑嵌入应用程序，并使整个系统变得脆弱。请不要指责WMQ在故意击败除实际队列/出列操作之外的所有最佳功能后无法正常工作。

但是，要直接回答您的问题，请使用队列对象的getOpenInputCount方法来获取打开的输入句柄的数量。方法如下：

MQQueue outQ = qMgr.accessQueue(qName, 
           openOptions, 
           null,   // default q manager 
           null,   // no dynamic q name 
           null);   // no alternate user id 

int inCount = outQ.getOpenInputCount(); 

请注意，您只能查询本地队列上的输入句柄。如果队列托管在QMgr 其他之上，那么该方法将不起作用。当然，正常情况下，消息发送者和接收者将驻留在不同的QMgr上。然而，由于你没有提及设计，所以我将假设这个答案的目的是来自消息生产者和消费者的连接连接到同一个QMgr。如果情况并非如此，我们需要讨论PCF，甚至更强烈地警告设计。