RocketMQ多Master集群模式部署-創(chuàng)新互聯(lián)

1 概述

多Master集群模式指的是一個(gè)集群無(wú)Slave，全是Maste。

創(chuàng)新互聯(lián)技術(shù)團(tuán)隊(duì)10年來(lái)致力于為客戶提供網(wǎng)站制作、網(wǎng)站設(shè)計(jì)、品牌網(wǎng)站制作、網(wǎng)絡(luò)營(yíng)銷推廣、搜索引擎SEO優(yōu)化等服務(wù)。經(jīng)過(guò)多年發(fā)展，公司擁有經(jīng)驗(yàn)豐富的技術(shù)團(tuán)隊(duì)，先后服務(wù)、推廣了1000多家網(wǎng)站，包括各類中小企業(yè)、企事單位、高校等機(jī)構(gòu)單位。

優(yōu)點(diǎn)：配置簡(jiǎn)單，單個(gè)Master宕機(jī)或重啟維護(hù)對(duì)應(yīng)用無(wú)影響，在磁盤(pán)配置為RAID10 時(shí)，即使機(jī)器宕機(jī)不可恢復(fù)情
由于RAID10 磁盤(pán)非?？煽?，消息也不會(huì)丟（異步刷盤(pán)丟失少量消息，同步刷盤(pán)一條不丟）。性能最高。

缺點(diǎn)：?jiǎn)闻_(tái)機(jī)器宕機(jī)期間，這臺(tái)機(jī)器上未被消費(fèi)的消息在機(jī)器恢復(fù)之前不可訂閱，消息實(shí)時(shí)性會(huì)受到受到影響。

1 環(huán)境信息
序號(hào)IP地址主機(jī)名用戶角色模式
1192.168.3.41rocketmq01rootnameServer1,brokerServer1Master1
2192.168.3.42rocketmq02rootnameServer2,brokerServer2Master2
2 安裝前準(zhǔn)備工作 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環(huán)境部署

在/usr/目錄下創(chuàng)建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

設(shè)置環(huán)境變量

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

驗(yàn)證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 上傳解壓【兩臺(tái)機(jī)器操作】
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 創(chuàng)建存儲(chǔ)路徑【兩臺(tái)機(jī)器操作】
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配置文件配置【兩臺(tái)機(jī)器】
vim /usr/local/rocketmq/conf/2m-noslave/broker-a.properties
vim /usr/local/rocketmq/conf/2m-noslave/broker-a.properties

broker-a.properties配置文件內(nèi)容如下：

#所屬集群名字
brokerClusterName=rocketmq-cluster
#broker名字，注意此處不同的配置文件填寫(xiě)的不一樣
brokerName=broker-a
#0 表示 Master，>0 表示 Slave
brokerId=0
#nameServer地址，分號(hào)分割
namesrvAddr=192.168.3.41:9876;192.168.3.42:9876
#在發(fā)送消息時(shí)，自動(dòng)創(chuàng)建服務(wù)器不存在的topic，默認(rèn)創(chuàng)建的隊(duì)列數(shù)
defaultTopicQueueNums=4
#是否允許 Broker 自動(dòng)創(chuàng)建Topic，建議線下開(kāi)啟，線上關(guān)閉
autoCreateTopicEnable=true
#是否允許 Broker 自動(dòng)創(chuàng)建訂閱組，建議線下開(kāi)啟，線上關(guān)閉
autoCreateSubscriptionGroup=true
#Broker 對(duì)外服務(wù)的監(jiān)聽(tīng)端口
listenPort=10911
#刪除文件時(shí)間點(diǎn)，默認(rèn)凌晨 4點(diǎn)
deleteWhen=04
#文件保留時(shí)間，默認(rèn) 48 小時(shí)
fileReservedTime=120
#commitLog每個(gè)文件的大小默認(rèn)1G
mapedFileSizeCommitLog=1073741824
#ConsumeQueue每個(gè)文件默認(rèn)存30W條，根據(jù)業(yè)務(wù)情況調(diào)整
mapedFileSizeConsumeQueue=300000
#destroyMapedFileIntervalForcibly=120000
#redeleteHangedFileInterval=120000
#檢測(cè)物理文件磁盤(pán)空間
diskMaxUsedSpaceRatio=88
#存儲(chǔ)路徑
storePathRootDir=/usr/local/alibaba-rocketmq/store
#commitLog 存儲(chǔ)路徑
storePathCommitLog=/usr/local/alibaba-rocketmq/store/commitlog
#消費(fèi)隊(duì)列存儲(chǔ)路徑存儲(chǔ)路徑
storePathConsumeQueue=/usr/local/alibaba-rocketmq/store/consumequeue
#消息索引存儲(chǔ)路徑
storePathIndex=/usr/local/alibaba-rocketmq/store/index
#checkpoint 文件存儲(chǔ)路徑
storeCheckpoint=/usr/local/alibaba-rocketmq/store/checkpoint
#abort 文件存儲(chǔ)路徑
abortFile=/usr/local/alibaba-rocketmq/store/abort
#限制的消息大小
maxMessageSize=65536
#flushCommitLogLeastPages=4
#flushConsumeQueueLeastPages=2
#flushCommitLogThoroughInterval=10000
#flushConsumeQueueThoroughInterval=60000
#Broker 的角色
#- ASYNC_MASTER 異步復(fù)制Master
#- SYNC_MASTER 同步雙寫(xiě)Master
#- SLAVE
brokerRole=ASYNC_MASTER
#刷盤(pán)方式
#- ASYNC_FLUSH 異步刷盤(pán)
#- SYNC_FLUSH 同步刷盤(pán)
flushDiskType=ASYNC_FLUSH
#checkTransactionMessageEnable=false
#發(fā)消息線程池?cái)?shù)量
#sendMessageThreadPoolNums=128
#拉消息線程池?cái)?shù)量
#pullMessageThreadPoolNums=128

broker-b.properties配置文件內(nèi)容如下：

#所屬集群名字
brokerClusterName=rocketmq-cluster
#broker名字，注意此處不同的配置文件填寫(xiě)的不一樣
brokerName=broker-b
#0 表示 Master，>0 表示 Slave
brokerId=0
#nameServer地址，分號(hào)分割
namesrvAddr=192.168.3.41:9876;192.168.3.42:9876
#在發(fā)送消息時(shí)，自動(dòng)創(chuàng)建服務(wù)器不存在的topic，默認(rèn)創(chuàng)建的隊(duì)列數(shù)
defaultTopicQueueNums=4
#是否允許 Broker 自動(dòng)創(chuàng)建Topic，建議線下開(kāi)啟，線上關(guān)閉
autoCreateTopicEnable=true
#是否允許 Broker 自動(dòng)創(chuàng)建訂閱組，建議線下開(kāi)啟，線上關(guān)閉
autoCreateSubscriptionGroup=true
#Broker 對(duì)外服務(wù)的監(jiān)聽(tīng)端口
listenPort=10911
#刪除文件時(shí)間點(diǎn)，默認(rèn)凌晨 4點(diǎn)
deleteWhen=04
#文件保留時(shí)間，默認(rèn) 48 小時(shí)
fileReservedTime=120
#commitLog每個(gè)文件的大小默認(rèn)1G
mapedFileSizeCommitLog=1073741824
#ConsumeQueue每個(gè)文件默認(rèn)存30W條，根據(jù)業(yè)務(wù)情況調(diào)整
mapedFileSizeConsumeQueue=300000
#destroyMapedFileIntervalForcibly=120000
#redeleteHangedFileInterval=120000
#檢測(cè)物理文件磁盤(pán)空間
diskMaxUsedSpaceRatio=88
#存儲(chǔ)路徑
storePathRootDir=/usr/local/alibaba-rocketmq/store
#commitLog 存儲(chǔ)路徑
storePathCommitLog=/usr/local/alibaba-rocketmq/store/commitlog
#消費(fèi)隊(duì)列存儲(chǔ)路徑存儲(chǔ)路徑
storePathConsumeQueue=/usr/local/alibaba-rocketmq/store/consumequeue
#消息索引存儲(chǔ)路徑
storePathIndex=/usr/local/alibaba-rocketmq/store/index
#checkpoint 文件存儲(chǔ)路徑
storeCheckpoint=/usr/local/alibaba-rocketmq/store/checkpoint
#abort 文件存儲(chǔ)路徑
abortFile=/usr/local/alibaba-rocketmq/store/abort
#限制的消息大小
maxMessageSize=65536
#flushCommitLogLeastPages=4
#flushConsumeQueueLeastPages=2
#flushCommitLogThoroughInterval=10000
#flushConsumeQueueThoroughInterval=60000
#Broker 的角色
#- ASYNC_MASTER 異步復(fù)制Master
#- SYNC_MASTER 同步雙寫(xiě)Master
#- SLAVE
brokerRole=ASYNC_MASTER
#刷盤(pán)方式
#- ASYNC_FLUSH 異步刷盤(pán)
#- SYNC_FLUSH 同步刷盤(pán)
flushDiskType=ASYNC_FLUSH
#checkTransactionMessageEnable=false
#發(fā)消息線程池?cái)?shù)量
#sendMessageThreadPoolNums=128
#拉消息線程池?cái)?shù)量
#pullMessageThreadPoolNums=128
3.4 修改日志配置文件【兩臺(tái)機(jī)器】
mkdir -p /usr/local/rocketmq/logs
cd /usr/local/rocketmq/conf && sed -i 's#${user.home}#/usr/local/rocketmq#g' *.xml
3.5 修改啟動(dòng)腳本參數(shù)【兩臺(tái)機(jī)器】
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 啟動(dòng)NameServer【兩臺(tái)機(jī)器】
cd /usr/local/rocketmq/bin
nohup sh mqnamesrv &
3.7 啟動(dòng)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 啟動(dòng)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

下面的是我的公眾號(hào)二維碼，歡迎關(guān)注。文章轉(zhuǎn)載請(qǐng)注明出處www.leexide.com
RocketMQ多Master集群模式部署

本文題目：RocketMQ多Master集群模式部署-創(chuàng)新互聯(lián)
當(dāng)前地址：http://bm7419.com/article18/gddgp.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供動(dòng)態(tài)網(wǎng)站、品牌網(wǎng)站建設(shè)、Google、ChatGPT、網(wǎng)站制作、定制網(wǎng)站

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請(qǐng)盡快告知，我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng)，如需處理請(qǐng)聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時(shí)需注明來(lái)源： 創(chuàng)新互聯(lián)

成都網(wǎng)頁(yè)設(shè)計(jì)公司