第十三篇: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

  • 发表于:
  • 原文链接https://kuaibao.qq.com/s/20180524G098MP00?refer=cp_1026
  • 腾讯「云+社区」是腾讯内容开放平台帐号(企鹅号)传播渠道之一,根据《腾讯内容开放平台服务协议》转载发布内容。
  • 如有侵权,请联系 yunjia_community@tencent.com 删除。

扫码关注云+社区

领取腾讯云代金券