18-RabbitMQ高级特性-消息追踪
18-RabbitMQ高级特性-消息追踪
18-RabbitMQ高级特性-消息追踪
消息追踪
在使用任何消息中间件的过程中，难免会出现某条消息异常丢失的情况。对于 RabbitMQ 而言，可能是因为生产者或消费者与RabbitMQ 断开了连接，而它们与 RabbitMQ 又采用了不同的确认机制；也有可能是因为交换器与队列之间不同的转发策略；甚至是交换器并没有与任何队列进行绑定，生产者又不感知或者没有采取相应的措施；另外 RabbitMQ 本身的集群策略也可能导致消息的丢失。这个时候就需要有一个较好的机制跟踪记录消息的投递过程，以此协助开发和运维人员进行问题的定位。
在 RabbitMQ 中可以使用 Firehose 和 rabbitmq_tracing 插件功能来实现消息追踪。
消息追踪-Firehose
firehose的机制是将生产者投递给rabbitmq的消息，rabbitmq投递给消费者的消息按照指定的格式发送到默认的exchange上。
这个默认的exchange的名称为 amq.rabbitmq.trace ，它是一个topic类型的exchange。
发送到这个exchange上的消息的routing key为 publish.exchangename 和 deliver.queuename。
其中exchangename和queuename为实际exchange和queue的名称，分别对应生产者投递到exchange的消息，和消费者从queue上获取的消息。
注意：打开 trace 会影响消息写入功能，适当打开后请关闭。
# 开启Firehose命令
rabbitmqctl trace_on
# 关闭Firehose命令
rabbitmqctl trace_off
演示
1.查看日志跟踪交换机 amq.rabbitmq.trace
2.创建队列，并且与 日志跟踪交换机 amq.rabbitmq.trace 绑定
创建一个 test_trace 的队列，下面我们回到交换机 amq.rabbitmq.trace 详情页进行绑定如下：
3.在队列 test_trace 发送一条消息，查看确认消息
查看队列的消息如下：
4.开启 Firehose 功能
rabbitmqctl trace_on
执行命令如下：
root@d52d13792d25:/# rabbitmqctl trace_on
Starting tracing for vhost "/" ...
Trace enabled for vhost /
root@d52d13792d25:/#
5.在队列 test_trace 发送一条消息，查看确认消息
再来查看队列里面的消息：
4. 关闭 Firehose 功能
rabbitmqctl trace_off
执行如下：
root@d52d13792d25:/# rabbitmqctl trace_off
Stopping tracing for vhost "/" ...
Trace disabled for vhost /
root@d52d13792d25:/#
小结
简单来说就是创建一个队列（任意的）绑定 amq.rabbitmq.trace 交换机上即可。
当然还要命令行开启跟踪功能。
消息追踪-rabbitmq_tracing
rabbitmq_tracing和Firehose在实现上如出一辙，只不过rabbitmq_tracing的方式比Firehose多了一层GUI的包装，更容易使用和管理。
启用插件：
rabbitmq-plugins enable rabbitmq_tracing
演示
1.启动跟踪插件
# 查看当前跟踪插件的状态：未启用
root@d52d13792d25:/# rabbitmq-plugins list | grep rabbitmq_tracing
[ ] rabbitmq_tracing 3.9.13
root@d52d13792d25:/#
# 启动跟踪插件
root@d52d13792d25:/# rabbitmq-plugins enable rabbitmq_tracing
Enabling plugins on node rabbit@d52d13792d25:
rabbitmq_tracing
The following plugins have been configured:
rabbitmq_management
rabbitmq_management_agent
rabbitmq_tracing
rabbitmq_web_dispatch
Applying plugin configuration to rabbit@d52d13792d25...
The following plugins have been enabled:
rabbitmq_tracing
started 1 plugins.
# 查看状态已启用
root@d52d13792d25:/# rabbitmq-plugins list | grep rabbitmq_tracing
[E*] rabbitmq_tracing 3.9.13
root@d52d13792d25:/#
启用插件后，Web管理页面的 Admin 选项增加了 Tracing 跟踪日志，如下：
2.增加日志跟踪的虚拟机
此时任何所有的消息都会发送到日志中。
3.在任意队列发送消息
4.查看跟踪的日志
5.停用跟踪插件
# 停用插件
root@d52d13792d25:/# rabbitmq-plugins disable rabbitmq_tracing
Disabling plugins on node rabbit@d52d13792d25:
rabbitmq_tracing
The following plugins have been configured:
rabbitmq_management
rabbitmq_management_agent
rabbitmq_web_dispatch
Applying plugin configuration to rabbit@d52d13792d25...
The following plugins have been disabled:
rabbitmq_tracing
stopped 1 plugins.
# 查看插件的z
root@d52d13792d25:/# rabbitmq-plugins list | grep rabbitmq_tracing
[ ] rabbitmq_tracing 3.9.13
root@d52d13792d25:/#
小结
开启日志跟踪功能虽然可以跟踪日志的信息，但是也会影响 rabbitmq 的性能（每一条消息都要被转发记录），所以尽量只在排查问题的时候开启。