消息队列中间件是分布式系统中重要的组件，主要解决应用耦合，异步消息，流量削锋等问题实现高性能，高可用，可伸缩和最终一致性架构。使用较多的消息队列有ActiveMQ，RabbitMQ，ZeroMQ，Kafka，MetaMQ，RocketMQ，这里主要介绍下RocketMQ。RocketMQ的前身是Metaq，3.0后更名为RocketMQ，apache地址为：http://rocketmq.apache.org/

RocketMQ是什么？

看下Apache上关于RocketMQ的介绍：RocketMQ是一款低延迟、高可靠、可伸缩、易于使用的消息中间件。具有以下特征：

1.支持发布/订阅（Pub/Sub）和点对点（P2P）消息模型

2.在一个队列中可靠的先进先出（FIFO）和严格的顺序传递                                                                                                             

3.支持拉pull和推push两种消费方式                                                                                                                                                       

4.单一队列百万消息的堆积能力                                                                                                                                                           

5.支持多种消息协议，如 JMS、MQTT 等                                                                                                                                             

6.分布式高可用的部署架构,满足至少一次消息传递语义                                                                                                                     

7.提供 docker 镜像用于隔离测试和云集群部署                                                                                                                                   

8.提供配置、指标和监控等功能丰富的 Dashboard

RocketMQ架构

 RocketMQ主要由三部分组成：client（producer，consumer），broker，nameServer，如下架构图所示：

从上图可以看出每一部分都为集群，当然也可以部署为单点。集群的部署方式增加了系统的可靠性和吞吐量。

NameServer：MQ集群服务的治理者和协调者，相当于zookeeper之于kafka。

Broker：通过提供轻量级的Topic和Queue机制来存储和处理消息。上图中可以看到broker可以提供主从方式以保证消息的可靠性，可以1主1从，也可以1主多从，主能读写，从只能读。主从之间消息同步可以采取同步或者异步，同步可靠性更高，异步效率更高，可根据实际情况选择。笔者从事于电商公司，选择的是主从同步复制。

Producer：即消息的发送者，生产者将消息组装，从NameServer获取Topic的路由信息，然后将消息发送到具体的broker，broker收到消息后，采用同步刷盘或者异步刷盘的模式持久到本地磁盘。

Consumer：即消息消费方。consumer是以组（ConsumerGroup）为单位消费消息的，即一个消息只能被同一消费组下一个消费者消费。消费者通过NameServer获取需要消费的topic的broker信息，与之建立连接，轮训试的访问是否有消息到来从而消费，push是pull的一种变种，只是单独起了一个线程负责拉取消息而已。

到这里为止，相信大家已经对RocketMQ有了一个简单的概念，后面即将揭开每一部分的实现原理，及解析部分源码。

参考文章链接：RocketMQ 实战之快速入门

                         消息队列的使用场景