您现在的位置是：首页 > 文章详情

为什么是RocketMQ（翻译）

日期：2018-10-28点击：557收藏

动机

在早期阶段，我们构建分布式中间件基于ActiveMQ 5.x(早于 5.3)。我们的国际业务将其用于异步通信，搜索，社交网络活动流，数据管道，甚至在其交易流程中。随着我们的交易业务吞吐量增加，源自我们的消息集群的压力也变得迫切。

为什么是RocketMQ

基于我们的研究，随着使用的队列和虚拟主题的增加，ActiveMQ IO 模块成为了瓶颈。我们尽力通过节流，断路器或降级解决这个问题，但效果不佳。因此我们开始关注那时候比较流行的消息解决方案kafka。不幸的是，就低延迟和高可用方面而言，kafka不能解决我们的特殊需求,详情看这里。

在这种情况下，我们决定创造一个新的消息引擎来解决更广泛的使用场景，从传统的发布/订阅情景到大容量的实时零容错零容忍事物系统。我们认为这个解决方案可能是有益的，因此我们希望将它向社区开源。目前，有超过100家公司在生产环境中使用开源的RocketMQ版本。我们还发布了基于RocketMQ的商业发行版，一种被称为阿里云平台的paas产品。

下面的表格展示RocketMQ，ActiveMQ 和Kafka （来自awesome-java的流行消息解决方案）之间的对比

Rocket ，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和命令行暴露核心指标