摘要:每個(gè)記錄完整的路由信息,提供相應(yīng)的讀寫服務(wù),并支持快速存儲(chǔ)擴(kuò)展。此外,提供災(zāi)難恢復(fù),豐富的指標(biāo)統(tǒng)計(jì)數(shù)據(jù)和警報(bào)機(jī)制,而傳統(tǒng)的消息傳遞系統(tǒng)都缺乏這些機(jī)制。發(fā)送過程支持并具有低延遲。
概覽
Apache RocketMQ是一款具有低延遲,高性能和可靠性,數(shù)十億容量和靈活可擴(kuò)展性的分布式消息傳遞和流媒體平臺(tái)。它由四部分組成:Name Servers,brokers,producers和consumers。 它們中的每一個(gè)都可以在沒有單點(diǎn)故障的情況下進(jìn)行水平擴(kuò)展。
NameServer集群Name Servers提供輕量級(jí)服務(wù)發(fā)現(xiàn)和路由。每個(gè)Name Server記錄完整的路由信息,提供相應(yīng)的讀寫服務(wù),并支持快速存儲(chǔ)擴(kuò)展。
Broker集群Brokers通過提供輕量級(jí)的TOPIC和QUEUE機(jī)制來實(shí)現(xiàn)消息存儲(chǔ)。 它們支持Push和Pull模式,包含容錯(cuò)機(jī)制(2個(gè)或3個(gè)副本),并提供強(qiáng)大的峰值填充和按原始時(shí)間順序累積數(shù)千億條消息的能力。此外,broker提供災(zāi)難恢復(fù),豐富的指標(biāo)統(tǒng)計(jì)數(shù)據(jù)和警報(bào)機(jī)制,而傳統(tǒng)的消息傳遞系統(tǒng)都缺乏這些機(jī)制。
Producer集群Producer集群支持分布式部署。分布式producer通過多種負(fù)載均衡模式向Broker集群發(fā)送消息。發(fā)送過程支持fast failure并具有低延遲。
Consumer集群Consumer也支持Push和Pull模型的分布式部署。 它還支持群集消費(fèi)和消息廣播。 它提供了實(shí)時(shí)的消息訂閱機(jī)制,可以滿足大多數(shù)消費(fèi)者的需求。
文章版權(quán)歸作者所有,未經(jīng)允許請(qǐng)勿轉(zhuǎn)載,若此文章存在違規(guī)行為,您可以聯(lián)系管理員刪除。
轉(zhuǎn)載請(qǐng)注明本文地址:http://m.hztianpu.com/yun/68997.html
摘要:和之間的關(guān)系通過來綁定,來定義,即相同的,等于表示節(jié)點(diǎn),非表示節(jié)點(diǎn)。所有的節(jié)點(diǎn)與集群的所有節(jié)點(diǎn)保持長連接,定時(shí)注冊(cè)信息到所有的。對(duì)磁盤的訪問串行化,避免磁盤竟?fàn)?,不?huì)因?yàn)殛?duì)列增加導(dǎo)致增高。要保證與完全的一致,增加了編程的復(fù)雜度。 Apache RocketMQ?是一個(gè)開源的分布式消息和流數(shù)據(jù)平臺(tái)。 1、既然是消息系統(tǒng),最核心的功能就是要提供消息的發(fā)布與訂閱功能,最簡單的概念模型如下: ...
摘要:通過以上分析我們可以得出消息隊(duì)列具有很好的削峰作用的功能即通過異步處理,將短時(shí)間高并發(fā)產(chǎn)生的事務(wù)消息存儲(chǔ)在消息隊(duì)列中,從而削平高峰期的并發(fā)事務(wù)。 該文已加入開源項(xiàng)目:JavaGuide(一份涵蓋大部分Java程序員所需要掌握的核心知識(shí)的文檔類項(xiàng)目,Star 數(shù)接近 16k)。地址:https://github.com/Snailclimb... 本文內(nèi)容思維導(dǎo)圖:showImg(ht...
閱讀 2407·2021-10-09 09:41
閱讀 1806·2019-08-30 15:53
閱讀 1056·2019-08-30 15:52
閱讀 3523·2019-08-30 11:26
閱讀 835·2019-08-29 16:09
閱讀 3506·2019-08-29 13:25
閱讀 2328·2019-08-26 16:45
閱讀 1995·2019-08-26 11:51