centos中安装rocketmq
(
相关资源下载:
rocketmq-all-4.6.1-bin-release.zip
链接:https://pan.baidu.com/s/1pGn8q1t-Hyvp_7zDAknVrQ
提取码:kw65
rocketmq-console-ng-1.0.0.jar
链接:https://pan.baidu.com/s/1OrLF-9vU_SQMFgUqJ9_ffg
提取码:o8ai
)
1、从官网rocketmq的二进制安装包
http://rocketmq.apache.org/dowloading/releases/
下载包: rocketmq-all-4.6.1-bin-release.zip
或者从我的百度网盘下载
rocketmq-all-4.6.1-bin-release.zip
链接:https://pan.baidu.com/s/1pGn8q1t-Hyvp_7zDAknVrQ
提取码:kw65
2、解压安装
unzip rocketmq-all-4.6.1-bin-release.zip
mv rocketmq-all-4.6.1-bin-release /usr/local/rocketmq #移动目录并重命名
cd /usr/local/rocketmq
3、启动mq服务
(1) 启动namesrv
nohup bin/mqnamesrv >/dev/null 2>&1 &
tail -f ~/logs/rocketmqlogs/namesrv.log
(2) 启动broker
修改conf/broker.conf 配置 ,添加
brokerIP1=192.168.11.10 #本机ip地址
nohup bin/mqbroker -n localhost:9876 -c conf/broker.conf >/dev/null 2>&1 &
tail -f ~/logs/rocketmqlogs/broker.log
(
启动之前,可适当地调整启动的内存参数
vi runserver.sh
JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx256m -Xmn128m -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"
vi runbroker.sh
JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx256m -Xmn128m"
)
4、测试mq是否启动成功
export NAMESRV_ADDR=localhost:9876
bin/tools.sh org.apache.rocketmq.example.quickstart.Producer
export NAMESRV_ADDR=localhost:9876
bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer
5、 关闭mq
bin/mqshutdown broker
bin/mqshutdown namesrv
6、启动rocketmq-console控制台 ,这是一个springboot开发的rocketmq管理后台程序。
百度网盘下载:
rocketmq-console-ng-1.0.0.jar
链接:https://pan.baidu.com/s/1OrLF-9vU_SQMFgUqJ9_ffg
提取码:o8ai
用压缩程序打开修改jar包中的application.properties配置文件
server.contextPath= server.port=7777 #spring.application.index=true spring.application.name=rocketmq-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 rocketmq.config.namesrvAddr NAMESRV_ADDR | now, you can set it in ops page.default localhost:9876 rocketmq.config.namesrvAddr=localhost:9876 #if you use rocketmq version < 3.5.8, rocketmq.config.isVIPChannel should be false.default true rocketmq.config.isVIPChannel= #rocketmq-console's data path:dashboard/monitor rocketmq.config.dataPath=/logs/rocketmq_console/data #set it false if you don't want use dashboard.default true rocketmq.config.enableDashBoardCollect=true
注意修改下其中 rocketmq.config.namesrvAddr和rocketmq.config.dataPath 值即可
启动控制台
nohup java -jar rocketmq-console-ng-1.0.0.jar >console.log 2>&1 &
Copyright © 叮叮声的奶酪 版权所有
备案号:鄂ICP备17018671号-1