1.创建安装目录,上传压缩包:
百度云盘路径:/安装包/linux/rocketmq
cd /usr
2.解压:
unzip rocketmq-all-4.3.2-bin-release.zip mv rocketmq-all-4.3.2-bin-release rocketmq cd rocketmq
3.启动nameserver
#一般启动: /usr/rocketmq/bin/mqnamesrv #后台启动 sh /usr/rocketmq/bin/mqnamesrv & #看日志: sh /usr/rocketmq/rocketmq/bin/mqnamesrv >>/logs/namesrv.log 2>&1 & #指定配置文件: sh /usr/rocketmq/bin/mqnamesrv -c /usr/rocketmq/conf/namesrv-a.properties > /dev/null /usr/rocketmq/logs/mqnamesrv.log 2>&1 & #关闭namesrv服务: sh /usr/rocketmq/bin/mqshutdown namesrv
4.配置2m2s集群
进入rocketmq的conf文件夹进行配置
broker-a-master
#集群名称 brokerClusterName = rmqCluster brokerName = broker-a #master为0,slave为1 brokerId = 0 # 这个ip配置为内网访问,让mq只能内网访问,不配置默认为内网 brokerIP1 = 172.0.0.10 brokerIP2 = 172.0.0.10 #数据清除时间 凌晨4点 deleteWhen = 04 #清除48小时之前的数据 fileReservedTime = 48 #Broker角色 brokerRole = SYNC_MASTER #刷盘方式 flushDiskType = ASYNC_FLUSH # nameserver的地址,如果只有一个nameserver,填一个即可 namesrvAddr=172.0.0.1:9876;172.0.0.2:9876 autoCreateTopicEnable=true #Broker 对外服务的监听端口, listenPort = 10911 #Broker角色 #- ASYNC_MASTER 异步复制Master #- SYNC_MASTER 同步双写Master #- SLAVE #brokerRole=SLAVE #刷盘方式 #- ASYNC_FLUSH 异步刷盘 #- SYNC_FLUSH 同步刷盘 #flushDiskType=SYNC_FLUSH
broker-a-slave
brokerClusterName = rmqCluster brokerName = broker-a brokerId = 1 brokerIP1 = 172.0.0.11 deleteWhen = 04 fileReservedTime = 48 brokerRole = SLAVE flushDiskType = ASYNC_FLUSH namesrvAddr=172.0.0.1:9876;172.0.0.2:9876 autoCreateTopicEnable=true listenPort = 10911
broker-b-master
brokerClusterName = rmqCluster brokerName = broker-b brokerId = 0 brokerIP1 = 172.0.0.20 brokerIP2 = 172.0.0.20 deleteWhen = 04 fileReservedTime = 48 brokerRole = SYNC_MASTER flushDiskType = ASYNC_FLUSH namesrvAddr=172.0.0.1:9876;172.0.0.2:9876 autoCreateTopicEnable=true listenPort = 10911
broker-b-slave
brokerClusterName = rmqCluster brokerName = broker-b brokerId = 1 brokerIP1 = 172.0.0.21 deleteWhen = 04 fileReservedTime = 48 brokerRole = SLAVE flushDiskType = ASYNC_FLUSH namesrvAddr=172.0.0.1:9876;172.0.0.2:9876 autoCreateTopicEnable=true listenPort = 10911
5.启动broker
#修改内存: vim /usr/rocketmq/bin/runbroker.sh #指定nameserver地址和端口: nohup sh /usr/rocketmq/bin/mqbroker -n localhost:9876 & #指定配置文件: nohup sh /usr/rocketmq/rocketmq/bin/mqbroker -c /usr/rocketmq/rocketmq/conf/broker.conf >>/logs/broker.log 2>&1 & #关闭 : sh /usr/rocketmq/bin/mqshutdown broker
6.查看日志
tail -f ~/logs/rocketmqlogs/namesrv.log tail -f ~/logs/rocketmqlogs/broker.log
7.数据清除:
rm -rf /root/logs/rocketmqlogs/* rm -rf /root/store/*
软件连接
链接:https://pan.baidu.com/s/1u4Os0MM8Uhu2HLjopXZYgA
提取码:istl
复制这段内容后打开百度网盘手机App,操作更方便哦



