RocketMQ-Dashboard 控制台使用详解

news2025/1/19 2:52:12

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.coloradmin.cn/o/1682366.html

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

相关文章

FileLink如何实现金融行业跨网文件传输

在金融行业,跨网文件传输一直是一个备受关注的问题。由于金融数据的敏感性和重要性,如何确保文件在传输过程中的安全性、稳定性和合规性成为了金融机构急需解决的难题。而FileLink作为一款跨网文件交换系统,凭借其强大的功能和优势&#xff0…

Leetcode - 130双周赛

目录 一,3142. 判断矩阵是否满足条件 二,3143. 正方形中的最多点数 三,3144. 分割字符频率相等的最少子字符串 四,3145. 大数组元素的乘积 一,3142. 判断矩阵是否满足条件 本题题意,满足每一列的数全部…

YOLOV8环境部署(GPU版本)

一、安装cuda和cudnn 1、安装cuda之前先打开英伟达控制面板查看自己的显卡信息 2、“帮助”—>“系统信息”—>“组件”,然后看第三行的信息“Nvidia …

2024做安全测试必须要知道的几种方法!

前言 安全性测试(Security Testing)是指有关验证应用程序的安全等级和识别潜在安全性缺陷的过程,其主要目的是查找软件自身程序设计中存在的安全隐患,并检查应用程序对非法侵入的防范能力,安全指标不同,测试策略也不同。 但安全…

.net下使用cap实现消息异步处理

介绍 github地址 CAP 是一个基于 .NET Standard 的 C# 库,它是一种处理分布式事务的解决方案,同样具有 EventBus 的功能,它具有轻量级、易使用、高性能等特点。 新建项目 新建.net7web项目 安装依赖包 安装软件 安装redis和Sql Server …

【免费Web系列】大家好 ,今天是Web课程的第一天点赞收藏关注,持续更新作品 !

开干,开干!!! 1. 前端开发介绍 我们介绍Web网站工作流程的时候提到,前端开发,主要的职责就是将数据以好看的样式呈现出来。说白了,就是开发网页程序,如下图所示: 那在讲解web前端开发之前,我们先需要对we…

如何加密电脑文件夹?重要文件夹怎么加密?

文件夹可以帮助我们管理电脑数据,而文件夹并不具有安全保护功能,很容易导致数据泄露。因此,我们需要加密保护电脑文件夹。那么,如何加密电脑文件夹呢?下面我们就来了解一下。 EFS加密 EFS加密是Windows提供的数据加密…

【2024】最新微信小程序商城源码开源版 多用户无限多开+15大功能模块

随着微信小程序市场的蓬勃发展,越来越多的商家和企业意识到了微信小程序作为线上销售平台的重要性。为了满足广大用户的需求,分享一款2024年最新微信小程序商城源码开源版,该版本不仅支持多用户无限多开,还集成了15大功能模块&…

Vue的学习 —— <vue事件处理>

前言 事件指的就是用户和网页交互的行为,这些行为,包括:鼠标单击、鼠标双击、键盘按下、抬起等。为了简化开发,Vue为开发者提供了事件修饰符,它可以与v-on配合使用,以便于对事件进行控制和处理&#xff0c…

单体测试Junit

本来是想要查找关于junit 的知识,查找了依赖注入方式不同对junit测试也有影响。 正好备注下。 依赖注入三种方式: 字段注入(Autowird) 优点: 操作简单 代码简洁 缺点: 不支持…

Java面试八股之HashMap和HashTable有什么区别

Java中HashMap和HashTable有什么区别 线程安全性: HashMap:非线程安全。在多线程环境下,如果没有采取适当的同步措施,直接并发访问可能会导致数据不一致、死锁等问题。如果需要在多线程环境中安全地使用HashMap,通常…

【FFmpeg】Filter 过滤器 ② ( 裁剪过滤器 Crop Filter | 裁剪过滤器语法 | 裁剪过滤器内置变量 | 裁剪过滤器常用用法 )

文章目录 一、裁剪过滤器1、裁剪过滤器简介2、裁剪过滤器语法3、裁剪过滤器内置变量4、裁剪过滤器示例5、裁剪过滤器应用6、裁剪过滤器图示 二、裁剪过滤器常用用法1、裁剪指定像素的视频区域2、裁剪视频区域中心正方形 - 默认裁剪3、裁剪视频区域中心正方形 - 手动计算4、裁剪…

STM32程序下载电路设计

一、背景介绍 使用STM32F103RCT6作为单片机主控芯片,在进行电路板设计过程中,需要预留程序下载接口,可以选择使用JLINK下载器下载程序。 二、设计过程 1、查看STM32F103RCT6的芯片手册,找到下载程序的引脚端口PA13和PA14&#x…

使用WPF中的Trigger实现按钮样式动态更改

使用WPF中的Trigger实现按钮样式动态更改 在Windows Presentation Foundation (WPF)中,Trigger 是一种强大的机制,它可以基于控件的属性值来动态更改控件的样式。这篇博客将介绍如何使用Trigger实现按钮在鼠标悬停时样式动态更改的效果。我们将详细讨论为…

自然语言处理通用框架BERT原理解读

相关代码见文末 1.概述 问题背景: 传统Seq2Seq模型的局限性: 早期的机器翻译和文本生成任务常采用基于循环神经网络(RNN)的序列到序列(Seq2Seq)模型,这类模型在处理长序列时容易遇到梯度消失/爆炸问题,导致训练效率低,难以捕捉长期依赖。 RNN网络的问题: RNN及其变…

基于vs和C#的WPF应用之动画4---跳跳球

一、画布和图形 <Canvas x:Name"canvas4" Grid.Row"1" Grid.Column"1" Width"200" Height"200"><Canvas.Triggers><EventTrigger RoutedEvent"Loaded"><BeginStoryboard Storyboard"…

牛客热题:合并二叉树

牛客热题&#xff1a;二叉树与双向链表> &#x1f4df;作者主页&#xff1a;慢热的陕西人 &#x1f334;专栏链接&#xff1a;力扣刷题日记 &#x1f4e3;欢迎各位大佬&#x1f44d;点赞&#x1f525;关注&#x1f693;收藏&#xff0c;&#x1f349;留言 文章目录 牛客热题…

TypeScript基础知识:TypeScript是什么?为什么会出现TypeScript?TypeScript相较于javascript有那些优势?

TypeScript(简称:TS)是JavaScript的超集(JS有的TS 都有)。 图解就是&#xff1a; TypeScriptType javaScript(在JS 基础之上&#xff0c;为JS 添加了类型支持)。 TypeScript 是微软开发的开源编程语言&#xff0c;可以在任何运行JavaScript的地方运行。 那么为什么要出现type…

CPT7数据保存详细步骤

一、连接设备、打开NovAtelConnect 软件 (1)点击1,并在2中输入如下命令: LOG RANGEB ONTIME 1 // 输出原始数据记录在板卡LOG RAWEPHEMB ONTIME 1 // 输出 GPS 原始星历记录在板卡LOG bdsephemerisb ONTIME 1 // 输出

VMware17.5与Ubuntu22.04虚拟机环境搭建

VMware17.5安装教程也有参考此链接 简介 Linux是一套免费使用和自由传播的类Unix操作系统,是一个基于POSIX和Unix的多用户、多任务、支持多线程和多CPU的操作系统。它能运行主要的Unix工具软件、应用程序和网络协议。它支持32位和64位硬件。Linux继承了Unix以网络为核心的设…