rocketMq-namesrv介紹

系列

rocketMq概念介紹

rocketMq-namesrv介紹

rocketMq-Topic創(chuàng)建過程

rocketMq-producer介紹

rocketMq-consumer介紹

rocketMq - rebalance介紹

rocketMq - 并發(fā)消費過程

rocketMq - 串行消費過程

rocketMq-broker介紹

rocketMq-broker消息存儲介紹

rocketMq - commitLog

rocketMq - index介紹

rocketMq-延遲消息介紹

rocketMq-事務消息介紹

rocketMq消息查詢

rocketMq和kafka的架構(gòu)區(qū)別

rocketMq - master/slave同步


namesrv的作用

????namesrv的定位是作為注冊中心硕舆,保存broker節(jié)點的路由信息,保存一些簡單的k/v信息暖释。

????namesrv支持集群模式戚炫,但是每個namesrv之間相互獨立不進行任何通信剑刑,它的多點容災通過producer/consumer在訪問namesrv的時候輪詢獲取信息(當前節(jié)點訪問失敗就轉(zhuǎn)向下一個)。

????namesrv作為注冊中心双肤,負責接收broker定期的注冊信息并維持在內(nèi)存當中施掏,沒錯namesrv是沒有持久化功能的,所有數(shù)據(jù)都保存在內(nèi)存當中杨伙,broker的注冊過程也是循環(huán)遍歷所有namesrv進行注冊其监。

????namesrv通過提供對外接口給producer和consumer訪問broker的路由信息,底層通過netty來實現(xiàn)限匣。

????namesrv對broker的存活檢測機制:心跳機制即namesrv作為broker的server端定期接收broker的心跳信息抖苦,超時無心跳就移除broker;連接異常檢測機制即底層通過epoll的消息機制來檢測連接的斷開米死。


namesrv的數(shù)據(jù)存儲

namesrv broker路由存儲

說明:

? ? 參見RouteInfoManager類

? ? topicQueueTable:topic及topic實際數(shù)據(jù)存儲的隊列信息锌历。

? ? brokerAddrTable:brokerName及實際機器ip地址的信息。

? ? clusterAddrTable:clusterName及相關(guān)的brokerName信息峦筒。

? ? brokerLiveTable:broker存活信息其中BrokerLiveInfo保存上次心跳時間究西。

????filterServerTable:暫時不知道保存的信息


namesrv的k/v存儲

namesrv的k/v存儲
k/v存儲樣例

說明:

????參見KVConfigSerializeWrapper類

????保存一些k/v信息,但是實際信息有什么作用不是特別清楚物喷。


namesrv異常連接檢測

連接異常檢測

說明:

????參見BrokerHousekeepingService類

????底層借助于epoll的事件通知機制實現(xiàn)


namesrv對外服務

注冊中心

說明:

????參見DefaultRequestProcessor類

? ? 通俗講就提供讀寫功能卤材,包括broker的注冊,取消注冊等操作峦失。


namesrv心跳異常檢測

心跳異常檢測


異常連接清除

說明:

????參見NettyRemotingServer類

? ? 通過心跳時間戳檢測異常連接

最后編輯于
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
  • 序言:七十年代末扇丛,一起剝皮案震驚了整個濱河市,隨后出現(xiàn)的幾起案子尉辑,更是在濱河造成了極大的恐慌帆精,老刑警劉巖,帶你破解...
    沈念sama閱讀 211,348評論 6 491
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件,死亡現(xiàn)場離奇詭異卓练,居然都是意外死亡隘蝎,警方通過查閱死者的電腦和手機,發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 90,122評論 2 385
  • 文/潘曉璐 我一進店門襟企,熙熙樓的掌柜王于貴愁眉苦臉地迎上來嘱么,“玉大人,你說我怎么就攤上這事顽悼」澳欤” “怎么了?”我有些...
    開封第一講書人閱讀 156,936評論 0 347
  • 文/不壞的土叔 我叫張陵表蝙,是天一觀的道長。 經(jīng)常有香客問我乓旗,道長府蛇,這世上最難降的妖魔是什么? 我笑而不...
    開封第一講書人閱讀 56,427評論 1 283
  • 正文 為了忘掉前任屿愚,我火速辦了婚禮汇跨,結(jié)果婚禮上,老公的妹妹穿的比我還像新娘妆距。我一直安慰自己穷遂,他們只是感情好,可當我...
    茶點故事閱讀 65,467評論 6 385
  • 文/花漫 我一把揭開白布娱据。 她就那樣靜靜地躺著蚪黑,像睡著了一般。 火紅的嫁衣襯著肌膚如雪中剩。 梳的紋絲不亂的頭發(fā)上忌穿,一...
    開封第一講書人閱讀 49,785評論 1 290
  • 那天,我揣著相機與錄音结啼,去河邊找鬼掠剑。 笑死,一個胖子當著我的面吹牛郊愧,可吹牛的內(nèi)容都是我干的朴译。 我是一名探鬼主播,決...
    沈念sama閱讀 38,931評論 3 406
  • 文/蒼蘭香墨 我猛地睜開眼属铁,長吁一口氣:“原來是場噩夢啊……” “哼眠寿!你這毒婦竟也來了?” 一聲冷哼從身側(cè)響起红选,我...
    開封第一講書人閱讀 37,696評論 0 266
  • 序言:老撾萬榮一對情侶失蹤澜公,失蹤者是張志新(化名)和其女友劉穎,沒想到半個月后,有當?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體坟乾,經(jīng)...
    沈念sama閱讀 44,141評論 1 303
  • 正文 獨居荒郊野嶺守林人離奇死亡迹辐,尸身上長有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點故事閱讀 36,483評論 2 327
  • 正文 我和宋清朗相戀三年,在試婚紗的時候發(fā)現(xiàn)自己被綠了甚侣。 大學時的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片明吩。...
    茶點故事閱讀 38,625評論 1 340
  • 序言:一個原本活蹦亂跳的男人離奇死亡,死狀恐怖殷费,靈堂內(nèi)的尸體忽然破棺而出印荔,到底是詐尸還是另有隱情,我是刑警寧澤详羡,帶...
    沈念sama閱讀 34,291評論 4 329
  • 正文 年R本政府宣布仍律,位于F島的核電站,受9級特大地震影響实柠,放射性物質(zhì)發(fā)生泄漏水泉。R本人自食惡果不足惜,卻給世界環(huán)境...
    茶點故事閱讀 39,892評論 3 312
  • 文/蒙蒙 一窒盐、第九天 我趴在偏房一處隱蔽的房頂上張望草则。 院中可真熱鬧,春花似錦蟹漓、人聲如沸炕横。這莊子的主人今日做“春日...
    開封第一講書人閱讀 30,741評論 0 21
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽份殿。三九已至,卻和暖如春塔鳍,著一層夾襖步出監(jiān)牢的瞬間伯铣,已是汗流浹背。 一陣腳步聲響...
    開封第一講書人閱讀 31,977評論 1 265
  • 我被黑心中介騙來泰國打工轮纫, 沒想到剛下飛機就差點兒被人妖公主榨干…… 1. 我叫王不留腔寡,地道東北人。 一個月前我還...
    沈念sama閱讀 46,324評論 2 360
  • 正文 我出身青樓掌唾,卻偏偏與公主長得像放前,于是被迫代替她去往敵國和親。 傳聞我的和親對象是個殘疾皇子糯彬,可洞房花燭夜當晚...
    茶點故事閱讀 43,492評論 2 348

推薦閱讀更多精彩內(nèi)容

  • 姓名:周小蓬 16019110037 轉(zhuǎn)載自:http://blog.csdn.net/YChenFeng/art...
    aeytifiw閱讀 34,713評論 13 425
  • Spring Cloud為開發(fā)人員提供了快速構(gòu)建分布式系統(tǒng)中一些常見模式的工具(例如配置管理凭语,服務發(fā)現(xiàn),斷路器撩扒,智...
    卡卡羅2017閱讀 134,629評論 18 139
  • RocketMQ總結(jié) 1 rocketmq是什么似扔? 是一個隊列模型的消息中間件吨些,具有高性能、高可靠炒辉、高實時豪墅、分布式...
    隨意多好閱讀 6,170評論 1 14
  • 因為unittest支持的html報告在作為郵件附加時耗時較長,故將報告擴展支持為unishark框架黔寇。 基于un...
    五娃兒閱讀 518評論 0 0
  • 我承認現(xiàn)在的我是失敗的偶器,沒工作,先前的收入今天剛剛刷完缝裤。 今天和媽媽一起逛街屏轰,我試穿了一件風衣,700多沒舍得買憋飞,...
    午小陽閱讀 483評論 0 1