初始化安装环境

下载RocketMQ安装包

wget http://mirror.bit.edu.cn/apache/rocketmq/4.6.1/rocketmq-all-4.6.1-bin-release.zip

安装jdk

yum install -y jdk8

启动namesrv

#执行脚本调整系统参数
bash /opt/rocketmq/bin/os.sh
#vim /lib/systemd/system/rocketmq-nameserver.service
---------------
cat > /lib/systemd/system/rocketmq-nameserver.service << EOF
[Unit]
Description=rocketmq-nameserver
After=syslog.target network.target remote-fs.target nss-lookup.target
​
[Service]
User=admin
Type=simple
ExecStart=/bin/sh /opt/rocketmq/bin/mqnamesrv
ExecStop=/bin/sh /opt/rocketmq/bin/mqshutdown namesrv
Restart=always
PrivateTmp=true
​
[Install]
WantedBy=multi-user.target
EOF
systemctl enable rocketmq-nameserver.service
systemctl start rocketmq-nameserver.service

修改配置文件

broker Master配置文件模板

cat > broker-Master.conf << EOF
#集群名，同集群必须一致
brokerClusterName=Yunxi
#节点名，用于确认主从关系
brokerName=broker-1
brokerId=0
deleteWhen=04
fileReservedTime=48
#节点角色 可以选择同步方式同步方式 ASYNC(异步)与SYNC(同步)
brokerRole=SYNC_MASTER
flushDiskType=ASYNC_FLUSH
#监听地址，可以有多个
brokerIP1=192.168.33.130
#brokerIP2
#监听端口
listenPort=10911
#NameServer地址
namesrvAddr=192.168.33.130:9876;192.168.33.131:9876;192.168.33.132:9876
#定义存储路径，多个broker放同一台主机建议使用用户区分。
#storePathRootDir=/opt/rocketmq/store/Master1
EOF

broker Slave配置文件模板

cat > broker-Slave.conf << EOF
#集群名，同集群必须一致
brokerClusterName=Yunxi
#节点名，用于确认主从关系
brokerName=broker-1
brokerId=1
deleteWhen=04
fileReservedTime=48
#节点角色 SLAVE节点
brokerRole=SLAVE
flushDiskType=ASYNC_FLUSH
#监听地址，可以有多个
brokerIP1=192.168.33.130
#brokerIP2
#监听端口
listenPort=11911
#storePathRootDir=/opt/rocketmq/store/slave2
namesrvAddr=192.168.33.130:9876;192.168.33.131:9876;192.168.33.132:9876
#定义存储路径，多个broker放同一台主机建议使用用户区分。
#storePathRootDir=/opt/rocketmq/store/Master1
EOF

启动brocker

#PS:默认brocker启动内存为8G，内存过小的服务器无法启动。
#需要调整 bin/runbroker.sh 下的java参数
#vim /lib/systemd/system/rocketmq-broker-master.service
----------
cat > /lib/systemd/system/rocketmq-broker-master.service << EOF
[Unit]
Description=rocketmq-broker-master
After=syslog.target network.target remote-fs.target nss-lookup.target
​
[Service]
User=master
Type=simple
ExecStart=/opt/rocketmq/bin/mqbroker -c /opt/rocketmq/conf/broker-master.conf
ExecStop=/opt/rocketmq/bin/mqshutdown broker
Restart=always
PrivateTmp=true
​
[Install]
WantedBy=multi-user.target
EOF
systemctl enable rocketmq-broker-master
systemctl start rocketmq-broker-master

启动brocker-slave

#vim /lib/systemd/system/rocketmq-broker-slave.service
----------
cat > /lib/systemd/system/rocketmq-broker-slave.service << EOF
[Unit]
Description=rocketmq-broker-slave
After=syslog.target network.target remote-fs.target nss-lookup.target

[Service]
User=slave
Type=simple
ExecStart=/opt/rocketmq/bin/mqbroker -c /opt/rocketmq/conf/broker-slave.conf
ExecStop=/opt/rocketmq/bin/mqshutdown broker
Restart=always
PrivateTmp=true

[Install]
WantedBy=multi-user.target
EOF
systemctl enable rocketmq-broker-slave
systemctl start rocketmq-broker-slave