RabbitMQ系列【2】核心概念

忘是亡心i 2024-04-01 17:39 80阅读 0赞

> **有道无术，术尚可求，有术无道，止于术。**

#### 文章目录 ####

*   *  核心概念
     *   *  Producer（生产者）
         *  Connection（连接）
         *  Channel（信道）
         *  Broker（服务端）
         *  Virtual host（虚拟主机）
         *  Exchange（交换机）
         *  Queue（队列）
         *  Binding（绑定）
         *  Routing Key（路由键）
         *  Consumer（消费者）

### 核心概念 ###

**RabbitMQ的工作模型如下图所示**：  
![在这里插入图片描述][f9dffbff8536438d9952ca3eceb12670.png]  
涉及到`RabbitMQ的`核心概念：**Producer（生产者）、Connection（连接）、Channel（信道）、Exchange（交换机）、Queue（队列）、Virtual host（虚拟主机）、Consumer（消费者）、Routing Key（路由键）、Binding（绑定）等。**

#### Producer（生产者） ####

产生数据发送消息的程序是`生产者（Producer）`。

#### Connection（连接） ####

每个生产者或者消费者要通过`RabbitMQ`发送与消费消息，首先就要与`RabbitMQ`建立连接，这个连接就是`Connection`，这是一个`TCP`长连接。

#### Channel（信道） ####

如果每一次访问`RabbitMQ`都建立一个`Connection`，在消息量大的时候建立 `TCP 连接`的开销将是巨大的，效率也较低，在系统访问流量高峰时，会严重影响系统性能。

`Channel（信道）`是在`Connection`内部建立的逻辑连接，如果应用程序支持多线程，通常每个线程创建单独的`channel`进行通讯， channel 之间是完全隔离的。`Channel`作为轻量级的`Connection` 极大减少了操作系统建立`TCP connection`的开销 。

`RabbitMQ`中大部分的操作都是使用`Channel`完成的，比如：声明`Queue`、声明`Exchange`、发布消息、消费消息等。

#### Broker（服务端） ####

`Broker（服务端）`接收和分发消息的应用，`RabbitMQ Server`（服务端） 就是 `Message Broker`。

#### Virtual host（虚拟主机） ####

`Virtual host`是一个虚拟主机的概念，一个`Broker`中可以有多个虚拟主机。

出于多租户和安全因素设计的，把 `AMQP` 的基本组件划分到一个虚拟的分组中，类似于网络中的命名空间概念。

当多个不同的用户使用同一个`RabbitMQ server` 提供的服务时，可以划分出多个`vhost`，每个用户在自己的 `vhost`创建 `exchange／queue`等，很好地做到了不同用户之间相互隔离的效果。

#### Exchange（交换机） ####

`交换机`是 `RabbitMQ`非常重要的一个部件，一方面它接收来自生产者的消息，另一方面它将消息推送到队列中。交换机必须确切知道如何处理它接收到的消息，是将这些消息推送到特定队列还是推送到多个队列，亦或者是把消息丢弃，这个由交换机类型决定。

交换机有4种类型：`direct、fanout、topic、headers`。

#### Queue（队列） ####

队列是`RabbitMQ` 内部使用的一种数据结构，尽管消息流经`RabbitMQ`和应用程序，但它们只能存储在队列中。队列仅受主机的内存和磁盘限制的约束，本质上是一个大的消息缓冲区。许多生产者可以将消息发送到一个队列，许多消费者可以尝试从一个队列接收数据。

#### Binding（绑定） ####

`Binding（绑定）`是指交换机和队列之间的虚拟连接，绑定信息被保存到交换机中的查询表中，用于消息的分发依据。

#### Routing Key（路由键） ####

创建好`Exchange`和`Queue`之后，需要使用`Routing key（或者叫做Binding key）`将它们绑定起来，生产者在向交换机发送一条消息的时候，必须指定一个`Routing key`，然后交换机接收到这条消息之后，会解析`Routing key`，然后根据`Exchange`和`Queue`的绑定规则，将消息分发到符合规则的`Queue`中。

#### Consumer（消费者） ####

接受消息并进行消费的程序是`Consumer（消费者）`。

[f9dffbff8536438d9952ca3eceb12670.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/01/d891e58025614776a1f95e6438274744.png