MQ消息队列应用研究

男娘i 2022-05-22 06:24 283阅读 0赞

**分布式项目中有一个框架基本是必不可少的，那就是消息队列（简称MQ）**。消息队列的话，我们项目中最经常用到就是两个功能，一个是MQ是几种消息发送接收模式（ **简单模式、工作模式、消息发布和订阅、\*路由模式、主题模式**）、另一个就是MQ的 **延时队列**。下面我针对具体的应用场景来介绍一下这两种功能。

**应用场景：**

**场景一：**项目不可避免的会有那种异步操作，比如项目中我们需要删除商品这个功能，可是因为关联的操作很多，所以是一个很耗时间的操作，这个时候我们就可以采用MQ来处理这个删除商品的功能，MQ的操作是异步的，所以用户点击删除的时候可以马上返回删除成功的提示，后台我们可以慢慢进行删除的操作。

**场景二：**项目中有一个活动要开始，但是时间并不是马上执行，而是过一段时间之后在开始执行。基于这种情况我们就可以采用MQ的延迟队列来实现了，通过设置消息发送的时间，就可以随意的让它在规定的时间内执行了。

**应用升级：**

**升级一：**因为很多耗时的工作都放在MQ上面异步执行，而且耗时的操作往往是非常重要的操作，所以肯定要保证MQ的高可用性，不然要是MQ突然挂掉，所有的走MQ的功能全部卡死了，这是非常恐怖的一件事情。基于这种情况，我们肯定必须将MQ也进行集群，来提高MQ系统的高可用性。这里的方案就是采用Kubernetes（k8s）来实现MQ的集群。我们可以部署多个MQ，然后通过k8s来进行负载均衡这些MQ。方案图如下所示：

![151_method_get-resource_shareToken_93795533414A41B0AEB795232F653937_entryId_200471640][]

**升级二：**这个时候MQ的安全性提升了，但是k8s还是存在挂掉的可能性，这边我们也可以对k8s进行集群，通过集群就可以完美的解决这个问题了。

想要更多干货、技术猛料的孩子，快点拿起手机扫码关注我，我在这里等你哦~

![70][]

[151_method_get-resource_shareToken_93795533414A41B0AEB795232F653937_entryId_200471640]: https://note.youdao.com/yws/api/group/76450073/noteresource/B36943D02F5C46E3B01DEB2FE45B5731/version/151?method=get-resource&shareToken=93795533414A41B0AEB795232F653937&entryId=200471640
[70]: /images/20220522/5adde01ecaac4047b14d50c431725fb6.png