如何通过stomp.py或stomp-js清除ActiveMQ队列？

可以实现，但STOMP协议本身没有提供直接清除/删除队列的标准命令，需要借助ActiveMQ的管理队列机制或REST管理API结合STOMP客户端来操作，具体方式如下：

1. 使用stomp.py操作 #

方法一：发送命令到ActiveMQ管理队列 #

ActiveMQ提供了ActiveMQ.Advisory.Command队列用于接收管理命令，通过stomp.py发送指定格式的消息即可清除或删除队列：

import stomp

# 建立STOMP连接
conn = stomp.Connection([('localhost', 61613)])
conn.connect('admin', 'admin', wait=True)

# 清除指定队列
purge_cmd = str({'command': 'purge', 'destination': '/queue/your-target-queue'})
conn.send(body=purge_cmd, destination='ActiveMQ.Advisory.Command')

# 删除指定队列（谨慎操作，队列及消息会被完全移除）
remove_cmd = str({'command': 'remove', 'destination': '/queue/your-target-queue'})
conn.send(body=remove_cmd, destination='ActiveMQ.Advisory.Command')

conn.disconnect()

注意：连接用户需具备ActiveMQ的管理权限（如admin角色）。

方法二：调用ActiveMQ REST管理API #

结合Python的requests库直接调用API，无需依赖STOMP协议：

import requests

# 清除队列
purge_response = requests.delete(
    'http://localhost:8161/api/jolokia/exec/org.apache.activemq:type=Broker,brokerName=localhost,destinationType=Queue,destinationName=your-target-queue/purge()',
    auth=('admin', 'admin')
)

# 删除队列
remove_response = requests.delete(
    'http://localhost:8161/api/jolokia/exec/org.apache.activemq:type=Broker,brokerName=localhost,destinationType=Queue,destinationName=your-target-queue/remove()',
    auth=('admin', 'admin')
)

2. Angular TypeScript中使用stomp-js操作 #

方法一：通过管理队列发送命令 #

利用stomp-js连接后，向ActiveMQ.Advisory.Command队列发送管理命令：

import { Client } from '@stomp/stompjs';

const stompClient = new Client({
  brokerURL: 'ws://localhost:61614/ws',
  connectHeaders: { login: 'admin', passcode: 'admin' }
});

stompClient.activate();

stompClient.onConnect = () => {
  // 清除队列
  const purgeCmd = JSON.stringify({
    command: 'purge',
    destination: '/queue/your-target-queue'
  });
  stompClient.publish({ destination: 'ActiveMQ.Advisory.Command', body: purgeCmd });

  // 删除队列
  const removeCmd = JSON.stringify({
    command: 'remove',
    destination: '/queue/your-target-queue'
  });
  stompClient.publish({ destination: 'ActiveMQ.Advisory.Command', body: removeCmd });

  stompClient.deactivate();
};

方法二：调用REST API（Angular HttpClient） #

在Angular中通过HttpClient直接调用ActiveMQ的管理API：

import { HttpClient, HttpHeaders } from '@angular/common/http';

constructor(private http: HttpClient) {}

// 清除队列
purgeQueue(queueName: string) {
  const authHeader = new HttpHeaders({
    'Authorization': 'Basic ' + btoa('admin:admin')
  });
  return this.http.delete(
    `http://localhost:8161/api/jolokia/exec/org.apache.activemq:type=Broker,brokerName=localhost,destinationType=Queue,destinationName=${queueName}/purge()`,
    { headers: authHeader }
  );
}

// 删除队列
deleteQueue(queueName: string) {
  const authHeader = new HttpHeaders({
    'Authorization': 'Basic ' + btoa('admin:admin')
  });
  return this.http.delete(
    `http://localhost:8161/api/jolokia/exec/org.apache.activemq:type=Broker,brokerName=localhost,destinationType=Queue,destinationName=${queueName}/remove()`,
    { headers: authHeader }
  );
}

注意事项 #

• 操作前需确保ActiveMQ已开启管理功能，且用户拥有足够权限；
• 删除队列会永久移除队列及所有未处理消息，需谨慎执行；
• 若使用ActiveMQ Artemis，命令格式或API路径需参考对应版本文档调整。

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