当前位置: 首页 > news >正文

RabbitMQ延迟队列

1场景:

1.下单之后,给10分钟时间进行支付,如果10分钟后,没有支付,订单取消。(可以使用队列的ttl,因为所有的消息都是一样的停留时长10分钟)

2.定时发布文章(要求4月1号凌晨发布)

小张 8:00 编辑了一篇文章,目前状态为草稿,发布到队列该消息在队列停留 16个小时,消费者拿到消息后,更改该文章的状态为发布即可。

小芳 13:00 编辑了一篇文章,目前状态为草稿,发布到队列该消息在队列停留 11个小时,消费者拿到消息后,更改该文章的状态为发布即可。

3.预约餐厅,提前半个小时发短信通知用户。

A包间 -> 13:00 17:00 16:30 延迟时间: 7*30 * 60 * 1000

B包间 -> 11:00 18:00 17:30 延迟时间: 13*30 * 60 * 1000

C包间 -> 8:00 20:00 19:30 延迟时间: 17*30 * 60 * 1000

2第一种方式:创建具有超时功能且绑定死信交换机的消息队列

   @Beanpublic Queue directQueueLong(){return   QueueBuilder.durable("业务队列名称").deadLetterExchange("死信交换机名称").deadLetterRoutingKey("死信队列 RoutingKey").ttl(20000) // 消息停留时间//.maxLength(500).build();}

监听死信队列,即可处理超时的消息队列

缺点:

上述实现方式中,ttl延时队列中所有的消息超时时间都是一样的,如果不同消息想设置不一样的超时时间,就需要建立多个不同超时时间的消息队列,比较麻烦,且不利于维护。

3第二种方式:创建通用延时消息

rabbitTemplate.convertAndSend("交换机名称", "RoutingKey","对象",message => {message.getMessageProperties().setExpiration(String.valueOf(5000))return message;});

缺点:

该种方式可以创建一个承载不同超时时间消息的消息队列,但是这种方式有一个问题,如果消息队列中排在前面的消息没有到超时时间,即使后面的消息到了超时时间,先到超时时间的消息也不会进入死信队列,而是先检查排在最前面的消息队列是否到了超时时间,如果到了超时时间才会继续检查后面的消息。

4 第三种方式:使用rabbitmq的延时队列插件,实现同一个队列中有多个不同超时时间的消息,并按时间超时顺序出队

4.1下载延迟插件

在 RabbitMQ 的 3.5.7 版本之后,提供了一个插件(rabbitmq-delayed-message-exchange)来实现延迟队列 ,同时需保证 Erlang/OPT 版本为 18.0 之后。

我这里 MQ 的版本是 3.10.0 现在去 GitHub 上根据版本号下载插件

Releases · rabbitmq/rabbitmq-delayed-message-exchange (github.com)

4.2安装插件并启用

我用的是 Docker 客户端,下载完成后直接把插件放在 /opt目录,然后拷贝到容器内plugins目录下(rabbitmq是容器的name,也可以使用容器id)

docker cp /opt/rabbitmq/rabbitmq_delayed_message_exchange-3.10.0.ez rabbitmq:/plugins

进入 Docker 容器

docker exec -it rabbitmq /bin/bash

在plugins内启用插件

#先执行,解除防火墙限制,增加文件权限
umask 0022rabbitmq-plugins enable rabbitmq_delayed_message_exchange

退出容器

exit

重启 RabbitMQ

docker restart rabbitmq

通过UI查看

4.3原理

4.4如何使用?

1、消费者

2、生产者


http://www.mrgr.cn/news/46336.html

相关文章:

  • 21.数据结构与算法-遍历二叉树/三种遍历算法/递归遍历/非递归遍历/建立,复制二叉树/求二叉树的深度,节点个数,叶子节点个数
  • 嵌入式仿真实验教学平台
  • 理解Web3的互操作性:不同区块链的连接
  • 鸿蒙开发(NEXT/API 12)【ArkWeb接入密码保险箱】系统安全
  • 最好的超声波清洗机是哪款牌子?四款顶流超声波清洗机强烈推荐!
  • java实现桌面程序开机自启动
  • postman变量,断言,参数化
  • sass学习笔记(1.0)
  • AI工程师:AI时代的新岗位
  • Python 语法及入门(超全超详细)!
  • 【RAG论文精读5】RAG论文综述1(2312.10997)-第3部分:检索器
  • 高效开发最佳实践全面指南
  • 智能矿山建设方案
  • inBuilder低代码平台新特性推荐-第二十五期
  • 第三方软件测试报告包括哪些内容?需要多少时间和费用?
  • KDTS 实现MySQL至KingbaseES迁移实践
  • AVL树学习笔记
  • ai写作,五款软件助你快速写作!
  • AbMole揭秘BaP/BPDE与lnc-HZ08如何影响人类滋养层细胞的DNA修复
  • GC 算法