# RocketMQ 概念
我在学习 RocketMQ
的时候,看到文档中介绍了很多的概念。我非常反感,但是又没有办法,没有这些概念,就没办法更好的去学习后面的内容,当后面使用很多名词来梳理实现原理的时候,就会一头雾水。
上一篇文章中,我们知道了 RocketMQ
由四部分构成。
# 消息模型
Producer
负责生产消息, Consumer
负责消费消息, Broker
负责存储消息, NameServer
负责对 Producer
和 Customer
的服务发现,还有路由这两个功能。 Broker
在实际部署过程中对应一台服务器,每个 Broker
可以存储多个 Topic
的消息,每个 Topic
的消息也可以分片存储于不同的 Broker
。 Message Queue
用于存储消息的物理地址,每个 Topic
中的消息地址存储于多个 Message Queue
中。 ConsumerGroup
由多个 Consumer
实例构成。
# 消息生产者(Producer)
负责生产消息,一般由业务系统负责生产消息。一个消息生产者会把业务应用系统里产生的消息发送到 broker
服务器。 RocketMQ
提供多种发送方式,同步发送、异步发送、顺序发送、单向发送。同步和异步方式均需要 Broker
返回确认信息,单向发送不需要。
# 消息消费者( Consumer
)
负责消费消息,一般是后台系统负责异步消费。一个消息消费者会从 Broker
服务器拉取消息、并将其提供给应用程序。从用户应用的角度而言提供了两种消费形式:拉取式消费 ( pull
)、推动式消费 ( push
)。
# 生产者组( Producer Group
)
同一类 Producer
的集合,这类 Producer
发送同一类消息且发送逻辑一致。如果发送的是事务消息且原始生产者在发送之后崩溃,则 Broker
服务器会联系同一生产者组的其他生产者实例以提交或回溯消费。
# 消费者组( Consumer Group
)
同一类 Consumer
的集合,这类 Consumer
通常消费同一类消息且消费逻辑一致。消费者组使得在消息消费方面,实现负载均衡和容错的目标变得非常容易。要注意的是,消费者组的消费者实例必须订阅完全相同的 Topic
。 RocketMQ
支持两种消息模式:集群消费( Clustering
)和广播消费( Broadcasting
)。
# 拉取式消费( Pull Consumer
)
Consumer
消费的一种类型,应用通常主动调用 Consumer
的拉消息方法从 Broker
服务器拉消息、主动权由应用控制。一旦获取了批量消息,应用就会启动消费过程。
# 推动式消费( Push Consumer
)
Consumer
消费的一种类型,该模式下 Broker
收到数据后会主动推送给消费端,该消费模式一般实时性较高。
# 主题( Topic
)
表示一类消息的集合,每个主题包含若干条消息,每条消息只能属于一个主题,是 RocketMQ
进行消息订阅的基本单位。
# 代理服务器( Broker Server
)
消息中转角色,负责存储消息、转发消息。代理服务器在 RocketMQ
系统中负责接收从生产者发送来的消息并存储、同时为消费者的拉取请求作准备。代理服务器也存储消息相关的元数据,包括消费者组、消费进度偏移和主题和队列消息等。
# NameServer
NameServer
充当路由消息的提供者。生产者或消费者能够通过名字服务查找各主题相应的 Broker IP
列表。多个 Nameserver
实例组成集群,但相互独立,没有信息交换。
# 集群消费( Clustering
)
集群消费模式下,相同 Consumer Group
的每个 Consumer
实例平均分摊消息。
# 广播消费( Broadcasting
)
广播消费模式下,相同 Consumer Group
的每个 Consumer
实例都接收全量的消息。
# 普通顺序消息( Normal Ordered Message
)
普通顺序消费模式下,消费者通过同一个消息队列( Topic
分区,称作 M essage Queue
) 收到的消息是有顺序的,不同消息队列收到的消息则可能是无顺序的。
# 严格顺序消息( Strictly Ordered Message
)
严格顺序消息模式下,消费者收到的所有消息均是有顺序的。
# 消息( Message
)
消息系统所传输信息的物理载体,生产和消费数据的最小单位,每条消息必须属于一个主题。 RocketMQ
中每个消息拥有唯一的 Message ID
,且可以携带具有业务标识的 Key
。系统提供了通过 Message ID
和 Key
查询消息的功能。
# 标签( Tag
)
为消息设置的标志,用于同一主题下区分不同类型的消息。来自同一业务单元的消息,可以根据不同业务目的在同一主题下设置不同标签。标签能够有效地保持代码的清晰度和连贯性,并优化 RocketMQ
提供的查询系统。消费者可以根据 Tag
实现对不同子主题的不同消费逻辑,实现更好的扩展性。
这是一篇极为枯燥的文章。从下篇文章开始,我们开始对 RocketMQ
进行实践。从零搭建 RocketMQ
集群.
# 最后
希望和你一起遇见更好的自己