【笔记】RocketMQ安装笔记

前言

RocketMQ安装笔记

准备工作

  • JDK环境
1
java -version

下载安装包

解压软件包

1
2
unzip rocketmq-all-4.7.0-bin-release.zip
cd rocketmq-all-4.7.0-bin-release

启动

修改启动配置(可选)

编辑runserver.sh

1
vim bin/runserver.sh

修改runserver.sh

  • 修改第67行,减少启动内存
1
JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx256m -Xmn128m -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=    320m"

编辑runbroker.sh

1
vim bin/runbroker.sh

修改runbroker.sh

  • 修改第67行,减少启动内存
1
JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx256m -Xmn128m"

启动

启动name server

1
nohup sh bin/mqnamesrv &

启动broker

-n localhost:9876:指定注册中心。name server就是默认的注册中心,它会在本地的9876端口启动

1
nohup sh bin/mqbroker -n localhost:9876 &

测试

1
2
3
export NAMESRV_ADDR=localhost:9876
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer

关闭命令

关闭broker

1
2
cd bin
./mqshutdown broker

关闭name server

1
2
cd bin
./mqshutdown namesrv

完成