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