如何为绍兴企业定制专属的网站模板?
摘要:平台网站定制,绍兴网站建设模板网站,龙岩房产网,Wordpress要建数据库吗文章说明 本文主要说明RocketMQ的控制台(Dashboard)的安装过程。工作中一直用的是别人装
平台网站定制,绍兴网站建设模板网站,龙岩房产网,Wordpress要建数据库吗文章说明
本文主要说明RocketMQ的控制台#xff08;Dashboard#xff09;的安装过程。工作中一直用的是别人装好的#xff0c;这次终于自己亲手装了一遍。 由于每次都要启动三个应用#xff0c;比较烦#xff0c;于是我写了一键启动脚本#xff0c;分享给大家。这个脚本…文章说明
本文主要说明RocketMQ的控制台Dashboard的安装过程。工作中一直用的是别人装好的这次终于自己亲手装了一遍。 由于每次都要启动三个应用比较烦于是我写了一键启动脚本分享给大家。这个脚本可以一键启动RocketMQ的所有应用。还能自动识别应用是否已经启动成功。 文章目录 文章说明参考说明控制台(Dashboard)环境要求下载修改配置打包启动访问控制台使用 一键启动脚本 参考说明
本文内容主要来源于马士兵李瑾老师的视频教程RocketMQ基础实战版结合了老师的笔记以及根据自己的实践做了一些修改。
控制台(Dashboard)
官网文档https://rocketmq.apache.org/zh/docs/4.x/deployment/03Dashboard
环境要求
jdk1.8Maven 3.2.x
启动前确认RocketMQ NameServer和Broker已安装且已经启动成功。
下载
新版本地址推荐https://rocketmq.apache.org/zh/download
老版本地址下载https://codeload.github.com/apache/rocketmq-externals/zip/master
本文用的是RocketMQ Dashboard 1.0.0 新版本。
下载成功后解压到一个源代码目录。例如D:\Workspace\idea\alibaba\rocketmq-dashboard-1.0.0
修改配置
使用idea载入刚才下载好的源代码然后在settings中确认maven配置正确。
打开src/main/resources/application.properties文件进行如下配置
# dashboard服务启动之后的端口
server.port8089
# 配置NameServer地址如果多个可以以分号隔开
rocketmq.config.namesrvAddrlocalhost:9876打包
执行mvn install -Dmaven.test.skiptrue命令可以在右侧的Maven页签的lifecycle中双击install同时勾选Skip Test。
成功的话会在target目录生成jar包rocketmq-dashboard-1.0.0.jar
启动
启动之前请先确保配置文件中对应的NameSever和Broker已经启动。否则dashboard启动起来也没读取不到内容。
启动有如下方式
通过打出来的jar包启动。cmd进入项目target目录执行java -jar rocketmq-dashboard-1.0.0.jar通过代码直接启动。通过启动类org.apache.rocketmq.dashboard.App启动
访问
浏览器输入localhost:8089成功后即可进行管理端查看。
控制台使用
运维 你可以修改这个服务使用的namesrv的地址 你可以修改这个服务是否使用VIPChannel(如果你的mq server版本小于3.5.8请设置不使用)
驾驶舱 查看broker的消息总量左边的是最近5分钟的趋势图。 查看单一主题的消息量总量/趋势图
集群 查看集群的broker情况分布情况cluster与broker关系 查看broker具体信息/运行信息 查看broker配置信息
主题页面 展示所有的主题可以通过搜索框进行过滤 筛选 普通/重试/死信 主题重试为消息发送失败之后的重试主题。死信就是默认发送失败15次的消息。 添加/更新主题
l clusterName 创建在哪几个cluster上
l brokerName 创建在哪几个broker上
l topicName 主题名
l writeQueueNums 写队列数量
l readQueueNums 读队列数量
l perm //2是写 4是读 6是读写 状态 查询消息投递状态投递到哪些broker/哪些queue/多少量等 路由 查看消息的路由现在你发这个主题的消息会发往哪些broker对应broker的queue信息 CONSUMER管理这个topic都被哪些group消费了消费情况何如 topic配置查看变更当前的配置 发送消息向这个主题发送一个测试消息 重置消费位点(分为在线和不在线两种情况不过都需要检查重置是否成功) 删除主题 会删除掉所有broker以及namesrv上的主题配置和路由信息
消费者页面 展示所有的消费组可以通过搜索框进行过滤 刷新页面/每隔五秒定时刷新页面 按照订阅组/数量/TPS/延迟 进行排序 添加/更新消费组
l clusterName 创建在哪几个集群上
l brokerName 创建在哪几个broker上
l groupName 消费组名字
l consumeEnable //是否可以消费 FALSE的话将无法进行消费
l consumeBroadcastEnable //是否可以广播消费
l retryQueueNums //重试队列的大小
l brokerId //正常情况从哪消费
l whichBrokerWhenConsumeSlowly//出问题了从哪消费 终端 在线的消费客户端查看包括版本订阅信息和消费模式 消费详情 对应消费组的消费明细查看这个消费组订阅的所有Topic的消费情况每个queue对应的消费client查看包括Retry消息 配置 查看变更消费组的配置 删除 在指定的broker上删除消费组
生产者页面
通过Topic和Group查询在线的消息生产者客户端
信息包含客户端主机 版本
消息查询页面 根据Topic和时间区间查询 *由于数据量大 最多只会展示2000条多的会被忽略 根据Topic和Key进行查询
最多只会展示64条 根据消息主题和消息Id进行消息的查询 消息详情可以展示这条消息的详细信息查看消息对应到具体消费组的消费情况如果异常可以查看具体的异常信息。可以向指定的消费组重发消息 一键启动脚本
这个脚本主要用于一键启动RocketMQ的NameServerBrokerDashboard三个应用。 并且启动之前会自动识别要启动的应用是否已经启动启动成功则自动启动下一个。
#!/bin/bash#软件安装目录设置先读环境变量读不到则用默认值
ROCKETMQ_HOME$ROCKETMQ_HOME
if [ -z $ROCKETMQ_HOME]; thenecho ROCKETMQ_HOME is not set! the program will use default valueROCKETMQ_HOME/www/wwwroot/install/rocketmq-all-4.9.7-bin-release
fi
echo ROCKETMQ_HOME$ROCKETMQ_HOME# 启动rocketmq nameserver
cd ${ROCKETMQ_HOME}/bin
# 检查Zookeeper是否启动成功
if jps -ml | grep namesrv.NamesrvStartup; thenecho rocketmq nameserver is running.;
elseecho rocketmq nameserver is Starting ...;rm -rf nohup.out;nohup sh mqnamesrv count0while [ $count -le 10 ]; doif tail -100 nohup.out | grep Name Server boot success; thenecho rocketmq nameserver has been started successfully;breakelsecount$((count1))sleep 2fidone
fi# 启动rocketmq broker
# 检查Zookeeper是否启动成功
if jps -ml | grep org.apache.rocketmq.broker.BrokerStartup; thenecho rocketmq broker is running.;
elseecho rocketmq broker is Starting ...;rm -rf nohup.out;nohup sh mqbroker -c ../conf/broker.conf -n dev-study:9876 autoCreateTopicEnabletrue count0while [ $count -le 10 ]; doif tail -100 nohup.out | grep broker.*success; thenecho rocketmq broker has been started successfully;breakelsecount$((count1))sleep 2fidone
fi# 启动rocketmq dashboard
cd ${ROCKETMQ_HOME}/dashboard
if jps -ml | grep rocketmq-dashboard; thenecho rocketmq dashboard is running.;
elseecho rocketmq dashboard is Starting ...;rm -rf nohup.out;nohup java -jar rocketmq-dashboard-1.0.0.jar count0while [ $count -le 10 ]; doif tail -100 nohup.out | grep Tomcat started on port(s); thenecho rocketmq dashboard has been started successfully;breakelsecount$((count1))sleep 2fidone
fiecho All services started.;
