使用 RabbitMQ 和 RocketMQ 的人是幸运的，因为这两个 MQ 自身提供了延迟队列的实现，不像用 Kafka 的同学那么苦逼，还要自己实现延迟队列。当然，这都是题外话，今天咱们重点来聊聊 RabbitMQ 延迟队列的实现原理，以及 RabbitMQ 实现延迟队列的优缺点有哪些？
很多人知道使用 RabbitMQ 是可以实现延迟队列的，但对于 RocketMQ 自身也提供了延迟队列这件事却持有不同态度，这是因为网上有些资料说 RocketMQ 和 Kafka 没有内置延迟队列。其实这种说法是因为，RocketMQ 在早期版本中确实没有内置延迟队列，但在 4.x 就内置了 18 个级别的延迟队列了（最长支持 2 小时的延迟队列），5.x 就支持随机延迟时间的延迟队列了，所以这里需要特殊强调一下。
延迟队列（Delay Queue）是一种特殊类型的队列，它的主要特点是可以让进入队列的元素在指定的延迟时间之后才被取出进行处理。
延迟队列的主要使用场景有以下这些：
那么延迟队列的实现方式有哪些呢？
延迟队列的实现方式通常有以下几种：
我们通常会使用延迟队列来存储（和实现）延迟消息，所以大部分时候，我们说的延迟队列和延迟消息其实是一回事。
使用 RabbitMQ 实现延迟队列有以下两种实现方式：
早期大部分公司都会采用第一种方式，而随着 RabbitMQ 3.5.7（2015 年底发布）的延迟插件的发布，因为其使用更简单、更方便，所以它现在才是大家普通会采用的，实现延迟队列的方式。
使用延迟插件的实现原理是通过创建一个延迟交换机（Delay Exchange），延迟消息首先会把消息投递到延迟交换机，并不是直接将消息投递业务队列（所以不会立即执行），由延迟交换机控制消息在延迟一段时间后，再将消息投递到真正的队列中进行消费，从而实现延迟队列，它的实现流程如下图所示：
其中 Mnesia 可以理解为基于文件存储的数据库。
使用死信队列实现延迟任务有个缺点，它不能实现随机延迟任务，每个无消费者的队列上只能设置一个 ttl（消息过期时间），所以只能实现固定过期时间的延迟任务。
使用延迟插件实现延迟任务有以下两个缺点：
本文链接：http://www.28at.com/showinfo-26-101269-0.html说说MQ延迟队列实现原理？
声明：本网页内容旨在传播知识，若有侵权等问题请及时与本网联系，我们将在第一时间删除处理。邮件：2376512515@qq.com
上一篇： 微前端代码隔离方案，手把手实现一个 JS 沙箱隔离！
下一篇： 不掉头发“逆向”旋转验证码
Copyright © 2016-2023 天津谷骐科技有限公司 版权所有 sitemap.xml
违法及侵权请联系：2376512515@qq.com 津ICP备18001702号
津公网安备 12010102000574号
