Kafka、RabbitMQ、RocketMQ常见消息中间件的介绍和对比

在分布式系统中，我们将广泛使用各种消息中间件在系统间交换数据，以实现系统间的异步解耦目前，市场上有很多开源消息中间件:卡夫卡、拉比、火箭等

什么是消息队列

在正式介绍和比较卡夫卡、拉比姆克和罗基特姆克之前，让我们谈谈什么是消息队列(MQ)，它实际上是一个存储消息的容器那我们为什么需要这样一个容器呢？事实上，为了分离不同的系统，让我们举一个例子:

有一个非常简单的场景，系统a负责生成用户标识并调用系统b和c如果系统BC的频繁更改需要用户标识参数，则系统A的代码必须不断更改。如果系统定义也需要该参数……...总有一天，系统A将不得不添加大量的业务逻辑，这使得其他系统之间的交互变得更加容易。此外，大量系统与系统A相互作用，容易导致问题。将

添加到消息队列后，a只负责生成用户标识。谁想使用这个参数以及如何使用？系统a不在乎对这些数据感兴趣的系统可以自己使用，并且可以在每个系统之间实现解耦。此外，在解耦之后，整个服务也变成了异步模式。系统A生成数据后，不需要依次调用BCD来累计时间消耗。每个系统都可以同时访问消息队列中的数据进行处理，并提高吞吐量。

消息队列

1先进先出的特点:消息队列的顺序基本上是在进入队列时确定的，一般不需要人工干预

2，发布订阅:发布订阅是一种非常有效的处理方法。如果没有阻塞，基本上可以认为是同步运行。

3，持久性:持久性确保消息队列的使用不仅是某些场景的辅助工具，而且还使消息队列能够存储核心数据，如数据库。

4，分布式:在当前大流量和大数据的使用场景中，支持广泛使用分布式部署。消息队列的定位是一个高性能的中间件

Kafka，RabbitMQ，RocketMQ简介

Kafka

Kafka是LinkedIn的开源分布式发布-订阅消息系统，目前属于Apache的顶级项目卡夫卡主要是为高吞吐量订阅发布系统设计的，追求速度和持久性。卡夫卡的信息由密钥、值和时间戳组成。卡夫卡不记录谁使用了每条信息，而只记录哪些信息是未读的。在卡夫卡那里，可以指定一个消费群体来实现订阅和出版的功能。

Rabbit MQ

Rabbit MQ是一个用Erlang语言开发并基于AMQP协议实现的开源消息队列系统AMQP的主要特点是面向消息、面向队列、路由(包括点对点和发布/订阅)、可靠性和安全性AMQP协议更多地用于企业系统。它对数据一致性、稳定性和可靠性有很高的要求，对性能和吞吐量的要求排在第二位。

火箭MQ

火箭MQ是阿里的开源消息中间件。它完全用Java开发，具有高吞吐量、高可用性和适合大规模分布式系统应用的特点。火箭智商起源于卡夫卡，但它不是卡夫卡的复制品。它优化了消息的可靠传输和事务。目前，火箭MQ广泛应用于阿里集团的交易、充值、流量计算、消息推送、日志流、binglog分发等场景。支持的客户端语言不多，目前有Java和C++，其中C++还不成熟。

kafka、RabbitMQ、RocketMQ与

1相比，Rabbitmq比Kafka更可靠，Kafka更适合IO高吞吐量处理，如ELK日志收集

2和kafka具有高吞吐量，内部采用消息的批处理和零拷贝机制。数据存储和获取是本地磁盘的顺序批处理操作，具有O(1)复杂性和高消息处理效率RabbitMQ的吞吐量略低于卡夫卡。他们的出发点不同。rabbitMQ支持可靠的消息传输，支持事务，不支持批处理操作。根据存储可靠性的要求，可以使用内存或硬盘进行存储

本文由 在线网速测试 整理编辑，转载请注明出处，原文链接：https://www.wangsu123.cn/news/2701.html。