《RabbitMQ》|《RabbitMQ》| 解决消息延迟和堆积问题《RabbitMQ》|解决消息延迟和堆

大家好，我是小菜。
一个希望能够成为吹着牛X谈架构的男人！如果你也想成为我想成为的人，不然点个关注做个伴，让小菜不再孤单！

本文主要介绍 RabbitMQ的常见问题
如有需要，可以参考
【《RabbitMQ》|《RabbitMQ》| 解决消息延迟和堆积问题】如有帮助，不忘点赞 ?
微信公众号已开启，小菜良记，没关注的同学们记得关注哦！

消息可靠性问题：如何确保发送的消息至少被消费一次？
延迟消息问题：如何实现消息的延迟投递？
消息堆积问题：如何解决数百万级以上消息堆积，无法及时消费问题？

我们在上篇已经说明了如何解决消息丢失的问题，也就是保证了消息的可靠性，那么其余两个问题同样重要，这篇我们将讲述其余两个问题的解决方式~！

消息丢失解决方案：《RabbitMQ》 | 消息丢失也就这么回事

一、延迟消息
延迟消息字面意思就是让延迟接收消息，那么如何能让消息延迟到达？这就是我们要思考解决的问题，在了解延迟队列之前我们需要先明白 RabbitMQ 中的两个概念

死信交换机
TTL

1）死信交换机死信（dead letter），也就是废弃已死亡的消息，那什么情况下一个普通的消息能够成为死信？需要符合以下三个条件：

消费者使用 basic.reject 或 basic.nack 声明消费失败，并将消息的 requeue 参数设置为 false
消息是一个过期消息，超时后无人消费
要投递的队列消息堆积满了，最早的消息就会成为死信

而 死信交换机 便是 死信 的归属。
如果一个队列配置了 dead-letter-exchange 属性，指定了一个交换机，那么队列中的死信就会投递到这个交换机中，而这个交换机就称为 死信交换机 - DLX（Dead Letter Exchange ）
步骤：当生产者正常投递到队列（simple.queue）中，如果消费者从队列（simple.queue）消费消息却声明了 reject，那并且队列绑定了死信交换机（dl.queue），那么这个时候成为死信的消息就会投递到这个死信队列（dl.queue）中。

文章图片

从正常队列 --> 死信队列 的过程，我们必须声明两个关键信息

死信交换机的名称
死信交换机与死信队列绑定的路由key

而这两个信息也是我们投递消息的基础配置。
接下来我们简单模拟一下条件1 所产生的场景
1、首先声明一个死信交换机和死信队列我们这边是使用简单的注解方式直接生成

文章图片

通过 RabbitMQ 控制台界面可以看出已经成功生成

文章图片

2、声明正常使用交换机与队列然后这个时候我们就可以创建一个正常使用的交换机与队列，并指明死信交换机

文章图片

同样可以通过控制台查看创建状态

文章图片

其中是否有声明死信交换机我们可以通过队列的 DLX 和 DLK 标志判断
3、模拟拒收然后我们现在通过代码模拟客户端拒绝消息的场景
1）消息发送

文章图片

2）消息接收

文章图片

查看控制台，结果如下：

2021-11-06 23:56:52.095INFO 2112 --- [ntContainer#0-1] c.l.m.c.listener.SpringRabbitListener: 正常业务交换机 | 接收到的消息 : [hello] 2021-11-06 23:56:52.118INFO 2112 --- [ntContainer#1-1] c.l.m.c.listener.SpringRabbitListener: 死信交换机 | 接收到的消息 : hello

这说明我们死信交换机已经成功发挥作用
2）TTL 以上我们已经成功认识到了 死信交换机 的使用，但是这与我们一开始说的延迟队列似乎并没有太大关系，莫急~接下来说到的 TTL(Time-To-Live) 就是用来处理延迟消息的~！
在 TTL 的概念中，如果一个队列中的消息 TTL 结束后仍未被消费，那么这个消息就会自动变为死信，而 TTL 超时情况分为两种：

消息所在的队列设置了存活时间
消息本身设置了存活时间

文章图片

我们同样进行上述条件2 的模拟场景
1、声明死信交换机与死信队列（上述已完成） 2、声明延迟队列并指定死信交换机

文章图片

同样控制台查看创建结果，并且我们发现不止有 DLX 和 DLK 标志，还多了个 TTL ，说明该队列是延迟队列

文章图片

3、模拟消费超时情况我们往延迟队列中发送一条消息，并且没有消费者进行消费，等待 1 分钟后查看是否能进入死信队列中

文章图片

我们已经发送了一条消息到延迟队列并且一分钟后也成功在控制台发现了这条信息已经进入到了死信交换机

2021-11-07 00:01:30.854INFO 32752 --- [ntContainer#1-1] c.l.m.c.listener.SpringRabbitListener: 死信交换机 | 接收到的消息 : test ttl-message

以上是配置了队列超时时间，消息本身自然也能配置超时时间，当消息和队列都存在超时时间时，那么就以最短的 TTL 为准，消息的超时配置如下：

文章图片

如上图所示，我们可以利用 Message 这个类来传递消息信息，并设置上超时时间，我们设置的是 5000 ms，等待发送成功后，控制台过5000 ms 也成功打印了死信交换机消费的消息：

2021-11-07 00:03:09.048INFO 39996 --- [ntContainer#1-1] c.l.m.c.listener.SpringRabbitListener: 死信交换机 | 接收到的消息 : this is a ttl message

3）延迟队列我们上述是使用死信交换机来间接实现延迟队列的效果，但实际在 RabbitMQ 不必如此麻烦，RabbitMQ 已经为我们封装好了插件，我们只需要下载安装即可~

RabbitMQ 插件下载地址

我们进入地址可以发现有许多插件，搜索 delay 关键字找到我们需要的插件进行下载

文章图片

下载完后直接上传到 RabbitMQ 的插件目录 - plugins，小菜这边是使用 docker 临时安装测试的，所以已经将该插件目录挂载出来了：

docker run -itd --name rabbitmq -v plugins:/plugins -p 15672:15672 -p 5672:5672 rabbitmq:management

因此我这边直接将插件上传到容器中的 plugins 目录即可~
然后进入到容器中执行以下命令进行插件开启

rabbitmq-plugins enable rabbitmq_delayed_message_exchange

文章图片

并且我们在控制台创建交换机的时候可以看到 type 类型多了个选项

文章图片

成功执行到这步就说明已经开启了 RabbitMQ 的延迟队列功能
那接下来我们就可以来使用 DelayExchange，首先我们需要了解代码的方式创建延迟交换机：
方式1

文章图片

方式2

文章图片

当我们万事具备之后就可以来发送消息了

在发送消息的时候，消息头中一定要携带上 x-delay 参数，指定上延迟时间

文章图片

通过这样配置之后，我们可以在控制台看到，经过10秒后 delay.queue 才收到对应消息，然后被对应消费者消费
3）总结我们上面从 死信交换机 到 TTL 到 延迟队列，一步步认识了如何实现延迟消息的功能，然后我们进行一个小小的总结：
问题1：什么样的消息会成为死信？