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 - 开发者的代码家园

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

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

【Kubenetes】边缘计算KubeEdge架构设计详解

文章目录 前言KubeEdge云边通信方式云端架构设计EdgeController:云到边:边到云 DeviceController:云到边边到云 边缘端架构设计EdgedPod的管理部分Pod的监控部分Pod的卷管理Pod的垃圾回收Pod同步管理 MetaMangger从云到边缘的更新 (Update From Cloud To Edge)从边缘…

Covalent长期数据设施,支持基于 “blob” 、总锁仓54亿美元的L2

Covalent Network(CQT)是领先的历史数据可用性网络,通过其在 Web3 中超过 225 个区块链上的结构化数据基础设施,为数千名客户和开发人员提供支持。Covalent Network(CQT)正在与未来以太坊的进步需求相匹配&…

SQL慢查询学习篇

https://www.cnblogs.com/isyues/p/17733015.html 1. 对扫到的SQL慢查询语句执行 explain explain select task_id, channel, count(task_id) as count from tablename where send_time > "2024-05-10 16:13:59" and send_time < "2024-05-14 16:13:59…

api接口、api文档、api调试、api测试

应用程序接口是一组定义、程序及协议的集合&#xff0c;通过 API 接口实现计算机软件之间的相互通信。API 的一个主要功能是提供通用功能集。程序员通过调用 API 函数对应用程序进行开发&#xff0c;可以减轻编程任务。 API 同时也是一种中间件&#xff0c;为各种不同平台提供数…

展馆展厅设计施工流程

1、需求分析和确定&#xff1a; 与客户沟通&#xff0c;了解客户需求&#xff0c;对展馆展厅的用途、面积、功能、展品特点等进行分析&#xff0c;并确定设计方案。 2、方案设计 根据需求确定设计方案&#xff0c;包括平面布局、展品陈列、展示方式、照明等。设计师需要提供设计…

如何在Spring启动的时候执行一些操作

如何在Spring启动的时候执行一些操作 在Spring启动的时候执行一些操作有多种方式。你可以通过实现ApplicationRunner或者CommandLineRunner接口&#xff0c;在Spring Boot应用程序启动后执行特定操作。另外&#xff0c;你也可以使用PostConstruct注解&#xff0c;在Spring Bea…

【考研数学】张宇《1000题》强化阶段正确率多少算合格?

张宇1000题真的很练人心态.... 基础不好&#xff0c;建议别碰1000题 基础好&#xff0c;1000题建议在两个月以内刷完 如果自己本身在基础阶段学的比较水&#xff0c;自己的薄弱点刷了一小部分题没有针对性完全解决&#xff0c;转身去刷1000题就会发现&#xff0c;会的题目刷…

shell脚本-重定向与管道符

一、重定向 因为shell脚本有着批量操作的特殊性&#xff0c;大部分操作处于后台执行&#xff0c;不需要用户进行干预&#xff0c;所以提取、过滤并执行信息十分需要重定向和管道。重定向的意思是不输出到默认设备上&#xff0c;而是输出到你指定的位置&#xff08;文件、其他输…

1.微信小程序开发之准备工作

1.微信小程序账号注册 小程序开发 与 网页开发不一样&#xff0c;在开始微信小程序开发之前&#xff0c;需要访问 微信公众平台&#xff0c;注册一个微信小程序账号。 在拥有了小程序的账号以后&#xff0c;我们才可以开发和管理小程序&#xff0c;后续可以通过该账号进行开发…

国网电力分公司、税务企业如何向央媒投稿?

税务、电力、银行等单位如果想要将稿件发布到中央媒体&#xff0c;可以遵循为大家整理的以下步骤和建议&#xff1a; 了解央媒的定位与要求&#xff1a;中央媒体&#xff0c;如新华社、人民日报、中央电视台等&#xff0c;都有其独特的报道风格和关注重点。在投稿前&#xff0…

【Web后端】会话跟踪技术及过滤器

1.会话跟踪技术 1.1 会话的概念 在web应用中&#xff0c;浏览器和服务器在一段时间内发送请求和响应的连续交互的全过程 1.2 会话跟踪概念 对同一个用户跟服务器的连续请求和接收响应的监视过程 1.3 会话跟踪作用 浏览器和服务器是以http协议进行通信&#xff0c;http协议是…

算法工程师面试问题 | YOLOv8面试考点原理全解析(一)

本文给大家带来的百面算法工程师是深度学习目标检测YOLOv8面试总结&#xff0c;文章内总结了常见的提问问题&#xff0c;旨在为广大学子模拟出更贴合实际的面试问答场景。在这篇文章中&#xff0c;我们还将介绍一些常见的深度学习目标检测面试问题&#xff0c;并提供参考的回答…

AWS RDS ElasticCache 监控可观测最佳实践

在当今的电子商务时代&#xff0c;一个高效、稳定的电商平台对于保持竞争力至关重要。数据库作为电商平台的核心支撑&#xff0c;其性能直接影响到用户体验和业务流畅度。本文将深入探讨如何在电商场景下通过观测云对亚马逊云科技 RDS&#xff08;MySQL&#xff09; 和 Elastic…

python+selenium - UI自动框架之封装log类

通过自定log类&#xff0c;能把执行过程记录到日志&#xff0c;方便检查和重现问题。 log类介绍&#xff1a; 每次调用log函数&#xff0c;会根据绝对路径生成日志文件在logs目录下面(在被调用的时候日志会输出到指定的文件&#xff09;&#xff0c;日志文件的格式是年月日.lo…

vue+element的表格(el-table)排班情况表(2024-05-09)

vueelement的表格&#xff08;el-table&#xff09;排班情况&#xff0c;增删查改等简单功能 代码&#xff1a; <template><!-- 表格 --><div class"sedules"><el-header><el-date-pickerv-model"monthValue2"type"month…

postgresql中控制符带来的数据错觉

简介 在数据库字符集中&#xff0c;由于数据质量的控制不够完善&#xff0c;每一个字符集都并不是所有字符的能看见&#xff0c;有些字符的展示可能会出现乱码&#xff0c;甚至出现不同字符展示成同样效果的可能&#xff0c;给开发人员造成分析错觉。 当数据库存入了控制符&am…

【Unity Shader入门精要 第7章】基础纹理(三)

1. 渐变纹理 另外一种对于纹理的使用方式是通过渐变纹理为物体提供漫反射光照效果。 顾名思义&#xff0c;渐变纹理本身就是一张颜色渐变&#xff08;可以是连续渐变&#xff0c;也可能是突变&#xff09;的图片&#xff0c;这个渐变的过程模拟的就是光源从不同的角度照射物体…

Win11下Java环境安装指南

Windows下Java环境安装指南 前言一、安装简介JDK与JRE安装包 二、JDK安装检查操作系统类型基于Win11基于Win10 安装包准备工作 三、配置环境配置JAVA_HOME配置Path配置CLASSPATH 四、检验配置是否打开cmd命令行窗口输出java -version命令 五、注意事项 前言 在Windows系统上安…

移动机器人的机动性

移动机器人的机动性 机器人底盘运动学的活动性是表示它在环境中直接运动的能力。限制活动性的基本约束是每一轮子必须满足它的滑动约束的规则。所以,我们可从方程(3.26)正式地推导机器人的活动性。 除了瞬时的运动学运动之外,移动机器人通过操纵可操纵的轮子,能够随时操纵它的…

基于springboot实现的教师人事档案管理系统

开发语言&#xff1a;Java 框架&#xff1a;springboot JDK版本&#xff1a;JDK1.8 服务器&#xff1a;tomcat7 数据库&#xff1a;mysql 5.7&#xff08;一定要5.7版本&#xff09; 数据库工具&#xff1a;Navicat11 开发软件&#xff1a;eclipse/myeclipse/idea Maven包&…