消息队列的作用有哪些

本篇内容介绍了“消息队列的作用有哪些”的有关知识，在实际案例的操作过程中，不少人都会遇到这样的困境，接下来就让小编带领大家学习一下如何处理这些情况吧！希望大家仔细阅读，能够学有所成！

流量削峰

消息队列，其实并不是什么深奥的东西，类似这次我们的国庆出行，许多的景区都会出现人满为患，到处都是人从众的现象，这个时候，景区是怎么解决问题的呢?通常就是排队限流了，在检票处设一个等待区域，如果景区里面的人太多，那么就在售票处设立一个等待区，让游客进行排队，  等景区出来一些游客后，再放一批游客进去。

现实的生产环境也是如此，在生产环境中，每个系统的容量是不一样的，核心系统或者简单的系统吞吐量往往比较大，非核心系统与复杂系统往往吞吐量比较低。举个例子，在电商系统中，我们经常要对用户行为进行数据上报，相对于用户浏览、交易等行为，数据上报显得并不那么重要，所以支撑数据上报的系统性能往往是不如核心功能的。

在一些流量的高峰，例如双十一大促，我们一般不会对这种上报系统进行扩容，这个时候，同步的进行数据上报容易引发雪崩，应对这种情况，我们可以把用户行为数据的写入放入异步队列，可以根据数据的写入速度进行消费，从而保证系统的鲁棒性。

系统解耦

当我们开始开发一个系统的时候，逻辑总是比较清晰跟简单，随着需求的迭代，系统会变得越来越复杂，举个简单的例子，原先我们进行一次交易的时候，可能交易系统可能只是践行简单的库存扣减，然后写入订单。随着功能的迭代，我们需要通知广告系统、第三方的卖家的话、需要通知商家系统等等，像阿里巴巴，每发生一次简单的交易行为之后，可能需要通知数十个不同的业务方进行处理。

这些增加的逻辑，假如我们都做在交易系统的话，就会发现交易系统会变得越来越臃肿不堪，而且会难以保证数据的一致性。假如成单之后，通知广告系统失败了(例如网络波动)，那么，这次交易行为是否还要进行下去呢，通知广告系统这种可能失败了就算了，要是通知商家系统失败了呢?数据不一致可能会给公司带来投诉与资损，后期开发要花大量的时间进行数据修复。

消息队列，是一种更简单又更可靠的方法。当我们成功完成一次交易行为之后，我们生产一条消息，所有的业务方都来消费这条消息，由业务方自己来保证成功消费。这样子，交易系统就不用关心交易行为的后续动作，大大减少了交易系统的复杂性。

延迟与异步

这样的场景在电商系统是非常常见的，用户创建一次订单之后，可能没有支付，我们可以在创建订单25分钟之后去提醒用户，告诉他有笔订单未支付，从而提高转化率。假如让你来实现这个功能，那么你要怎么做呢?

我们可以使用一个定时任务，每分钟都去扫描数据库，把未支付的订单扫出来，然后通知用户进行支付。这也是一个不错的方法，但是，一个可靠的定时任务的难点这里就不进行赘述了，我们今天来介绍另外一个方法，那就是消息队列。

一些消息队列提供了延迟队列功能，例如RabbitMQ，我们可以利用其延迟的特性，非常简单地实现这个功能。当用户下单的时候，我们发布一个延迟消息，等到消费的时候，再去查询订单的状态，后面，我们会单独讲消息队列延迟是如何保证可靠性的。

“消息队列的作用有哪些”的内容就介绍到这里了，感谢大家的阅读。如果想了解更多行业相关的知识可以关注亿速云网站，小编将为大家输出更多高质量的实用文章！