本文共 1160 字，大约阅读时间需要 3 分钟。
在早期阶段，我们构建分布式中间件基于ActiveMQ 5.x(早于 5.3)。我们的国际业务将其用于异步通信，搜索，社交网络活动流，数据管道，甚至在其交易流程中。随着我们的交易业务吞吐量增加，源自我们的消息集群的压力也变得迫切。
基于我们的研究，随着使用的队列和虚拟主题的增加，ActiveMQ IO 模块成为了瓶颈。 我们尽力通过节流，断路器或降级解决这个问题，但效果不佳。因此我们开始关注那时候比较流行的消息解决方案kafka。不幸的是，就低延迟和高可用方面而言，kafka不能解决我们的特殊需求,详情。
在这种情况下，我们决定创造一个新的消息引擎来解决更广泛的使用场景，从传统的发布/订阅情景到大容量的实时零容错零容忍事物系统。我们认为这个解决方案可能是有益的，因此我们希望将它向社区开源。目前，有超过100家公司在生产环境中使用开源的RocketMQ版本。我们还发布了基于RocketMQ的商业发行版，一种被称为阿里云平台的paas产品。
下面的表格展示RocketMQ，ActiveMQ 和Kafka （来自的流行消息解决方案）之间的对比
| 消息产品 | ActiveMQ | Kafka | RocketMQ |
|---|---|---|---|
| 客户端SDK | Java, .NET, C++ 等 | Java, Scala 等 | Java, C++, Go |
| 协议和规范 | push模式，支持OpenWire, STOMP, AMQP, MQTT, JMS | pull模式，支持TCP | pull模式，支持TCP，JMS，OpenMessaging |
| 有序消息 | 独有消费者或队列可保证顺序 | 分区内保证消息顺序 | 保证严格的消息顺序，可优雅的横向扩展 |
| 定时消息 | 支持 | 不支持 | 支持 |
| 批量消息 | 不支持 | 支持，通过异步发送者 | 支持，通过同步模式避免消息丢失 |
| 广播消息 | 支持 | 不支持 | 支持 |
| 消息过滤器 | 支持 | 支持，可通过streams来过滤消息 | 支持，基于SqL92的属性过滤器表达式 |
| 服务器触发重发 | 不支持 | 不支持 | 支持 |
| 消息存储 | 支持快速持久化jdbc和高性能日志文件，例如levelDB，kahaDB | 高性能文件存储 | 高性能低延迟文件存储 |
| 消息回溯 | 支持 | 支持偏移量 | 支持时间偏移量 |
| 消息优先级 | 支持 | 不支持 | 支持 |
| 高可用故障转移 | 支持，依赖存储，kahadb需zookeeper | 支持，需要zookeeper | 支持，主从模式，不需其他组件 |
| 消息追踪 | 不支持 | 不支持 | 支持 |
| 配置 | 默认配置是低级别的，用户需优化配置参数 | kafka使用格式化键值对配置。值可通过文件或编程提供 | 开箱即用，用户只需关注一部分配置 |
| 管理和操纵工具 | 支持 | 支持，使用命令行暴露核心指标 | 支持，web和命令行暴露核心指标 |
转载地址：http://gmmaa.baihongyu.com/