0
点赞
收藏
分享

微信扫一扫

RocketMQ控制台

参考链接:​​RocketMQ之console监控平台使用详解(三) - 老郭种树-老郭种树​​

二、模块

RocketMQ控制台_java

1.OPS

RocketMQ控制台_java-rocketmq_02

这里很容易看清楚,双击标签可以修改​​NameSer​​​的​​IP+Port​​。这里我测试过修改端口,发现重新发送一样的消息,还是能消费。

其实也能理解,因为​​NameSer​​​改变了,也只是使得​​Broker​​​不能从本地获取最新的路由信息。但是本地还是缓存了路由信息,所以一样的​​Topic​​​还是能获取到路由信息,可以获取到路由信息还是能发送到​​Brokder​​。

所以这里我的测试是一次失败的对照测试,但是这个模块平时需求不大,就过了。

2.Dashboard

RocketMQ控制台_java-rocketmq_03

此图表较简单,其实是指所有​​Brokder​​​处理消息的数量。比如从上图可以看出来,我只有一个​​Brokder​​​,并且此​​Brokder​​处理了6条消息。

RocketMQ控制台_发送消息_04

此图标可以筛选出某个​​Topic​​​下5分钟的消息数量。但是可以切换时间,所以就相当于可以查看某个​​Topic​​下的消息数量趋势。

这条趋势曲线有时候貌似不准确,测试过几次有一次在那个时间点并没有变化。

3.Cluster

RocketMQ控制台_消息队列_05

这里有点坑,​​Cluster​​翻译过来叫集群。这里并不是指消费模式中的集群消费,而是指​​Brokder​​的集群部署

但是我这里并没有使用​​Broker​​​的集群部署,所以只有一条数据。如果有多个​​broker​​那这里应该有多行数据。

每一行中各项代表的意思如下

  • Broker —​​Broker​​的名字
  • Address — 地址
  • Today Produce Count — 今天发送的消息数量
  • Today Consume Count —- 今天消费的消息数量

4.Topic

​Topic​​算是重点之一。

RocketMQ控制台_java-rocketmq_06

这里的​​ADD/UPDATE​​​是有作用的,可以在这里添加一个​​Topic​​,经过测试,感觉在这里意义不大。这里涉及到消息的发送消费与​​Topic​​、​​Broker​的关系,下篇文章分析。

每一行的​​Topic​​分成如下几个操作按钮

RocketMQ控制台_rocketmq_07

点击第一个[status]按钮。显示如下界面。可以从中获取的信息比较多。该消息队列的​​Topic​​​、​​BrokerName​​​、​​queueId​​。

这里涉及到发送消息的原理。简单来说

通过一个Topic可以获取到对应的路由信息,路由信息里面维护了消息队列集合,而我们发送消息其实就是通过消息队列发送

消息队列集合是个集合,所以也是有集合的属性。其中每一项就是消息队列,就是如下图的每一行,每一行在集合中的位置就是​​queueId​

RocketMQ控制台_java-rocketmq_08

点击第二项是保存在​​NameSer​​的路由信息。

RocketMQ控制台_java-rocketmq_08

这里可能要注意下。保存在​​NameServer​​的路由信息和本地缓存的不一样,本地缓存的属性内容更丰富更多。看看源码吧!

保存在​​NameSer​​的路由对象

发现没,其中包含的属性和如上图片类似。

​queueDatas​​​和​​brokerDatas​​​,其中​​queueDatas​​​包含消息队列的基本情况,读/写的最大数目,​​brokerDatas​​​包含​​Broker​​的位置信息。

再看看本地的真正路由信息,如上对象是它的属性。

这下很明白了。

第三项[Consumer Manage],看名字也知道啥意思,该​​Topic​​的消费管理。

第四项[Topic Config],修改​​Topic​​的属性,没啥作用,本来代码也可以控制。

第五项[Send Message],向该​​Topic​​​发送消息。可以测试玩玩,将​​Consumer​​​配置好,然后运行,不通过代码发送,在这里发送消息,​​Consumer​​也能接受到。

RocketMQ控制台_rocketmq_10

RocketMQ控制台_发送消息_11

5.Consumer

RocketMQ控制台_消息队列_12

没太看懂这每一行代表啥意思。估计是一个​​Consumer​​​对象。后面几个按钮点击后,可以看看该​​Consumer​​的具体配置信息,好像没啥东西。

6.Message

该模块很重要,信息量也很多。

RocketMQ控制台_rocketmq_13

比较容易理解,根据如上三项对​​Message​​​分组查询。一般第一项根据​​Topic​​​查询比较多。因为据说根据​​key​​​去查询有坑。建议​​id​​​和​​Topic​​​,​​id​​因为唯一最简单。

RocketMQ控制台_rocketmq_14

这是该​​Topic​​下的所有消息,不管是否消费都在内。

Message ID 、Tag 、Key都是消息比较重要的属性。点击右方的按钮,可以看到该消息更加具体的情况。

RocketMQ控制台_消息队列_15

注意点都用箭头标出来了,其他可能比较容易理解,无非就那几个属性。最后的​​TrackType​​很重要,对于排查问题。该属性的值有好几个,现在看到的几个总结如下

  • CONSUMED 代表该消息已经被消费
  • NOT_CONSUME_YET 还没被消费
  • UNKNOW_EXCEPTION 报错了,可以看日志,一般报错内容会紧跟其后,具体很容易排查出来
  • NOT_ONLINE 代表该​​Consumer​​并没有运行

总共有如下几个



举报

相关推荐

0 条评论