浅解RocketMQ

RocketMQ相关知识学习

官方中文文档：
https://github.com/apache/rocketmq/blob/master/docs/cn

在官网进行下载并安装
安装后进行相关环境变量的配置
官网：https://rocketmq.apache.org/

RocketMQ主要由Producer、Broker、Consumer三部分组成，其中Producer负责生产消息、Broker负责存储消息、Consumer负责消费消息。Broker在实际部署过程中对应一台服务器，每个 Broker 可以存储多个Topic的消息，每个Topic的消息也可以分片存储于不同的 Broker。Message Queue 用于存储消息的物理地址，每个Topic中的消息地址存储于多个 Message Queue 中。ConsumerGroup 由多个Consumer 实例构成。

• 消息的生产者
• 水机选择其中的一个NameServer节点建立长连接，获得Topic路由信息（包括topic下的quere，这些quere分布在那些broker上等等）。
• 接下来向提供topic服务的master建立长链接（因为rocketMQ只有master才能写消息），且定时向master发生心跳。
• Producer负责生产消息，一般由业务系统负责生产消息。一个消息生产者会把业务应用系统里产生的消息发送到broker服务器。RocketMQ提供多种发送方式，同步发送、异步发送、顺序发送、单向发送。同步和异步方式都需要Broker返回确认信息，单向发送不需要。

• 消息的消费者。
• 通过NameServer集群获得Topic的路由信息，连接到对应的Broker上消费消息。
• 由于Master和Slave都可以读取消息，因此Consumer会与Master和Slave都建立连接进行消费消息。
• 负责消费消息，一般是后台系统负责异步消费。一个消息消费者会从Broker服务器拉取消息、并将其提供给应用程序。从用户应用的角度而言提供了两种消费形式：拉取式消费（PullConsumer）、推动式消费（PushConsumer）。

• 理解成RocketMQ本身。
• broker主要用于producer和consumer接收和发送消息。
• broker会定时向nameserver提交自己的信息。
• 是消息中间件的消息存储、转发服务器。
• 每个Broker节点，在启动时，都会遍历NameServer列表，与每个NameServer建立长连接，注册自己的信息，之后定时上报。
• 消息中转角色，负责存储消息、转发消息。代理服务器在RocketMQ系统中负责接收从生产者发送来的消息并存储、同时为消费者的拉取请求作准备。代理服务器也存储消息相关的元数据，包括消费者组、消费进度偏移和主题和队列消息等。

• 理解成zookeeper的效果，只是他没用zk，而是自己写了个nameserver来替代zk。
• 底层由netty实现，提供了路由管理、服务注册、服务发现的功能，是一个无状态节点。
• nameserver是服务发现者，集群中各个角色（producer、broker、consumer等）都需要定时向nameserver上报自己的状态，以便互相发现彼此，超时不上报的话，nameserver会把它从列表中剔除。
• nameserver可以部署多个，当多个nameserver存在的时候，其他角色同时向他们上报信息，以保证高可用。
• NameServer集群间互不通信，没有主备的概念。
• nameserver内存式存储，nameserver中的broker、topic等信息默认不会持久化，所以他是无状态节点

• 消息系统所传输信息的物理载体，生产和消费数据的最小单位，每条消息必须属于一个主题。
• RocketMQ中每个消息拥有唯一的Message ID，且可以携带具有业务标识的Key。系统提供了通过Message ID和Key查询消息的功能。
• Message发送或者消费的时候必须指定Topic。

• 表示一类消息的集合，每个主题包含若干条消息，每条消息只能属于一个主题，是RocketMQ进行消息订阅的基本单位。
• 消息的逻辑分类，发消息之前必须要指定一个topic才能发，就是将这条消息发送到这个topic上。消费消息的时候指定这个topic进行消费。就是逻辑分类。

• Tag 是 Topic 的进一步细分，顾名思义，标签。每个发送的时候消息都能打tag，消费的时候可以根据tag进行过滤，选择性消费。
• 用于同一主题下区分不同类型的消息。
• 来自同一业务单元的消息，可以根据不同业务目的在同一主题下设置不同标签。标签能够有效地保持代码的清晰度和连贯性，并优化RocketMQ提供的查询系统。
• 消费者可以根据Tag实现对不同子主题的不同消费逻辑，实现更好的扩展性。

• 同一类Producer的集合。
• 这类Producer发送同一类消息且发送逻辑一致。
• 如果发送的是事务消息且原始生产者在发送之后崩溃，则Broker服务器会联系同一生产者组的其他生产者实例以提交或回溯消费。

• 同一类Consumer的集合。
• 这类Consumer通常消费同一类消息且消费逻辑一致。
• 消费者组使得在消息消费方面，实现负载均衡和容错的目标变得非常容易。
• 要注意的是，消费者组的消费者实例必须订阅完全相同的Topic。
• RocketMQ 支持两种消息模式：集群消费（Clustering）和广播消费（Broadcasting）。