java - 计算 JMS 队列上的消息时的奇怪行为

Question

我正在使用 Active MQ 和 Java JMS。

我想统计队列中消息的数量。

一种方法是使用浏览器计算消息数:

    Queue queue = (Queue) session.createQueue(subject);
    QueueBrowser queueBrowser = session.createBrowser(queue);
    Enumeration<?> e = queueBrowser.getEnumeration();
    int numMsgs = 0;
    // count number of messages
    while (e.hasMoreElements()) {
    //    Message m = (Message) e.nextElement();
        e.nextElement();
        numMsgs++;
    }

但对于具有 5000 个待处理请求的队列，这只会返回 500。

另一种方法是(迭代队列中的所有消息):

Message message= consumer.receive(500);
while(message!= null)
    {

        if (message instanceof TextMessage) 
        {
            TextMessage textMessage = (TextMessage) message;
       //     BytesMessage Byte

            System.out.println("Received message '"+ textMessage.getText() + "'");
        }
        if(message!=null)
            Messages_list.add(message);

        message = consumer.receive(1);
    } 

但这也没有给出正确数量的待处理消息。

我如何自信地迭代 akk 队列中等待的消息？

Answer 1

ActiveMQ 中有一个错误阻止浏览器返回实际的消息数。在这种情况下，浏览器仅返回单页消息，由 maxPageSize 属性设置并记录在此处:http://activemq.apache.org/per-destination-policies.html

ActiveMQ 目前有一个关于这个问题的错误报告，它正在这里被跟踪:https://issues.apache.org/jira/browse/AMQ-4181 .此问题已解决，目前计划在 ActiveMQ 5.8.0 中修复。