在Java中获取MQ队列统计信息

import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.JMSException;
import javax.jms.Queue;
import javax.jms.Session;
import javax.jms.MessageConsumer;
import javax.jms.MessageProducer;
import javax.jms.TextMessage;

public class MQQueueStats {
    private static final String MQ_URL = "tcp://localhost:61616"; // MQ的连接地址
    private static final String QUEUE_NAME = "YourQueueName"; // 队列名称

    public static void main(String[] args) {
        ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(MQ_URL);
        Connection connection = null;
        Session session = null;

        try {
            // 创建连接和会话
            connection = connectionFactory.createConnection();
            connection.start();
            session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);

            // 获取队列对象
            Queue queue = session.createQueue(QUEUE_NAME);

            // 创建消息消费者
            MessageConsumer consumer = session.createConsumer(queue);

            // 接收消息并处理
            while (true) {
                TextMessage message = (TextMessage) consumer.receive();
                if (message != null) {
                    System.out.println("Received message: " + message.getText());
                }
            }
        } catch (JMSException e) {
            e.printStackTrace();
        } finally {
            // 关闭连接和会话
            if (session != null) {
                try {
                    session.close();
                } catch (JMSException e) {
                    e.printStackTrace();
                }
            }
            if (connection != null) {
                try {
                    connection.close();
                } catch (JMSException e) {
                    e.printStackTrace();
                }
            }
        }
    }
}