所屬集群名字
附加:如果有多個(gè)master,那么每個(gè)master配置的名字應(yīng)該一樣性昭,要不然識(shí)別不了對(duì)方吮龄,不知道是一個(gè)集群內(nèi)部的
brokerClusterName=rocketmq-cluster
此處需手動(dòng)更改
broker名字羡疗,注意此處不同的配置文件填寫的不一樣
附加:按配置文件文件名來匹配
brokerName=broker-a
0 表示Master, > 0 表示slave
brokerId=0
此處許手動(dòng)更改
(此處nameserver跟host配置相匹配,9876為默認(rèn)rk服務(wù)默認(rèn)端口)nameServer 地址懒浮,分號(hào)分割
附加:broker啟動(dòng)時(shí)會(huì)跟nameserver建一個(gè)長(zhǎng)連接,broker通過長(zhǎng)連接才會(huì)向nameserver發(fā)新建的topic主題识藤,然后java的客戶端才能跟nameserver端發(fā)起長(zhǎng)連接砚著,向nameserver索取topic眯牧,找到topic主題之后,判斷其所屬的broker赖草,建立長(zhǎng)連接進(jìn)行通訊学少,這是一個(gè)至關(guān)重要的路由的概念,重點(diǎn)秧骑,也是區(qū)別于其它版本的一個(gè)重要特性
namesrvAddr=rocketmq-nameserver1:9876;rocketmq-nameserver2:9876
在發(fā)送消息時(shí)版确,自動(dòng)創(chuàng)建服務(wù)器不存在的Topic,默認(rèn)創(chuàng)建的隊(duì)列數(shù)
defaultTopicQueueNums=4
是否允許Broker 自動(dòng)創(chuàng)建Topic乎折,建議線下開啟绒疗,線上關(guān)閉
autoCreateTopicEnable=true
是否允許Broker自動(dòng)創(chuàng)建訂閱組,建議線下開啟骂澄,線上關(guān)閉
autoCreateSubscriptionGroup=true
Broker 對(duì)外服務(wù)的監(jiān)聽端口
listenPort=10911
刪除文件時(shí)間點(diǎn)吓蘑,默認(rèn)是凌晨4點(diǎn)
deleteWhen=04
文件保留時(shí)間,默認(rèn)48小時(shí)
fileReservedTime=120
commitLog每個(gè)文件的大小默認(rèn)1G
附加:消息實(shí)際存儲(chǔ)位置坟冲,和ConsumeQueue是mq的核心存儲(chǔ)概念磨镶,之前搭建2m環(huán)境的時(shí)候創(chuàng)建在store下面,用于數(shù)據(jù)存儲(chǔ)健提,consumequeue是一個(gè)邏輯的概念琳猫,消息過來之后,consumequeue并不是把消息所有保存起來私痹,而是記錄一個(gè)數(shù)據(jù)的位置脐嫂,記錄好之后再把消息存到commitlog文件里
mapedFileSizeCommitLog=1073741824
ConsumeQueue每個(gè)文件默認(rèn)存30W條,根據(jù)業(yè)務(wù)情況調(diào)整
mapedFileSizeConsumeQueue=300000
destroyMapedFileIntervalForcibly=120000
redeleteHangedFileInterval=120000
檢測(cè)物理文件磁盤空間
diskMaxUsedSpaceRatio=88
存儲(chǔ)路徑
storePathRootDir=/usr/local/rocketmq/store
commitLog存儲(chǔ)路徑
storePathCommitLog=/usr/local/rocketmq/store/commitlog
消費(fèi)隊(duì)列存儲(chǔ)路徑
storePathConsumeQueue=/usr/local/rocketmq/store/consumequeue
消息索引存儲(chǔ)路徑
storePathIndex=/usr/local/rocketmq/store/index
checkpoint 文件存儲(chǔ)路徑
storeCheckpoint=/usr/local/rocketmq/store/checkpoint
abort 文件存儲(chǔ)路徑
abortFile=/usr/local/rocketmq/store/abort
限制的消息大小
maxMessageSize=65536
flushCommitLogLeastPages=4
flushConsumeQueueLeastPages=2
flushCommitLogThoroughInterval=10000
flushConsumeQueueThoroughInterval=60000
Broker 的角色
- ASYNC_MASTER 異步復(fù)制Master
- SYNC_MASTER 同步雙寫Master
- SLAVE
brokerRote=ASYNC_MASTER
刷盤方式
- ASYNC_FLUSH 異步刷盤
- SYNC_FLUSH 同步刷盤
flushDiskType=ASYNC_FLUSH
checkTransactionMessageEnable=false
發(fā)消息線程池?cái)?shù)量
sendMessageTreadPoolNums=128
拉消息線程池?cái)?shù)量
pullMessageTreadPoolNums=128