RocketMQ多Master集群模式部署

1 概述

多Master集群模式指的是一个集群无Slave，全是Maste。

优点：配置简单，单个Master宕机或重启维护对应用无影响，在磁盘配置为RAID10 时，即使机器宕机不可恢复情
由于RAID10 磁盘非常可靠，消息也不会丢（异步刷盘丢失少量消息，同步刷盘一条不丢）。性能最高。

缺点：单台机器宕机期间，这台机器上未被消费的消息在机器恢复之前不可订阅，消息实时性会受到受到影响。

1 环境信息

序号	IP地址	主机名	用户	角色	模式
1	192.168.3.41	rocketmq01	root	nameServer1,brokerServer1	Master1
2	192.168.3.42	rocketmq02	root	nameServer2,brokerServer2	Master2

2 安装前准备工作

2.1 /etc/hosts配置

cat >> /etc/hosts << EOF 192.168.3.41 rocketmq-nameserver1 192.168.3.41 rocketmq-master1 192.168.3.42 rocketmq-nameserver2 192.168.3.42 rocketmq-master2 EOF

2.2 Java环境部署

在/usr/目录下创建java目录

mkdir /usr/local/java cd /usr/local/java 

下载jdk,然后解压

curl -O http://download.oracle.com/otn-pub/java/jdk/8u171-b11/512cd62ec5174c3487ac17c61aaa89e8/jdk-8u171-linux-x64.tar.gz tar -zxvf jdk-8u171-linux-x64.tar.gz -C /usr/local/java

设置环境变量

cat >> /etc/profile << EOF #set java environment JAVA_HOME=/usr/local/java/jdk1.8.0_171 JRE_HOME=/usr/java/jdk1.8.0_171/jre CLASS_PATH=.:$JAVA_HOME/lib/dt.jar:$JAVA_HOME/lib/tools.jar:$JRE_HOME/lib PATH=$PATH:$JAVA_HOME/bin:$JRE_HOME/bin export JAVA_HOME JRE_HOME CLASS_PATH PATH EOF

让修改生效

source /etc/profile

验证JDK有效性

java -version java version "1.8.0_171" Java(TM) SE Runtime Environment (build 1.8.0_171-b11) Java HotSpot(TM) 64-Bit Server VM (build 25.171-b11, mixed mode)

3 安装rocketmq

3.1 上传解压【两台机器操作】

mkdir /usr/local/rocketmq4.2 cd /usr/local/rocketmq4.2 curl -O https://www.apache.org/dyn/closer.cgi?path=rocketmq/4.2.0/rocketmq-all-4.2.0-bin-release.zip unzip rocketmq-all-4.2.0-bin-release.zip rm -f rocketmq-all-4.2.0-bin-release.zip cd /usr/local ln -s rocketmq4.2 rocketmq ll /usr/local

3.2 创建存储路径【两台机器操作】

mkdir /usr/local/rocketmq/store mkdir /usr/local/rocketmq/store/commitlog mkdir /usr/local/rocketmq/store/consumequeue mkdir /usr/local/rocketmq/store/index

3.3 RocketMQ配置文件配置【两台机器】

vim /usr/local/rocketmq/conf/2m-noslave/broker-a.properties vim /usr/local/rocketmq/conf/2m-noslave/broker-a.properties

broker-a.properties配置文件内容如下：

#所属集群名字 brokerClusterName=rocketmq-cluster #broker名字，注意此处不同的配置文件填写的不一样 brokerName=broker-a #0 表示 Master，>0 表示 Slave brokerId=0 #nameServer地址，分号分割 namesrvAddr=192.168.3.41:9876;192.168.3.42:9876 #在发送消息时，自动创建服务器不存在的topic，默认创建的队列数 defaultTopicQueueNums=4 #是否允许 Broker 自动创建Topic，建议线下开启，线上关闭 autoCreateTopicEnable=true #是否允许 Broker 自动创建订阅组，建议线下开启，线上关闭 autoCreateSubscriptionGroup=true #Broker 对外服务的监听端口 listenPort=10911 #删除文件时间点，默认凌晨 4点 deleteWhen=04 #文件保留时间，默认 48 小时 fileReservedTime=120 #commitLog每个文件的大小默认1G mapedFileSizeCommitLog=1073741824 #ConsumeQueue每个文件默认存30W条，根据业务情况调整 mapedFileSizeConsumeQueue=300000 #destroyMapedFileIntervalForcibly=120000 #redeleteHangedFileInterval=120000 #检测物理文件磁盘空间 diskMaxUsedSpaceRatio=88 #存储路径 storePathRootDir=/usr/local/alibaba-rocketmq/store #commitLog 存储路径 storePathCommitLog=/usr/local/alibaba-rocketmq/store/commitlog #消费队列存储路径存储路径 storePathConsumeQueue=/usr/local/alibaba-rocketmq/store/consumequeue #消息索引存储路径 storePathIndex=/usr/local/alibaba-rocketmq/store/index #checkpoint 文件存储路径 storeCheckpoint=/usr/local/alibaba-rocketmq/store/checkpoint #abort 文件存储路径 abortFile=/usr/local/alibaba-rocketmq/store/abort #限制的消息大小 maxMessageSize=65536 #flushCommitLogLeastPages=4 #flushConsumeQueueLeastPages=2 #flushCommitLogThoroughInterval=10000 #flushConsumeQueueThoroughInterval=60000 #Broker 的角色 #- ASYNC_MASTER 异步复制Master #- SYNC_MASTER 同步双写Master #- SLAVE brokerRole=ASYNC_MASTER #刷盘方式 #- ASYNC_FLUSH 异步刷盘 #- SYNC_FLUSH 同步刷盘 flushDiskType=ASYNC_FLUSH #checkTransactionMessageEnable=false #发消息线程池数量 #sendMessageThreadPoolNums=128 #拉消息线程池数量 #pullMessageThreadPoolNums=128

broker-b.properties配置文件内容如下：

#所属集群名字 brokerClusterName=rocketmq-cluster #broker名字，注意此处不同的配置文件填写的不一样 brokerName=broker-b #0 表示 Master，>0 表示 Slave brokerId=0 #nameServer地址，分号分割 namesrvAddr=192.168.3.41:9876;192.168.3.42:9876 #在发送消息时，自动创建服务器不存在的topic，默认创建的队列数 defaultTopicQueueNums=4 #是否允许 Broker 自动创建Topic，建议线下开启，线上关闭 autoCreateTopicEnable=true #是否允许 Broker 自动创建订阅组，建议线下开启，线上关闭 autoCreateSubscriptionGroup=true #Broker 对外服务的监听端口 listenPort=10911 #删除文件时间点，默认凌晨 4点 deleteWhen=04 #文件保留时间，默认 48 小时 fileReservedTime=120 #commitLog每个文件的大小默认1G mapedFileSizeCommitLog=1073741824 #ConsumeQueue每个文件默认存30W条，根据业务情况调整 mapedFileSizeConsumeQueue=300000 #destroyMapedFileIntervalForcibly=120000 #redeleteHangedFileInterval=120000 #检测物理文件磁盘空间 diskMaxUsedSpaceRatio=88 #存储路径 storePathRootDir=/usr/local/alibaba-rocketmq/store #commitLog 存储路径 storePathCommitLog=/usr/local/alibaba-rocketmq/store/commitlog #消费队列存储路径存储路径 storePathConsumeQueue=/usr/local/alibaba-rocketmq/store/consumequeue #消息索引存储路径 storePathIndex=/usr/local/alibaba-rocketmq/store/index #checkpoint 文件存储路径 storeCheckpoint=/usr/local/alibaba-rocketmq/store/checkpoint #abort 文件存储路径 abortFile=/usr/local/alibaba-rocketmq/store/abort #限制的消息大小 maxMessageSize=65536 #flushCommitLogLeastPages=4 #flushConsumeQueueLeastPages=2 #flushCommitLogThoroughInterval=10000 #flushConsumeQueueThoroughInterval=60000 #Broker 的角色 #- ASYNC_MASTER 异步复制Master #- SYNC_MASTER 同步双写Master #- SLAVE brokerRole=ASYNC_MASTER #刷盘方式 #- ASYNC_FLUSH 异步刷盘 #- SYNC_FLUSH 同步刷盘 flushDiskType=ASYNC_FLUSH #checkTransactionMessageEnable=false #发消息线程池数量 #sendMessageThreadPoolNums=128 #拉消息线程池数量 #pullMessageThreadPoolNums=128

3.4 修改日志配置文件【两台机器】

mkdir -p /usr/local/rocketmq/logs cd /usr/local/rocketmq/conf && sed -i 's#${user.home}#/usr/local/rocketmq#g' *.xml

3.5 修改启动脚本参数【两台机器】

cd /usr/local/rocketmq/bin vim runbroker.sh #将JAVA_OPT修改为 JAVA_OPT="${JAVA_OPT} -server -Xms1g -Xmx1g -Xmn512m -XX:PermSize=128m -XX:MaxPermSize=320m" vim runserver.sh #将JAVA_OPT修改为 JAVA_OPT="${JAVA_OPT} -server -Xms1g -Xmx1g -Xmn512m -XX:PermSize=128m -XX:MaxPermSize=320m"

3.6 启动NameServer【两台机器】

cd /usr/local/rocketmq/bin nohup sh mqnamesrv &

3.7 启动BrokerServer A【192.168.3.41】

cd /usr/local/rocketmq/bin nohup sh mqbroker -c /usr/local/rocketmq/conf/2m-noslave/broker-a.properties > /dev/null 2>&1 & netstat -ntlp jps tail -500f /usr/local/rocketmq/logs/rocketmqlogs/broker.log tail -500f /usr/local/rocketmq/logs/rocketmqlogs/namesrv.log

3.8 启动BrokerServer B【192.168.3.42】

cd /usr/local/rocketmq/bin nohup sh mqbroker -c /usr/local/rocketmq/conf/2m-noslave/broker-b.properties > /dev/null 2>&1 & netstat -ntlp jps tail -500f /usr/local/rocketmq/logs/rocketmqlogs/broker.log tail -500f /usr/local/rocketmq/logs/rocketmqlogs/namesrv.log

下面的是我的公众号二维码，欢迎关注。文章转载请注明出处www.leexide.com