如何通过命令行或备份文件获取RabbitMQ所有_error队列的异常信息

一、通过命令行批量获取 #

可以通过RabbitMQ自带工具组合实现批量提取目标队列的消息，步骤如下：

1. 筛选所有带_error后缀的队列
   用rabbitmqctl结合jq（JSON处理工具）过滤队列：

   rabbitmqctl list_queues name --formatter=json | jq -r '.[] | select(. | contains("_error"))'
   

   执行后会输出所有名称包含_error的队列名。

2. 批量提取队列内的异常消息
   编写shell脚本遍历筛选出的队列，用rabbitmqadmin提取消息（需确保已启用management插件）：

   #!/bin/bash
   queues=$(rabbitmqctl list_queues name --formatter=json | jq -r '.[] | select(. | contains("_error"))')
   for queue in $queues; do
       echo "=== 提取队列 $queue 的异常消息 ==="
       # ackmode=reject_requeue_true 保证提取后消息重新入队，避免丢失
       rabbitmqadmin get queue="$queue" count=all ackmode=reject_requeue_true
   done
   

   若需保存结果，可在rabbitmqadmin命令后追加>> error_messages.log。

二、通过JSON备份文件分析 #

注意：RabbitMQ默认导出的定义备份文件（definitions.json）仅包含队列元数据（名称、参数、绑定等），不存储队列内的消息内容。要通过JSON文件分析异常信息，需先导出消息的JSON备份：

1. 导出单个_error队列的消息到JSON
   用rabbitmqadmin将指定队列的消息导出为JSON文件：

   rabbitmqadmin export queue=xxx_error messages.json
   

2. 批量导出并解析异常内容
   结合shell脚本批量导出所有_error队列的消息，再用jq提取JSON中的异常信息（通常存于payload字段）：

   #!/bin/bash
   queues=$(rabbitmqctl list_queues name --formatter=json | jq -r '.[] | select(. | contains("_error"))')
   for queue in $queues; do
       rabbitmqadmin export queue="$queue" "${queue}_messages.json"
       echo "=== 队列 $queue 的异常信息 ==="
       jq -r '.messages[].payload' "${queue}_messages.json"
   done
   

   直接查看导出的JSON文件或脚本输出，即可获取完整的异常信息列表。

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