单机下RocketMq安装-多Master模式

cd /usr/local
mkdir rocketmq
wget https://dist.apache.org/repos/dist/release/rocketmq/5.1.1/rocketmq-all-5.1.1-bin-release.zip

yum install -y unzip zip
unzip rocketmq-all-5.1.1-bin-release.zip

cd /usr/local/rocketmq/rocketmq-all-5.1.1-bin-release
mkdir -p store store/commitlog store/consumequeue

# Licensed to the Apache Software Foundation (ASF) under one or more
# contributor license agreements.  See the NOTICE file distributed with
# this work for additional information regarding copyright ownership.
# The ASF licenses this file to You under the Apache License, Version 2.0
# (the "License"); you may not use this file except in compliance with
# the License.  You may obtain a copy of the License at
#
#     http://www.apache.org/licenses/LICENSE-2.0
#
#  Unless required by applicable law or agreed to in writing, software
#  distributed under the License is distributed on an "AS IS" BASIS,
#  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
#  See the License for the specific language governing permissions and
#  limitations under the License.

#集群名称
brokerClusterName = DefaultCluster 

#broker名称
brokerName = broker-a

#broekrId #0 表示 Master，>0 表示 Slave
brokerId = 0

#删除时间凌晨4点
deleteWhen = 04

#文件保留时间,默认48小时
fileReservedTime = 48

#broker的角色
#ASYNC_MASTER异步复制master
#SYNC_MASTER 同步双写Master
brokerRole = ASYNC_MASTER

#刷盘方式
#- ASYNC_FLUSH 异步刷盘
#- SYNC_FLUSH 同步刷盘
flushDiskType = ASYNC_FLUSH

# Licensed to the Apache Software Foundation (ASF) under one or more
# contributor license agreements.  See the NOTICE file distributed with
# this work for additional information regarding copyright ownership.
# The ASF licenses this file to You under the Apache License, Version 2.0
# (the "License"); you may not use this file except in compliance with
# the License.  You may obtain a copy of the License at
#
#     http://www.apache.org/licenses/LICENSE-2.0
#
#  Unless required by applicable law or agreed to in writing, software
#  distributed under the License is distributed on an "AS IS" BASIS,
#  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
#  See the License for the specific language governing permissions and
#  limitations under the License.

#集群名称
brokerClusterName = DefaultCluster 

#broker名称
brokerName = broker-a

#broekrId #0 表示 Master，>0 表示 Slave
brokerId = 0

#在每天的什么时间删除已经超过文件保留时间的 commit log
deleteWhen = 04

#文件保留时间,默认48小时
fileReservedTime = 48

#broker的角色
#ASYNC_MASTER异步复制master
#SYNC_MASTER 同步双写Master
brokerRole = ASYNC_MASTER

#刷盘方式
#- ASYNC_FLUSH 异步刷盘
#- SYNC_FLUSH 同步刷盘
flushDiskType = ASYNC_FLUSH

#监听端口
listenPort=10911

#nameserver地址，多个地址时用分号(;)分割
namesrvAddr=公网ip:9876

#存储根路径
storePathRootDir=/usr/local/rocketmq/rocketmq-all-5.1.1-bin-release/store

#存储commitlog路径
storePathCommitLog=/usr/local/rocketmq/rocketmq-all-5.1.1-bin-release/store/commitlog

#当前broker监听的ip
brokerIP1=公网ip

#存在主从 broker 时，如果在 broker 主节点上配置了 brokerIP2 属性，#broker 从节点会连接主节点配置的 brokerIP2 进行同步
brokerIP2=公网ip

#是否自动创建topic
autoCreateTopicEnable=true

--清除缓存
echo 1 > /proc/sys/vm/drop_caches --清除pagecache
echo 2 > /proc/sys/vm/drop_caches --清除回收slab分配器中的对象（包括目录项缓存和inode缓存）。slab分配器是内核中管理内存的一种机制，其中很多缓存数据实现都是用的pagecache
echo 3 > /proc/sys/vm/drop_caches --清除pagecache和slab分配器中的缓存对象

#启动，并打印日志到文件
nohup sh /usr/local/rocketmq/rocketmq-all-5.1.1-bin-release/bin/mqnamesrv >/usr/local/rocketmq/mqnamesrv.log 2>&1 &
#关闭
sh /usr/local/rocketmq/rocketmq-all-5.1.1-bin-release/bin/mqshutdown namesrv

#启动broker，并打印日志到相关文件
nohup sh /usr/local/rocketmq/rocketmq-all-5.1.1-bin-release/bin/mqnamesrv >/usr/local/rocketmq/mqnamesrv.log 2>&1 &

#集群名称
brokerClusterName = DefaultCluster

#broker名称
brokerName = broker-b

#0表示master > 0表示save
brokerId = 0

#删除commitlog文件时间点,默认凌晨4点
deleteWhen = 04

#文件保留时间，默认48小时
fileReservedTime = 48

#Broker 的角色
#- ASYNC_MASTER 异步复制Master
#- SYNC_MASTER 同步双写Master
#- SLAVE
brokerRole = ASYNC_MASTER


#刷盘方式
#- ASYNC_FLUSH 异步刷盘
#- SYNC_FLUSH 同步刷盘
flushDiskType = ASYNC_FLUSH


listenPort=11911
namesrvAddr=120.53.239.169:9876
storePathRootDir=/usr/local/rocketmq/rocketmq-all-5.1.1-bin-release/store_a
storePathCommitLog=/usr/local/rocketmq/rocketmq-all-5.1.1-bin-release/store_a/commitlog
storePathConsumerQueue=/usr/local/rocketmq/rocketmq-all-5.1.1-bin-release/store_a/consumequeue
brokerIP1=120.53.239.169
brokerIP2=120.53.239.169

autoCreateTopicEnable=true

nohup sh /usr/local/rocketmq/rocketmq-all-5.1.1-bin-release/bin/mqbroker -c /usr/local/rocketmq/rocketmq-all-5.1.1-bin-release/conf/broker_b.conf  >/usr/local/rocketmq/broker_b.log 2>&1 &