Apache RocketMQ

历史

RocketMQ的发展可分为三个阶段。
第一代在数据传输中使用push模式，在数据存储中使用关系型数据库。它展现了消息传递的低延迟，并且满足了具有分布式事务的典型电子商务平台 的用途。
第二代在数据传输中使用pull模式，在数据存储中使用文件系统。它更注重稳定性和可靠性，并显示出与第一代响应时间和Kafka日志收集相当的性能。
第三代将pull模式与一些push操作相结合。它继承了第一代和第二代的优点，并在并发性和大量数据场景中表现出高性能。

架构

RocketMQ由四部分组成：命名服务器（Name Server）、代理（Broker）、生产者（Producer）和消费者（Consumer），其中每一个都可以水平扩展而没有单点故障，如上图所示。

命名服务器集群

命名服务器集群是用于服务发现的轻量级组件，它们可用于读取和写入路由信息。每个命名服务器可以记录全局信息，并支持快速存储扩展。

代理集群

代理集群使用轻量级主题（topic）和队列（queue）机制来管理数据存储。为了实现容错，代理提供2份或3份数据。客户端可以在Push和Pull模型中获取消息。此外，还支持灾难恢复和丰富的指标统计信息。

生产者集群

生产者（Producer）可以分布式部署，从生产者到代理的消息可以通过多路径进行平衡。此外，还支持快速故障恢复和低延迟。

消费者集群

消费者也可以在Push和Pull模型中进行分布式部署，他们可以实时订阅消息，以集群为单位消费消息，同时还支持消息广播。

社区维护

RocketMQ团队为活跃社区做了很多工作。聚会、研讨会、ApacheCon和Code Marathon定期在北京、深圳、杭州等地举行，以吸引新的贡献者和提交者。OpenMessaging基准测试套件目前可用于RocketMQ，它使RocketMQ与分布式消息传递的全球标准保持同步。对于版本管理，采用了一系列标准化的软件开发过程。最新版本是4.2.0，4.3.0即将推出。可在此处获取更多信息。

获奖

2016年度最受欢迎中国开源软件奖
2017年度最受欢迎中国开源软件奖
第12次中日韩(中国-日本-韩国)开源软件优秀技术奖
2018年度最受欢迎中国开源软件奖