求MQ的队列深度

Question

我想找到MQ当前的队列深度。我的程序可以读取和写入队列。我能够编写一个消费者来消费队列中的消息。我可以使用计数器来计算队列中有多少消息。但我需要找到队列深度而不丢失消息。try {        // Create a connection factory        JmsFactoryFactory ff = JmsFactoryFactory.getInstance(WMQConstants.WMQ_PROVIDER);        JmsConnectionFactory cf = ff.createConnectionFactory();        // Set the properties        cf.setStringProperty(WMQConstants.WMQ_HOST_NAME, HOST);        cf.setIntProperty(WMQConstants.WMQ_PORT, PORT);        cf.setStringProperty(WMQConstants.WMQ_CHANNEL, CHANNEL);        cf.setIntProperty(WMQConstants.WMQ_CONNECTION_MODE, WMQConstants.WMQ_CM_CLIENT);        cf.setStringProperty(WMQConstants.WMQ_QUEUE_MANAGER, QMGR);        cf.setStringProperty(WMQConstants.WMQ_APPLICATIONNAME, "JmsPutGet (JMS)");        cf.setBooleanProperty(WMQConstants.USER_AUTHENTICATION_MQCSP, true);        cf.setStringProperty(WMQConstants.USERID, APP_USER);        cf.setStringProperty(WMQConstants.PASSWORD, APP_PASSWORD);        // Create JMS objects        context = cf.createContext();        destination = context.createQueue("queue:///" + QUEUE_NAME);        long uniqueNumber = System.currentTimeMillis() % 1000;        TextMessage message = context.createTextMessage("Your lucky number today is " + uniqueNumber);        producer = context.createProducer();        producer.send(destination, message);        System.out.println("Sent message:\n" + message);        consumer = context.createConsumer(destination); // autoclosable        String receivedMessage = consumer.receiveBody(String.class, 15000); // in ms or 15 seconds        System.out.println("\nReceived message:\n" + receivedMessage);        recordSuccess();    }代码应该打印队列深度。

Answer 1

队列深度可以通过浏览消息来统计。浏览不消耗消息。

Connection connection = connectionFactory.createConnection();

connection.start();

Session session = connection.createSession(false, Session.DUPS_OK_ACKNOWLEDGE);

Queue q = session.createQueue("exampe_queue");

QueueBrowser browser = session.createBrowser(q);

Enumeration enumeration = browser.getEnumeration();

long msgCounter = 0;

while (enumeration.hasMoreElements()) {

    Message msg = (Message) enumeration.nextElement();

    msgCounter += 1;

}

System.out.println("Queue depth: " + msgCounter);

然而，当客户端从代理中提取消息时，这种方法非常慢。如果您需要偶尔检查队列深度以进行监控或类似目的，那么它会起作用。

更好的解决方案是使用 get-me-aq-depth 调用，但这不是 JMS api 指定的；然而，它通常存在于特定于实现的库中。