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 的性能(每一条消息都要被转发记录),所以尽量只在排查问题的时候开启。
相关文章
- 在 Go 里用 CGO?这 7 个问题你要关注!
- 9款优秀的去中心化通讯软件 Matrix 的客户端
- 求职数据分析,项目经验该怎么写
- 在OKR中,我看到了数据驱动业务的未来
- 火山引擎云原生大数据在金融行业的实践
- OpenHarmony富设备移植指南(二)—从postmarketOS获取移植资源
- 《数据成熟度指数》报告:64%的企业领袖认为大多数员工“不懂数据”
- OpenHarmony 小型系统兼容性测试指南
- 肯睿中国(Cloudera):2023年企业数字战略三大趋势预测
- 适用于 Linux 的十大命令行游戏
- GNOME 截图工具的新旧截图方式
- System76 即将推出的 COSMIC 桌面正在酝酿大变化
- 2GB 内存 8GB 存储即可流畅运行,Windows 11 极致精简版系统 Tiny11 发布
- 迎接 ecode:一个即将推出的具有全新图形用户界面框架的现代、轻量级代码编辑器
- loongarch架构介绍(三)—地址翻译
- Go 语言怎么解决编译器错误“err is shadowed during return”?
- 敏捷:可能被开发人员遗忘的部分
- Denodo预测2023年数据管理和分析的未来
- 利用数据推动可持续发展
- 在 Vue3 中实现 React 原生 Hooks(useState、useEffect),深入理解 React Hooks 的