1.下载RocketMq二进制包并上传到服务器
https://rocketmq.apache.org/zh/docs/quickStart/01quickstart
点击链接进入RocketMq官网,即可下载二进制包
cd /usr/local
mkdir rocketMq
上传RocketMq二进制包到该目录
2.解压RocketMq二进制包
# 我这里下载的是5.3.2版本
unzip rocketmq-all-5.3.2-bin-release.zip
3.修改RocketMq的配置文件
由于RocketMq推荐的运行内存比较大,我们的Linux虚拟机一般就2-4G左右。因此要修改RocketMq的运行内存
3.1 修改runserver.sh文件
vim /usr/local/rocketMq/rocketmq-all-5.3.2-bin-release/bin/runserver.sh
#找到 JAVA_OPT="${JAVA_OPT} -server -Xms4g -Xmx4g -Xmn2g -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"
#将 -Xms4g改为 -Xms512m, -Xmn2g改为-Xmn512m,-Xmn2g改为-Xmn256m
#这段配置的意思是:rockerMq的jvm初始化内存是512m,最大内存是512m,新生代大小为256m,元空间的初识大小是128m
#wq保存修改的配置
3.2 修改runbroker.sh文件
vim /usr/local/rocketMq/rocketmq-all-5.3.2-bin-release/bin/runbroker.sh
# 找到JAVA_OPT="${JAVA_OPT} -server -Xms8g -Xmx8g"
# 将两个8g都改成512m
4.启动RocketMq的各个组件
4.1 启动NameServer
#进入rockermq可执行脚本目录
cd /usr/local/rocketMq/rocketmq-all-5.3.2-bin-release/bin/
#启动RocketMq的组件之一:NameServer
nohup sh mqnamesrv &
# 查看NameServer启动日记
tail -f ~/logs/rocketmqlogs/namesrv.log
4.2 启动Broker
nohup sh mqbroker -n localhost:9876 --enable-proxy &
#查看broker的日志,检查是否启动成功
tail -f ~/logs/rocketmqlogs/proxy.log
5.运行测试脚本测试RocketMq是否启动
RocketMq提供了发送消息和消费消息的测试脚本,让我尝试自己的RocketMq是否部署完成。
cd /usr/local/rocketMq/rocketmq-all-5.3.2-bin-release/bin/
export NAMESRV_ADDR=localhost:9876
#发送测试消息。这个命令会需要一定时间,执行完会自己退出。并会打印[ok]表示消息发送成功
sh tools.sh org.apache.rocketmq.example.quickstart.Producer
既然已经发送了消息,接着测试下消费消息是否成功
sh tools.sh org.apache.rocketmq.example.quickstart.Consumer
#这个命令会有[true]的提示。这条命令不会自动退出,因为消费者是需要一直等待消息的。
至此,RocketMq的单机安装已经完成。后面再安装一下RocketMq的可视化页面。
文章评论