如何通过JMS消费者获取ActiveMQ Artemis队列长度？

一、标准JMS API的限制 #

标准javax.jms包中的MessageConsumer本身没有提供直接获取队列长度的方法——队列长度属于消息中间件Broker的管理属性，JMS作为抽象规范并未强制要求暴露该能力。

另外，想用Consumer实现"不读取消息"的长度统计也不可行：MessageConsumer的接收操作（同步receive()或异步监听）会将消息从队列中取出，即便使用CLIENT_ACKNOWLEDGE模式，未确认的消息会被Broker标记为"已消费但未确认"，不会留在原队列中，还会占用Broker资源，不符合你的需求。

二、优先基于javax.jms的替代方案 #

1. 优化QueueBrowser实现（标准JMS） #

你当前的QueueBrowser思路是标准JMS中唯一合规的无侵入统计方式，可优化代码减少内存占用——无需将所有消息存入List，直接计数即可：

QueueSession queueSession = null;
QueueConnectionFactory connectionFactory;
QueueConnection connection;
try {
    connectionFactory = new ActiveMQQueueConnectionFactory("tcp://" + urlBroker);
    connection = connectionFactory.createQueueConnection(login, password);
    connection.start(); // 必须启动连接，否则无法获取消息枚举
    queueSession = connection.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
    Queue queue = (Queue) initialContext.lookup("dynamicQueues/" + queueName);
    QueueBrowser queueBrowser = queueSession.createBrowser(queue);
    
    Enumeration<Message> messageEnumeration = queueBrowser.getEnumeration();
    int queueSize = 0;
    while (messageEnumeration.hasMoreElements()) {
        messageEnumeration.nextElement(); // 仅计数，不存储消息
        queueSize++;
    }
    System.out.println("队列长度：" + queueSize);
} catch (JMSException | NamingException e) {
    e.printStackTrace();
} finally {
    // 关闭资源避免泄漏
    try {
        if (queueSession != null) queueSession.close();
        if (connection != null) connection.close();
    } catch (JMSException e) {
        e.printStackTrace();
    }
}

2. ActiveMQ专属扩展（基于javax.jms实现类） #

如果你使用的是ActiveMQ，可以将Queue强转为ActiveMQ的实现类org.apache.activemq.command.ActiveMQQueue，调用其getQueueSize()方法——该方法通过Broker管理API直接获取长度，无需遍历消息，效率更高：

// 假设已通过JNDI获取到Queue实例
ActiveMQQueue activeMQQueue = (ActiveMQQueue) queue;
try {
    int queueSize = activeMQQueue.getQueueSize();
    System.out.println("队列长度：" + queueSize);
} catch (JMSException e) {
    e.printStackTrace();
}

注意：该方法属于ActiveMQ的扩展实现，并非标准JMS API，切换到其他中间件（如RabbitMQ、IBM MQ）时无法使用。

三、总结 #

• 标准JMS中MessageConsumer没有专属的队列长度统计方法，且无法通过Consumer实现"不读取消息"的统计；
• 最优标准方案是优化QueueBrowser代码，直接计数而非存储所有消息；
• ActiveMQ环境下可使用其扩展类的getQueueSize()方法提升效率。

内容的提问来源于stack exchange，提问作者PingvinAnbu