如何在Spring Boot中获取IBM MQ队列连接消费者数并清空队列

1. 获取队列的连接消费者数量 #

JMS规范本身并未定义统一的API来获取队列的消费者数量，具体实现依赖于你使用的MQ中间件（如ActiveMQ、Artemis等）。以下以ActiveMQ为例，通过JmsTemplate获取队列的消费者数量：

public String getConsumerCount(String qname) {
    log.info("Getting consumer count for queue: " + qname);
    try {
        return this.jmsTemplate.execute(session -> {
            // 针对ActiveMQ，转换为具体队列类型获取属性
            ActiveMQQueue queue = (ActiveMQQueue) session.createQueue(qname);
            Long consumerCount = queue.getConsumerCount();
            return consumerCount == null ? "0" : String.valueOf(consumerCount);
        }, true);
    } catch (JmsException ex) {
        log.error("Exception while fetching consumer count for qname {}: ", qname, ex.getMessage());
        return "FAIL";
    }
}

如果使用其他MQ（如Artemis），核心思路是通过JMS Session获取对应MQ实现的队列实例，调用其内置的统计方法即可。

2. 清空队列 #

清空队列有两种常用方式，一种是通用跨MQ方案，另一种是利用特定MQ的管理API实现高效清空：

方式一：通用跨MQ实现 #

通过循环接收队列中的所有消息完成清空，适配所有兼容JMS规范的MQ：

public String purgeQueue(String qname) {
    log.info("Purging queue: " + qname);
    try {
        this.jmsTemplate.execute(session -> {
            MessageConsumer consumer = session.createConsumer(session.createQueue(qname));
            // 设置100ms超时，避免无消息时阻塞
            while (consumer.receive(100) != null) {
                // 直接消费消息，不做额外处理
            }
            consumer.close();
            return null;
        }, true);
        log.info("Queue {} purged successfully", qname);
        return "SUCCESS";
    } catch (JmsException ex) {
        log.error("Exception while purging queue {}: ", qname, ex.getMessage());
        return "FAIL";
    }
}

方式二：ActiveMQ专属高效实现 #

如果使用ActiveMQ，可直接调用其内置的清空方法，效率更高：

public String purgeActiveMQQueue(String qname) {
    log.info("Purging ActiveMQ queue: " + qname);
    try {
        this.jmsTemplate.execute(session -> {
            ActiveMQQueue queue = (ActiveMQQueue) session.createQueue(qname);
            queue.purge(session);
            return null;
        }, true);
        log.info("ActiveMQ queue {} purged successfully", qname);
        return "SUCCESS";
    } catch (JmsException ex) {
        log.error("Exception while purging ActiveMQ queue {}: ", qname, ex.getMessage());
        return "FAIL";
    }
}

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