一、前置准备
安装JDK,要是没有安装,请参考如下文章进行安装
https://blog.csdn.net/HelloWorld20161112/article/details/129085841
二、安装
2.1、下载RocketMQ安装包
# 官网
https://rocketmq.apache.org/download
# 我分享的
链接:https://pan.baidu.com/s/1xWJvwXoKSVsU2VD0UvxfYw?pwd=yyds
提取码:yyds
2.2、上传至 /opt 目录
2.3、解压
unzip rocketmq-all-4.4.0-bin-release.zip
2.3.1、目录介绍
- bin:启动脚本,包括shell脚本和cmd脚本
- conf:实例配置文件,包括broker配置文件,logback配置文件等
- lib:依赖jar包,包括Netty、commons-lang、FastJSON等
2.4、将解压包移动[剪切]至 /usr/local/myRocketMQ
# 剪切
mv rocketmq-all-4.4.0-bin-release /usr/local/myRocketMQ
2.5、启动RocketMQ
2.5.1、修改JVM内存大小
问题描述:RocketMQ默认的虚拟机内存比较大,启动Broker可能会因为内存不足失败,需要修改如下两个配置文件,修改其默认的JVM内存大小。
RocketMQ JVM 默认配置
修改RocketMQ JVM默认配置
# 1、进入 bin 目录
# 2、编辑 runbroker.sh 和 runserver.sh,修改默认JVM大小
vim runbroker.sh
vim runserver.sh
# 参考配置
JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx256m -Xmn128m -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"
2.5.2、启动NameServer
# 第一步:进入bin目录
cd /usr/local/myRocketMQ/bin
# 第二步:启动NameServer
nohup sh mqnamesrv &
# 第三步:查看启动日志
tail -f ~/logs/rocketmqlogs/namesrv.log
2.5.3、启动Broker
# 1、进入 bin 目录
cd /usr/local/myRocketMQ/bin
# 2、启动Broker
nohup sh mqbroker -n localhost:9876 &
# 3、查看启动日志
tail -f ~/logs/rocketmqlogs/broker.log
2.5.4、查看NameServer & Broker启动是否成功
jps
2.6、测试RocketMQ
2.6.1、发送消息
# 1、进入 bin 目录
cd /usr/local/myRocketMQ/bin
# 2、设置环境变量
export NAMESRV_ADDR=localhost:9876
# 2、使用安装包的Demo发送消息
sh tools.sh org.apache.rocketmq.example.quickstart.Producer
2.6.2、接收消息
# 1、进入 bin 目录
cd /usr/local/myRocketMQ/bin
# 2、设置环境变量
export NAMESRV_ADDR=localhost:9876
# 2、使用安装包的Demo接收消息
sh tools.sh org.apache.rocketmq.example.quickstart.Consumer
2.7、关闭RocketMQ
# 1、进入 bin 目录
cd /usr/local/myRocketMQ/bin
# 2、关闭 NameSrv
sh mqshutdown namesrv
# 3、关闭 Broker
sh mqshutdown broker