欧美一级特黄大片做受成人-亚洲成人一区二区电影-激情熟女一区二区三区-日韩专区欧美专区国产专区

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

1 概述

多Master集群模式指的是一個集群無Slave，全是Maste。

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

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

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

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

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

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

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

廣告

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

成都網(wǎng)頁設(shè)計(jì)公司
欧美日韩在线一区二区精品 | 另类欧美亚洲中文在线综合| 日韩高清在线亚洲专区不卡| 午夜体内射精免费视频| 欧美亚洲另类激情另类的| 亚洲一区二区三区不卡视频| 亚洲精品一区二区毛豆| 手机在线看国产后入| 免费视频观看在线一区二区三区| 夜夜嗨精品免费视频播放| 九九热精品只有这里有| 18禁的视频在线观看| 日本人妻在线不卡视频| 欧美专区另类综合日韩| 久久久久久国产精品亚洲| 国产精品情侣av自拍| 日本国产一区二区精品| 天堂av在线免费观看| 亚洲成av人在线播放| 99热这里只有精品三区| 亚洲中文字幕精品视频乱码| 日韩av黄色制服在线网站| 亚洲综合成人av在线| 国产欧美日本综合一区| 国产精品精品国产一区二区| 欧美日韩一区二区三区色拉拉| 青青成线在人线免费啪| 成人av影视中文字幕 | 一区二区三区特黄色片| 精品久久精品久久人妻九色| 同为人妻一区二区三区| 亚洲人的av在线播放| 日本高清精品视频免费| 国产真人作爱视频免费| 国产精品三级久久久| 午夜少妇诱惑一区二区三区| 蜜桃精品国产一区二区三区| 丝袜美腿亚洲欧美日韩| 日韩欧美一区二区三区在线| 午夜福利片免费在线观看| 亚洲精品国产av成人网|