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