高并发架构设计(二)—消息队列应用场景和注意事项

发布时间：2025-11-05 03:58:23 来源：云智核 作者：人工智能

 消息队列中间件是高并构设分布式系统中重要的组件之一，在高并发的发架系统中是更是必不可少的，主要解决应用耦合，计消景和异步消息，息队流量削锋等问题。用场实现高性能、注意高可用、事项可伸缩和最终一致性架构。高并构设使用较多的发架消息队列有ActiveMQ、RabbitMQ、计消景和Kafka、息队RocketMQ。用场今天讲讲消息队列在高并发系统中的注意具体应用场景和注意事项

一、什么是事项消息队列

我们可以把消息队列看作是一个存放消息的容器，当我们需要使用消息的高并构设时候，直接从容器中取出消息供自己使用即可。

队列Queue是一种先进先出的数据结构，所以消费消息时也是按照顺序来消费的。服务器托管

二、为什么要使用消息队列

通常来说，使用消息队列能为我们的系统带来下面三点好处：

2.1、异步处理

同步处理过程

异步处理过程

将用户的请求数据存储到消息队列之后就立即返回结果。随后，系统再对消息进行消费。因为用户请求数据写入消息队列之后就立即返回给用户了，但是请求数据在后续的业务校验、写数据库等操作中可能失败。因此，使用消息队列进行异步处理之后，需要适当修改业务流程进行配合，比如用户在提交订单之后，订单数据写入消息队列，不能立即返回用户订单提交成功，需要在消息队列的订单消费者进程真正处理完该订单之后，甚至出库后，再通过电子邮件或短信通知用户订单成功，以免交易纠纷。这就类似我们用手机订火车票和电影票。

2.2 流量削峰

先将短时间高并发产生的事务消息存储在消息队列中，然后后端服务再慢慢根据自己的能力去消费这些消息，b2b供应网这样就避免直接把后端服务打垮掉。

例如：在电子商务一些秒杀、促销活动中，合理使用消息队列可以有效抵御促销活动刚开始大量订单涌入对系统的冲击。如下图所示：

2.3 应用解耦

使用消息队列还可以降低系统耦合性。我们知道如果模块之间不存在直接调用，那么新增模块或者修改模块就对其他模块影响较小，这样系统的可扩展性无疑更好一些。

假设有这样的一个场景：A系统发送数据到B、C、D三个系统，通过接口调用发送。如果E系统也要这个数据呢?那如果C系统现在不需要了呢?A系统负责人几乎要改到崩溃......

在这个场景中，A 系统跟其它各种乱七八糟的系统严重耦合，A系统产生一条比较关键的数据，很多系统都需要A系统将这个数据发送过来。A系统要时时刻刻考虑B、C、D、E四个系统如果挂了该怎么办?要不要重发，要不要把消息存起来?头发都白了啊!

如果使用MQ，A系统产生一条数据，发送到MQ里面去，哪个系统需要数据自己去MQ里面消费。如果新系统需要数据，直接从MQ里消费即可;如果某个系统不需要这条数据了，就取消对MQ消息的消费即可。IT技术网这样下来，A系统压根儿不需要去考虑要给谁发送数据，不需要维护这个代码，也不需要考虑人家是否调用成功、失败超时等情况。如下图所示：

生产者(客户端)发送消息到消息队列中去，接受者(服务端)处理消息，需要消费的系统直接去消息队列取消息进行消费即可而不需要和其他系统有耦合， 这显然也提高了系统的扩展性。

消息队列是用发布-订阅模式工作，消息发送者(生产者)发布消息，一个或多个消息接受者(消费者)订阅消息。 从上图可以看到消息发送者(生产者)和消息接受者(消费者)之间没有直接耦合，消息发送者将消息发送至分布式消息队列即结束对消息的处理，消息接受者从分布式消息队列获取该消息后进行后续处理，并不需要知道该消息从何而来。对新增业务，只要对该类消息感兴趣，即可订阅该消息，对原有系统和业务没有任何影响，从而实现系统业务的可扩展性设计。

三、使用消息队列带来的一些问题

四、常用消息队列对比

市面上有很多MQ产品，主流的就是Kafka、ActiveMQ、RabbitMQ、RocketMQ这四种，但是我们在做技术选型的时候该用哪一个呢?每一个MQ没有绝对的好坏，就是看用在哪个场景可以扬长避短，利用其优势，规避其劣势。

总结：

相关文章