RocketMQ入门安装

前提准备

因为RocketMQ是用Java开发的,所以启动RocketMQ必须有Java运行环境,JDK在CentOS7安装教程请点击

下载Rocket

wget https://archive.apache.org/dist/rocketmq/4.8.0/rocketmq-all-4.8.0-bin-release.zip

解压

tar xvf ./rocketmq-all-4.8.0-bin-release.zip -C ./rocketmq-4.8.0

修改JVM配置

./rocketmq-4.8.0/bin/runserver.sh

JAVA_OPT="${JAVA_OPT} -server -Xms128m -Xmx256m -Xmn128m -XX:MetaspaceSize=64m -XX:MaxMetaspaceSize=160m"

./rocketmq-4.8.0/bin/runbroker.sh

JAVA_OPT="${JAVA_OPT} -server -Xms128m -Xmx128m -Xmn64m"

端口修改与确定

确定Broker启动的端口

在[./rocketmq-4.8.0/rocketmq-9876/conf/broker.conf]尾部添加如下内容

listenPort=10909

修改NameServer默认启动端口[采用默认端口可以跳过此步骤]

1.在[./rocketmq-4.8.0/rocketmq-9876/conf]创建[namesrv.conf]文件
2.文件内容```listenPort=5432```
3.启动NameServer时命令```nohup ./rocketmq-4.8.0/bin/mqnamesrv -c ./rocketmq-4.8.0/conf/namesrv.conf  > ./rocketmq-4.8.0/logs/mqnamesrv.log 2>&1```

开放防火墙[9876]和[10909]端口,操作步骤点击查看

启动MQ

nohup ./rocketmq-4.8.0/bin/mqnamesrv > ./rocketmq-4.8.0/logs/mqnamesrv.log 2>&1

nohup ./rocketmq-4.8.0/bin/mqbroker -c ./rocketmq-4.8.0/conf/broker.conf > ./rocketmq-4.8.0/logs/broker.log 2>&1

查看启动情况

jps

测试脚本

消息生产者

./rocketmq-4.8.0/bin/tools.sh org.apache.rocketmq.example.quickstart.Producer

消息消费者

./rocketmq-4.8.0/bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer