一、安装RocketMQ(单机版)
1.1、前置准备
通过前面系列一、MQ简介、系列二、RocketMQ简介的文章我们知道RocketMQ是用Java语言编写的,所以在安装RocketMQ之前,需要保证Linux中的JDK是已经安装好了的,要不然无法安装!至于如何在Linux中安装JDK,请参考系列二、Linux中安装JDK,这里不再赘述。
1.2、安装
1.2.1、下载安装包
官网:
https://rocketmq.apache.org/download/
我分享的:
链接:https://pan.baidu.com/s/1ZFKuMlMpsO26rjSKZRr_-A?pwd=yyds
提取码:yyds
1.2.2、上传至/opt目录并解压
1.2.3、目录介绍
1.2.4、配置环境变量
编辑 /etc/profile 文件,添加如下内容:
# RocketMQ Config
export NAMESRV_ADDR=localhost:9876备注:此处的localhost根据自己的实际情况进行填写,具体语法为:export NAMESRV_ADDR=[localhost | 阿里云公网IP]:9876
1.2.5、生效环境变量
source /etc/profile
1.2.6、修改运行脚本(记得备份)
(一)修改runserver.sh
文件位置:/usr/local/rocketmq-4.9.2/bin/runserver.sh
修改内容如下:
JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx256m -Xmn128m -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"
题外话:为什么要修改?
因为默认的配置,堆的大小为4G,考虑到自己笔记本的性能问题,如果直接搞4G的话,可能会导致服务起不来,这里只是搭建简单的RocketMQ环境,上述配置足够用了!
(二)修改runbroker.sh
文件位置:/usr/local/rocketmq-4.9.2/bin/runbroker.sh
修改内容如下:
JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx256m"
1.2.7、修改broker.conf(记得备份)
文件位置:
/usr/local/rocketmq-4.9.2/conf/broker.sh
修改内容(末尾增加如下内容,IP根据自己的实际情况填写):
autoCreateTopicEnable=true
namesrvAddr=192.168.173.232:9876
brokerIP1=192.168.173.232
1.2.8、创建logs文件夹
在 /usr/local/rocketmq-4.9.2 目录创建logs文件夹,用于存放RocketMQ的日志信息。
1.2.9、启动 & 关闭
(一)启动
(1)启动NameServer
命令:nohup sh mqnamesrv > ../logs/namesrv.log &
查看namesrv启动日志是否有异常:
(2)启动broker
命令:nohup sh mqbroker -n 192.168.173.232:9876 -c ../conf/broker.conf > ../logs/broker.log &
查看broker启动日志是否有异常:
(3)运行可视化面板dashboard(文章开头我分享的链接里边有)
命令:
nohup java -jar rocketmq-dashboard-1.0.0.jar --server.port=8001 --rocketmq.config.namesrvAddr=192.168.173.232:9876 > /usr/local/rocketmq-4.9.2/logs/dashboard.log &
查看dashboard启动日志是否有异常:
(4)访问dashboard可视化面板
http://192.168.173.232:8001
(5)可能会遇到的坑
问题描述:org.apache.rocketmq.remoting.exception.RemotingConnectException: connect to <172.17.0.1: 10911> failed
解决方法:解决org.apache.rocketmq.remoting.exception.RemotingConnectException: connect to <172.17.0.1: 10911> failed
(二)关闭
cd /usr/local/rocketmq-4.9.2/bin
sh mqshutdown namesrv
sh mqshutdown broker