ActiveMQ 是 Apache 出品的最流行的、性能强劲的开源消息总线,并且其是一个完全支持 JMS 规范的消息中间件。其丰富的 API、多种集群构建模式使得它成为业界老牌消息中间件,广泛应用于中小型企业。
Kafka 是 LinkedIn 开源的分布式发布-订阅消息系统,目前属于 Apache 顶级项目。
Kafka 主要特点是基于 Pull 的模式来处理消息消费,追求高吞吐量,一开始的目的就是用于日志收集和传输。0.8 版本开始支持复制,不支持事务,对消息的重复、丢失、错误没有严格要求,适合产生大量数据的互联网服务的数据收集业务。
RocketMQ 是阿里开源的消息中间件,目前也已经孵化为 Apache 顶级项目,它是纯 Java 开发,具有高吞吐量、高可用性、适合大规模分布式系统应用的特点。
RocketMQ 思路起源于 Kafka,它对消息的可靠传输及事务性做了优化,目前在阿里集团被广泛应用于交易、充值、流计算、消息推送、日志流式处理、binglog 分发等场景。
RabbitMQ 是使用 Erlang 语言开发的开源消息队列系统,基于 AMQP 协议来实现。
AMQP 的主要特征是面向消息、队列、路由(包括点对点和发布/订阅)、可靠性、安全。AMQP 协议更多用在企业系统内,对数据一致性、稳定性和可靠性要求很高的场景,对性能和吞吐量的要求还在其次。
| 消息中间件 | ActiveMQ | Kafka | RocketMQ | RabbitMQ |
|---|---|---|---|---|
| 吞吐量 | 万数量级 | 十万级,高吞吐 | 十万级,高吞吐 | 万数量级 |
| Topic 数量对吞吐量影响 | / | Topic 从几十到几百时,吞吐量会大幅度下降, 在同等机器下,Kafka 尽量保证 Topic 数量不要过多,如果要支撑大规模的 Topic,需要增加更多的机器 |
Topic 可达百/千级,吞吐量下降幅度小 在同等机器下,可以支撑大量的 Topic |
/ |
| 时效性 | 毫秒级 | 毫秒级 | 毫秒级 | 微秒级 |
| 可用性 | 高 基于主从架构实现高可用高 |
非常高 分布式架构 |
非常高 分布式架构 |
高 基于主从架构实现高可用高 |
| 可靠性 | 丢失数据的概率低 | 优化参数配置, 可以做到零丢失 |
优化参数配置, 可以做到零丢失 |
基本不会丢失数据 |
| 功能 | 功能较完备 | 功能较为简单,主要支持简单的 MQ 功能,在大数据领域的实时计算以及日志采集被大规模使用 | MQ 功能较为完善,还是分布式的,扩展性好 | 基于 ErLang 开发,并发能力很强,性能极好,延时很低 |