RabbitMQ消息队列

Posted 2021-02-14 believepd

一、介绍

官方教程：https://www.rabbitmq.com/tutorials/tutorial-one-python.html

消息队列（Message Queue）是一种应用程序对应用程序的通信方式，应用程序通过读写出入队列的消息来通信。

消息发送后可以立即返回，由消息系统来确保消息的可靠传递。消息发布者只管把消息发布到 MQ 中而不用管谁来取，消息使用者只管从 MQ 中取消息而不管是谁发布的。这样发布者和使用者都不用知道对方的存在。

通俗理解消息队列：

生活中的消息队列，如同邮局的邮箱，如果没有邮箱的话，邮递员必须要"找到"接收邮件的人，递给他这封邮件，才算完成任务，可以想象这个过程是很麻烦、很慢、效率低下的；但是如果有了邮箱，邮件直接放进邮箱中，用户只需要去邮箱中找，看看有没有自己的邮件，有就拿走，没有就下次再来，这样就极大的提升了邮件的收发效率。

官方介绍：

RabbitMQ是一个消息代理：它接受和转发消息。您可以将其视为邮局：当您将要发布的邮件放在邮箱中时，您可以确定，邮递员最终会将邮件发送给您的收件人。在这个类比中，RabbitMQ是一个邮箱，邮局和邮递员。

二、在什么情况下会用消息队列?

2.1 电商订单

比如点外卖，点击下单后的业务逻辑可能包括：检查库存、生成单据、发红包、短信通知等，如果这些业务同步执行，完成下单率会非常低；如发红包，短信通知等不必要的流程，异步执行即可。此时使用MQ，可以在核心流程（扣减库存、生成订单记录）等完成后发送消息到MQ，快速结束本次流程。消费者拉取MQ消息时，发现发红包、短信通知等消息时，再进行处理。

场景：双11是购物狂节，用户下单后，订单系统需要通知库存系统。

传统的做法就是订单系统调用库存系统的接口：

缺点：

• 当库存系统出现故障时，订单就会失败。
• 订单系统和库存系统高耦合。

引入消息队列：

订单系统：用户下单后，订单系统完成持久化处理，将消息写入消息队列，返回用户订单下单成功。

库存系统：订阅下单的消息，获取下单消息，进行库存操作。就算库存系统出现故障，消息队列也能保证消息的可靠投递，不会导致消息丢失。

2.2 秒杀活动

流量削峰一般在秒杀活动中应用广泛。

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

作用：

1. 可以控制活动人数，超过此一定阀值的订单直接丢弃（为什么秒杀你抢不到，知道了吧）；
2. 可以缓解短时间的高流量压垮应用（应用程序按自己的最大处理能力获取订单）；
3. 用户的请求，服务器接收到之后，写入消息队列，超过定义的阈值就直接丢弃请求，或者跳转错误页面；
4. 业务系统取出队列中的消息，再做后续处理。

 

 

 

 

 

 

 

 

 

 

 

 

 

 

 

 

 

 

 

 

 

 

 

 

 

1