消息队列的介绍

ゝ一纸荒年。 2024-03-26 04:35 114阅读 0赞

### 1.什么时候会用到消息队列？ ###

公司本身业务小，可以做单体的，但是后面业务体量不断扩大，采用**[微服务][Link 1]的设计思想**，**分布式的部署方式**，所以拆分了很多的服务，随着体量的增加以及业务场景越来越复杂了，很多场景单机的[技术栈][Link 2]和中间件以及不够用了，而且对系统的友好性也下降了，最后做了很多技术选型的工作，此时就需要引入**消息队列中间件**。

### 2.什么是消息队列？ ###

**消息队列**：在消息的传输过程中保存消息的容器。

> **队列**的主要目的是**提供路由并保证消息的传递**；如果发送消息时接收者不可用，[消息队列][Link 3]会**保留消息**，**直到**可以**成功地传递它**。

提到消息队列就要想到**异步、削峰、解耦 ，**就像是提到面向对象会想到封装，继承，多态一样，形成条件反射的那种┗|｀O′|┛ 奥~~

接下来一步步的说做异步，削峰，解耦

### **3.异步处理** ###

**场景：**我们在进行淘宝购物的时候，平时的购物流程都是

![893e7b1e39cc4c8280e95d8ab66212fd.png][]

中间只会有是支付处理占用时间

当然这样的流程在我们的生活中被应用的已经是少数的了~

我们在进行购物的时候不只是会有下单系统，还会出现积分系统，短信通知系统，优惠券系统等等。。。

这个时候我们就需要用到**异步处理**，这是为什么呢，请看下图

![9143631490214d95b7d4461049697b6a.png][]

假如支付本来100ms可以完成的事，同步处理的话现在这样的流程下来是不是需要500ms

等我用你的软件买下来黄花菜都凉了~

更何况实际的购物流程列举出来的还要多~ o(\*￣▽￣\*)o

> 上面的流程其实可以**同时做**的呀，你支付成功后，我去校验优惠券的同时我可以去增减积分啊，还可以同时发个短信啊。

![a704e3f7dbc04e0bbf90d05753286f5a.png][]

这样就可以优化速度啦~

在此我的下意识感觉可以用线程，线程池，阿西吧实际上这种下意识**是错误滴**

一个订单流程，扣积分，扣优惠券，发短信，扣库存。。。等等这么多业务要调用这么多的接口，**每次加一个你要调用一个接口然后还要重新发布系统**，写一次两次还好，写多了系统不崩人先崩了，这样的情况不出错还好，出错就是跟bug地老天荒。既然用到了消息队列，就不能跟bug地老天荒，接下来就是

### 4.应用解耦 ###

你下单了，你就把**支付成功的消息告诉别的系统**，他们收到了去处理就好了，只用走完自己的流程，把自己的消息发出去，那后面要接入什么系统简单，直接订阅你发送的支付成功消息，你支付成功了我**监听就好了**。只要自己的流程是成功的就好，管别人的咋样呢bug漫天飞也不影响你嘞~

这是消息队列的缺点一致性问题、如何保证消息不被重复消费，如何保证保证消息可靠传输。

![cd4362815fbc4e8d8a8f73d3e6517fb8.png][]

### 5. 流量削锋 ###

应用场景：秒杀活动，一般会因为流量过大，导致流量暴增，应用挂掉。为解决这个问题，一般需要在应用前端加入消息队列。

*  可以控制活动的人数
 *  可以缓解短时间内高流量压垮应用
 *  用户的请求，服务器接收后，首先写入消息队列。假如消息队列长度超过最大数量，则直接抛弃用户请求或跳转到错误页面
 *  秒杀业务根据消息队列中的请求信息，再做后续处理

### 6.MQ选型对比文档 ###

![753b5aea1e0b47cd880dedd25d29288f.png][]

关于选择那个去做消息队列就看具体的需求啦~

[Link 1]: https://www.zhihu.com/search?q=%E5%BE%AE%E6%9C%8D%E5%8A%A1&search_source=Entity&hybrid_search_source=Entity&hybrid_search_extra=%7B%22sourceType%22%3A%22answer%22%2C%22sourceId%22%3A1021886547%7D
[Link 2]: https://www.zhihu.com/search?q=%E6%8A%80%E6%9C%AF%E6%A0%88&search_source=Entity&hybrid_search_source=Entity&hybrid_search_extra=%7B%22sourceType%22%3A%22answer%22%2C%22sourceId%22%3A1021886547%7D
[Link 3]: https://so.csdn.net/so/search?q=%E6%B6%88%E6%81%AF%E9%98%9F%E5%88%97&spm=1001.2101.3001.7020
[893e7b1e39cc4c8280e95d8ab66212fd.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/26/a30e14fd8cd242c8aab8ad2179c63c9b.png
[9143631490214d95b7d4461049697b6a.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/26/5c90652d09d446e4a569c0836bc1fc28.png
[a704e3f7dbc04e0bbf90d05753286f5a.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/26/5dc5bdbde9464ecf8c195e7e25149241.png
[cd4362815fbc4e8d8a8f73d3e6517fb8.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/26/8da79f1c7d224677985ffaf6854c3d8d.png
[753b5aea1e0b47cd880dedd25d29288f.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/26/84e4d931575c42e38d7218653a28f4f1.png