任何简单的方法来获取ActiveMQ的队列长度？[已关闭]

java jms activemq

2022-09-04 02:32:22

如何使用Java在ActiveMQ中获取队列长度（发送到队列的未使用消息的数量）？

答案 1

您必须使用 JMX，因为队列接口不提供此类信息。

检索特定队列大小的示例：

// connection
String url = "service:jmx:rmi:///jndi/rmi://localhost:1099/jmxrmi";
JMXConnector connector = JMXConnectorFactory.connect(new JMXServiceURL(url));
MBeanServerConnection connection = connector.getMBeanServerConnection();
// get queue size
ObjectName nameConsumers = new ObjectName("org.apache.activemq:type=Broker,brokerName=localhost,destinationType=Queue,destinationName=myqueue");
DestinationViewMBean mbView = MBeanServerInvocationHandler.newProxyInstance(connection, nameConsumers, DestinationViewMBean.class, true);
long queueSize = mbView.getQueueSize();

参考：ActiveMQ JMX，必需的 MBean

示例：使用 JMX API 管理 ActiveMQ

答案 2

像这样;

QueueBrowser browser = session.createBrowser(queue);
Enumeration enu = browser.getEnumeration();
List list = new ArrayList();        
  while (enu.hasMoreElements()) {
    TextMessage message = (TextMessage) enu.nextElement();          
    list.add(message.getText());
   }
System.out.println("Size " + list.size());