MQ 的作用及主流 MQ 对比 - 干啥啥不行，参考第一名

特性 ActiveMQ RabbitMQ RocketMQ Kafka 单机吞吐量 万级，吞吐量比RocketMQ和Kafka要低了一个数量级 万级，吞吐量比RocketMQ和Kafka要低了一个数量级 10万级，RocketMQ也是可以支撑高吞吐的一种MQ 10万级别，这是kafka最大的优点，就是吞吐量....

本文介绍了消息队列（MQ）的基本概念及其在分布式系统中的作用，包括实现异步通信、削峰限流和应用解耦等方面的优势，并对ActiveMQ、RabbitMQ、RocketMQ及Kafka四种MQ产品进行了对比分析，涵盖了它们的开发语言、吞吐量、时效性和可用性等特点。此外，文章还特别介绍了RocketMQ，包括其架构设计、高可用性实现方式以及消费模式等内容，突出了RocketMQ在消息顺序消费、拉取模式、扩展性等方面的优势。

activeMQ：高效、可扩展、稳定安全企业级消息通信 rabbitMQ：分布式系统可靠、可扩展、功能丰富，内存式堆积，某些条件下触发换页动作将内存中消息换页到磁盘；支持多租户 不支持重试队列，二次封装延迟队列实现呢 拉模式，不回溯，支持消息追踪 多租户 kafka：高吞吐量分布式发布订阅消息系统，可水平扩展，磁盘式堆积，冗余功能 过滤：consumerInterceptor接口或kafka stream的filter消息过滤 不支持优先级、延迟、死信...

消息中间件，其实准确的叫法应该叫消息队列（message queue），简称MQ。其本质上是个队列，有FIFO的性质，即first in first out，先入先出。

在消息队列中，连接器也称为 Connector，它的作用是把不同数据源中的数据导入到消息队列，或者把消息队列中的数据导出到下游的各种存储引擎。连接器对于用户的价值是，可以很方便地将数据导入、导出消息队列。听起来，它和MQ - 38 Serverless : 基于Serverless架构实现流式数据处理中讲的基于 Serverless 实现流式计算和事件驱动架构的作用很类似，从功能上看，Flink 或 Spark 也能实现。那为什么还有连接器这个概念呢？它的价值是什么？

我们来看看消息队列中的 Schema 模块。看到 Schema 这个词， Schema 是什么？它有什么用？什么时候可以用到它？Schema 是数据结构定义的意思，即定义数据是什么格式的。消息队列中的 Schema 用来保证上下游数据在传递过程中，消息根据指定的格式和定义进行传递，从而解决上游的数据变更所导致的下游消费失败问题。消息队列 Schema 的核心是：客户端按照指定的数据格式发送数据，Broker 按照配置的数据格式进行校验，消费者根据指定的格式解析数据。

rocketmq 的前身为 metaq，metaq 的第一个版本是可以看成是 linkedin 的 kafka（scala）的 java 版本，并对其增加了事务的支持。rocketmq 为 metaq3.0，相比于原始 kafka，其擅长点出了原始的 log collecting 之外，还增加诸如 HA、事务等特性，使得从功能点上讲，可以替代传统大部分 MQ。更多工作是保证消息递交；的 MQ API，这一层API可以将上层应用和下层 MQ 的实现解耦（阿里内部有多个mq的实现，如 notify、

https://www.cnblogs.com/ly-radiata/articles/5563744.html

下面是关于主流的 Kafka、RabbitMQ、ZeroMQ、RocketMQ 和 ActiveMQ 的一些介绍：Kafka 是一个分布式流处理平台，设计用于处理高吞吐量的实时数据流。它具有高可靠性、可扩展性和持久性，适用于构建实时数据管道和流式处理应用程序。Kafka 使用发布-订阅模型，消息以主题（topic）的形式进行发布和订阅。RabbitMQ 是一个功能丰富且易于使用的开源消息队列系统，实现了高级消息队列协议（AMQP）。

MQ对比选型：RocketMQ、Kafka、RabbitMQ、ActiveMQ、ZeroMQ

特性 ActiveMQ RabbitMQ RocketMQ Kafka 单机吞吐量 万级，吞吐量比RocketMQ和Kafka要低了一个数量 万级，吞吐量比RocketMQ和Kafka要低了一个数量级 10万级，RocketMQ也是可以支撑高吞吐的一种MQ 10万级别，这是kafka最大的优点，就是吞吐量高,一般配合大数据类的系统来进行实时数据计算、日志采集等场景 topic数量对吞吐量的影响 topic可以达到几百，几千个的级别，吞吐量会有较小幅度的下降,这是RocketMQ的一大...

在构建分布式系统时，选择适合的消息中间件是至关重要的决策。RabbitMQ、Kafka、ActiveMQ 和 RocketMQ 是当前流行的消息中间件之一，它们各自具有独特的特点和适用场景。本文将对这四种消息中间件进行综合比较，帮助您在项目中作出明智的选择。