https://www.bilibili.com/video/BV1ZUedzdEVr

昨天晚上系统从阿里云迁移到腾讯云，今天就出现MQ消息堆积。在已往的认知里，消息堆积基本上是消费者不给力，但在监控上看发现生产者消息很少，每秒也就几条，没理由消费者忙不过来。

但基于认知，还是第一时间去增加了消费者（把pod从3个节点加到了5个，队列始终是3个），过了几个小时又出现了消息堆积，这时候我们犯了第一个错误。当某个消费组的消费者数量大于队列数的时候，增加消费者其实是没用的。 可参看 RocketMQ 消费关系图

B站学习地址

上一遍学习了三种常见队列的消费原理，本次我们来从源码的角度来证明上篇中的理论。

1、准备

RocketMQ 版本

<!-- RocketMQ -->
<dependency>
    <groupId>org.apache.rocketmq</groupId>
    <artifactId>rocketmq-spring-boot-starter</artifactId>
    <version>2.3.0</version>
</dependency>

B站视频地址

一、开始

先来定义一下何为顺序消息，比如有A、B两条消息，消息处理的流程是 1、2、3 ... 10，只有当A消息执行10完毕后，B消息才可以进行1流程。
注：如果A执行到7，B开始执行1，这其实不一定是顺序消息，因为各种原因最终可能导致B先执行完10。

• B站 https://www.bilibili.com/video/BV1rX4y1z72v

今天我们阅读源码的目的：在SpringBoot项目中，RocketMQ是如何通过 @RocketMQMessageListener 来进行消费的。

在SpringBoot项目中，我们要接收消息只需要使用一个注解就好了 @RocketMQMessageListener 下面的代码就是一个简单的 consumer 的案例。

视频地址：https://www.bilibili.com/video/BV1mr4y1J77n

之前面试的时候都会被问到为什么使用MQ，使用MQ的好处是什么，我都会照本宣科的说：异步、解耦、削峰，这几个词也好理解，都是字面意思，今天我们就来进一步加深理解异步和结解耦。

一、引入问题

视频地址

之前一直没使用过RabbitMQ，最近有一个需求需要用到延迟消息，就简单的使用了一下，发现还是有蛮多坑的。

此篇文章只是RabbitMQ延迟消息相关内容，至于安装RabbitMQ等其它操作，参考百度。

一、什么是延迟消息

顾问思议所谓延迟消息就是延迟消息！！！

二、延迟消息实现方法

1、下载

https://rocketmq.apache.org/dowloading/releases/

2、安装

2-1：上传

把刚刚下载的安装包上传到Linux上去，我是上传到 /usr/local 目录下，你想上传到那里都可以。