RabbitMq (一）理论篇部分 MQ作用是什么 MQ的优缺点 RabbitMQ的基础架构 RabbitMQ 五种常用工作模式 RabbitMQ消息确认机制

曾经终败给现在 2022-09-09 09:12 154阅读 0赞

本次的内容是rabbitmq，写这个专题的目的是为了更好的巩固和自我总结，因为暂时工作中是用不到的，所以也是希望自己下次在使用时，也能够借助文章轻松回顾，更快地着手应用。因为个人是第一次提及mq相关的内容，因此也会简单地介绍mq的相关特点。  
如果理论部分，你比较清楚了，就想知道怎么快速跑起来，那么看这里吧[RabbitMQ（二）实践篇 动手理解RabbitMQ五种模式][RabbitMQ_ _RabbitMQ]

### 文章目录 ###

*  一、MQ的基本概念
 *   *  1.1概述
     *  1.2削峰填谷
     *  1.3异步提速
     *  1.4MQ的劣势
 *  二、RabbitMQ
 *   *  2.1简介
     *  2.2基础架构
     *  2.3 五种常用工作模式
     *  2.4 RabbitMQ消息确认机制
 *  下一章

--------------------

# 一、MQ的基本概念 #

## 1.1概述 ##

Message Queue（消息队列），是在消息的传输过程中保存消息的容器（中间件）。  
![在这里插入图片描述][251e39f68d41457aafc5591aa7fab114.png]  
其过程是A系统只管将需要其他系统例如B系统处理的请求发到MQ中  
B系统也只管去MQ中寻找需要自己处理的请求  
这样做的好处

## 1.2削峰填谷 ##

服务器同时处理请求的数量是有限的，如果cpu超负荷，服务宕机后果严重。此时把请求放到队列中等待，达到削峰的目的。波峰过后渐渐处理滞留的请求，达到提升系统稳定性的目的。  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAVF9BbnRyeQ_size_20_color_FFFFFF_t_70_g_se_x_16]

## 1.3异步提速 ##

一个订单完成下单，需要处理库存，支付，物流，加起来需要九百多毫秒。把任务拆分完分给不同的系统处理，就可以大大减少时间。单位时间内就可以处理更多的数目。  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAVF9BbnRyeQ_size_20_color_FFFFFF_t_70_g_se_x_16 1]  
有优点，自然也会带来缺点，老天总是公平的

## 1.4MQ的劣势 ##

*  系统可用性降低  
    系统看似解耦了，但是各个系统都和MQ手拉手。MQ一旦宕机，大家都跑不动了。
 *  系统复杂度提高  
    MQ的加入大大增加了系统的复杂度，因为引入了MQ后是异步调用，就有顺序，数据丢失等问题需要解决。

# 二、RabbitMQ #

## 2.1简介 ##

*  基于AMQP网络协议的消息中间件（Adcanced Message Queuing Protocol高级消息队列协议）
 *  RabbitMQ是采用Erlang语言开发的（Erlang语言是由Ericson设计，专门为高并发和分布式系统的一种语言）

## 2.2基础架构 ##

通过一张图了解rabbitMQ的大体架构

*  server内部有很多个虚拟机。
 *  外部生产者（Producer）都是连接（connect）到指定虚拟机的指定交换机。
 *  外部消费者（Consumer）都是连接到指定虚拟机的指定队列中。
 *  交换机（Exchange）和队列（Queue）都有绑定关系  
    ![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAVF9BbnRyeQ_size_20_color_FFFFFF_t_70_g_se_x_16 2]  
    **RabbitMQ中的相关概念：**
 *  Broker : 接收和分发消息的应用，RabbitMQ Server就是 Message Broker

我特地百度翻译了一下Broker  
![在这里插入图片描述][a6178998240f442b970e6d4417b3fde0.png]

*  Virtual host : 出于多租户的安全因素设计的， 当多个不同的用户使用同一个MQ server提供服务时，可以花费出多个虚拟机，每个用户在自己的虚拟机创建交换机等。就像mysql可以创建不同的数据库一样，每个库都有自己的表。
 *  Connection ：消费者/提供者和broker之间建立的TCP连接
 *  Channel ：如果每次访问Broker，都建立一次连接，在消息量大的时候建立TCP Connection的开销僵尸巨大的，效率也很低。Channel是connection内部建立的逻辑连接，多线程应用通常每个thread创建单独的channel进行通讯。AMQP method 包含了 channel id 帮助客户端和message broker识别channel，所以channel之间也是完全隔离的。channel作为轻量级连接，极大减少了操作系统建立TCP连接的开销。
 *  Exchange：message到达exchange，根据分发规则，匹配查询表中的routing key，分发到queue中去，常用的类型有direct（point-to-point），topic（publish-subscribe）和fanout（multicast）
 *  Queue：消息在这里等待被取走
 *  Binding：exchange和queue之间的虚拟连接，bingding中可以包含routing key。Binding信息被保存到exchange中的查询表。

## 2.3 五种常用工作模式 ##

**（一）简单模式**  
![在这里插入图片描述][fbdc66fb6fef4a5caa4b8c9c8ccc05aa.png]  
P:生产者C：消费者 queue：图中红色部分，生产者向其投递消息，消费者从中取出消息

**（二）Work Queues工作队列模式**  
![在这里插入图片描述][b10b9bcac49c4e35a41973790bdc7204.png]  
与简单模式相似，多了一个或多个消费者，多个消费者共同消费同一个队列中的消息

**（三）发布与订阅模式**  
![在这里插入图片描述][ef3cfd6dd0a644f0a4bcf090581018d2.png]

这里出现了交换机的概念，前面两种模式不是没有交换机，只是使用了默认交换机  
**交换机：**

*  接收生产者发送的消息
 *  投递给对应的队列

交换机一共有三种类型：

*  fanout：广播，将消息缴费所有绑定到交换机的队列
 *  Direct：定向，把消息交给符合指定routing key的队列
 *  Topic：通配符，把消息交给符合routing pattern（路由模式）的队列
 *  注意，交换机只负责转发，不负责存储，如果没有找到要发送的队列，那么消息会丢失

**（四）路由模式**  
![在这里插入图片描述][e98dc3b3b7d248d2a8bf2177d287f1c5.png]

*  队列越交换机的绑定，不是任意绑定，要指定一个RoutingKey（路由Key）
 *  消息发送给交换机，也必须指定消息的RoutingKey
 *  交换机不会交给每一个绑定的队列，二十根据RoutingKey判断，只有队列的RoutingKey和消息的RoutingKey完全一致，才会接收到消息

**（五）通配符模式**  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAVF9BbnRyeQ_size_20_color_FFFFFF_t_70_g_se_x_16 3]

*  Topic类型与Direct相比，都是通过RoutingKey把消息路由到不同的队列，只不过Topic类型Exchange可以让队列在绑定Routing key的时候使用**通配符**！
 *  RoutingKey一般是有一个或多个单词组成，用“.”分割。
 *  通配符规则：\#匹配一个或多个词，\*匹配恰好一个词

![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAVF9BbnRyeQ_size_20_color_FFFFFF_t_70_g_se_x_16 4]  
例如：

*  红色Queue：绑定的是usa.\#，因此以usa.开头的routing key 都会被匹配到
 *  黄色Queue：绑定的是\#.news，因此凡是以.news结尾的routing key 都会被匹配到

## 2.4 RabbitMQ消息确认机制 ##

RabbitMQ在消息传递的过程中，充当了代理人（Broker）的角色，那生产者（Producer）怎样知道消息被正确投递了呢？

*  RabbitMQ提供了监听器（Lisener）来接收消息投递的状态。
 *  消息确认有两种状态：Confirm和Return
 *  Comfirm代表生产者将消息送到Broker时产生的状态，后续会出现两种情况
    
     *  ack 代表Broker已经将数据接收
     *  nack 代表Broker拒收消息。
 *  Return代表被Broker正常接收（ack）后，但Broker没有对应的队列进行投递时产生的状态，消息被退回给生产者
 *  这两种状态只是生产者和Broker之间的关系，与是否消费无关

# 下一章 #

[RabbitMQ（二）实践篇 动手理解RabbitMQ五种模式][RabbitMQ_ _RabbitMQ]

[RabbitMQ_ _RabbitMQ]: https://blog.csdn.net/qq_39150049/article/details/120030406?spm=1001.2014.3001.5501
[251e39f68d41457aafc5591aa7fab114.png]: /images/20220829/f95de06e1b9d404c98ef5f3e539eab0f.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAVF9BbnRyeQ_size_20_color_FFFFFF_t_70_g_se_x_16]: /images/20220829/cd0ae967e51848da8a3e362a2e62e787.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAVF9BbnRyeQ_size_20_color_FFFFFF_t_70_g_se_x_16 1]: /images/20220829/1833199b97af43cc96514aff498eb952.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAVF9BbnRyeQ_size_20_color_FFFFFF_t_70_g_se_x_16 2]: /images/20220829/ec96e709657c4ac38768a0c1b846bded.png
[a6178998240f442b970e6d4417b3fde0.png]: /images/20220829/ad19fd94154c4c1ebc1546db02e07b5e.png
[fbdc66fb6fef4a5caa4b8c9c8ccc05aa.png]: /images/20220829/638dd3c8d48046ef8bf70fc7b423210b.png
[b10b9bcac49c4e35a41973790bdc7204.png]: /images/20220829/f36a3f8cabbc4062a104a8f6732ff769.png
[ef3cfd6dd0a644f0a4bcf090581018d2.png]: /images/20220829/44d96586a8d541e1b8aa3afb27c4cfcb.png
[e98dc3b3b7d248d2a8bf2177d287f1c5.png]: /images/20220829/535a7088b7434fbf951b695aa85ff0a8.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAVF9BbnRyeQ_size_20_color_FFFFFF_t_70_g_se_x_16 3]: /images/20220829/150f454c01bc4d99a62d7f07b23d0fd2.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAVF9BbnRyeQ_size_20_color_FFFFFF_t_70_g_se_x_16 4]: /images/20220829/87fd5e7250d042139e64c4efd6d354cc.png