浅谈RabbitMQ的延迟队列

Part 01、  延迟队列是什么 

延迟队列代表了一种强大的消息传递机制,允许我们在将消息发送至RabbitMQ时,规定它们只能在未来某个预定的时间点被消费。这种特殊类型的消息被简称为"延迟消息"。

以RabbitMQ为例,它允许我们通过延迟队列实现这种消息的延迟传递和消费。通过将消息放入延迟队列,我们可以确保消息在特定时间之后才会被传递给消费者,从而实现了对消息传递的精确控制。这对于构建高效的异步任务调度、定时提醒和实现时间敏感性业务逻辑非常有价值。

Part 02、延迟队列的实现 

延迟队列的实现原理实际上是将消息投递到一个普通队列中,不过该队列具有一项特殊属性:消息的消费被推迟了一段时间。这个延迟时间可以是灵活设定的,也可以是固定的。一旦消息进入队列,一个定时器开始计时;一旦计时器到达设定的时间,消息就会被移送到等待消费的队列中,准备被消费。在RabbitMQ中,提供了x-delayed-message插件为开发者快速实现延迟队列,主要包含以下几步:

1.安装插件: 确保安装了 RabbitMQ。然后,通过执行命令安装并启用 x-delayed-message 插件:

代码段:

rabbitmq-plugins enable rabbitmq_delayed_message_exchange

2.创建交换器: 使用 x-delayed-message 插件创建一个延迟交换器(Delayed Message Exchange)。这个交换器将用于处理延迟消息。

代码段:

rabbitmqadmin declare exchange name=delayed_exchange type=x-delayed-message arguments='{"x-delayed-type":"direct"}'

3.发送延迟消息: 当需要发送延迟消息时,将消息发送到刚创建的延迟交换器,并设置消息的延迟时间。这可以通过在消息头中添加 x-delayed-message 属性来实现。

代码段:

AMQP.BasicProperties.Builder builder = new AMQP.BasicProperties.Builder();
builder.deliveryMode(2);
builder.headers(new HashMap<String, Object>(){{put("x-delay", 1000);}});
AMQP.BasicProperties properties = builder.build();
channel.basicPublish("delayed_exchange", "delayed_routing_key", properties, message.getBytes());

4.创建队列和绑定: 创建一个普通的队列,并将其绑定到延迟交换器上。这样,延迟交换器会根据消息的延迟时间将消息传递给队列。

代码段:

# 创建普通队列
rabbitmqadmin declare queue name=delayed_queue
# 将队列绑定到延迟交换器
rabbitmqadmin declare binding source=delayed_exchange destination_type=queue destination=delayed_queue routing_key=delayed_queu

5.消费消息: 启动一个消费者来从队列中获取延迟消息。一旦延迟时间过去,消息会被传递给消费者。

代码段:

channel.exchangeDeclare("delayed_exchange", "x-delayed-message", true, false, arguments);
channel.queueDeclare("delayed_queue", true, false, false, null);
channel.queueBind("delayed_queue", "delayed_exchange", "delayed_routing_key");
channel.basicConsume(queue=queue_name, on_message_callback=callback, auto_ack=True)
channel.startConsuming()

总的来说,x-delayed-message 插件使得在 RabbitMQ 中实现延迟队列变得更加直观和方便,它允许将消息的延迟时间嵌入消息本身,无需使用TTL和死信队列来处理延迟消息。

Part 03、延迟队列的应用场景 

延迟队列在现代分布式系统中具有广泛的应用场景,下面列举了一些常见的应用场景:

1.红包定时抢夺:在红包抢夺场景中,用户发起红包活动后,可能希望在一段时间后才开始抢夺,而非立即开启。在这种情况下,我们可以将红包信息发送至一个延迟队列。经过预定时间后,系统会自动触发红包的开启,这时用户才能实际参与抢红包活动。这种方式能够更好地掌控红包活动的时间,为用户提供更灵活的体验。

图1红包定时抢夺流程

图1红包定时抢夺流程

2.商品预售:在商品预售流程中,订单需要在未来特定时间点进行处理,如在一段时间后才能进行发货。在这种情况下,我们可以将这类订单置于延迟队列中,待预定时间一到,再进行相应的处理操作。这种方法能够有效地处理那些需要时机掌握的订单,确保在合适的时间点完成相应的任务。

图2商品预售发货流程

图2商品预售发货流程

3.优惠券定时生效:在优惠券管理系统中,存在一些优惠券需要在未来特定时间点才能生效。在这种情况下,我们可以将这些待激活的优惠券置于延迟队列中,待预定时间到达时再进行激活处理。通过这种方式,我们能够灵活地控制优惠券的生效时间,确保在合适的时机为用户提供优惠服务。

图3优惠券生效流程

图3优惠券生效流程

Part 04、 延迟队列的注意事项  

1.延迟队列不要使用太多:使用延迟队列可以在一定程度上减少系统的负载,但是使用过多的延迟队列会导致系统变得更加复杂,维护起来也更加困难。

2.延迟队列可能会导致消息丢失:在RabbitMQ中,当一个带有TTL消息被发送到队列中时,如果队列中的消息太多,或者队列的消费者速度太慢,就会导致消息失效,如果没有使用死信机制,消息就会被丢失。为了避免这种情况发生,我们需要对队列进行监控,及时发现问题并进行处理。

3.设置合适的延迟时间:在使用延迟队列时,需要根据实际需求设置合适的延迟时间。如果延迟时间太短,可能会导致消息延迟效果不明显;如果延迟时间太长,可能会导致系统累积大量的消息,导致负载过高。

Part 05、 总结 

RabbitMQ的延迟队列是一项极具实用性的功能,能够协助我们有效实现定时任务、流量控制以及峰值平滑等关键功能。然而,在利用延迟队列时,必须以谨慎态度对待。必须根据具体需求来设定延迟时间,并且要时刻监测队列内的消息,以避免可能的消息丢失情况。希望今天的技术分享能为大家带来启发。

最后,推荐一款应用开发神器

关于目前低代码在技术领域很活跃!

低代码是什么?一组数字技术工具平台,能基于图形化拖拽、参数化配置等更为高效的方式,实现快速构建、数据编排、连接生态、中台服务等。通过少量代码或不用代码实现数字化转型中的场景应用创新。它能缓解甚至解决庞大的市场需求与传统的开发生产力引发的供需关系矛盾问题,是数字化转型过程中降本增效趋势下的产物。

这边介绍一款好用的低代码平台——JNPF快速开发平台。近年在市场表现和产品竞争力方面表现较为突出,采的是最新主流前后分离框架(SpringBoot+Mybatis-plus+Ant-Design+Vue3)。代码生成器依赖性低,灵活的扩展能力,可灵活实现二次开发。

以JNPF为代表的企业级低代码平台为了支撑更高技术要求的应用开发,从数据库建模、Web API构建到页面设计,与传统软件开发几乎没有差异,只是通过低代码可视化模式,减少了构建“增删改查”功能的重复劳动,还没有了解过低代码的伙伴可以尝试了解一下。

应用:https://www.jnpfsoft.com/?csdn

有了它,开发人员在开发过程中就可以轻松上手,充分利用传统开发模式下积累的经验。所以低代码平台对于程序员来说,有着很大帮助。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/116875.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

SQL*PLUS对文本长度的限制

SQL*PLUS对文本长度的限制 一、可解决SQL * Plus行长限制的部分选项&#xff1a;二、SQL * plus 因为以上限制导致脚本执行过程可能遇到的错误1、CLOB字段超4000报ORA-22835或ORA-017042、CLOB处理&#xff1a;SP2-0027: 输入太长 (> 2499 个字符) 收到错误SP2-0027&#xf…

cpp断言

断言 Cpp中的断言是一种调试工具&#xff0c;用于开发过程中的假设。其主要目的是捕获程序中的逻辑错误。当某个条件为false时&#xff0c;断言会触发一个运行时的错误&#xff0c;从而使开发者能够及时地知道并处理这个错误。 使用断言需要包括头文件<cassert>或<a…

聊聊分布式架构10——Zookeeper入门详解

目录 01ZooKeeper的ZAB协议 ZAB协议概念 ZAB协议基本模式 消息广播 崩溃恢复 选举出新的Leader服务器 数据同步 02Zookeeper的核心 ZooKeeper 的核心特点 ZooKeeper 的核心组件 选举算法概述 服务器启动时的Leader选举 服务器运行期间的Leader选举 03ZooKeeper的…

人工智能算法PPT学习

YOLO You only look once 是一种图像识别算法&#xff0c;速度较快。高效、灵活、泛化性能好&#xff0c;在工业中较为受欢迎。 图像金字塔 一幅图像的多个不同分辨率的子图构成的图像集合。是通过一个图像不断的降低采样率产生的&#xff0c;最小的图像可能仅仅有一个像素点…

C# out参数out多个参数

文章目录 C# out参数out多个参数背景说明作用方法定义调用方法测试结果注意 C# out参数out多个参数 背景说明 一个方法返回多个相同数据类型的变量&#xff0c;可以采用数据的方式&#xff1b; 我需要返回多个不同数据类型的方法&#xff0c;在这里采用out多个参数的方式。 …

vue3项目使用TypeIt打字机

官网: TypeIt | The most versatile JavaScript typewriter effect library on the planet. 下载: npm i typeit 使用方法: 正常打字 多行打字机 input输入框实现打字机效果 打字机颜色变化 删除,光标移动,最全面的打字机效果 官网最下面还可以输入你想有的打字效果,然后生…

【文件操作】Java -操作File对象

个人简介&#xff1a;Java领域新星创作者&#xff1b;阿里云技术博主、星级博主、专家博主&#xff1b;正在Java学习的路上摸爬滚打&#xff0c;记录学习的过程~ 个人主页&#xff1a;.29.的博客 学习社区&#xff1a;进去逛一逛~ 文件操作 Java - File对象 Java - File对象 Fi…

计算机视觉-数学基础*变换域表示

被研究最多的图像&#xff08;或任何序列数据&#xff09;变换域表示是通过傅 里叶分析 。所谓的傅里叶表示就是使用 正弦函数的线性组合来表示信号。对于一个给定的图像I(n1,n2) &#xff0c;可以用如下方式分解它&#xff08;即逆傅里叶变换&#xff09;&#xff1a; 其中&a…

【lesson14】进程控制之进程等待

文章目录 为什么要有进程等待&#xff1f;如何等待和什么是等待&#xff1f; 为什么要有进程等待&#xff1f; 1.子进程退出&#xff0c;父进程不管子进程&#xff0c;子进程就要处于僵尸状态------会导致内存泄漏 2.父进程创建子进程是要让子进程办事的&#xff0c;那么子进…

【Tensorflow 2.12 简单智能商城商品推荐系统搭建】

Tensorflow 2.12 简单智能商城商品推荐系统搭建 前言架构数据召回排序部署调用结尾 前言 基于 Tensorflow 2.12 搭建一个简单的智能商城商品推荐系统demo~ 主要包含6个部分&#xff0c;首先是简单介绍系统架构&#xff0c;接着是训练数据收集、处理&#xff0c;然后是召回模型、…

Word Power S

题目描述 约翰想要计算他那N(l < N < 1000)只奶牛的名字的能量.每只奶牛的名字由不超过1000个字 符构成&#xff0c;没有一个名字是空字体串. 约翰有一张“能量字符串表”&#xff0c;上面有M(1 < M < 100)个代表能量的字符串.每个字符串 由不超过30个字体构成&a…

使用.NET设计一个Epub电子书生成工具

1. 背景 可能我们接触到更多的小说文件都是普普通通的TXT格式&#xff0c;用于分享的文档更多的是PDF。TXT虽然轻巧&#xff0c;但是不如PDF丰富和强大。而 Epub 电子书格式因为其丰富的展示效果和较小的文件大小&#xff0c;这样一个微妙的平衡就刚刚好。作为一个喜欢看小说的…

apache开启https

本文基于windows平台。 个人感觉使用apache配置起来比较繁琐&#xff0c;而使用upupw或者xmpp等集成开发工具更方便。 在httpd.conf中&#xff0c;将下一行的注释去掉&#xff1a;LoadModule ssl_module modules/mod_ssl.so。另外&#xff0c;千万不要注释掉下面的一行&#…

How to install mongodb 7.0 to Ubuntu 22.04

How to install mongodb 7.0 to Ubuntu 22.04 1、安装1.1、添加gpg1.2、添加apt源1.3、更新1.4、安装 2、管理2.1、服务管理2.1.1、查看服务状态2.1.2、启动服务2.1.3、 设置服务为开机启动2.1.4、取消服务开机启动2.1.5、关闭服务2.1.6、服务重启 2.2、mongosh2.2.1、进入mong…

“深入探讨Java JUC中的ReentrantLock锁:实现多线程同步与并发控制“

简介 1、从Java5开始&#xff0c;Java提供了一种功能更强大的线程同步机制——通过显式定义同步锁对象来实现同步&#xff0c;在这种机制下&#xff0c;同步锁由Lock对象充当。 2、Lock 提供了比synchronized方法和synchronized代码块更广泛的锁定操作&#xff0c;Lock允许实…

arcgis js api FeatureLayer加载时返回数据带*问题

接着这一问题衍生出来的问题 arcgis的MapServer服务查询出来的结果geometry坐标点带*的问题-CSDN博客 个人感觉像是server版本的问题&#xff0c;具体不清楚&#xff0c;pg数据库里面的shape点集合坐标点的精度是8&#xff0c;但是server服务查出来的默认都十几位。所以存在一…

c_指针

文章目录 *(p1)1表示第 1 行第 1 个元素的地址。如何理解呢&#xff1f;下标运算符的规则括号 int a; // 1.一个整数 int *a; // 2.一个指向整数的指针 int **a; // 3.一个指向指针的指针, 它所指向的指针又指向一个整数型数据 ;一个指向 …

用Python绘制简单曲线的几个方法

画曲线的基本方法 1.用圆的一部分来画曲线&#xff1a; circle(半径&#xff0c;度数) 比如说想画一个半径为50的半圆的曲线&#xff0c;就可以用circle(50,180)来表示 如果想截取一个半径为100的圆中110的部分&#xff0c;就可以用circle(100,110)来表示 若要更改方向&am…

使用CPR库和Python编写程序

以下是一个使用CPR库和Python编写的爬虫程序&#xff0c;用于爬取。此程序使用了proxy的代码。 import requests from cpr import CPR ​ def get_proxy():url "https://www.duoip.cn/get_proxy"headers {"User-Agent": "Mozilla/5.0 (Windows NT …

C语言可变参数函数及其实现

概述 本文讨论C语言中的可变参数函数&#xff0c;特别关注printf和scanf&#xff0c;它们允许根据需要确定参数的个数。这篇文章还介绍了可变参数函数的实现细节和相关宏 1. 可变参数函数的概念 C语言引入了可变参数函数的概念&#xff0c;允许函数的参数个数根据需要确定。…