RocketMQ Dashboard可视化工具

  RocketMQ Dashboard 将 RocketMQ的相关指标展示在web页面 ,支持以可视化工具代替 Topic 配置、Broker 管理等命令行操作。

官方文档地址:RocketMQ Dashboard | RocketMQ

目录

1.下载安装

1.1 系统要求:

1.2 源码安装

 1.3 访问页面

2.功能概览

2.1 运维

2.2 驾驶舱

2.3 集群

2.4 主题

2.5  消费者

2.6 生产者

2.7 消息

2.8 死信消息

2.9 消息轨迹


1.下载安装

1.1 系统要求:

  1. Linux/Unix/Mac
  2. 64bit JDK 1.8+
  3. Maven 3.2.x 下载地址:Maven最新以及历史版本下载地址-CSDN博客
  4. 启动RocketMQ RocketMQ单节点安装教程-CSDN博客

1.2 源码安装

官方源码地址:apache/rocketmq-dashboard

 本文中使用的源码:

 源码及缺失包:https://download.csdn.net/download/liguo886/88705158

打包运行方式:

提示:

  1. 此处要注意application.yml文件中的端口设置的是8080,建议提前改下。启动Broker+Proxy时默认也会占用8080,导致启动服务时可能会报端口被占用错误。
  2. application.yml中默认关联的namesrvAddrs为127.0.0.1:9876,此处要与需监控的namesrv服务地址保持一致。(也可运行后在页面的“运维”页签中新增NameServer地址)

接下来直接使用maven命令。先下载源码到本地,解压后进入rocketmq-dashboard目录后执行maven打包命令:

mvn clean package -Dmaven.test.skip=true

打包成功后会在当前目录下生成target文件,里面包含rocketmq-dashboard-1.0.1-SNAPSHOT.jar

运行jar包:

java -jar target/rocketmq-dashboard-1.0.1-SNAPSHOT.jar

 1.3 访问页面

        浏览器页面访问:localhost:8088

至此,已经可以很直观的看到RocketMQ中各个指标,也可以很方便通过此页面来执行某些命令。

2.功能概览

  RocketMQ Dashboard包括运维、驾驶舱、集群、主体、消费者、生产者、消息等模块。

2.1 运维

        运维界面可以新增nameserver 地址,默认取的是application.yml中的namesrvAddrs节点;

2.2 驾驶舱

        驾驶舱界面可以查看 broker, topic 消息量。

  • Broker TOP 10:查看消息量最多的10个broker的消息量(总量)
  • Broker 5min trend:查看broker消息量5分钟的趋势
  • 主题 TOP 10:查看消息量最多的10个单一主题的消息量(总量)
  • 主题 5min trend:查看主题消息量5分钟的趋势

2.3 集群

        集群界面可以查看集群分布,broker 配置、运行信息

2.4 主题

        主题界面可以搜索、筛选、删除、更新/新增主题,消息路由,发送消息,重置消费位点。

        按钮介绍:

  • 新增/更新:可以新增或更新主题,扩容Topic队列。perm表示权限:2写,4读,6读写
  • 状态:显示此主题下的所有队列信息。由新增/更新主题时设置的perm和读写队列数量控制。
  • 路由:主题关联的broker信息以及队列信息。
  • CONSUMER管理:订阅此主题的消费组以及各队列消费情况。
  • TOPIC配置:修改主题。
  • 发送消息:可以在此处发送消息到主题中。
  • 重置消费位点:將消息偏移量重置到自己选择的时间(只能影响当时在线的消费者,广播模式订阅的消费者不支持重置消费位点),消费者重新进行消费。(有BUG,我试精确到时分的都没起作用,但是设置到提前一天时可以重新消费)
  • 跳过堆积:感觉跟重置消费位点很像,不过是将消费者位点跳到最后一条数据上。
  • 删除:谨慎谨慎谨慎。

2.5  消费者

配置按钮指标介绍

consumeEnable:是否可以消费

consumeBroadcastEnable:广播消费

retryQueueNums:重试队列的大小

brokerId:正常情况从哪消费

whichBrokerWhenConsumeSlowly:出问题了从哪消费

2.6 生产者

2.7 消息

2.8 死信消息

2.9 消息轨迹

 

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

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

相关文章

如何搭建开源知识库软件AFFiNE并实现公网环境远程协作【内网穿透】

目录 前言 1. 使用Docker安装AFFINE 2. 安装cpolar内网穿透工具 3. 配置AFFINE公网访问地址 4. 实现公网远程访问AFFINE 结语 作者简介: 懒大王敲代码,计算机专业应届生 今天给大家聊聊如何搭建开源知识库软件AFFiNE并实现公网环境远程协作【内网穿…

借势API电商数据采集汇总分析

电商数据采集的网页抓取数据、淘宝、天猫、京东等平台的电商数据抓取,网页爬虫、采集网站数据、网页数据采集软件、python爬虫、HTM网页提取、APP数据抓包、APP数据采集、一站式网站采集技术、BI数据的数据分析、数据标注等成为大数据发展中的热门技术关键词。那么电…

使用python读取yaml文件数据

使用python读取yaml文件: yaml文件数据:data.yaml login_data:url: http://www.baidu.comcase1:user1: password1: 12345errorText: 请输入用户名case2:user2: adminpassword2: errorText: 请输入密码case3:user3: adminpassword3: 123456errorText: 登…

19. 从零用Rust编写正反向代理, 配置数据的热更新原理及实现

wmproxy wmproxy是由Rust编写,已实现http/https代理,socks5代理, 反向代理,静态文件服务器,内网穿透,配置热更新等, 后续将实现websocket代理等,同时会将实现过程分享出来&#xff…

探索 Java 8 中的 Stream 流:构建流的多种方式

目录 前言 什么是 Stream 流? 创建 Stream 流 1. 从集合创建 Stream 2. 从数组创建 Stream 3. 使用 Stream.of 创建 Stream 4. 使用 Stream.generate 创建 Stream 5. 使用 Stream.iterate 创建 Stream Stream 流的操作 1. 过滤数据 2. 映射数据 …

01 ZigBee开发环境IAR搭建

链接:https://pan.baidu.com/s/18l8z9qajPBj2X5WzgjT0TA?pwd41qc 提取码:41qc 注意:安装包和注册机都要右击用管理员权限打开,安装过程中关闭杀毒软件(否则后续程序不行) 安装IAR-8051 以管理员身份运行E…

鸿蒙开发已解决-arkts编译报错-arkts-limited-stdlib错误

文章目录 项目场景:问题描述原因分析:解决方案:适配指导案例此Bug解决方案总结项目场景: arkts编译报错-arkts-limited-stdlib错误。 我用Deveco studio4.0 beta2开发应用,报arkts-limited-stdlib错误 报错内容为: ERROR: ArKTS:ERROR File: D:/prRevivw/3792lapplica…

行列式的计算

1、基本性质: 1)行列式转置相等 2)任意两行(列)成比例,行列式为0 3)对换任意某两行(列),行列式变号 4)某一行(列)乘某…

Ubuntu下VsCode+CMake 交叉编译

参考连接: Ubuntu下VsCodeCMake 交叉编译 VSCode与CMake搭配使用之基本配置 VSCode与CMake搭配使用之交叉编译 step1: CtrlShiftp打开VSCode的指令面板,然后输入cmake:q ; 在窗口搜索:“ >CMake:Edit user-loacl CMake kits ”会打开一个…

SpringBoot集成阿里云短信实现发送短信验证码

SpringBoot集成阿里云短信实现发送短信验证码 一、准备工作1、注册账号2、申请资质3、申请签名4、创建模板 二、springboot集成发送短信1、引入依赖2、编写短信配置文件3、编写短信发送工具类 一、准备工作 在使用springboot集成短信服务之前,需要先注册阿里云的账…

VMware vSphere运维管理手册

适用版本:VMware vSphere 7.0 VMware vSphere 是 VMware 的虚拟化平台,可将数据中心转换为包括 CPU、存储和网络资源的聚合计算基础架构。vSphere 将这些基础架构作为一个统一的运行环境进行管理,并为您提供工具来管理加入该环境的数据中心。 ![[Pasted image 20231212132…

uni-app的学习【第二节】

四 路由配置及页面跳转 (1)路由配置 uni-app页面路由全部交给框架统一管理,需要在pages.json里配置每个路由页面的路径以及页面样式(类似小程序在app.json中配置页面路由) (2)路由跳转 uni-app有两种页面路由跳转方式:使用navigator组件跳转(标签式导航)、调用API跳…

比亚迪:从低谷中涅槃,内功造就辉煌

修炼内功才能绽放光芒吗? 比亚迪用自己的奋斗史证明~ 只有经历低谷的洗礼,才能铸就属于自己的辉煌。 比亚迪这家公司的发展历程可谓是一部从战略转型到今天这个行业翘楚的奋斗史,真是跌宕起伏令人唏嘘。早期比亚迪从一个传统企业转型到汽车行业&#xf…

电源模块常见温升测试方法分享 -纳米软件

温升测试是电器产品安规测试项目之一,是为了检测电器产品及部件的温度变化情况,判断是否符合要求。在设备运行过程中会释放一定的热量,如果内部温度过高会影响产品的性能和稳定性,导致绝缘性能下降,因此温升测试是确保…

sshpass 命令exit code 6 问题解决方法

近期在使用sshpass做自动化交互的脚本,结果运行命令后会返回错误码6,命令如下: sshpass -p 123456 ssh test192.168.1.100 "uname -a" 经搜索资料发现,错误码6指的是Host public key is unknown,也就是说要访问的地址是…

股东分红模式玩法解析!

股东分红模式股东分红模式是指公司通过向股东支付现金或股票的方式,将公司利润分配给股东的一种方式。不同的股东分红模式有着不同的特点和应用场景。 ​一、模式概述 一个私域电商平台,非常重要的一个角色是“团队长”,尤其是能够带动业绩和…

MoE模型性能还能更上一层楼?一次QLoRA微调实践

Fine-Tuning Mixtral 8x7B with QLoRA:Enhancing Model Performance 🚀 编者按:最近,混合专家(Mixture of Experts,MoE)这种模型设计策略展现出了卓越的语言理解能力,如何在此基础上进一步提升 MoE 模型的性能成为业界…

Win10子系统Ubuntu实战(二)

在 Windows 10 中安装 Ubuntu 子系统(Windows Subsystem for Linux,简称 WSL)有几个主要的用途和好处:Linux 环境的支持、跨平台开发、命令行工具、测试和验证、教育用途。总体而言,WSL 提供了一种将 Windows 和 Linux…

使用python执行系统命令的五种方式

在日常开发中,有时需要在Python脚本中执行系统命令,Python有五种方式来执行系统命令,推荐使用第五种。 python执行系统命令的五种方式 方法1: os.system 这是最简单的方法,适合简单的业务场景,输入为完整命令字符串…

【IP-Adapter】进阶 - 同款人物【2】 ☑

测试模型:###最爱的模型\flat2DAnimerge_v30_2.safetensors [b2c93e7a89] 原图: 加入 control1 [IP-Adapter] 加入 control 2 [OpenPose] 通过openpose骨骼图修改人物动作。 加入 control 3 lineart 加入cotrol3 …