开发者学堂课程【全面讲解 Spring Cloud Alibaba 技术栈(知识精讲+项目实战)第四阶段:RocketMQ 控制台安装】学习笔记,与课程紧密联系,让用户快速学习知识。
课程地址:https://developer.aliyun.com/learning/course/686/detail/11905
RocketMQ 控制台安装
1、下载
#在qit上下载下面的工程rocketmq-console-1.0.0
http://github.com/apache/rocketmq-externals/releases
2、修改配置文件
#修改配置文件
rocketmg-console\src\mainresources\applica
tion.properties
server.port=7777 #项目启动后的端口号
rocketmq.config.namesrvAddr=192.168.109.131:9876#nameserv的地址,注意防火墙要开启 9876 端口
3、打成jar包,并启动
# 进入控制台项目,将工程打成 jar 包
mvn clean package-Dmaven.test.skip=true
# 启动控制台
java -jar target/rocketm-console-ng-1.0.0.jar
4、访问控制台
RocketMQ 中是什么样的形式存在是没有办法得到直观展示的,安装一个 RocketMQ 的控制台通过控制台,能够清晰的看到消息在 RocketMQ 中的存在形式,控制台提供了各种各样的查询条件,通过产品条件还可以实现对消息的过滤。
(1)安装
第一步拿到安装包提供出一个下载地址,把地址复制出来到浏览器。
最下面有一个 rocketmq-console-1.0.0版本,也是 rocketmq 的控制台,最新版本给的是1.0.0下面有对应的下载格式 zip 和 tar.gz,进行解压缩操作
点进去 rocket mq console 会发现是一个 xml 工程,只需要使用xml 命令对它进行一个打包,然后运行操作就可以,在打包运行之前需要修改里面的两个配置。
server.contextPath=
server.port=8080
#spring.application.index=true
spring.application.name=rocketma-console
spring.http.encoding.charset=UTF-8
spring.http.encoding.enabled=true
spring.http.encoding.force=true
logging.config=classpath:logback.xml
#if this value is empty,use env value
rocketmg.config.namesrv Addr NAMESRV ADDR I now, you can set it in ops page.default localhos
rocketmg.config.namesrvAddr=
#if you use rocketmg version < 3.5.8, rocketm
g.config.isVIPChannel should be false.default true
rocketmg.config.isvipchannel=
#rocketmg-console's data path:dashboard/monitor
rocketmg.config.dataPath=/tmp/rocketmg-console/data
#set it false if you don't want use dashboard.default true
rocketma.config.enableDashBoardcollect=true
修改的地方有两处,当前工程所在的端口因为 8080 前面已经被sentno 占用,所以要调整掉改成四个七,只要改成没有用过的端口就可以,这是第一个位置。第二个位置要修改的是指定一下 Name Server 的地址,因为控制台要连上 NameServer 去获取里面的各种信息号,192.168.109.131 后边对应 9876端口。
server.contextPath=
server.port=7777
#spring.application.index=true
spring.application.name=rocketma-console
spring.http.encoding.charset=UTF-8 spring.http.encoding.enabled=true spring.http.encoding.force=true
logging.config=classpath:logback.xml
#if this value is empty,use env value
rocketmg.config.namesrv Addr NAMESRV ADDR I now, you can set it in ops page.default localhos
rocketmg.config.namesrvAddr=192.168.109.131:9876
#if you use rocketmg version < 3.5.8, rocketm
g.config.isVIPChannel should be false.default true
rocketmg.config.isvipchannel=
#rocketmg-console's data path:dashboard/monitor
rocketmg.config.dataPath=/tmp/rocketmg-console/data
#set it false if you don't want use dashboard.default true
rocketma.config.enableDashBoardcollect=true
退回到根目录上,把打包 jar 直接拷过来首先执行一个清理,然后打包,最后跳过测试。因为前面已经运行过了,所以速度还是比较快的,如果第一次运行可能要联网去下载很多的依赖,所以要耐心等待一下。
Ws 目录下面就出现一个 rocketmq-counsole-ng-1.0.0.jar,接下来运行 cmd。然后 java-jar-rocketmq,这是 spring boot 开发的项目,只需要等待它启动完毕以后,就能通过所设定的端口进行访问了。
可以进行访问,现在已经启动成功,localhost 7777。
默认的英文界面
切换语言为简体中文,简单的控制台
通过控制台可以查看各种信息,首先是运维,已经配置好连接默认的 NameServer
驾驶舱里可以看到直观的图表包括 topical、Broker 等等
还可以通过集群、主题、消费者、生产者等各种条件去筛选,比如集群
因为现在没有集群,只能看到默认的第一个 DefaultCluster ,131服务器,也写了生产消息的数量和消费数量。
还可以按照主题、消费者、生产者分别搜索,最后可以直接按照消息来搜索
消息里面可以挑选主题 Topic Test,可以控制时间,点击搜索
这段时间内所生产消费的消息,通过后面的消息详情可以看到更加详细的消息界面,比如消息的主题、ID、标签、键、存储时间和消息内容.