如何通过Jolokia调用Artemis REST API清除所有队列中的消息

Artemis 原生没有提供单步清除所有队列消息的MBean接口，你可以结合 Broker 层面的查询接口 + Jolokia 批量请求能力实现需求，具体操作如下： #

1. 第一步：查询获取所有队列的MBean标识 #

调用Broker核心MBean的查询接口，拿到全量队列的完整信息，请求参数如下：

{
  "type": "exec",
  "mbean": "org.apache.activemq.artemis:broker=\"你的Broker实例标识，示例为1.1.1.1\"",
  "operation": "listQueues()"
}

返回结果中每个队列条目都包含objectName字段，该字段就是对应队列的完整MBean路径，无需你手动拼接参数。你可以根据业务需要先过滤队列，比如排除死信队列、延时调度队列等不需要清除的目标。 #

2. 第二步：发起Jolokia批量清除请求 #

Jolokia 支持在单个HTTP请求中提交多个操作指令，避免循环调用多次接口，批量请求格式示例如下：

[
  {
    "type": "exec",
    "mbean": "org.apache.activemq.artemis:broker=\"1.1.1.1\",component=addresses,address=\"demoAddress1\",subcomponent=queues,routing-type=\"multicast\",queue=\"demoQueue1\"",
    "operation": "removeAllMessages()"
  },
  {
    "type": "exec",
    "mbean": "org.apache.activemq.artemis:broker=\"1.1.1.1\",component=addresses,address=\"demoAddress2\",subcomponent=queues,routing-type=\"anycast\",queue=\"demoQueue2\"",
    "operation": "removeAllMessages()"
  }
  // 其余队列的清除请求按以上格式追加即可
]

请求地址和你之前调用单队列清除的Jolokia端点一致，HTTP方法使用POST，请求头Content-Type设置为application/json即可。 #

注意事项 #

• 清除消息操作不可逆，执行前建议先备份关键业务消息
• 若Artemis开启了权限管控，调用账号需要分配队列的管理操作权限

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