赞
踩
使用RocketMQ需要3个服务组件:
①nameserver :路由中心,为整个MQ集群提供服务协调与治理
②broker: 提供消息的转发和存储功能
③console :可视化的控制台面板工具
下载RocketMQ:https://rocketmq.apache.org/dowloading/releases/,选择Binary下载(不要选择源码,Binary是已经经过编译的可以直接使用),本文使用的是4.9.3版本,下载好后解压备用
RocketMQ可视化仪表台下载:https://github.com/apache/rocketmq-externals/tags,下载rocketmq-console-1.0.0这个版本就行,下载完成后解压,进入rocketmq-externals\rocketmq-console\src\main\resources文件夹,打开application.properties进行配置修改
配置完成后将项目达成jar包,如果嫌打包麻烦或者不会操作,可以直接使用作者打好的jar包
https://download.csdn.net/download/m0_68772878/88718264
配置MQ环境变量(这一步必须要做,否则很有可能无法启动nameserve服务)
首先确保本机已经配置了java环境变量,在控制台输入检查是否配置了java环境
echo $JAVA_HOME
打开解压后的MQ目录,进入bin目录,找到runbroker.sh和runserver.sh两个文件,找到JAVA环境变量配置,注释掉第二行和第三行,将第一行的JAVA_HOME替换成自己的 jdk 的安装目录,配置完成后保存
替换成
在MQ目录下的bin目录进入控制台
- //启动namaserver服务
- nohup sh mqnamesrv &
-
- // 查看namaserver日志
- tail -f ~/logs/rocketmqlogs/namesrv.log
-
显示以下内容代表路由启动成功
如果控制台出现类似的提示很有可能是JAVA环境变量没有配置成功
[1]+ Exit 1 nohup sh mqnamesrv
也可以通过 ./mqnamesrv 进行检查
- //启动broker组件
- nohup sh mqbroker -n localhost:9876 &
-
- // 查看broker日志
- tail -f ~/logs/rocketmqlogs/broker.log
-
显示以下内容代表启动broker成功
- //停止 broker
- sh mqshutdown broker
-
- //停止 nameserver
- sh mqshutdown namesrv
在控制台输入jar包命令启动进程
java -jar jar包路径 --server.port=8080 --rocketmq.config.namesrvAddr=localhost:9876
通过浏览器访问http://localhost:8080/#/即可进入MQ仪表台(如果之前配置了不同的端口就根据自己的端口进入仪表台)
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。