1、應(yīng)用場景

RabbitMQ：

適用于易用性和靈活性要求較高的場景：

• 異步任務(wù)處理：RabbitMQ提供可靠的消息傳遞機制，適用于處理異步任務(wù)，例如將耗時的任務(wù)放入消息隊列中，然后由消費者異步處理，提高系統(tǒng)的響應(yīng)速度和可伸縮性。
• 解耦系統(tǒng)組件：通過使用RabbitMQ作為消息中間件，不同的系統(tǒng)組件可以通過消息進行解耦，實現(xiàn)松耦合的架構(gòu)，提高系統(tǒng)的可維護性和靈活性。
• 事件驅(qū)動架構(gòu)：RabbitMQ的發(fā)布-訂閱模式可以用于構(gòu)建事件驅(qū)動架構(gòu)，將系統(tǒng)中的事件作為消息發(fā)布到相應(yīng)的主題，不同的消費者可以訂閱感興趣的主題進行相應(yīng)的處理。

RocketMQ：

適用于大規(guī)模數(shù)據(jù)處理和高吞吐量的場景：

• 分布式事務(wù)：RocketMQ支持分布式事務(wù)消息，適用于涉及多個業(yè)務(wù)系統(tǒng)的分布式事務(wù)場景，確保消息的一致性和可靠性，同時提供高吞吐量的消息傳遞能力。
• 實時日志處理：由于RocketMQ具備高吞吐量和低延遲的特點，可以用于實時日志處理，例如日志收集和分析、日志聚合等場景。
• 流式處理：RocketMQ支持流式處理模式，可以將產(chǎn)生的數(shù)據(jù)流通過消息隊列傳遞給流處理框架（如Flink、Spark Streaming），實現(xiàn)實時數(shù)據(jù)處理和分析。

Kafka：

適用于高吞吐量的實時數(shù)據(jù)流處理和流式處理場景：

• 數(shù)據(jù)管道和實時數(shù)據(jù)處理：Kafka的高吞吐量和可持久化存儲特性使其成為構(gòu)建可靠的數(shù)據(jù)管道和實時數(shù)據(jù)處理系統(tǒng)的理想選擇，用于流式數(shù)據(jù)的收集、傳輸和處理。
• 日志和事件流處理：Kafka的分區(qū)和有序性保證特性使其成為日志和事件流處理的理想解決方案，例如應(yīng)用日志收集、事件溯源、業(yè)務(wù)監(jiān)控等。
• 實時流分析和機器學(xué)習(xí)：Kafka與流處理框架（如Flink、Spark Streaming）結(jié)合使用，支持實時流分析和機器學(xué)習(xí)任務(wù)，處理實時數(shù)據(jù)流以獲取實時的洞察和決策支持。

2、服務(wù)架構(gòu)

RabbitMQ

• Channel（通道）：Channel是RabbitMQ與應(yīng)用程序之間的虛擬連接。通過在物理連接（connection）上創(chuàng)建多個通道，應(yīng)用程序可以并發(fā)地進行消息傳遞操作。通道負責(zé)發(fā)送和接收消息，并執(zhí)行一些與消息相關(guān)的操作，如聲明隊列、定義交換機和綁定等。通道可以看作是輕量級的會話，通過一個物理連接與RabbitMQ進行交互。
• Exchange（交換機）：交換機是消息的接收和轉(zhuǎn)發(fā)中心。當(dāng)消息發(fā)送到RabbitMQ時，會通過交換機進行路由。交換機根據(jù)其類型和綁定規(guī)則，將消息路由到一個或多個隊列中。常見的交換機類型包括直連交換機（direct）、主題交換機（topic）、扇形交換機（fanout）和頭部交換機（headers）。
• Queue（隊列）：隊列是RabbitMQ用于存儲消息的緩沖區(qū)。當(dāng)消息無法立即路由到消費者時，會被存儲在隊列中，等待消費者來獲取和處理。每個隊列都有一個唯一的名稱，并且按照FIFO（先進先出）的順序進行消息的投遞和消費。
• Virtual Host（虛擬主機）：虛擬主機是邏輯上的隔離環(huán)境，用于將RabbitMQ服務(wù)器劃分為多個獨立的部分。每個虛擬主機都有自己的交換機、隊列、綁定和權(quán)限設(shè)置。虛擬主機可以幫助不同應(yīng)用程序或服務(wù)之間進行隔離，并提供安全性和資源管理的控制。
• Broker（代理）：Broker是RabbitMQ消息隊列服務(wù)器的實例，負責(zé)接收、存儲和路由消息。它充當(dāng)中間人的角色，將生產(chǎn)者發(fā)送的消息傳遞給消費者。一個RabbitMQ實例可以包含多個Broker，每個Broker可以承載多個虛擬主機和隊列。

RocketMQ

• NameServer（命名服務(wù)器）：NameServer是RocketMQ的命名服務(wù)組件，用于管理和提供Broker的路由信息。它充當(dāng)元數(shù)據(jù)的中心，負責(zé)維護Broker的注冊信息、Topic的路由信息等。Producer和Consumer在發(fā)送和接收消息之前，需要與NameServer進行交互以獲取正確的Broker信息。
• Controller（控制器）：Controller是RocketMQ的控制器組件，負責(zé)協(xié)調(diào)和管理整個RocketMQ集群的工作。它監(jiān)控Broker的狀態(tài)變化，處理集群的擴容和縮容，進行負載均衡等操作。Controller是RocketMQ集群的核心組件之一，確保集群的可靠運行和自動化管理。

  

• Broker（代理）：Broker是RocketMQ的消息存儲和處理節(jié)點。它負責(zé)接收來自Producer的消息，并將其存儲在磁盤上。Broker還負責(zé)處理Consumer的消息拉取請求，并將消息推送給Consumer進行消費。一個RocketMQ集群可以包含多個Broker，每個Broker負責(zé)存儲一部分Topic的消息數(shù)據(jù)。

KafkaMQ

• Broker（代理）：Broker是Kafka集群中的一個節(jié)點，負責(zé)存儲和處理消息。每個Broker都是一個獨立的Kafka服務(wù)器實例。它可以是單獨的物理服務(wù)器、虛擬機或容器。一個Kafka集群可以包含多個Broker，它們共同協(xié)作來實現(xiàn)高可用、高吞吐量的消息傳遞。
• Topic（主題）：Topic是消息的邏輯分類或主題。它是消息發(fā)布和訂閱的單位。Producer將消息發(fā)布到指定的Topic，而Consumer則訂閱感興趣的Topic以接收消息。Topic可以被認為是一個消息的容器，用于將相關(guān)的消息進行歸類和分組。
• Partition（分區(qū)）：Topic可以分成一個或多個分區(qū)，每個分區(qū)是Topic的子集。分區(qū)是消息存儲和傳遞的最小單位。每個分區(qū)在物理上對應(yīng)一個獨立的日志文件，它們分布在不同的Broker上。分區(qū)使得Kafka能夠?qū)崿F(xiàn)水平擴展和并行處理，同時提供更高的吞吐量。每個分區(qū)中的消息按照先入先出的順序進行存儲和傳遞。

3、持久化和可靠性：

• RabbitMQ：RabbitMQ采用消息持久化機制，消息被持久化到磁盤上，保證消息的可靠性。支持多種消息確認機制和事務(wù)，可以保證消息的可靠傳遞。
• RocketMQ：RocketMQ具有強大的持久化和可靠性特性，支持同步刷盤和異步復(fù)制機制，能夠提供高可靠性的消息傳遞保證。
• Kafka：Kafka以持久化的方式存儲消息，消息被寫入磁盤上的日志文件。通過分區(qū)和復(fù)制機制，提供了高可靠性和持久化存儲的能力。

4、吞吐量

• RabbitMQ：RabbitMQ的吞吐量通常較低，適合中小規(guī)模的應(yīng)用場景。RabbitMQ適用于中小規(guī)模的應(yīng)用場景，通常能夠處理萬級到十萬級的消息量級。它主要側(cè)重于消息的可靠性傳遞和消息的持久化，對于高吞吐量的需求可能需要進行優(yōu)化和調(diào)整。
• RocketMQ：RocketMQ具有較高的吞吐量，可以達到百萬級消息的處理能力。它在分布式事務(wù)和大規(guī)模消息傳遞場景下表現(xiàn)出色。
• Kafka：Kafka是以高吞吐量而著稱的消息隊列系統(tǒng)，能夠處理百萬級甚至更高的消息量級。Kafka適用于大規(guī)模數(shù)據(jù)處理、實時流處理和日志處理等高吞吐量場景。

5、響應(yīng)時間

6、社區(qū)及生態(tài)

• RabbitMQ：RabbitMQ擁有豐富的插件和工具生態(tài)系統(tǒng)，具有廣泛的開發(fā)者社區(qū)支持。
• RocketMQ：RocketMQ在國內(nèi)得到廣泛應(yīng)用，具有豐富的阿里巴巴生態(tài)系統(tǒng)和社區(qū)支持。
• Kafka：Kafka擁有活躍的開源社區(qū)和廣泛的生態(tài)系統(tǒng)，被許多大型公司廣泛采用。

Github Star

Github Contributors

總的來說：rabbitmq<rocketmq<kafka。

7、設(shè)計理念

• RabbitMQ：RabbitMQ是一個基于AMQP（高級消息隊列協(xié)議）的開源消息中間件，強調(diào)易用性和靈活性，支持多種消息模式和可靠的消息傳遞。
• RocketMQ：RocketMQ是阿里巴巴開源的分布式消息中間件，最初是為了滿足阿里巴巴內(nèi)部的海量數(shù)據(jù)處理需求而設(shè)計的，具有高吞吐量和低延遲的特點。在2016年阿里巴巴將RocketMQ捐贈給了Apache軟件基金會。
• Kafka：Kafka是由LinkedIn開發(fā)的分布式流處理平臺，主要用于高吞吐量的實時數(shù)據(jù)流處理，以持久化的方式存儲和處理數(shù)據(jù)。在2011年Kafka成為Apache開源項目。

8、數(shù)據(jù)模型

• RabbitMQ：RabbitMQ采用隊列（Queue）模型，消息被發(fā)送到隊列中，消費者從隊列中接收消息并進行處理。
• RocketMQ：RocketMQ采用主題（Topic）和標(biāo)簽（Tag）的模型，消息被發(fā)布到主題上，消費者可以根據(jù)主題和標(biāo)簽進行訂閱和過濾消息。
• Kafka：Kafka采用發(fā)布-訂閱的模型，消息被發(fā)布到主題上，多個消費者可以訂閱同一個主題并獨立消費消息。

9、Web管理工具

• RabbitMQ

RabbitMQ Web管理界面：RabbitMQ自帶一個Web管理界面，可以通過瀏覽器訪問。它提供了直觀的用戶界面，可以查看和管理RabbitMQ服務(wù)器的各個方面，包括隊列、交換機、綁定、用戶權(quán)限等。默認情況下，Web管理界面運行在15672端口。

RokcetMQ

RocketMQ Console：RocketMQ官方提供了一個Web控制臺，稱為RocketMQ Console。它提供了一個可視化界面，用于管理和監(jiān)控RocketMQ集群的各個方面，包括Topic、消費者組、消息查詢、性能統(tǒng)計等。你可以通過訪問控制臺的URL來使用該工具。

Kafka

Kafka Manager：Kafka Manager是由Yahoo開發(fā)的一個開源圖形化管理工具，用于管理Apache Kafka集群。它提供了集群狀態(tài)的實時監(jiān)控、主題和分區(qū)的管理、消費者組的管理等功能。

10、消息模式

主流的消息中間件的傳輸模型主要為點對點模型和發(fā)布訂閱模型。具體來說：

RabbitMQ：

• 發(fā)布-訂閱模式：RabbitMQ支持發(fā)布-訂閱模式，其中生產(chǎn)者將消息發(fā)布到交換機（Exchange），然后交換機將消息傳遞給多個綁定（Binding）到它的隊列。消費者可以獨立地從隊列中接收消息。
• 點對點模式：RabbitMQ也支持點對點模式，其中生產(chǎn)者將消息發(fā)送到指定的隊列，然后消費者從該隊列中接收消息。每條消息只能被一個消費者接收和處理。

RocketMQ：

• 發(fā)布-訂閱模式：RocketMQ支持發(fā)布-訂閱模式，其中生產(chǎn)者將消息發(fā)送到指定的主題（Topic），然后消費者訂閱感興趣的主題。RocketMQ的訂閱模式支持多種訂閱方式，如廣播模式和集群模式，可以實現(xiàn)消息的多播或負載均衡消費。
• 隊列模式：RocketMQ還支持隊列模式，其中生產(chǎn)者將消息發(fā)送到指定的隊列，然后消費者從指定的隊列中接收消息。多個消費者可以并行地從同一個隊列消費消息。

Kafka：

• 發(fā)布-訂閱模式：Kafka采用發(fā)布-訂閱模式，其中生產(chǎn)者將消息發(fā)布到指定的主題（Topic），然后消費者訂閱感興趣的主題。Kafka的訂閱模式支持多個消費者組，每個消費者組都可以獨立地消費消息，實現(xiàn)了高吞吐量和水平擴展。
• 分區(qū)模式：Kafka通過分區(qū)將主題劃分為多個分區(qū)，每個分區(qū)在物理上對應(yīng)一個獨立的日志文件。生產(chǎn)者將消息發(fā)送到指定分區(qū)，消費者可以按照分區(qū)進行并行消費。這種分區(qū)模式使得Kafka能夠?qū)崿F(xiàn)水平擴展和高吞吐量。