吃透 MQ 系列之核心

考虑哪些问题?又有哪些技术挑战?

有了这个基础后，我相信后面几篇文章再讲 Kafka 和 RocketMQ 这两种具体的消息中间件时，大家能很快地抓住主脉络，同时分辨出它们各自的特点。

对于 MQ 来说，不管是 RocketMQ、Kafka 还是其他消息队列，它们的本质都是：一发一存一消费。下面我们以这个本质作为根，一起由浅入深地聊聊 MQ。

01 从 MQ 的本质说起

将 MQ 掰开了揉碎了来看，都是「一发一存一消费」，再直白点就是一个「转发器」。

生产者先将消息投递一个叫做「队列」的容器中，然后再从这个容器中取出消息，最后再转发给消费者，仅此而已。个图便是消息队列最原始的模型，它包含了两个关键词：消息和队列。

1、消息：就是要传输的数据，可以是最简单的文本字符串，也可以是自定义的复杂格式(只要能按预定格式解析出来即可)。

2、队列：大家应该再熟悉不过了，是一种先进先出数据结构。它是存放消息的容器，消息从队尾入队，从队头出队，入队即发消息的过程，出队即收消息的过程。

02 原始模型的进化

再看今天我们最常用的消息队列产品(RocketMQ、Kafka 等等)，你会发现：它们都在最原始的消息模型上做了扩展，同时提出了一些新名词，比如：主题(topic)、分区(partition)、队列(queue)等等。

要彻底理解这些五花八门的新概念，我们化繁为简，先从消息模型的演进说起(道理好比：架构从来不是设计出来的，而是演进而来的)

2.1 队列模型

最初的消息队列就是上一节讲的原始模型，它是一个严格意义上的队列(Queue)。消息按照什么顺序写进去，就按照什么顺序读出来。不过，队列没有 “读” 这个操作，读就是出队，从队头中 “删除” 这个消息。

（编辑：开发网_郴州站长网）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!