赞
踩
主要是想备注一下阿里云的《控制台使用指南》这个肯定是产品经理写的。
RocketMQ提供一个自带web项目rocketmq-console-***.war,对RocketMQ集群进行可视化管理。控制台提供运维管理,查询消息,查询消息轨迹,查看消费者状态,重置消费位点,死信队列,全球消息路由,查看订阅关系,资源报表,监控报警。
可视化控制台的安装部署和tomcat环境下部署war包是同样的模式
1. 下载开源的rocketmq-externals项目
https://github.com/apache/rocketmq-externals
2. 将rocktmq-console打成jar包,得到rocketmq-console-***.war
3. 启动tomcat服务
4.http://ip:8080/rocketmq-console访问控制台界面
1.消息查询-阿里云《控制台使用指南-消息查询》
如遇消息消费有问题,则可通过查询具体发送的消息内容来排查问题。消息队列 RocketMQ 版提供了三种消息查询的方式,分别是按 Message ID、Message Key 以及 Topic 查询。
可以在控制台的消息查询页面看到查询到的消息。直接显示的信息包含 Message ID、Tag、Key 和存储时间。此外,您还可以在每一行消息操作列下载消息内容、查询消息轨迹以及查看消息详情。
2.查询消息轨迹-阿里云《控制台使用指南-查询消息轨迹》
消息轨迹是指一条消息从生产者发送到消息队列 RocketMQ 版服务端,再到消费者消费处理,整个过程中的各个相关节点的时间、状态等数据汇聚而成的完整链路信息。该轨迹可作为生产环境中排查问题强有力的数据支持。
3.查看消费者状态-阿里云《控制台使用指南-查看消费者状态》
如遇消息消费异常,可在消息队列 RocketMQ 版控制台查看消费者状态初步诊断原因。您可查看每个 Group ID 代表的消费者实例群组的信息,也可查看该群组下单个消费者实例的信息。
4.重置消费位点-阿里云《控制台使用指南-重置消费位点》
您可通过重置消费位点,按需清除堆积的或不想消费的这部分消息再开始消费,或直接跳转到某个时间点消费该时间点之后的消息。但是需要注意1.广播消费模式不支持重置消费位点。2,目前不支持指定 Message ID、Message Key 和 Tag 来重置消息的消费位点。
5.死信队列-阿里云《控制台使用指南-死信队列》
死信队列用于处理无法被正常消费的消息,即死信消息。当一条消息初次消费失败,消息队列 RocketMQ 版会自动进行消息重试;达到最大重试次数后,若消费依然失败,则表明消费者在正常情况下无法正确地消费该消息,此时,消息队列 RocketMQ 版不会立刻将消息丢弃,而是将其发送到该消费者对应的特殊队列中。在消息队列 RocketMQ 版中,这种正常情况下无法被消费的消息称为死信消息(Dead-Letter Message),存储死信消息的特殊队列称为死信队列(Dead-Letter Queue)。
6.资源报表-阿里云《控制台使用指南-资源报表》
资源报表是消息生产和消费数据的统计功能。通过该功能,您可查询在一段时间范围内发送至某 Topic 的消息总量或者 TPS(消息生产数据),也可查询在一个时间段内某 Topic 投递给某 Group ID 的消息总量或 TPS(消息消费数据)
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。