如何获取ActiveMQ队列中的待处理消息？

1. STOMP协议本身无法直接获取待处理消息列表 #

STOMP是面向消息收发的轻量级协议，核心能力是生产/消费消息，没有内置命令用于查询队列中所有待处理消息的具体内容。虽然通过订阅队列可以接收消息，但这属于消费行为——消息被接收后会从队列中移除（除非配置了特定的持久化/ack模式），无法实现“仅浏览、不消费”的查询需求。

2. 可行方案及推荐库 #

方案一：调用ActiveMQ REST管理API #

ActiveMQ自带REST风格的管理接口，支持以“浏览”模式查询队列消息（不会消费消息），可以用Node.js的HTTP请求库（如axios、node-fetch）调用。

示例代码（使用axios）：

const axios = require('axios');

async function browsePendingQueue() {
  try {
    // 替换为你的ActiveMQ管理地址、队列名和账号密码
    const response = await axios.get('http://localhost:8161/api/message/queue/PENDING', {
      auth: {
        username: 'admin',
        password: 'admin'
      },
      params: {
        browse: true, // 启用浏览模式，不删除消息
        count: 50     // 指定获取的最大消息数量
      }
    });
    console.log('待处理消息列表:', response.data);
  } catch (err) {
    console.error('查询队列消息失败:', err.message);
  }
}

browsePendingQueue();

方案二：通过JMX管理接口查询 #

ActiveMQ支持JMX监控管理，Node.js可以用jmx库连接JMX服务器，查询队列的消息详情。

示例代码：

const jmx = require('jmx');

// 连接ActiveMQ的JMX服务（默认端口1099）
const jmxClient = jmx.createClient({
  host: 'localhost',
  port: 1099,
  username: 'admin',
  password: 'admin'
});

jmxClient.connect();

jmxClient.on('connect', () => {
  // 队列对应的MBean路径，替换为你的队列名
  const queueMBean = 'org.apache.activemq:type=Broker,brokerName=localhost,destinationType=Queue,destinationName=PENDING';
  
  // 调用browse方法获取消息列表
  jmxClient.invoke(queueMBean, 'browse', [], (err, messages) => {
    if (err) {
      console.error('获取消息失败:', err);
    } else {
      console.log('待处理消息详情:', messages);
    }
    jmxClient.disconnect();
  });
});

方案三：使用AMQP协议客户端（可选） #

如果可以切换协议，AMQP协议支持队列消息的浏览操作，推荐使用rhea库（Node.js的AMQP客户端），需要先在ActiveMQ中启用AMQP协议（默认端口5672）。

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