十一、RabbitMQ高级 – 延迟队列

不管现实多么惨不忍睹,都要持之以恒地相信,这只是黎明前短暂的黑暗而已。不要惶恐眼前的难关迈不过去,不要担心此刻的付出没有回报,别再花时间等待天降好运。真诚做人,努力做事!你想要的,岁月都会给你。十一、RabbitMQ高级 – 延迟队列,希望对大家有帮助,欢迎收藏,转发!站点地址:www.bmabk.com,来源:原文


利用TTL结合死信交换机,我们实现了消息发出后,消费者延迟收到消息的效果。这种消息模式就称为延迟队列(Delay Queue)模式。

延迟队列的使用场景包括:

  • 延迟发送短信
  • 用户下单,如果用户在15 分钟内未支付,则自动取消
  • 预约工作会议,20分钟后自动通知所有参会人员

因为延迟队列的需求非常多,所以 RabbitMQ 的官方也推出了一个插件,原生支持延迟队列效果。

这个插件就是 DelayExchange 插件。参考RabbitMQ的插件列表页面:
插件

image-20210718192529342.png
使用方式可以参考官网地址:
官网

1. 安装 DelayExchange 插件

2. DelayExchange 原理

DelayExchange 需要将一个交换机声明为 delayed 类型。当我们发送消息到 delayExchange 时,流程如下:

  • 接收消息
  • 判断消息是否具备x-delay属性
  • 如果有x-delay属性,说明是延迟消息,持久化到硬盘,读取x-delay值,作为延迟时间
  • 返回routing not found结果给消息发送者
  • x-delay 时间到期后,重新投递消息到指定队列

3. 使用

插件的使用也非常简单:声明一个交换机,交换机的类型可以是任意类型,只需要设定 delayed 属性为true 即可,然后声明队列与其绑定即可。

3.1 声明DelayExchange交换机

基于注解方式(推荐):
在这里插入图片描述

也可以基于@Bean的方式:

在这里插入图片描述

3.2 发送消息

发送消息时,一定要携带x-delay属性,指定延迟的时间:
image-20210718193917009.png

4. 总结

延迟队列插件的使用步骤包括哪些?
•声明一个交换机,添加 delayed 属性为true
•发送消息时,添加 x-delay 头,值为超时时间

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。

文章由极客之音整理,本文链接:https://www.bmabk.com/index.php/post/162285.html

(0)
飞熊的头像飞熊bm

相关推荐

发表回复

登录后才能评论
极客之音——专业性很强的中文编程技术网站,欢迎收藏到浏览器,订阅我们!