Rocket MQ 架构介绍

文章目录

为什么选择Rocket MQ
基本概念
优点
缺点
架构图
编程模型
- 发送者发送消息固定步骤
- 消费者消费消息固定步骤

为什么选择Rocket MQ

Rocket MQ是阿帕奇顶级的开源项目，由阿里开发并开源。它的研发背景是Active MQ与Kafka不能很好的解决当时的业务场景。官网上是这么描述的：

   在阿里孕育 RocketMQ 的雏形时期，我们将其用于异步通信、搜索、社交网络活动流、数据管道，贸易流程中。随着我们的贸易业务吞吐量
的上升，源自我们的消息传递集群的压力也变得紧迫。根据我们的研究，随着队列和虚拟主题使用的增加，ActiveMQ IO模块达到了一个瓶颈。我们尽力通过节流、断路器或降级来解决这个问题，
但效果并不理想。于是我们尝试了流行的消息传递解决方案Kafka。不幸的是，Kafka不能满足我们的要求，其尤其表现在低延迟和高可靠性
方面，详见下文。在这种情况下，我们决定发明一个新的消息传递引擎来处理更广泛的消息用例，覆盖从传统的pub/sub场景到高容量的实时
零误差的交易系统。

基本概念

名词	描述
Producer（生产者）	消息的生产者，一般是系统中的一个功能模块
Consumer（消费者）	消息的消费者，一般是系统中的一个功能模块
Name server 命名空间	用于维护Broker与Topic的信息，提供轻量级的Broker路由服务
Broker	实际处理消息存储、转发等服务的核心组件
Topic	区分消息的种类，用于路由消息
Message Queqe	Topic的分区，用于并行发送和接收消息

优点

异步：可以提高系统的响应速度，吞吐量。比如现在的菜鸟驿站/快递柜，快递员只需把快递送到驿站/快递柜即可送下一个快递，不用等A客户拿到快递后，再去给B客户拿快递。
解耦：快递员是一个独立的角色，负责派送包裹，而不需要直接与收件人进行实时交互。快递员可以通过查询系统或从调度中心获取待派送的包裹信息，然后根据包裹上的地址信息进行派送。
削峰：超市618，双十一都会有大促活动。超市可以采用分时段入场、预约购物或提前安排活动等措施，将顾客的到达时间分散在更长的时间段内，从而减少高峰时段的拥堵和排队等待时间。