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

rabbitmqp安装延迟队列

在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/521473.html

相关文章:

  • 深入探讨DICOM医学影像中的MPPS服务及其具体实现
  • 集合帖:区间问题
  • C#,入门教程(27)——应用程序(Application)的基础知识
  • 迅翼SwiftWing | ROS 固定翼开源仿真平台正式发布!
  • CSS 样式 box-sizing: border-box; 详细解读
  • FLASK创建下载
  • 漫话架构师|什么是系统架构设计师(开篇)
  • Web Socket
  • JavaSE学习心得(反射篇)
  • 使用FRP进行内网穿透
  • 长安“战疫”网络安全公益赛的一些随想
  • flutter 安卓端打包
  • Cesium中的CustomDataSource 详解
  • [Qt]常用控件介绍-按钮类控件-QPushButton、QRedioButton、QCheckBox、QToolButton控件
  • Windows 蓝牙驱动开发-安装蓝牙设备
  • element表格有横向滚动条时产生错位或者偏移(火狐浏览器)
  • C# 下 SQLite 并发操作与锁库问题的 5 种解决方案
  • 2025封禁指定国家ip-安装xtables-addons记录
  • 卷积神经02-CUDA+Pytorch环境安装
  • 高斯数据库与MySQL数据库的区别
  • 【 PID 算法 】PID 算法基础
  • 【AI】【RAG】如何通过WebUI部署与优化RAG问答系统
  • SpringBoot之OriginTrackedPropertiesLoader类源码学习
  • 51单片机 AT24C02(I2C总线)
  • Shell正则表达式与文本处理三剑客(grep、sed、awk)
  • Docker Desktop 中安装 MySQL 并开启远程访问的详细教程
  • 计算机网络 (39)TCP的运输连接管理
  • 麦田物语学习笔记:构建游戏的时间系统
  • Tauri教程-进阶篇-第二节 命令机制
  • candb++ windows11运行报错,找不到mfc140.dll