在選擇合適的消息隊列或消息傳遞系統時，了解各個系統的特點和優勢非常重要。下面對 RabbitMQ、RocketMQ、Kafka 和 Pulsar 進行綜合對比，涵蓋架構、性能、可用性、適用場景等方面：

• 排名

• 對比

一、消息模型

1.1、RabbitMQ

基于交換機（Exchange）和隊列（Queue）的靈活路由

• 交換機（Exchange）：消息發布到交換機，通過路由鍵（Routing Key）決定消息發送到哪個隊列。

• 隊列（Queue）：消息存儲的地方，消費者從隊列中獲取消息。

• 路由鍵（Routing Key）：用于匹配消息和隊列的鍵。

• 綁定（Binding）：連接交換機和隊列，定義路由規則。

消息傳遞模式：

• Direct：消息通過精確匹配路由鍵發送到隊列。

• Fanout：消息廣播到所有綁定的隊列。

• Topic：消息按模式匹配路由鍵發送到隊列。

RocketMQ

基于主題（Topic）和消息隊列的高可用、高吞吐量消息系統

• 主題（Topic）：消息按主題分類，每個主題可以有多個隊列。

• 消息隊列（Message Queue）：主題分為多個隊列，消息存儲在隊列中。

消息傳遞模式：

• 點對點：消息直接發送到隊列。

• 發布/訂閱：消息發布到主題，所有訂閱該主題的消費者接收消息。

Kafka

高吞吐量的發布/訂閱系統，基于主題和分區（Partition）

• 主題（Topic）：消息按主題分類，主題分為多個分區。

• 分區（Partition）：每個主題有多個分區，分區內消息有序存儲。

消息傳遞模式：

• 發布/訂閱：生產者發布消息到主題，消費者訂閱主題分區。

• 分區消費：消費者組內的消費者協作消費分區。

Pulsar

多租戶、高可用的消息流平臺，支持靈活的消息傳遞模式

• 主題（Topic）：消息按主題分類，主題可以分為多個分區。

• 分區（Partition）：主題分為多個分區，分區內消息有序存儲。

消息傳遞模式：

• 發布/訂閱：支持復雜訂閱模式和消息路由。

產品架構

RabbitMQ 架構

核心組件：

1. 生產者（Producer）：發送消息到交換機。

2. 交換機（Exchange）：根據綁定規則路由消息到隊列。主要類型有 direct、fanout、topic 和 headers。

3. 隊列（Queue）：存儲消息，消費者從隊列中消費消息。

4. 消費者（Consumer）：從隊列中獲取并處理消息。

5. 綁定（Binding）：連接交換機和隊列，定義路由規則。

架構特點：

• 靈活的消息路由機制，通過不同類型的交換機實現復雜的路由規則。

• 支持消息的持久化、事務和確認機制，確保消息可靠傳遞。

RocketMQ 架構

核心組件：

1. 生產者（Producer）：發送消息到主題（Topic）。

2. 主題（Topic）：按主題分類消息，每個主題有多個隊列。

3. 消息隊列（Message Queue）：存儲消息，是主題的子集。

4. 消費者（Consumer）：從消息隊列中消費消息。

5. 名稱服務器（Name Server）：管理主題和消息隊列的元數據，提供路由信息。

6. Broker：存儲消息并處理消息傳遞，管理消息隊列。

架構特點：

• 高可用性，通過多個 Broker 實現數據的復制和故障轉移。

• 支持順序消息和分布式事務，適合金融等需要嚴格消息順序和事務保證的場景。

Kafka 架構

核心組件：

1. 生產者（Producer）：將消息發送到主題的分區（Partition）。

2. 主題（Topic）：按主題分類消息，每個主題分為多個分區。

3. 分區（Partition）：消息按順序存儲在分區中，實現并行處理。

4. 消費者（Consumer）：從分區消費消息，可以指定消費位移（Offset）。

5. 消費者組（Consumer Group）：組內消費者協作消費分區，實現負載均衡。

6. Broker：Kafka 服務器，負責存儲消息并處理消息傳遞。

7. ZooKeeper：管理集群的元數據和協調 Broker 的活動。

架構特點：

• 高吞吐量，適合大規模實時數據流處理。

• 持久化存儲和分區機制確保數據的可靠性和可擴展性。

Pulsar 架構

核心組件：

1. 生產者（Producer）：發送消息到主題或分區。

2. 主題（Topic）：按主題分類消息，可以分為多個分區。

3. 分區（Partition）：主題的子集，分區內消息有序存儲。

4. 消費者（Consumer）：從主題或分區消費消息。

5. Broker：處理客戶端請求，協調消息的存儲和傳遞。

6. BookKeeper（Bookies）：提供持久化存儲，將消息存儲在多個 Bookie 中，確保數據可靠。

7. ZooKeeper：管理集群元數據，協調 Broker 和 BookKeeper 的活動。

架構特點：

• 多租戶支持，適合復雜的多用戶場景。

• 高可用性和可擴展性，通過水平擴展 Broker 和 BookKeeper 節點實現。

• 靈活的消息傳遞模式，支持獨占、共享和故障轉移訂閱。

產品性能

吞吐量

圖片來源于confluent.io

• RabbitMQ：靈活性和可靠性較高，但吞吐量最低。

• RocketMQ：高可用性和順序消息支持，吞吐量次于 RabbitMQ。

• Pulsar：多租戶和分區支持，提供較高吞吐量。

• Kafka：專為高吞吐量和低延遲設計，適合大規模數據流處理，吞吐量最高。

吞吐量從大到小的一般排名:

kafka->pulsar->rocketmq->rabbitmq

延遲

?

圖片與表格來源于confluent.io

在低吞吐量的情況下，消息隊列系統的響應時間會受到多種因素的影響，包括系統架構、消息大小、網絡延遲等。響應時間從快到慢的一般排名:

rabbitmq->kafka->pulsar->rocketmq

而在高吞吐量的情況下，不同的消息隊列系統的響應時間會受到它們設計和優化的影響。響應時間從快到慢的一般排名:

kafka->pulsar->rocketmq->rabbitmq

閱讀原文：原文鏈接