rabbitmq延时队列相关配置

确保 RabbitMQ 的延时消息插件已经安装和启用。你可以通过执行以下命令来安装该插件:

rabbitmq-plugins enable rabbitmq_delayed_message_exchange
如果提示未安装,以下是安装流程:

查看mq版本:

查看自己使用的 MQ(消息队列)的版本,可以使用以下方法之一:

查看 MQ 的安装目录或文档:在 MQ 的安装目录中,通常会包含一个关于版本信息的文件或文件夹,例如 version.txt、README.md、docs 等。你可以查找这些文件,其中应该包含有关 MQ 版本的信息。查看管理界面:某些 MQ 提供了管理界面,你可以通过浏览器登录管理界面,在界面上查看版本信息。通常,你需要提供相关的 URL、用户名和密码来访问管理界面。使用命令行工具:有些 MQ 提供了命令行工具,可以通过命令行查看版本信息。例如,如果你使用的是 Apache Kafka,则可以使用命令 kafka-topics.sh --version 来查看 Kafka 的版本号。查看依赖库或客户端:如果你使用的是 MQ 的客户端库或者集成了 MQ 的框架,可以查看相应的依赖库或客户端代码,通常会在其文档或源代码中提供版本信息。

下载插件

https://www.rabbitmq.com/community-plugins.html
rabbitmq_delayed_message_exchange 选择对应的版本
在这里插入图片描述
点击rabbitmq_delayed_message_exchange-3.12.0.ez 进行下载
在这里插入图片描述安装插件
进入MQ的安装目录中的plugins目录 把插件放入到plugins目录
在这里插入图片描述进入sbin目录,打开管理员控制台,
执行一下命令

bash rabbitmq-plugins enable rabbitmq_delayed_message_exchange

显示类似信息即可:
在这里插入图片描述

rabbitmq_delayed_message_exchange-3.12.0.ez 插件可以安装到 Linux 服务器上的
RabbitMQ。

要安装 RabbitMQ 插件,你需要确保已经安装了 RabbitMQ 服务器,并且具有适当的权限。以下是在 Linux 服务器上安装
RabbitMQ 插件的一般步骤:

下载插件文件 rabbitmq_delayed_message_exchange-3.12.0.ez 到 Linux 服务器上。打开终端,使用 cd 命令导航到 RabbitMQ 的安装目录,通常默认安装位置是 /usr/lib/rabbitmq 或 /usr/local/sbin。如果不清楚安装位置,可以使用 which rabbitmq-server 命令来查找 RabbitMQ

服务器的位置。

运行以下命令,将插件安装到 RabbitMQ 服务器中:
bash sudo rabbitmq-plugins enable rabbitmq_delayed_message_exchange

如果命令成功执行,将显示类似以下内容的消息:

The following plugins have been enabled:
rabbitmq_delayed_message_exchange Applying plugin configuration to
rabbit@localhost… started 6 plugins.

重启 RabbitMQ 服务器,以使插件生效:

bash sudo systemctl restart rabbitmq-server

完成以上步骤后,rabbitmq_delayed_message_exchange 插件将安装并启用在 RabbitMQ
服务器上,可以开始使用延迟消息交换功能。

请注意,确保你已经正确下载了兼容你所使用的 RabbitMQ 版本的插件文件。

查看延时队列
在这里插入图片描述

确保你的项目中引入了 spring-rabbit 依赖。在你的 Spring Boot 配置文件中添加以下配置:
spring:rabbitmq:host: 127.0.0.1password: ***port: 5672username: ***virtual-host: ***

这些属性是用于配置Spring框架中与RabbitMQ消息队列相关的属性。让我逐个介绍一下每个属性的作用:

rabbitmq.host: 指定RabbitMQ服务器的主机地址。在这个示例中,主机地址是127.0.0.1,也就是本地主机。rabbitmq.port: 指定RabbitMQ服务器的端口号。默认的RabbitMQ端口号是5672,因此在这个示例中,端口号为5672。rabbitmq.username: 指定连接RabbitMQ服务器时使用的用户名。在这个示例中,用户名是***。rabbitmq.password: 指定连接RabbitMQ服务器时使用的密码。在这个示例中,密码是***。rabbitmq.virtual-host: 指定RabbitMQ服务器的虚拟主机。虚拟主机是RabbitMQ中用于隔离不同应用之间的消息队列的逻辑概念。在这个示例中,虚拟主机是***。

rabbitmq管理平台配置延时队列:
直接使用 direct 类型的交换机是无法实现延时队列功能的。direct 类型的交换机是根据 Routing Key 进行精确匹配,将消息发送到与 Routing Key 完全匹配的队列中,而不会对消息进行延时投递。

如果你需要实现延时队列功能,可以考虑使用 RabbitMQ 插件 rabbitmq_delayed_message_exchange 提供的 x-delayed-message 类型的交换机。该插件允许你在 RabbitMQ 中创建一个特殊类型的交换机,支持延时消息的投递。

使用 x-delayed-message 类型的交换机,你可以在发送消息时设置消息的头部属性作为延时时间,并且消息将会在指定的延时时间之后被投递到相应的队列。

请注意,使用 x-delayed-message 类型的交换机需要安装并启用 rabbitmq_delayed_message_exchange 插件。安装完成后,你可以在 RabbitMQ 中创建该类型的交换机,并按需使用延时队列功能。

当你在 RabbitMQ 中新增一个交换机时,需要设置一些属性来定义该交换机的行为。下面是各个属性的详细介绍:

Name(名称):交换机的名称,用于标识该交换机。名称必须是唯一的。Type(类型):交换机的类型,用于定义消息的路由方式。常见的交换机类型包括 direct、fanout、headers、topic 和 x-delayed-message。Durability(持久化):交换机是否持久化到磁盘。如果将此属性设置为 true,则 RabbitMQ 会将该交换机保存到磁盘上,以便在服务器重启后仍然存在。Auto delete(自动删除):是否在最后一个绑定到交换机的队列被删除后自动删除交换机。如果将此属性设置为 true,则 RabbitMQ 会在没有任何队列绑定到该交换机时自动删除该交换机。Internal(内部):是否是一个内部交换机。如果将此属性设置为 true,则该交换机只能被其他交换机使用,而不能被客户端直接发送消息到该交换机。Arguments(参数):交换机的其他参数,用于控制交换机的行为。Argument 的值可以是任何有效的 Erlang 对象。

在设置延时队列时,你需要使用 x-delayed-type 参数来指定该交换机的类型为 x-delayed-message,并使用 x-delayed-message 的头部属性 x-delay 来指定消息的延迟时间。

在这里插入图片描述
通过配置这些属性,Spring框架可以使用指定的主机、端口、用户名和密码来连接RabbitMQ服务器,并在指定的虚拟主机中进行消息队列的操作。这样,我们就可以在Spring应用程序中方便地使用RabbitMQ来实现消息的发送和接收。

在你的代码中,使用 RabbitTemplate 的 convertAndSend() 方法发送消息到延时队列。同时,设置消息的延时时间。
import org.springframework.amqp.core.Message;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;@Component
public class DelayedQueueExample {@Autowiredprivate RabbitTemplate rabbitTemplate;public void sendMessageWithDelay(MessageDto messageDto, int delayInMillis) {rabbitTemplate.convertAndSend("my-delayed_exchange", "sms.api.routing",messageDto, message -> {message.getMessageProperties().setHeader("x-delay", delayInMillis);//毫秒return message;});System.out.println("Message sent to delayed queue.");}
}

在这个示例中,我们使用 RabbitTemplate 的 convertAndSend() 方法发送消息到名为 delayed_exchange 的交换机,并指定路由键为 ums.api.routing。我们还为消息设置了延时时间,通过在 convertAndSend() 方法中使用 lambda 表达式修改消息的属性。

请注意,你需要将 delayed_exchange 替换为实际的交换机名称,根据你的需求修改路由键和消息体。此外,确保 MessageDto 类是可序列化的,并在你的项目中定义。

这样,你的消息就会被发送到延时队列中,等待指定的延时时间后才会被消费。

如果在 x-delayed-message 交换机中不设置延迟时间,其行为与普通的 Direct 交换机非常相似。

Direct 交换机是 RabbitMQ 中最简单的一种交换机类型,它将消息发送到与绑定键完全匹配的队列。当你使用 Direct 交换机时,可以通过指定绑定键来路由消息到特定的队列。

x-delayed-message 交换机是一个插件提供的自定义交换机,它允许你发送带有延迟的消息。你可以通过设置消息的 x-delay 属性来指定消息的延迟时间。当消息到达 x-delayed-message 交换机时,交换机会根据消息的延迟时间将其暂时存储,然后在延迟时间到达后将其转发到相应的队列。

如果在 x-delayed-message 交换机中不设置延迟时间(即所有消息的 x-delay 属性都为零或未设置),该交换机将表现得与 Direct 交换机相同。消息将立即被路由到匹配的队列,没有任何延迟。

因此,如果不需要延迟消息功能,只需直接发送消息到 x-delayed-message 交换机,它将像 Direct 交换机一样工作。如果需要延迟消息功能,请确保为每条消息设置适当的 x-delay 属性,以指定延迟时间。

已经创建好的交换机不能再更新type:
RabbitMQ 中的交换机类型是在创建时确定的,一旦交换机创建后,就无法直接修改其类型。要更改交换机的类型,你需要按照以下步骤进行操作:

创建一个新的交换机,使用所需的类型。例如,如果你想将交换机从 Direct 类型更改为 Fanout 类型,可以创建一个新的 Fanout 交换机。将绑定到旧交换机上的队列和绑定迁移到新交换机。这可以通过解绑旧交换机和绑定新交换机来实现。解绑旧交换机:使用命令或管理界面将所有队列从旧交换机解绑。这将使队列不再接收来自旧交换机的消息。绑定新交换机:使用相同的绑定规则将队列绑定到新交换机上。这将确保消息可以通过新的交换机路由到正确的队列。确保在转移过程中不会丢失任何消息。你可以选择在迁移前停止消息发布者,以确保没有新消息发送到旧交换机上。然后,在完成旧交换机和新交换机之间的迁移后,重新启动消息发布者。

请注意,在进行交换机类型更改时,可能会涉及到一些风险和潜在问题,因此建议在生产环境中小心操作并进行充分的测试。

另外,如果你只是想更改交换机的属性而不是类型,例如更改交换机的名称、持久性或其他属性,你可以使用 RabbitMQ 的管理界面或命令行工具对交换机进行更新。

交换机类型区别:
在 RabbitMQ 中,有几种不同类型的交换机(Exchange),包括 direct、fanout、headers、topic 和 x-delayed-message。下面我将详细描述每种类型的区别:

Direct(直连交换机):Direct 交换机是最简单的一种类型,它将消息直接路由到与绑定键(Binding Key)完全匹配的队列。发送到 Direct 交换机的消息需要指定一个 Routing Key,该 Routing Key 与队列绑定时指定的 Binding Key 进行匹配。Fanout(扇形交换机):Fanout 交换机会将消息广播到绑定到它的所有队列,无论绑定键是什么。发送到 Fanout 交换机的消息会被转发到所有与之绑定的队列,而 Routing Key 将被忽略。Headers(标头交换机):Headers 交换机使用消息的标头属性来进行匹配,而不是使用 Routing Key。发送到 Headers 交换机的消息会根据标头属性的匹配情况被转发到相应的队列。Topic(主题交换机):Topic 交换机使用通配符和 Routing Key 的模式匹配来路由消息。发送到 Topic 交换机的消息的 Routing Key 是一个由多个单词组成的字符串,这些单词用点号(.)分隔。消息的 Routing Key 将被与队列绑定时指定的 Binding Key 进行模式匹配,符合匹配规则的消息将被路由到相应的队列。x-delayed-message(延迟消息交换机):x-delayed-message 交换机是 RabbitMQ 的一个插件提供的特殊类型的交换机,它支持延迟消息的投递。x-delayed-message 交换机可以根据消息的头部属性中设置的延迟时间来进行延迟投递。使用 x-delayed-message 交换机时,需要安装并启用 RabbitMQ 的 "rabbitmq_delayed_message_exchange" 插件。

总结:

Direct 交换机通过完全匹配 Routing Key 将消息发送到指定队列;
Fanout 交换机广播消息到所有绑定的队列;
Headers 交换机根据标头属性来匹配并转发消息;
Topic 交换机通过模式匹配 Routing Key 来转发消息;
x-delayed-message 交换机用于延迟消息的投递,需要安装额外的插件。

不同类型的交换机在消息路由和转发方式上有所不同,选择正确的交换机类型有助于实现所需的消息传递逻辑。

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

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

相关文章

全网最全丨傻瓜式Fiddler教程大全丨从安装到抓包

前言 在我们做接口测试的时候,经常需要验证发送的消息是否正确,或者在出现问题的时候,查看手机客户端发送给server端的包内容是否正确,就需要用到抓包工具。 今天,给大家带来最常用的Fiddler的傻瓜式教程大全——从安…

九、综合实例:修改用户资料(Qt5 GUI系列)

目录 一、设计需求 二、实现代码 三、代码解析 四、总结 一、设计需求 设计一个修改用户资料功能的对话框&#xff0c;要求包含基本信息、联系方式、详细资料的编辑和修改。本实例只实现界面。 二、实现代码 导航页面&#xff1a; //添加的头文件 #include <QStacked…

深入理解Python中的二分查找与bisect模块

&#x1f497;&#x1f497;&#x1f497;欢迎来到我的博客&#xff0c;你将找到有关如何使用技术解决问题的文章&#xff0c;也会找到某个技术的学习路线。无论你是何种职业&#xff0c;我都希望我的博客对你有所帮助。最后不要忘记订阅我的博客以获取最新文章&#xff0c;也欢…

安装Cygwin的包管理器apt-cyg并安装tree命令

文章目录 一、从官网添加必要软件包1. 安装2. 检查 二、安装apt-cyg1. 下载安装2.修复 三、安装tree命令1. 安装2.检验 一、从官网添加必要软件包 1. 安装 因为第一次安装cygwin时走的都是默认选项&#xff0c;所以这里是二次添加额外包。 打开官网&#xff0c;下载安装程序。…

【导出与导入Virtualbox虚拟机和启动连接openGauss数据库】

【导出与导入Virtualbox虚拟机和启动连接openGauss数据库】 一、导出虚拟机二、导入虚拟机三、启动数据库四、使用Data Studio连接数据库 一、导出虚拟机 选择关机状态的虚拟机 -> 管理菜单 -> 导出虚拟电脑 点击完成后&#xff0c;需要等待一小段时间&#xff0c;如…

每日一道算法题day-three(备战蓝桥杯)

哈喽大家好&#xff0c;今天来给大家带来每日一道算法题系列第三天&#xff0c;让我们来看看今天的题目&#xff0c;一起备战蓝桥杯 题目&#xff1a; 小 Y的桌子上放着 n 个苹果从左到右排成一列&#xff0c;编号为从 11 到 n。 小苞是小 Y 的好朋友&#xff0c;每天她都会…

Java JDK8到21演升特性汇总

Java JDK 8 到 19 演升特性汇总 文章目录 Java JDK 8 到 19 演升特性汇总一、版本roadmap图二、版本与特性JDK8 [2014-03-18]JDK11[2018-09-25]JDK17【2021-09-14】JDK21 [2023-09-19] 一、版本roadmap图 官方地址 JDK8,JDK11,JDK17,JDK21是长期维护的版本。spring boot3最低支…

D-Link DES-108 交换机

D-Link DES-108 交换机 1. 百兆交换机 8 口References ​ D-Link Corporation is a Taiwanese multinational networking equipment manufacturing corporation headquartered in Taipei, Taiwan. Taiwanese&#xff1a;adj. 台湾的 n. 台湾人 headquarter [hedkwɔ:tə]&#…

汽车电子学习总结

国内的主要有比亚迪、联合汽车电子&#xff08;联电&#xff09;、麦格米特、上海电驱动&#xff1b;国外的主要有欧美系的博世、麦格纳、大陆、博格华纳&#xff1b;日系的电装、电产等公司。

AIOps探索 | 基于大模型构建高效的运维知识及智能问答平台(2)案例分享

原作者&#xff1a;擎创科技产品专家 布博士 案例分享 所需要的软件列表 本次案例的实现&#xff0c;全部采用开源或SAAS的产品来提供&#xff0c;并不涉及到私有化部署的软件产品。软件列表如下所示&#xff0c;如何申请apikey请自行研究&#xff0c;在这里不再详细说明&…

VIT用于图像分类 学习笔记(附代码)

论文地址&#xff1a;https://arxiv.org/abs/2010.11929 代码地址&#xff1a;https://github.com/bubbliiiing/classification-pytorch 1.是什么&#xff1f; Vision Transformer&#xff08;VIT&#xff09;是一种基于Transformer架构的图像分类模型。它将图像分割成一系列…

如何实现安卓端与苹果端互通

在移动应用开发中&#xff0c;如何实现安卓端和苹果端的互通是一个重要的问题。二者缺少一个都会有损失&#xff0c;那如何实现安卓端跟苹果端互通&#xff0c;下面简单的介绍几点方法来帮助你再不同的平台上实现数据交互和功能互通。 基于Web技术 使用Web技术是一种常见并且…

数字孪生与大数据和分析技术的结合

数字孪生与大数据和分析技术的结合可以为系统提供更深入的见解、支持实时决策&#xff0c;并优化模型的性能。以下是数字孪生在大数据和分析技术中的一些应用&#xff0c;希望对大家有所帮助。北京木奇移动技术有限公司&#xff0c;专业的软件外包开发公司&#xff0c;欢迎交流…

美年大健康黄伟:从选型到迁移,一个月升级核心数据库

核心生产系统的数据库&#xff0c;从接到替换需求到完成分布式升级&#xff0c;需要多久&#xff1f;一个月&#xff0c;这是美年大健康的回答。一个月集中调配各种资源&#xff0c;美年大健康完成了应用程序基本零改造的平滑迁移&#xff0c;新数据库在成本更低的前提下&#…

2023-RunwayML-Gen-2 AI视频生成功能发展历程

RunwayML是一个人工智能工具&#xff0c;它为设计师、艺术家和创意人士提供了一种简单的方式来探索和应用机器学习技术。 RunwayML官方网页地址&#xff1a;Runway - Advancing creativity with artificial intelligence. RunwayML专区RunwayML-喜好儿aigcRunwayML 是一种先进…

P1192 台阶问题————C++

目录 台阶问题题目描述输入格式输出格式样例 #1样例输入 #1样例输出 #1 提示 解题思路Code运行结果 台阶问题 题目描述 有 N N N 级台阶&#xff0c;你一开始在底部&#xff0c;每次可以向上迈 1 ∼ K 1\sim K 1∼K 级台阶&#xff0c;问到达第 N N N 级台阶有多少种不同方…

电商平台低价品牌要如何处理

低价会影响品牌渠道的长期发展&#xff0c;同时还会衍生很多问题&#xff0c;如为了追求低价而导致的店铺窜货、商品假货等&#xff0c;对于渠道来说&#xff0c;都是要及时解决的问题&#xff0c;否则渠道乱了&#xff0c;最终腐蚀的是品牌价值&#xff0c;同时还会影响经销商…

【LeetCode-剑指offer】--1.两数相除

1.两数相除 方法&#xff1a;使用减法实现除法 用“被减数”能减去几次“减数”来衡量最后的结果&#xff0c;这时候我们想到求x的幂次的快速解法&#xff0c;将x成倍成倍的求幂&#xff0c;这里将减数成倍成倍的增大&#xff0c;次数对应也是成倍成倍的增大&#xff0c;例如&…

虚幻UE 增强输入-第三人称模板增强输入分析与扩展

本篇是增强输入模块&#xff0c;作为UE5.0新增加的模块。 其展现出来的功能异常地强大&#xff01; 让我们先来学习学习一下第三人称模板里面的增强输入吧&#xff01; 文章目录 前言一、增强输入四大概念二、使用步骤1、打开增强输入模块2、添加IA输入动作2、添加IMC输入映射内…

【亚马逊云科技】自家的AI助手 - Amazon Q

写在前面&#xff1a;博主是一只经过实战开发历练后投身培训事业的“小山猪”&#xff0c;昵称取自动画片《狮子王》中的“彭彭”&#xff0c;总是以乐观、积极的心态对待周边的事物。本人的技术路线从Java全栈工程师一路奔向大数据开发、数据挖掘领域&#xff0c;如今终有小成…