篇章二 需求分析（一）

目录

1.知名MQ

2.需求分析

2.1 核心概念

2.2 生产者消费者模型的类别

2.3 BrokerServer 内部的关键概念（MQ）

1.虚拟主机（Virtual Host）

2.交换机（Exchange）

3.队列（Queue）

4.绑定（Binding）

5.消息（Message）

2.4 结构图

---

1.知名MQ

这么有用的组件，很显然市面上出现了不少：

1.RabbitMQ：

2.Kafka

3.RocketMQ

4.ActiveMQ

这些MQ都大同小异

关于MQ的使用，很显然不是我们的重点，具体介绍后续会开栏目进行讲解。我们的目的是如何模拟实现出来一个。

2.需求分析

2.1 核心概念

参考RabbitMQ，首先来让我们了解一些贯穿项目的核心概念：

1.生产者（Producer）

2.消费者（Consumer）

3.中间人（Broker）

4.发布（Publish）  生产者向中间人投递消息的过程

5.订阅（Subscribe）哪些消费者要从中间人取数据，这个注册的过程，成为“订阅”

6.消费（Consume）消费者从中间人这里取数据的动作：

举个栗子：

我要定一个期刊

1.生产者：作者

2.中间人：书店老板

3.消费者：我

4.发布： 作者写出新的期刊，交给书店老板

5.订阅：提前和书店老板说好，我要定好几个月的期刊，把钱给了老板

6.消费：我从书店老板那里拿走期刊

2.2 生产者消费者模型的类别

此时我们要用的模型是生产者消费者类型，但是它具体有哪些类别呢？

生产者 vs 消费者

1. 1 vs 1

2. N vs N

2.3 BrokerServer 内部的关键概念（MQ）

1.虚拟主机（Virtual Host）

        类似于 我们熟悉的MySQL 中的 database，算是一个“逻辑”上的数据集合。

        一个BrokerServer 上也可以组织多种不同类别的数据，可以使用 Virtual Host做出逻辑上的区分

        实际开发中，一个BrokerServer可能会同时用来管理多组 业务线上的数据，就可以使用 Virtual Host 做出区分。

业务线的简单理解：

        百度可以搜索图片、网页、新闻等，有很多不同的子版块 ，每个子版块都可以视为一个单独的业务线

2.交换机（Exchange）

        生产者把消息投递给Broker Server 实际上，是先把消息给了 Broker Server上的某个交换机，再由交换机把消息转发给对应的队列

简单理解：类似于公司前台

3.队列（Queue）

        真正用来存储消息的实体。后续消费者也是从对应的队列取数据。一个大的消息队列可以有很多具体的小队列。

4.绑定（Binding）

把交换机和队列之间，建立起关联关系。

可以把交换机 和 队列 视为是类似于 数据库 中的“多对多”这样的关系。

一个交换机可以对应多个队列

一个队列也可以被多个交换机对应

在数据库中，表示多对多的关系，会使用一个中间表/关联表。

所以，在MQ中，也有一个这样的中间表，所谓的绑定就是中间表中的一项。

5.消息（Message）

简单理解：服务器A 给 服务器B 发的请求（通过MQ转发），就是一个消息。

当然，服务器B 给 服务器A 回的响应（通过MQ转发），也是一个消息。

一个消息，可以视为一个字符串（二进制数据）。

消息中具体包含什么由程序员决定。

2.4 结构图

所以我们参考RabbitMQ，结合上面的一些核心概念来画出我们的结构图

如果想看RabbitMQ的结构图

RabbitMQ 是一个高性能、高可靠的消息中间件，支持多种消息协议（如 AMQP、STOMP、MQTT 等），能够实现应用程序之间的异步通信、负载均衡、解耦等功能。它由 Erlang 语言编写，具有良好的高可用性和扩展性。

如果想了解AMQP协议

AMQP（Advanced Message Queuing Protocol）是一种高级消息队列协议，广泛用于构建可靠的消息中间件。