首页 > 其他分享 >recketmq-dashboard打包

recketmq-dashboard打包

时间:2022-10-16 14:00:20浏览次数:72  
标签:recketmq 打包 broker topic master 消息 集群 rocketmq dashboard

前提

使用JDK1.8

下载编译

rocketmq-dashboard-master (之前叫 rocketmq-console)是RocketMQ 的可视化插件,通过该插件我们可以在界面实现消息的生产和消费。

下载地址:https://gitcode.net/mirrors/apache/rocketmq-dashboard

下载好之后解压: image.png

解压完成,可以看到目录,这是一个springboot项目,使用Intellij打开: image.png

为了避免端口号冲突,接下来我们需要在项目的src/main/resources 文件夹里面的 application.yml 配置文件并打开,修改端口号,比如说此处我将其修改成了6688。 image.png

其次需要注意这里的“rocketmq.config.namesrvAddr=”配置,即需要设置自己的rocketmq的name服务的地址和端口号。默认端口号是9876。 image.png

使用Intellij编译打包项目 image.png

编译的过程中需要保持网络畅通。如果失败多编译几次–可能是网络问题。

编译成功之后,切换到项目根目录下的target下会看到生成的jar文件: image.png

运行

  • 第一步:双击rocketmq/bin/mqnamesrv.cmd,启动nameserver image.png

  • 第二步:在rocketmq/bin目录下打命令行,输入以下代码:

.\bin\mqbroker.cmd -n localhost:9876 autoCreateTopicEnable=true

image.png

  • 第三步:运行刚才编译好的dashboard项目jar文件: image.png

在浏览器中访问:localhost:6688

image.png 整体横向菜单分为八个部分:

  • OPS(运维):主要是设置nameserver和配置vipchannel
  • Dashboard(驾驶舱):控制台的dashboard,可以分别按broker和主题来查看消息的数量和趋势。
  • Cluster(集群):整个RocketMq的集群情况,包括分片,编号,地址,版本,消息生产和消息消费的TPS等,这个在做性能测试的时候可以作为数据指标。
  • Topic(主题):可以新增/更新topic;也看查看topic的信息,如状态,路由,消费者管理和发送消息等。
  • Consumer(消费者):可以在当前broker中查看/新建消费者group,包括消费者信息和消费进度
  • Producer(生产者):可以在当前broker中查看生产组下的生产者group,包生产者信息和生产者状态
  • Message(消息):可以按照topc,messageID,messageKey分别查询具体的消息 其中最常用的是集群,主题,消费者和消息这四部分。

切换成中文: image.png

运维

image.png 设置Nameserver

  • 打开/关闭vipchannnel 设置nameserver:可以添加多个nameserver地址到输入框内,默认读取的是DashBoard这个springboot启动配置里面的nameserver配置。如果rockermq集群里有加入新的nameserver节点,可以在这里动态配置后更新生效。

  • 打开/关闭vipchannel: 这里默认为false就好,vipchannnel针对的是topic的优先级,相当于在消息处理的时候,有些topic可以走vipchannel,可以优先被处理,这个除了电商场景用的一般不多。

驾驶仓

image.png 驾驶舱消息当前数量和最近的趋势,如图左侧为当前消息总数量,右侧为消息数量趋势。我们分别解释如下四张图。

  • 按broker实例为类目(比如说集群中有3个broker实例)展示当前的消息数
  • 按topic为类目(比如说当前所有broker中存在10个topic)展示当前的消息数
  • 指定某天和时间段,查询不同broker实例的消息数的趋势
  • 指定某天和时间段,查询某topic下消息数的趋势

集群

image.png 分片:指的是数据分片(或者broker),当前rocketmq集群的只有一个数据分片,id为RaftNode00,即所有数据都在这个分片上;rocketmq的消息数据可以分布在多个数据分片上(一般都是多broker集群),后面搭建集群化环境的时候会讲到。

  • 编号:标识了哪些是master(0是master),哪些是slave,master负责直接读写;slave相当于master的副本,定期从master同步数据,如果master挂掉,slave会自动内部选举一个master节点。
  • 地址:即broker的实际ip端口。
  • 版本:rocketmq的版本
  • 生产消息TPS:即broker中处理消息的TPS(每秒落盘的消息数)。
  • 消费消息TPS:即consumer从broker中收取消息的TPS(每秒接收的消息数) 。
  • 昨日生产总数:昨天落盘的总消息数。
  • 昨日消费总数:昨天消费的总消息数。
  • 今天生产总数:今天落盘的总消息数。
  • 今天消费总数:今天消费的总消息数。

主题

image.png 主题里面有三大类型

  • 普通主题:这里是rocketmq自动创建的一些系统topic,然后用户创建的topic也展示在这里。
  • 重试主题:这里是发送失败时候系统为之创建的topic。
  • 死信主题:这里的topic类似垃圾箱,无法从中生产或者消费消息。

消费者

image.png

标签:recketmq,打包,broker,topic,master,消息,集群,rocketmq,dashboard
From: https://blog.51cto.com/lianghecai/5760234

相关文章