RocketMQ-Dashboard 控制台使用详解

1 安装部署

具体部署启动请参考:RocketMQ从安装、压测到运维一站式文档_rocketmq benchmark压测-CSDN博客

RocketMq的dashboard,有运维页面,驾驶舱,集群页面,主题页面,消费者页面,生产者页面,发布管理页面,消息查询页面等,为开发和运维提供了强大的监控功能。

2 功能概览

2.1 OPS-运维

功能:namesrv地址,可以修改更新。

NameServerAddressList:namesrv地址,application.yml配置文件中namesrv参数配置。端口默认是9876,多个用分号隔开。

  • 你可以修改这个服务使用的namesrv的地址
  • 你可以修改这个服务是否使用VIPChannel(如果你的mq server版本小于3.5.8,请设置不使用)

2.2 Dashboard-驾驶舱

功能:查看broker和topic的消息量

Broker TOP 10:查看消息量最多的10个broker的消息量(总量)

Broker 5min trend:查看broker消息量5分钟的趋势

Topic TOP 10:查看消息量最多的10个单一主题的消息量(总量)

Topic 5min trend:查看主题消息量5分钟的趋势

2.3 Cluster-集群

功能:查看集群分布,broker 配置、运行信息

该架构采用的双主模式,其中0代表master,1代表slave。

集群页面展示了broker的配置,集今天和昨天的消息量。

2.4 Topic-主题

功能:topic管理,包括新增/更新、消息路由、发送消息、重置消费位点等。

1、ADD/UPDATE(新增/更新):可以新增或更新主题,扩容Topic队列。perm表示权限:2写,4读,6读写

  • clusterName 创建在哪几个cluster上
  • brokerName 创建在哪几个broker上
  • topicName 主题名
  • writeQueueNums:写队列数量,在创建主题时,写队列的数量。写队列是生产者发送消息时使用的队列。在物理文件层面,只有写队列才会创建实际的文件。例如如果writeQueueNums设置为16,则会创建16个文件夹,通常代表0-15的队列编号
  • readQueueNums:读队列数量,在创建topic时,读队列的数量。读队列是消费者消费消息时使用的队列。在消息消费时,消费者会根据读队列的个数返回路由信息。在物理文件层面,读队列并不直接对应文件,而是基于写队列来消费信息的。
  • 为了保证正常运行,通常要求readQueueNums>=writeQueueNums,最佳实践就是两者相等
  • perm: 设置主题topic的读写模式或权限。
    • 6:代表支持读写,生产者可以向给topic写入信息,消费者也可以从该topic读取消息;
    • 4:代表读,禁写,只有消费者可以从该topic读取消息,生产者不能向该topic写消息;
    • 2:代表写,禁读,只有生产者可以向topic写消息,消费者不能从该topic读取消息;
    • 为了确保topic正常使用,一般将其设置为6,即同时支持读写。

2、STATUS(状态):此主题下的所有队列信息
3、ROUTER(路由):主题关联的broker以及队列queue信息。
4、CONSUMER MANAGE(CONSUMER管理):订阅此主题的所有消费组,以及各队列消费情况。

关键指标:

Delay:代表该消费组积压的数量

diffTotal:brokerOffset和consumerOffset的差值,代表未消费的数量
通过查看这两个指标,可以看到该消费组的消息积压情况。

5、TOPIC CONFIG(TOPIC配置):主题topic的情况,broker、queue的信息
6、SEND MESSAGE(发送消息):向这个主题发送一个消息,可用于测试
7、RESET CONSUMER OFFSET(重置消费位点):將消息偏移量重置到自己选择的时间,消费者重新进行消费。

  • 只能影响当时在线的消费者(对于下线的消费者,不起作用)
  • 广播模式订阅的消费者不支持重置消费位点
  • 有些帖子说,精确到时分的都没起作用,但是设置到提前一天时可以重新消费

8、SKIP_MESSAGE_ACCUMULATE(跳过堆积):感觉跟重置消费位点很像,不过是将消费者位点跳到最后一条数据上
9、DELETE(删除):删除掉该topic的所有信息。高危操作,谨慎使用!

2.5 Consumer-消费者

功能:消息的消费情况

1、ADD/UPDATE(新增/更新):新增和更新消费组group。一般不需要手动创建,实例启动,消费组会自动注册上来

2、CLIENT(客户端):消费模式、消费实例等信息

3、CONSUME DETAIL(消费详情)

消费组对应的broker、队列以及消息消费情况。

关键指标:

Delay:代表该消费组积压的数量

diffTotal:brokerOffset和consumerOffset的差值,代表未消费的数量
通过查看这两个指标,可以看到该消费组的消息积压情况。

4、CONFIG(配置)

消费组的配置信息,包括broker、队列情况

5、DELETE(删除)

删除,高危操作,谨慎使用

之前删除过下线的group,不起作用,推测应该也是只能删除上线的消费组group。

2.6 Producer-生产者

功能:生产的概况

查看ProducerGroup下的实例情况。

2.7 Message-消息

功能:消息查询,可以按照消息ID和消息key查询

MESSAGE DETAIL:消息的详情,可以查看消息体以及消费情况,进行消费重试操作。

2.8 MessageTrace-消息踪迹

功能:记录消息的发送消费记录,是一种消息的log

这里需要开通消息轨迹,需要在broker端的配置文件中添加配置项:traceTopicEnable=true,默认情况下消息轨迹是存储在RMQ_SYS_TRACE_TOPIC。消息轨迹开启之后,很方便定位问题,但是也会增加额外的存储开支,考虑到消息量大,没有打开。推荐使用物理隔离的方式,单独使用一个broker存储消息轨迹。

参考:GitCode - 开发者的代码家园

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:/a/631324.html

如若内容造成侵权/违法违规/事实不符,请联系我们进行投诉反馈qq邮箱809451989@qq.com,一经查实,立即删除!

相关文章

2D Chests Assets - Mega Pack

科幻/奇幻/经典主题的箱子和容器。AAA质量,高分辨率,VFX,源PSD文件。 这是一个带有手绘套装的大包装: -【梦幻之栗】 -【科幻钱包】 AAA质量。高分辨率。一切都已准备就绪,可供使用。包括PSD文件。 在1.1版本中添加了VFX并将项目更新为URP。请注意,新的VFX仅适用于URP/HD…

ModuleNotFoundError: No module named ‘sklearn‘

ModuleNotFoundError: No module named sklearn 解决办法: pip install scikit-learn

GitHub配置SSH协议|什么是SSH

前言 之前用云服务器和GitHub的时候,因为比较懒一直没有配置过ssh。随着最近项目的迫在眉睫,通过Vs Code链接服务器和从GitHub白嫖代码的频率的大幅增加,拒绝接触新事物鼠鼠我只好转求ssh。此篇文章记录了我自己创建ssh密钥、配置ssh密钥的步…

每日5题Day2 - LeetCode 6 - 10

每一步向前都是向自己的梦想更近一步&#xff0c;坚持不懈&#xff0c;勇往直前&#xff01; 第一题&#xff1a;6. Z 字形变换 - 力扣&#xff08;LeetCode&#xff09; class Solution {public String convert(String s, int numRows) {//特殊情况的判定if(numRows < 2){…

联合新能源汽车有限公司出席2024年7月8日杭州快递物流展

参展企业介绍 青岛联合新能源汽车有限公司&#xff08;简称&#xff1a;联合汽车&#xff09;&#xff0c;是一家专注于纯电动汽车领域创新的科技公司&#xff0c;在国内率先提出车电分离&#xff0c;电池标准化并共享的方案&#xff0c;研发了包含标准电池、电池仓、可换电纯电…

DiffusionModel-DDIM推导+代码详解

视频deep_thoughts 论文https://arxiv.org/abs/2010.02502 参考https://blog.csdn.net/weixin_47748259/article/details/137018607 DDPM生成过程就是把每一步都看作高斯分布的形式&#xff0c;所以采样过程和前向加噪过程的链条长度是一致的。DDIM就是在思考能不能够加速这个采…

现货正泰漏电小型断路器NXB-32LE-C16 30MA1P+N原装正品NXB-40L

品牌&#xff1a;CHNT/正泰 型号&#xff1a;NXBLE 额定电流&#xff1a;25A,16A,20A,40A,32A 漏电保护器类型&#xff1a;2P 产地&#xff1a;中国大陆 电压&#xff1a;1000V及以下 极数&#xff1a;3P,4p,2P,1PN 电源方式&#xff1a;交流电 3C证书编号&#xff1a;…

【顺序程序设计-谭浩强适配】(适合专升本、考研)

无偿分享学习资料&#xff0c;需要的小伙伴评论区或私信dd。。。 无偿分享学习资料&#xff0c;需要的小伙伴评论区或私信dd。。。 无偿分享学习资料&#xff0c;需要的小伙伴评论区或私信dd。。。 完整资料如下&#xff1a;纯干货、纯干货、纯干货&#xff01;&#xff01;…

三.使用HashiCorp Vault工具管理数据库

三.ubuntu安装使用HashiCorp Vault工具管理数据库 HashiCorp Vault 是一个基于身份的秘密和加密管理系统。机密是您想要严格控制访问的任何内容,例如 API 加密密钥、密码和证书。Vault 提供由身份验证和授权方法门控的加密服务。使用 Vault 的 UI、CLI 或 HTTP API,可以安全…

基于Vue和uni-app的增强型多选框Checkbox组件开发

基于Vue和uni-app的增强型多选框&#xff08;Checkbox&#xff09;组件开发 摘要 随着前端技术的不断发展和用户体验要求的提升&#xff0c;传统的Checkbox组件已不能满足所有需求。本文介绍了一种基于Vue和uni-app的增强型多选框&#xff08;Checkbox&#xff09;组件的开发…

Ubuntu 安装 eclipse 的详细过程及工程创建和编译配置

目录 一、安装环境二、下载依赖 java jdk三、下载 eclipse四、安装4.1 java 环境4.2 eclipse 安装4.3 打开 eclipse 五、配置 eclipse5.1 新建 C 工程5.2 工具链 配置5.3 头文件路径5.4 链接库5.5 编译 一、安装环境 Ubuntu 版本&#xff1a;22.04.3 位数&#xff1a;64-bit 二…

期权(1):基本概念,权利金=定金,买方,卖方,零和游戏,对赌协议

期权是合约&#xff0c;权利金就是定金&#xff01; 合约到期时 买方可以选择行权&#xff0c;也可以选择不行权。代价就是定金损失。因此亏损封顶&#xff0c;但盈利无限。卖方赚的就是买方的定金&#xff0c;盈利封顶&#xff0c;但亏损无限。 从这里&#xff0c;我们看出…

C++ | Leetcode C++题解之第89题格雷编码

题目&#xff1a; 题解&#xff1a; class Solution { public:vector<int> grayCode(int n) {vector<int> ret(1 << n);for (int i 0; i < ret.size(); i) {ret[i] (i >> 1) ^ i;}return ret;} };

GPT4o“全能”模型发布;2人AI团队被收购;3款AI搜索引擎

1. OpenAI发布GPT4o&#xff0c;能实时语音视频交互 今天&#xff0c;OpenAI发布了最新的旗舰版模型GPT4o&#xff08;“o”代表全能&#xff09;。这是一个跨音频、视觉和文本的端到端的新模型&#xff0c;可以在平均320ms内对人类的语音输入进行响应&#xff0c;而此前ChatGP…

Golang | Leetcode Golang题解之第91题解码方法

题目&#xff1a; 题解&#xff1a; func numDecodings(s string) int {n : len(s)// a f[i-2], b f[i-1], c f[i]a, b, c : 0, 1, 0for i : 1; i < n; i {c 0if s[i-1] ! 0 {c b}if i > 1 && s[i-2] ! 0 && ((s[i-2]-0)*10(s[i-1]-0) < 26) {c…

数据结构——冒泡排序

懒猫老师-数据结构-(63)冒泡排序(起泡排序)_哔哩哔哩_bilibili 交换排序的一类 基本思想 两两比较相邻记录的关键码&#xff0c;如果反序则交换&#xff0c;直到没有反序的记录为止。 过程 有序区不断扩大&#xff0c;无序区不断减小

基于 Spring Boot 博客系统开发(十)

基于 Spring Boot 博客系统开发&#xff08;十&#xff09; 本系统是简易的个人博客系统开发&#xff0c;为了更加熟练地掌握 SprIng Boot 框架及相关技术的使用。&#x1f33f;&#x1f33f;&#x1f33f; 基于 Spring Boot 博客系统开发&#xff08;九&#xff09;&#x1f…

小红书笔记怎么发浏览量高?

小红书笔记发布是有技巧和策略的&#xff0c;为什么有的小红书笔记浏览量那么高&#xff0c;是因为下足了功夫&#xff0c;小红书笔记怎么发浏览量高&#xff1f;今天伯乐网络传媒就来给大家揭秘一下。 一、选题与定位 1. 热门话题选择 要想提高小红书笔记的浏览量&#xff0…

Python | Leetcode Python题解之第91题解码方法

题目&#xff1a; 题解&#xff1a; class Solution:def numDecodings(self, s: str) -> int:n len(s)# a f[i-2], b f[i-1], c f[i]a, b, c 0, 1, 0for i in range(1, n 1):c 0if s[i - 1] ! 0:c bif i > 1 and s[i - 2] ! 0 and int(s[i-2:i]) < 26:c aa,…

【Leetcode每日一题】 综合练习 - 括号生成(难度⭐⭐)(76)

1. 题目解析 题目链接&#xff1a;22. 括号生成 这个问题的理解其实相当简单&#xff0c;只需看一下示例&#xff0c;基本就能明白其含义了。 2.算法原理 问题描述 我们需要找出所有可能的、有效的括号序列。一个有效的括号序列指的是一个仅由(和)组成的字符串&#xff0c;…