第十三篇：RabbitMQ延迟队列

是为了简化 应用的创建、运行、调试、部署等一系列问题而诞生的产物，

初探RabbitMQ消息队列

中介绍了 的简单用法，顺带提及了下延迟队列的作用。所谓 就是指当消息被发送以后，并不想让消费者立即拿到消息，而是等待指定时间后，消费者才拿到这个消息进行消费。

延迟队列

延迟队列能做什么？

订单业务：在电商/点餐中，都有下单后 30 分钟内没有付款，就自动取消订单。

短信通知：下单成功后 60s 之后给用户发送短信通知。

失败重试：业务操作失败后，间隔一定的时间进行失败重试。

这类业务的特点就是：非实时的，需要延迟处理，需要进行失败重试。一种比较笨的方式是采用定时任务，轮训数据库，方法简单好用，但性能底下，在高并发情况下容易弄死数据库，间隔时间不好设置，时间过大，影响精度，过小影响性能，而且做不到按超时的时间顺序处理。另一种就是用，这玩意最大的问题就是

RabbitMQ 实现思路

本身是没有直接实现支持延迟队列的功能，但可以通过它的Time-To-Live Extensions 与 Dead Letter Exchange 的特性模拟出延迟队列的功能。

Time-To-Live Extensions

支持为队列或者消息设置TTL（time to live 存活时间）。TTL表明了一条消息可在队列中存活的最大时间。当某条消息被设置了TTL或者当某条消息进入了设置了TTL的队列时，这条消息会在TTL时间后成为。如果既配置了消息的TTL，又配置了队列的TTL，那么较小的那个值会被取用。

Dead Letter Exchange

，上文中提到设置了 TTL 的消息或队列最终会成为 。如果为队列设置了 ，那么这些 就会被重新发送到 中，然后通过 路由到其他队列，即可实现延迟队列的功能。

导入依赖

在 中添加 的依赖

属性配置

在 文件中配置 相关内容，值得注意的是这里配置了手动ACK的开关

具体编码

定义队列

如果手动创建过或者 中已经存在该队列那么也可以省略下述代码...

实体类

创建一个 类

控制器

编写一个 类，用于消息发送工作，同时为了看到测试效果，添加日志输出，将发送消息的时间记录下来..

消息消费者

默认情况下 是自动 机制，就意味着 MQ 会在消息消费完毕后自动帮我们去ACK，这样依赖就存在这样一个问题：如果报错了，消息不会丢失，会无限循环消费，很容易就吧磁盘空间耗完，虽然可以配置消费的次数但这种做法也有失优雅。目前比较推荐的就是我们 然后将消费错误的消息转移到其它的消息队列中，做补偿处理。由于我们需要手动控制 ，因此下面监听完消息后需要调用 通知 消息已被正确消费，可以将远程队列中的消息删除

主函数

测试

完成准备事项后，启动 访问 http://localhost:8080/books 将会看到如下内容，就代表一切正常....

总结

目前很多大佬都写过关于的教程了，如有雷同，请多多包涵，本教程基于最新的 编写，包括新版本的特性都会一起介绍...

说点什么

全文代码：https://github.com/battcn/spring-boot2-learning/tree/master/chapter12