Kafka 和 RabbitMQ 有何區別？

RabbitMQ 和 Apache Kafka 均允許生產者將訊息傳送給取用者。生產者是發佈資訊的應用程式，而取用者是訂閱和處理資訊的應用程式。

生產者和取用者在 RabbitMQ 和 Kafka 中以不同的方式互動。在 RabbitMQ 中，生產者傳送訊息並監控其是否到達預期的取用者處。另一方面，Kafka 生產者將訊息發佈到佇列，而不管消費者是否已擷取它們。

您可以將 RabbitMQ 視為接收郵件並將其交付給預定收件方的郵局。與此同時，Kafka 類似於圖書館，其中會按生產者發佈的不同流派組織書架上的訊息。然後，取用者閱讀各自書架上的訊息，並記住他們讀過的內容。 

RabbitMQ 架構方法

RabbitMQ 代理程式允許藉助下列元件進行低延遲和複雜的訊息分配：

• 交換會接收來自生產者的訊息，並決定應該將其路由到何處
• 佇列是接收來自交換的訊息並將其傳送給取用者的儲存空間
• 繫結是連線交換和代理程式的路徑

在 RabbitMQ 中，路由金鑰是用來將訊息從交換路由智特定佇列的訊息屬性。當生產者將訊息傳送至交換時，它會包含作為訊息一部分的路由金鑰。然後，交換會使用此路由金鑰來決定訊息應該傳遞至哪個佇列。

Kafka 架構方法

Kafka 叢集以更複雜的架構提供高輸送量串流事件處理。以下是一些重要的 Kafka 元件：

• Kafka 代理程式是 Kafka 私服器，允許生產者將資料流式傳輸給取用者。 Kafka 代理程式包含主題及其各自的分割區。 
• 主題是將類似資料分組在 Kafka 代理程式中的資料存儲。 
• 分割區是取用者所訂閱主題中較小規模的資料儲存。 
• ZooKeeper 是管理 Kafka 叢集和分割區以提供容錯串流的軟體。ZooKeeper 最近被取代為 Apache Kafka Raft (KRaft) 通訊協定。

Kafka 中的生產者為每條訊息指派一個訊息密鑰。然後，Kafka 代理程式將訊息儲存在該特定主題的主導分割區中。Kraft 通訊協定使用共識演算法來確定主導的分割區。 

RabbitMQ 以簡單的架構提供複雜的訊息路由，而 Kafka 提供耐用的訊息代理程式系統，可讓應用程式處理串流歷史記錄中的資料。

接下來，我們分享兩個訊息代理程式之間的更多差異。 

效能

RabbitMQ 和 Kafka 都為其預期的使用案例提供高效能的訊息傳輸。但是，Kafka 在訊息傳輸容量方面優於 RabbitMQ。

Kafka 每秒可以傳送數百萬條訊息，因為它使用序列化磁碟 I/O 來啟用高輸送量的訊息交換。序列化磁碟 I/O 是一種儲存系統，用於儲存和存取相鄰記憶體空間中的資料，該系統比隨機磁碟存取更快速。

RabbitMQ 還可以每秒傳送數百萬條訊息，但它需要多個代理程式執行此動作。通常，RabbitMQ 的效能是平均每秒傳送數千條訊息，並且如果 RabbitMQ 的佇列擁塞，則可能會降低速度。 

安全性

RabbitMQ 和 Kafka 均允許應用程式安全地交換訊息，但使用不同的技術。

RabbitMQ 附帶管理使用者許可和代理程式安全性的管理工具。

與此同時，Apache Kafka 架構使用 TLS 以及 Java 身分驗證和授權服務 (JAAS) 提供安全的事件串流。TLS 是一種加密技術，可防止意外竊聽訊息；JAAS 則控制哪個應用程式可以存取代理程式系統。 

程式設計語言和通訊協定

Kafka 和 RabbitMQ 均支援開發人員熟悉的各種語言、框架和通訊協定。

可以在為 Kafka 和 RabbitMQ 建置用戶端應用程式時使用 Java 和 Ruby 編寫程式碼。此外，Kafka 支援 Python 和 Node.js，而 RabbitMQ 支援 JavaScript、Go、C、Swift、Spring、Elixir、PHP 和 .NET。

Kafka 使用 TCP 上的二進位通訊協定跨即時資料管道流式傳輸訊息，而 RabbitMQ 預設情況下支援進階訊息佇列通訊協定 (AMQP)。RabbitMQ 還支援舊式通訊協定，例如簡單文字導向簡訊通訊協定 (STOMP) 和 MQTT，以此路由訊息。

閱讀有關 MQTT 的內容 »

務必了解的是，RabbitMQ 和 Kafka 不是互相競爭的訊息代理程式。兩者設計為在不同的使用案例中支援資料交換，各自具備不同的優勢。

接下來，我們討論一些可考慮使用 RabbitMQ 和 Kafka 的使用案例。

事件串流重播

Kafka 適用於需要重新分析所接收資料的應用程式。您可以在保留期間內多次處理串流資料，或收集日誌檔案進行分析。

使用 RabbitMQ 進行日誌彙總更具挑戰性，因為訊息一旦取用就會被刪除。解決方法是重播來自生產者的已儲存訊息。

即時資料處理

Kafka 以極低的延遲流式傳輸訊息，適合即時分析串流資料。例如，可以使用 Kafka 做為分散式監控服務，即時提出線上交易處理的提醒。

複雜的路由架構

RabbitMQ 為需求模糊或路由場景複雜的用戶端提供靈活性。例如，您可以設定 RabbitMQ，將資料路由到具有不同繫結和交換的不同應用程式。

有效的訊息交付

RabbitMQ 套用推送模型，這意味著生產者知道用戶端應用程式是否取用訊息。它適合在交換和分析資料時必須遵守特定序列和交付保證的應用程式。 

語言和通訊協定支援

開發人員將 RabbitMQ 用於需要向下相容於舊式通訊協定 (例如 MQTT 和 STOMP) 的用戶端應用程式。與 Kafka 相比，RabbitMQ 還支援更廣泛的程式設計語言。

	RabbitMQ	Kafka
架構	RabbitMQ 的架構專為複雜的訊息路由而設計。該代理程式使用推送模型。生產者傳送訊息給使用不同規則的取用者。	Kafka 使用基於分割區的設計進行即時、高吞吐量的串流處理。該代理程式使用提取模型。產生者會將訊息發佈至取用者訂閱的主題和分割區。
訊息處理	RabbitMQ 代理程式監控訊息取用。該代理程式會在訊息被取用後將其刪除。它支援訊息優先順序。	取用者使用偏移追蹤器追蹤訊息擷取。Kafka 依據保留政策保留訊息。沒有訊息優先順序。
效能	RabbitMQ 具有低延遲。該代理程式每秒傳送數千條訊息。	Kafka 提供高達每秒數百萬條訊息的即時傳輸。
程式設計語言和通訊協定	RabbitMQ 支援廣泛的語言和舊式通訊協定。	Kafka 的程式設計語言選擇有限。該代理程式透過 TCP 使用二進位通訊協定進行資料傳輸。