1.問(wèn)題：在Centos6.7配置RocketMQ，在product提交數(shù)據(jù)后，雙master有數(shù)據(jù)，slave沒(méi)有數(shù)據(jù)，這個(gè)是什么原因呢？本人已經(jīng)重裝也配置過(guò)所有的VM下4個(gè)服務(wù)器的配置，但是依然沒(méi)找到問(wèn)題所在，希望好心人提供解決方案，感激不盡！
2.提交數(shù)據(jù)，在rocketmq-console看到數(shù)據(jù)如下：
這里我的ip地址如以下的hosts文件如下：
我配置文件如下：全部均放在每個(gè)server的/usr/local/rocketmq/conf/2m-2s-async/
listenPort=10911
namesrvAddr=rocketmq-nameserver1:9876;rocketmq-nameserver2:9876;rocketmq-nameserver3:9876;rocketmq-nameserver4:9876
#啟動(dòng)MessageFilterServer進(jìn)程
filterServerNums=1
brokerIP1=192.168.63.3
brokerName=brocker-a
#Broker所屬集群
brokerClusterName=qipuTestCluster
#0:Master >0:Slave
brokerId=0
#Broker 的角色
#ASYNC_MASTER 主從異步復(fù)制
#SYNC_MASTER 主從同步雙寫(xiě)
#SLAVE Slave
brokerRole=ASYNC_FLUSH
#刷盤方式
#ASYNC_FLUSH:異步刷盤
#SYNC_FLUSH:同步刷盤
flushDiskType=ASYNC_FLUSH
#線下開(kāi)啟，線上關(guān)閉
autoCreateTopicEnable=TRUE
#自動(dòng)創(chuàng)建訂閱組,建議線下開(kāi)啟,線上關(guān)閉
autoCreateSubscriptionGroup=TRUE
#是否拒絕事務(wù)消息接入
rejectTransactionMessage=FALSE
#是否從web服務(wù)器獲取NameServer地址,針對(duì)大規(guī)模的Broker集群建議使用這種方式
fetchNamesrvAddrByAddressServer=FALSE
#日志根路徑
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
#刪除文件時(shí)間點(diǎn),默認(rèn)凌晨4點(diǎn)
deleteWhen=4
#文件保留時(shí)間,默認(rèn)48小時(shí)
fileReservedTime=48
#是否開(kāi)啟消息索引功能
messageIndexEnable=TRUE
#是否提供安全的消息索引機(jī)制，索引保證不丟
messageIndexSafe=FALSE
#在 Slave 上直接設(shè)置 Master地址，默認(rèn)從 Name Server 上自動(dòng)獲取，也可以手工強(qiáng)制配置
#haMasterAddress=
flushIntervalCommitLog=1000
#磁盤滿、且無(wú)過(guò)期文件情況下 TRUE 表示強(qiáng)制刪除文件，優(yōu)先保證服務(wù)可用; FALSE 標(biāo)記服務(wù)不可用，文件不刪除
cleanFileForciblyEnable=TRUE
#Topic持久化文件
topicConfigPath=/usr/local/rocketmq/store/config/topics.json
#ConsumerOffset持久化文件
consumerOffsetPath=/usr/local/rocketmq/store/config/consumerOffset.json
#subscriptionGroup 持久化文件
subscriptionGroupPath=/usr/local/rocketmq/store/config/subscriptionGroup.json
sendMessageThreadPoolNums=128listenPort=10911
namesrvAddr=rocketmq-nameserver1:9876;rocketmq-nameserver2:9876;rocketmq-nameserver3:9876;rocketmq-nameserver4:9876
#啟動(dòng)MessageFilterServer進(jìn)程
filterServerNums=1
brokerIP1=192.168.63.5
brokerName=brocker-a
#Broker所屬集群
brokerClusterName=qipuTestCluster
#0:Master >0:Slave
brokerId=1
#Broker 的角色
#ASYNC_MASTER 主從異步復(fù)制
#SYNC_MASTER 主從同步雙寫(xiě)
#SLAVE Slave
brokerRole=SLAVE
#刷盤方式
#ASYNC_FLUSH:異步刷盤
#SYNC_FLUSH:同步刷盤
flushDiskType=ASYNC_FLUSH
#線下開(kāi)啟，線上關(guān)閉
autoCreateTopicEnable=TRUE
#自動(dòng)創(chuàng)建訂閱組,建議線下開(kāi)啟,線上關(guān)閉
autoCreateSubscriptionGroup=TRUE
#是否拒絕事務(wù)消息接入
rejectTransactionMessage=FALSE
#是否從web服務(wù)器獲取NameServer地址,針對(duì)大規(guī)模的Broker集群建議使用這種方式
fetchNamesrvAddrByAddressServer=FALSE
#日志根路徑
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
#刪除文件時(shí)間點(diǎn),默認(rèn)凌晨4點(diǎn)
deleteWhen=4
#文件保留時(shí)間,默認(rèn)48小時(shí)
fileReservedTime=48
#是否開(kāi)啟消息索引功能
messageIndexEnable=TRUE
#是否提供安全的消息索引機(jī)制，索引保證不丟
messageIndexSafe=FALSE
#在 Slave 上直接設(shè)置 Master地址，默認(rèn)從 Name Server 上自動(dòng)獲取，也可以手工強(qiáng)制配置
#haMasterAddress=
flushIntervalCommitLog=1000
#磁盤滿、且無(wú)過(guò)期文件情況下 TRUE 表示強(qiáng)制刪除文件，優(yōu)先保證服務(wù)可用; FALSE 標(biāo)記服務(wù)不可用，文件不刪除
cleanFileForciblyEnable=TRUE
#Topic持久化文件
topicConfigPath=/usr/local/rocketmq/store/config/topics.json
#ConsumerOffset持久化文件
consumerOffsetPath=/usr/local/rocketmq/store/config/consumerOffset.json
#subscriptionGroup 持久化文件
subscriptionGroupPath=/usr/local/rocketmq/store/config/subscriptionGroup.json
sendMessageThreadPoolNums=128listenPort=10911
namesrvAddr=rocketmq-nameserver1:9876;rocketmq-nameserver2:9876;rocketmq-nameserver3:9876;rocketmq-nameserver4:9876
#啟動(dòng)MessageFilterServer進(jìn)程
filterServerNums=1
brokerIP1=192.168.63.4
brokerName=brocker-b
#Broker所屬集群
brokerClusterName=qipuTestCluster
#0:Master >0:Slave
brokerId=0
#Broker 的角色
#ASYNC_MASTER 主從異步復(fù)制
#SYNC_MASTER 主從同步雙寫(xiě)
#SLAVE Slave
brokerRole=ASYNC_MASTER
#刷盤方式
#ASYNC_FLUSH:異步刷盤
#SYNC_FLUSH:同步刷盤
flushDiskType=ASYNC_MASTER
#線下開(kāi)啟，線上關(guān)閉
autoCreateTopicEnable=TRUE
#自動(dòng)創(chuàng)建訂閱組,建議線下開(kāi)啟,線上關(guān)閉
autoCreateSubscriptionGroup=TRUE
#是否拒絕事務(wù)消息接入
rejectTransactionMessage=FALSE
#是否從web服務(wù)器獲取NameServer地址,針對(duì)大規(guī)模的Broker集群建議使用這種方式
fetchNamesrvAddrByAddressServer=FALSE
#日志根路徑
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
#刪除文件時(shí)間點(diǎn),默認(rèn)凌晨4點(diǎn)
deleteWhen=4
#文件保留時(shí)間,默認(rèn)48小時(shí)
fileReservedTime=48
#是否開(kāi)啟消息索引功能
messageIndexEnable=TRUE
#是否提供安全的消息索引機(jī)制，索引保證不丟
messageIndexSafe=FALSE
#在 Slave 上直接設(shè)置 Master地址，默認(rèn)從 Name Server 上自動(dòng)獲取，也可以手工強(qiáng)制配置
#haMasterAddress=
flushIntervalCommitLog=1000
#磁盤滿、且無(wú)過(guò)期文件情況下 TRUE 表示強(qiáng)制刪除文件，優(yōu)先保證服務(wù)可用; FALSE 標(biāo)記服務(wù)不可用，文件不刪除
cleanFileForciblyEnable=TRUE
#Topic持久化文件
topicConfigPath=/usr/local/rocketmq/store/config/topics.json
#ConsumerOffset持久化文件
consumerOffsetPath=/usr/local/rocketmq/store/config/consumerOffset.json
#subscriptionGroup 持久化文件
subscriptionGroupPath=/data/logs/rocketmq/store/config/subscriptionGroup.json
sendMessageThreadPoolNums=128listenPort=10911
namesrvAddr=rocketmq-nameserver1:9876;rocketmq-nameserver2:9876;rocketmq-nameserver3:9876;rocketmq-nameserver4:9876
#啟動(dòng)MessageFilterServer進(jìn)程
filterServerNums=1
brokerIP1=192.168.63.6
brokerName=brocker-b
#Broker所屬集群
brokerClusterName=qipuTestCluster
#0:Master >0:Slave
brokerId=1
#Broker 的角色
#ASYNC_MASTER 主從異步復(fù)制
#SYNC_MASTER 主從同步雙寫(xiě)
#SLAVE Slave
brokerRole=SLAVE
#刷盤方式
#ASYNC_FLUSH:異步刷盤
#SYNC_FLUSH:同步刷盤
flushDiskType=SYNC_FLUSH
#線下開(kāi)啟，線上關(guān)閉
autoCreateTopicEnable=TRUE
#自動(dòng)創(chuàng)建訂閱組,建議線下開(kāi)啟,線上關(guān)閉
autoCreateSubscriptionGroup=TRUE
#是否拒絕事務(wù)消息接入
rejectTransactionMessage=FALSE
#是否從web服務(wù)器獲取NameServer地址,針對(duì)大規(guī)模的Broker集群建議使用這種方式
fetchNamesrvAddrByAddressServer=FALSE
#日志根路徑
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
#刪除文件時(shí)間點(diǎn),默認(rèn)凌晨4點(diǎn)
deleteWhen=4
#文件保留時(shí)間,默認(rèn)48小時(shí)
fileReservedTime=48
#是否開(kāi)啟消息索引功能
messageIndexEnable=TRUE
#是否提供安全的消息索引機(jī)制，索引保證不丟
messageIndexSafe=FALSE
#在 Slave 上直接設(shè)置 Master地址，默認(rèn)從 Name Server 上自動(dòng)獲取，也可以手工強(qiáng)制配置
#haMasterAddress=
flushIntervalCommitLog=1000
#磁盤滿、且無(wú)過(guò)期文件情況下 TRUE 表示強(qiáng)制刪除文件，優(yōu)先保證服務(wù)可用; FALSE 標(biāo)記服務(wù)不可用，文件不刪除
cleanFileForciblyEnable=TRUE
#Topic持久化文件
topicConfigPath=/usr/local/rocketmq/store/config/topics.json
#ConsumerOffset持久化文件
consumerOffsetPath=/usr/local/rocketmq/store/config/consumerOffset.json
#subscriptionGroup 持久化文件
subscriptionGroupPath=/usr/local/rocketmq/store/config/subscriptionGroup.json
sendMessageThreadPoolNums=128
你好，你可先隨意在一臺(tái)slave的機(jī)器中看下broker打印的日志，該slave是否注冊(cè)到了namesrv中呢？也可以將HA方式改成同步雙寫(xiě)模式，就可以在producer發(fā)送消息會(huì)返回具體的問(wèn)題。
你這個(gè)問(wèn)題解決了嗎
您好，請(qǐng)問(wèn)您這個(gè)問(wèn)題解決了嗎
踩了一波坑，可能和樓主的不一樣。我是主備的brokerName配置的不一樣導(dǎo)致的。
北大青鳥(niǎo)APTECH成立于1999年。依托北京大學(xué)優(yōu)質(zhì)雄厚的教育資源和背景，秉承“教育改變生活”的發(fā)展理念，致力于培養(yǎng)中國(guó)IT技能型緊缺人才，是大數(shù)據(jù)專業(yè)的國(guó)家
北大青鳥(niǎo)中博軟件學(xué)院創(chuàng)立于2003年，作為華東區(qū)著名互聯(lián)網(wǎng)學(xué)院和江蘇省首批服務(wù)外包人才培訓(xùn)基地，中博成功培育了近30000名軟件工程師走向高薪崗位，合作企業(yè)超4
中公教育集團(tuán)創(chuàng)建于1999年，經(jīng)過(guò)二十年潛心發(fā)展，已由一家北大畢業(yè)生自主創(chuàng)業(yè)的信息技術(shù)與教育服務(wù)機(jī)構(gòu)，發(fā)展為教育服務(wù)業(yè)的綜合性企業(yè)集團(tuán)，成為集合面授教學(xué)培訓(xùn)、網(wǎng)
達(dá)內(nèi)教育集團(tuán)成立于2002年，是一家由留學(xué)海歸創(chuàng)辦的高端職業(yè)教育培訓(xùn)機(jī)構(gòu)，是中國(guó)一站式人才培養(yǎng)平臺(tái)、一站式人才輸送平臺(tái)。2014年4月3日在美國(guó)成功上市，融資1
浪潮集團(tuán)項(xiàng)目經(jīng)理。精通Java與.NET 技術(shù)， 熟練的跨平臺(tái)面向?qū)ο箝_(kāi)發(fā)經(jīng)驗(yàn)，技術(shù)功底深厚。 授課風(fēng)格 授課風(fēng)格清新自然、條理清晰、主次分明、重點(diǎn)難點(diǎn)突出、引人入勝。
曾工作于聯(lián)想擔(dān)任系統(tǒng)開(kāi)發(fā)工程師，曾在博彥科技股份有限公司擔(dān)任項(xiàng)目經(jīng)理從事移動(dòng)互聯(lián)網(wǎng)管理及研發(fā)工作，曾創(chuàng)辦藍(lán)懿科技有限責(zé)任公司從事總經(jīng)理職務(wù)負(fù)責(zé)iOS教學(xué)及管理工作。
精通HTML5和CSS3；Javascript及主流js庫(kù)，具有快速界面開(kāi)發(fā)的能力，對(duì)瀏覽器兼容性、前端性能優(yōu)化等有深入理解。精通網(wǎng)頁(yè)制作和網(wǎng)頁(yè)游戲開(kāi)發(fā)。
具有10 年的Java 企業(yè)應(yīng)用開(kāi)發(fā)經(jīng)驗(yàn)。曾經(jīng)歷任德國(guó)Software AG 技術(shù)顧問(wèn)，美國(guó)Dachieve 系統(tǒng)架構(gòu)師，美國(guó)AngelEngineers Inc. 系統(tǒng)架構(gòu)師。
掃碼關(guān)注鍍金池微信號(hào)
手機(jī)訂課，優(yōu)惠多多