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

rabbitmq安装延迟队列

在RabbitMQ中,延迟队列是一种特殊的队列类型。当消息被发送到此类队列后,不会立即投递给消费者,而是会等待预设的一段时间,待延迟期满后才进行投递。这种队列在多种场景下都极具价值,比如可用于处理需要在特定时间触发的任务,实现对消息处理的限流,或者在消息发送失败后设置延迟重试等。

使用场景

  • 定时任务: 例如发送提醒邮件或通知,确保在特定时间后再执行。
  • 限流: 控制请求速率,防止瞬时高并发导致的系统崩溃。
  • 重试机制: 在处理失败时,可以将消息延迟后重试,避免立即重试造成的负担。

第一步下载延迟插件

https://github.com/rabbitmq/rabbitmq-delayed-message-exchange/releases

注意:需要根据你自己的 RabbitMQ 服务器端版本选择相同版本的延迟插件,可以在 RabbitMQ 控制台查看:

 https://github.com/rabbitmq/rabbitmq-delayed-message-exchange/releases

我这里mq是3.9.1的所以延迟队列插件选择3.9.0

第二步将插件拷贝至容器中

复制到rabbitmq plugins目录下,linux查询rabbitmq安装包路径命令:whereis rabbitmq

复制到 /usr/lib/rabbitmq/lib/rabbitmq_server-3.9.1/plugins 的目录下,这里着重说一下,我们下载的是.ez文件,如下图所示,直接复制进去就好


第三步执行安装命令

rabbitmq-plugins enable rabbitmq_delayed_message_exchange
这里着重强调一下,我们复制进去的是
rabbitmq_delayed_message_exchange-3.9.0.ez
但是命令执行是不带-3.9.0.ez的

第四步启动插件并重启容器

 rabbitmq-plugins enable rabbitmq_delayed_message_exchange

启动成功

第五步在容器重启完成

我们可以登录RabbitMQ的Web端管理界面,在Exchanges选项卡下,点击Add a new exchange,在Type里面看是否出现了x-delayed-message选项,如下图所示:

表示插件已经安装成功

 结尾:样例小程序二维码,自己做的一个免费好用的排班小程序

http://www.lryc.cn/news/523071.html

相关文章:

  • Kubernetes (K8s) 入门指南
  • Python 调用 Ollama 库:本地大语言模型使用详解
  • python matplotlib绘图,显示和保存没有标题栏和菜单栏的图像
  • 无人机(Unmanned Aerial Vehicle, UAV)路径规划介绍
  • python爬虫入门(实践)
  • 于灵动的变量变幻间:函数与计算逻辑的浪漫交织(下)
  • python实现pdf转word和excel
  • Pandas使用笔记
  • 高等数学学习笔记 ☞ 定积分与积分公式
  • wow-agent---task2使用llama-index创建Agent
  • RabbitMQ实现延迟消息发送——实战篇
  • Oracle 拉链式merge sort join 原理
  • QModbusTCPClient占用内存持续增长
  • 代码中使用 Iterable<T> 作为方法参数的解释
  • Oracle数据库传统审计怎么用
  • leetcode-买卖股票问题
  • MYSQL学习笔记(三):分组、排序、分页查询
  • 上位机工作感想-2024年工作总结和来年计划
  • 【视觉惯性SLAM:十六、 ORB-SLAM3 中的多地图系统】
  • 【C++笔记】红黑树封装map和set深度剖析
  • 4.若依 BaseController
  • vue项目配置多语言
  • 数据可视化大屏设计与实现
  • PDF文件提取开源工具调研总结
  • 多监控m3u8视频流,怎么获取每个监控的封面图(纯前端)
  • 【机器学习实战入门项目】使用深度学习创建您自己的表情符号
  • 技术洞察:C++在后端开发中的前沿趋势与社会影响
  • 【人工智能 | 大数据】基于人工智能的大数据分析方法
  • 数字经济时代下的创新探索与实践:以“开源AI智能名片2+1链动模式S2B2C商城小程序源码”为核心
  • 【English-Book】Go in Action目录页翻译中文