RocketMQ环境搭建

1.安装

1.1环境要求

• linux64位系统
• java1.8（64位）
• maven（>=3.2.x）
  image.png

1.2安装步骤

1. 解压rocketmq安装包到/usr/local

   unzip rocketmq-all-4.4.0-source-release.zip -C /usr/local
   

2. 进入安装目录，赋予权限

   cd /usr/local
   sudo chown -R qianfg:qianfg rocketmq-all-4.4.0/
   

3. 进入rocketmq目录，maven打包

   cd rocketmq-all-4.4.0
   mvn -Prelease-all -DskipTests clean install -U
   

2.配置文件修改

maven打包后产生distribution目录，进入该目录下的bin，可看到一系列脚本

cd distribution
ls bin/

image.png

修改jvm内存大小

image.png

把原来的最小内存4g，最大内存8g改为最小内存128m，最大内存256m(根据自己的虚拟机内存情况进行配置)

1.vim bin/runserver.sh

修改JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx256m -Xmn128m"

2.vim bin/runbroker.sh

修改JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx256m -Xmn128m -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"

3、启动rocketMQ

image.png

1.启动namesrv

# i.启动namesrv
nohup sh bin/mqnamesrv &
# ii.查看启动日志
tail -f ~/logs/rocketmqlogs/namesrv.log

2.启动broker

i.启动broker
nohup sh bin/mqbroker -n localhost:9876 autoCreateTopicEnable=true &
ii.查看启动日志
tail -f ~/logs/rocketmqlogs/broker.log

4、测试rocketMQ

1.进入tartget/apache-rocketmq目录

cd target/apache-rocketmq

2.启用消息生产者样例

# i.设置环境变量
export NAMESRV_ADDR=localhost:9876
# ii.使用安装包的Demo发送消息
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer

image.png

3.启用消息消费者样例

# i.设置环境变量
export NAMESRV_ADDR=localhost:9876
# ii.接收消息
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer

image.png