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

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 交换机用于延迟消息的投递,需要安装额外的插件。

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

相关文章:

rabbitmq延时队列相关配置

确保 RabbitMQ 的延时消息插件已经安装和启用。你可以通过执行以下命令来安装该插件: rabbitmq-plugins enable rabbitmq_delayed_message_exchange 如果提示未安装,以下是安装流程: 查看mq版本: 查看自己使用的 MQ(…...

【工具】推荐一个好用的代码画图工具

PlantUML 官网地址:https://plantuml.com/zh/ 跳转 支持各种结构化数据画图支持代码调用jar包生成图片 提供在线画图能力 https://www.plantuml.com/plantuml/uml/SyfFKj2rKt3CoKnELR1Io4ZDoSa70000 有兴趣可以尝试下 over~~...

Leetcode14-判断句子是否为全字母句(1832)

1、题目 全字母句 指包含英语字母表中每个字母至少一次的句子。 给你一个仅由小写英文字母组成的字符串 sentence ,请你判断 sentence 是否为 全字母句 。 如果是,返回 true ;否则,返回 false 。 示例 1: 输入&am…...

HTTP和TCP代理原理及实现,主要是理解

Web 代理是一种存在于网络中间的实体,提供各式各样的功能。现代网络系统中,Web 代理无处不在。我之前有关 HTTP 的博文中,多次提到了代理对 HTTP 请求及响应的影响。今天这篇文章,我打算谈谈 HTTP 代理本身的一些原理,…...

MySQL中的连接池

数据库的连接池 1 )概述 网站连接数据库,为庞大用户的每次请求创建一个连接是不合适的关闭并重新连接的成本是很大的处理方法:设置最大值, 最小值, 设置最多闲置连接,设置等待阻塞 2 )示例演示 import threading i…...

css计时器 animation实现计时器延时器

css计时器 animation实现计时器延时器 缺点当切页面导航会休眠不执行 最初需求是一个列表每个项目都有各自的失效时间 然后就想到 计时器延时器轮询等方案 这些方案每一个都要有自己的计时器 感觉不是很好 轮询也占资源 然后突发奇想 css能不能实现 开始想到的是transition测…...

【win11 绕过TPM CPU硬件限制安装】

Qt编程指南 VX:hao541022348 ■ 下载iso文件■ 右键文件点击装载出现如下问题■ 绕过TPM CPU硬件限制安装方法■ 虚拟机安装win11 ■ 下载iso文件 选择Windows11 (multi-edition ISO)在选择中文 ■ 右键文件点击装载出现如下问题 ■ 绕过T…...

k8s的yaml文件中的kind类型都有哪些?(清单版本)

在操作kubernetes的过程中,我们接触到的yaml文件中的kind类型有很多。他们代表了kubernetes的不同类型的对象,了解了kind的类型,也就相当于了解了k8s都有哪些类型的对象。 类型清单及概要说明 序号类型简述1Pod一个Kubernetes中最基本的资源…...

Jetpack Room使用

Room使用 回顾 数据库有多张表,一张表只能记录一种Class,Class的具体属性是这个表的列;所有对表的操作都要通过Dao来访问 注解说明: Enity 作用于Class上,表示创建一张表记录该Class,Class内部属性使用…...

HarmonyOS应用开发之ArkTS语言学习记录

1、ArkTS介绍 ArkTS是鸿蒙生态的应用开发语言。它在保持TypeScript(简称TS)基本语法风格的基础上,对TS的动态类型特性施加更严格的约束,引入静态类型。同时,提供了声明式UI、状态管理等相应的能力,让开发者…...

windows 下 mongodb6.0 导入导出json文件

1.运行cmd窗口&#xff0c;进入MongoDB安装路径下的bin文件下&#xff0c;输入以下命令导入数据文件 mongoimport --host 127.0.0.1 --port 27017 --db <数据库名称&#xff0c;根据自个情况> -c <集合名称&#xff0c;自定义> --file <导入文件的路径名> …...

如何给 unplugin-vue-components/vite 写一个简单的 resolver

大部分工作 unplugin-vue-components 都已经处理好了, 我们只需要接收组件名来判断是否是自己的组件, 然后处理对应的导入逻辑。 一共 3 个字段 as 重命名类似 import { componentNameReName } from ‘xxxx’name 组件名 import { componentName } from ‘xxxx’from 导入路径…...

MYSQL篇--索引高频面试题

mysql索引 1什么是索引&#xff1f; 索引说白了就是一种数据结构&#xff0c;可以协助快速查询数据&#xff0c;以及更新数据库表中的数据&#xff0c;更通俗的来说索引其实就是目录&#xff0c;通过对数据建立索引形成目录&#xff0c;便于去查询数据&#xff0c;而mysql索引…...

视频号小店怎么上架商品?实操分享,干货满满!

我是电商珠珠 视频号小店从22年7月到现在也不过才发展了一年&#xff0c;它的风口才刚刚开始。 平台为了吸引商家入驻&#xff0c;会将大量红利向商家倾斜&#xff0c;只要把握住风口&#xff0c;就会很快起飞。 视频号小店对于很多人来说&#xff0c;都是新平台&#xff0c…...

Python 常用数据类型

Python 常用数据类型有以下这些&#xff1a; 数据类型中文解析例子int整数&#xff0c;表示整数值1、2float浮点数&#xff0c;表示带有小数点的数值3.14、2.718complex复数&#xff0c;表示实部和虚部组成的复数12j、3-4jstr字符串&#xff0c;表示文本数据&#xff0c;用引号…...

基于yolov2深度学习网络的车辆行人检测算法matlab仿真

目录 1.算法运行效果图预览 2.算法运行软件版本 3.部分核心程序 4.算法理论概述 5.算法完整程序工程 1.算法运行效果图预览 2.算法运行软件版本 MATLAB2022a 3.部分核心程序 .......................................................... load yolov2.mat% 加载训练好的…...

【QT】中英文切换

很高兴在雪易的CSDN遇见你 前言 本文分享QT中如何进行中英文切换&#xff0c;希望对各位小伙伴有所帮助&#xff01; 感谢各位小伙伴的点赞关注&#xff0c;小易会继续努力分享&#xff0c;一起进步&#xff01; 你的点赞就是我的动力(&#xff3e;&#xff35;&#xff3e…...

vue实现代码编辑器,无坑使用CodeMirror

vue实现代码编辑器,无坑使用CodeMirror vue实现代码编辑器,使用codemirror5 坑&#xff1a;本打算cv一下网上的&#xff0c;结果发现网上的博客教程都是错的&#xff0c;而且博客已经是几年前的了&#xff0c;我重新看了github上的&#xff0c;发现安装的命令都已经不一样了。我…...

MR实战:网址去重

文章目录 一、实战概述二、提出任务三、完成任务&#xff08;一&#xff09;准备数据1、在虚拟机上创建文本文件2、上传文件到HDFS指定目录 &#xff08;二&#xff09;实现步骤1、创建Maven项目2、添加相关依赖3、创建日志属性文件4、创建网址去重映射器类5、创建网址去重归并…...

linux 内核编译安装

一、配置 默认配置 make ARCHarm CROSS_COMPILEarm-linux-gnueabihf- omap2plus_defconfig原配置 make ARCHarm CROSS_COMPILEarm-linux-gnueabihf- oldconfig 重新配置 make ARCHarm CROSS_COMPILEarm-linux-gnueabihf- menuconfig二 kernel zImage make ARCHarm CRO…...

eNSP-Cloud(实现本地电脑与eNSP内设备之间通信)

说明&#xff1a; 想象一下&#xff0c;你正在用eNSP搭建一个虚拟的网络世界&#xff0c;里面有虚拟的路由器、交换机、电脑&#xff08;PC&#xff09;等等。这些设备都在你的电脑里面“运行”&#xff0c;它们之间可以互相通信&#xff0c;就像一个封闭的小王国。 但是&#…...

【SpringBoot】100、SpringBoot中使用自定义注解+AOP实现参数自动解密

在实际项目中,用户注册、登录、修改密码等操作,都涉及到参数传输安全问题。所以我们需要在前端对账户、密码等敏感信息加密传输,在后端接收到数据后能自动解密。 1、引入依赖 <dependency><groupId>org.springframework.boot</groupId><artifactId...

ESP32读取DHT11温湿度数据

芯片&#xff1a;ESP32 环境&#xff1a;Arduino 一、安装DHT11传感器库 红框的库&#xff0c;别安装错了 二、代码 注意&#xff0c;DATA口要连接在D15上 #include "DHT.h" // 包含DHT库#define DHTPIN 15 // 定义DHT11数据引脚连接到ESP32的GPIO15 #define D…...

蓝牙 BLE 扫描面试题大全(2):进阶面试题与实战演练

前文覆盖了 BLE 扫描的基础概念与经典问题蓝牙 BLE 扫描面试题大全(1)&#xff1a;从基础到实战的深度解析-CSDN博客&#xff0c;但实际面试中&#xff0c;企业更关注候选人对复杂场景的应对能力&#xff08;如多设备并发扫描、低功耗与高发现率的平衡&#xff09;和前沿技术的…...

【SQL学习笔记1】增删改查+多表连接全解析(内附SQL免费在线练习工具)

可以使用Sqliteviz这个网站免费编写sql语句&#xff0c;它能够让用户直接在浏览器内练习SQL的语法&#xff0c;不需要安装任何软件。 链接如下&#xff1a; sqliteviz 注意&#xff1a; 在转写SQL语法时&#xff0c;关键字之间有一个特定的顺序&#xff0c;这个顺序会影响到…...

spring:实例工厂方法获取bean

spring处理使用静态工厂方法获取bean实例&#xff0c;也可以通过实例工厂方法获取bean实例。 实例工厂方法步骤如下&#xff1a; 定义实例工厂类&#xff08;Java代码&#xff09;&#xff0c;定义实例工厂&#xff08;xml&#xff09;&#xff0c;定义调用实例工厂&#xff…...

现代密码学 | 椭圆曲线密码学—附py代码

Elliptic Curve Cryptography 椭圆曲线密码学&#xff08;ECC&#xff09;是一种基于有限域上椭圆曲线数学特性的公钥加密技术。其核心原理涉及椭圆曲线的代数性质、离散对数问题以及有限域上的运算。 椭圆曲线密码学是多种数字签名算法的基础&#xff0c;例如椭圆曲线数字签…...

汇编常见指令

汇编常见指令 一、数据传送指令 指令功能示例说明MOV数据传送MOV EAX, 10将立即数 10 送入 EAXMOV [EBX], EAX将 EAX 值存入 EBX 指向的内存LEA加载有效地址LEA EAX, [EBX4]将 EBX4 的地址存入 EAX&#xff08;不访问内存&#xff09;XCHG交换数据XCHG EAX, EBX交换 EAX 和 EB…...

重启Eureka集群中的节点,对已经注册的服务有什么影响

先看答案&#xff0c;如果正确地操作&#xff0c;重启Eureka集群中的节点&#xff0c;对已经注册的服务影响非常小&#xff0c;甚至可以做到无感知。 但如果操作不当&#xff0c;可能会引发短暂的服务发现问题。 下面我们从Eureka的核心工作原理来详细分析这个问题。 Eureka的…...

Redis的发布订阅模式与专业的 MQ(如 Kafka, RabbitMQ)相比,优缺点是什么?适用于哪些场景?

Redis 的发布订阅&#xff08;Pub/Sub&#xff09;模式与专业的 MQ&#xff08;Message Queue&#xff09;如 Kafka、RabbitMQ 进行比较&#xff0c;核心的权衡点在于&#xff1a;简单与速度 vs. 可靠与功能。 下面我们详细展开对比。 Redis Pub/Sub 的核心特点 它是一个发后…...