【消息队列】01 为什么需要消息队列 — 解耦、异步、削峰

mq 的作用有哪些？缺点有什么？ 我们大家都知道作用有解耦、接口异步处理、流量削峰，那么我这里来举例说明下这3个概念分别是什么。 解耦 首先我们看下耦合较高的情况，谁愿意负责A系统？难道被累死么？ 负责A系统的大兄弟自作主张引入MQ消息队列后，我管你老王、老张还是老李要什么数据，我放在MQ中，你们要就从MQ中拿，别来烦我、 接口异步处理 首先来看下没有引入MQ时候，假设打开一个网页随意...

有一个观点已经被说烂了：使用 MQ 可以帮助业务系统解耦。 想法很简单，在业务状态流转时，如果没有 MQ，那么其它系统想要知道状态变了，那就需要核心流程系统去主动做通知。 比如电商系统里订单从创建到处理中状态切换了，客服系统需要知道，风控系统需要知道，用户系统也需要知道。 这里的通知通过 RPC 来进行，下游系统需要的数据可以在这次 RPC 里携带上，也可以在请求的时候让下游系统自己去查。 下游系统增加的时候，核心业务的代码也需要修改，比如新做了一个积分系统，现在订单状态流转积分系统也想知道。 核心系统

通过消息队列，我们可以实现异步处理，订单系统只需要发送消息到消息队列，然后立即返回响应给用户，而不需要等待库存系统的响应。消息队列充当了消息的中转站，生产者将消息发送到消息队列，消费者从消息队列中获取消息并进行处理。消息队列可以用于削峰填谷，即将请求暂时存储在消息队列中，然后按照系统处理能力逐渐消费消息，从而平滑处理高峰期的请求，避免系统崩溃或性能下降。当一个系统产生消息时，将消息发送到消息队列，其他系统可以订阅消息队列并接收消息，从而实现解耦。而通过消息队列，我们可以实现它们之间的解耦。

解耦，即降低系统间的耦合度，使得各个模块或系统能够独立地发展和变化，而不相互影响。在传统的系统架构中，模块间通常通过直接调用接口进行通信，这种紧耦合的方式导致系统难以扩展和维护。当某个模块发生变化时，可能会引发其他模块的连锁反应，增加了系统的复杂性和风险。

消息队列（MQ）在分布式系统中扮演着核心角色，通过异步通信、系统解耦和流量控制等特性，有效应对高并发场景下的数据流动挑战。MQ的核心优势包括异步处理、系统解耦和流量削峰，能够显著提升系统性能和稳定性。典型应用场景包括异步处理、流量削峰、数据同步、顺序消息和分布式事务等。MQ的选型需根据业务场景和数据可靠性需求进行决策，主流消息队列如Kafka、RocketMQ、RabbitMQ和Pulsar各有其适用场景和优势。

A、添加/移除 　　void queue::push(elemValue);　// 尾部添加 　　viud queue::pop();　　　　　　 // 尾部移除 B、随机存取 C、数据存取 　　T queue::back();　　// 能用于设置吗？ 　　T queue::front();　　// 能用于设置吗？ 1、构造函数 　　1.1、默认构造函数 ==>...

在前面章节，我们了解了高并发系统设计的三个目标：性能、可用性和可扩展性，而在提升系统性能方面，我们一直关注的是系统的查询性能。也用了很多的篇幅去讲解数据库的分布式改造，各类缓存的原理和使用技巧。究其原因在于，我们遇到的大部分场景都是读多写少，尤其是在一个系统的初级阶段。 比如说，一个社区的系统初期一定是只有少量的种子用户在生产内容，而大部分的用户都在“围观”别人在说什么。此时，整体的流量比较小，而写流量可能只占整体流量的百分之一，那么即使整体的 QPS 到了 10000 次 / 秒，写请求也只是到了每秒 1

队列接口Queue 用接口Queue表示队列这种数据结构，具体的实现因底层使用到的数据结构的不同而不同； public interface Queue<E> { int getSize(); boolean isEmpty(); void enqueue(E e); E dequeue(); E getFront(); } 数组队列A...

MQ消息队列的解耦、接口异步处理、削峰

应用场景 为什么使用消息队列(面试官看你思不思考) 其实就是问问你消息队列都有哪些使用场景，然后你项目里具体是什么场景，说说你在这个场景里用消息队列是什么？ 面试官问你这个问题，期望的一个回答是说，你们公司有个什么业务场景，这个业务场景有个什么技术挑战，如果不用 MQ 可能会很麻烦，但是你现在用了 MQ 之后带给了你很多的好处。 先说一下消息队列常见的使用场景吧，其实场景有很多，但是比较核心的有 3 个：解耦、异步、削峰。 解耦 一个系统(模块)调用多个系统(模块)的场景 多个系统的添加或减少

传智扫地僧课程学习笔记。 直接看老师示例代码， #include using namespace std; #include //队列中基本数据类型 void main61() { queue q; q.push(1); q.push(2); q.push(3); cout << "队头元素:" << q.front() << endl; cout << "队

解耦 不使用MQ时 A系统发送数据到B、C、D系统，但没有使用消息队列时候的耦合场景 当后面系统不断增加，比如 E，F系统的加入，以及D系统的移除 因为A系统和其它各种系统耦合起来，那么需要处理的事情会给出多 使用MQ后 系统A发送一条消息，到消息队列中，哪个系统需要获取到哪里，那么从MQ中消费数据，如果新系统E加入的话，那么只需要编写代码，然后也直接从MQ中消费即可，当系统D不需要这个数据时，那么只需要不对该消息进行消费即可。系统A不需要考虑给谁发送数据，也不需要维护这个代码，不需要考

通过以上示例可以看出，消息队列在项目中具有重要的作用。它不仅可以降低系统间的耦合度、提高系统的响应速度和处理能力、实现负载均衡和数据一致性保障；还可以作为系统的缓冲区来应对流量峰值情况、提高系统的稳定性和可用性。因此，在大型分布式系统中引入消息队列是一种常见且有效的设计选择。欢迎访问我的(夏壹分享)公众号和博客（sanzhiwa）后缀top。

在了解什么事消息队列之前，我们要先知道同步和异步通讯的区别，我们从以下两方面介绍MQ:同步和异步通讯什么使用MQ。

如果你看过秒杀系统的流量监控图的话，你会发现它是一条直线，就在秒杀开始那一秒是一条很直很直的线，这是因为秒杀请求在时间上高度集中于某一特定的时间点。这样一来，就会导致一个特别高的流量峰值，它对资源的消耗是瞬时的。 但是对秒杀这个场景来说，最终能够抢到商品的人数是固定的，也就是说100人和10000人发起请求的结果都是一样的，并发度越高，无效请求也越多。 但是从业务上来说，秒杀活动是希望更多的人来参...

消息队列中间件是分布式系统中重要的组件，主要解决应用耦合，异步消息，流量削锋等问题。实现高性能，高可用，可伸缩和最终一致性架构。是大型分布式系统不可缺少的中间件。 目前在生产环境，使用较多的消息队列有ActiveMQ，RabbitMQ，ZeroMQ，Kafka，MetaMQ，RocketMQ等。