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 上使用二进制协议进行数据传输。