RabbitMQ集群中节点路由消息至队列Leader的日志获取方法咨询

场景描述 #

• 集群包含3个节点：RabbitMQ_node1、RabbitMQ_node2、RabbitMQ_node3
• RabbitMQ_node1是队列A的Leader，且该队列无镜像配置
• 客户端连接RabbitMQ_node2，以持久化模式发布消息，最终消息存储在RabbitMQ_node1中

根据RabbitMQ官方文档说明：

假设所有集群成员均可用，客户端可连接任意节点执行任意操作。节点会将操作透明路由至仲裁队列Leader或队列Leader副本。

需要记录该路由事件，了解如何查看RabbitMQ_node2将发布消息的操作路由至RabbitMQ_node1（队列Leader）的过程，可通过日志、事件或其他工具实现。

解决方案 #

1. 调整日志级别捕获路由细节 #

RabbitMQ默认日志级别无法展示路由过程，需调整至debug或info级别：

• 修改节点的rabbitmq.conf配置文件，设置日志级别：

  log.level = debug
  

• 重启RabbitMQ服务使配置生效：

  rabbitmqctl stop_app && rabbitmqctl start_app
  

• 查看RabbitMQ_node2的日志文件（通常路径为/var/log/rabbitmq/rabbit@RabbitMQ_node2.log），查找包含route、leader、queue A的条目，示例日志内容：

  [debug] <0.1234.0> routing publish operation for queue 'queue A' to leader node 'rabbit@RabbitMQ_node1'
  

2. 启用节点跟踪功能 #

使用rabbitmqctl trace_on可以捕获节点间的路由操作：

• 在任意集群节点执行命令开启跟踪：

  rabbitmqctl trace_on
  

• 客户端再次通过RabbitMQ_node2发布消息后，在RabbitMQ_node2的日志中会出现类似记录：

  [info] <0.5678.0> [trace] routed message from 'client-connection-123' on node 'rabbit@RabbitMQ_node2' to queue leader 'rabbit@RabbitMQ_node1' for queue 'queue A'
  

• 跟踪完成后关闭功能以避免性能损耗：

  rabbitmqctl trace_off
  

3. 利用事件插件订阅路由事件 #

通过rabbitmq_event_exchange插件可以获取集群内的路由事件：

• 启用插件：

  rabbitmq-plugins enable rabbitmq_event_exchange
  

• 创建消费者队列绑定到事件交换器amq.rabbitmq.event，订阅queue.routing类型的事件。事件消息会包含源节点、目标节点、队列名称等信息，示例：

  {
    "event_type": "queue.routing",
    "source_node": "rabbit@RabbitMQ_node2",
    "target_node": "rabbit@RabbitMQ_node1",
    "queue_name": "queue A",
    "operation": "publish"
  }
  

4. 查看队列元数据验证路由结果 #

使用诊断命令确认队列Leader节点及消息存储位置，辅助验证路由过程：

• 查看队列A的详细信息：

  rabbitmq-diagnostics queue_info "queue A"
  

• 输出结果中leader字段会显示为rabbit@RabbitMQ_node1，messages_stored_at也指向该节点，与实际存储情况匹配。

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