RabbitMQ安装及Springboot 集成RabbitMQ实现消息过期发送到死信队列

news2024/11/24 16:47:13

死信队列

RabbitMQ 的死信队列（Dead-Letter-Exchanges，简称 DLX）是一个强大的特性，它允许在消息在队列中无法被正常消费（例如，消息被拒绝并且没有设置重新入队，或者消息过期）时，将这些消息转发到另一个交换机。这个特性在很多场景下都非常有用，比如重试机制、延迟队列等。

以下是关于 RabbitMQ 死信队列的一些要点：

如何设置死信队列

要设置死信队列，你需要在队列声明时指定几个参数：

x-dead-letter-exchange：指定消息在变为死信后要发送到的交换机。
x-dead-letter-routing-key（可选）：指定消息在变为死信后使用的路由键。如果未设置，则使用原消息的路由键。
message-ttl 或 x-message-ttl（可选）：设置消息的生存时间（TTL）。当消息在队列中的时间超过此值后，它将成为死信。
x-max-length（可选）：设置队列的最大长度。当队列中的消息数量超过此值时，最早的消息将成为死信。
这些参数可以通过 RabbitMQ 的管理界面、命令行工具或编程 API 设置。

死信队列的工作流程

当一个消息在队列中由于某些原因（如过期、被拒绝且未设置重新入队、队列达到最大长度等）成为死信时。
RabbitMQ 会检查该队列是否配置了 x-dead-letter-exchange。
如果配置了，RabbitMQ 会将死信发送到指定的死信交换机。
死信交换机再根据配置的路由键或原消息的路由键将消息路由到相应的队列。

windows安装RabbitMQ

RabbitMQ是建立在强大的Erlang OTP平台上，因此安装Rabbit MQ的前提是安装Erlang。

安装Erlang

因为RabbitMQ服务器是用Erlang语言编写的， 所以，你需要去查看rabbitMq适应Erlang的版本，因为不同的rabbitMq版本对应不同的Erlang版本，可以点击如下该链接查看版本匹配度：
https://www.rabbitmq.com/which-erlang.html#compatibility-matrix

下载地址：Erlang
推荐使用链接: https://download.csdn.net/download/weixin_42123075/89064540，这里包含Erlang和对应版本的RabbitMQ。
下载完成后先安装Erlang。

RabbitMQ安装

下载地址： https://github.com/rabbitmq/rabbitmq-server/releases?page=7

设置环境变量

  1. windows + R 在左下角的弹出框中输入control system
  2. 点击高级系统设置，点击环境变量
  3. 系统变量，新建变量名：RABBITQM_SERVER
    变量值：rabbitmq安装地址bin目录之前的地址，比如我的是D:\Software\rabbitmq\rabbitmq_server-3.8.15
  4. 找到系统变量中的PATH，点击编辑，点击新建，输入%RABBITQM_SERVER%\sbin，点击确定。

安装 rabbitmq_management

  1. 打开Windows Poweshell或者cmd，输入如下指令
rabbitmq-plugins list

如下图所示
在这里插入图片描述

  1. 安装rabbitmq_management插件
    这款插件是可以可视化的方式查看RabbitMQ服务器实例的状态，以及操控RabbitMQ服务器。
rabbitmq-plugins enable rabbitmq_management

如下图所示
在这里插入图片描述

  1. 启动rabbitMq服务

安装rabbitMq的目录(我的是D:\Software\rabbitmq\rabbitmq_server-3.8.15) -> sbin目录 -> 双击rabbitmq-server.bat，我如下图所示：
在这里插入图片描述

  1. 如果启动报错在这里插入图片描述
    原因是：原先的RabbitMq数据与新的RabbitMq有些不兼容
    解决方案：
    sudo rm -rf /var/lib/rabbitmq/mnesia
    win解决方案，在 RabbitMQ 安装目录中找到 mnesia 目录（通常在 C:\Users\AppData\Roaming\RabbitMQ\db），然后删除其中的文件
    参考： https://www.cnblogs.com/gaoyuechen/p/10368188.html,重新启动。
    启动成功，但程序不是以deamon形式运行。只要执行-detached可执行成功。
rabbitmq-server -detached
  1. 访问http://localhost:15672/管理页面，用户名，密码默认均为guest。

创建死信队列和交换机

创建dead-letter-queue死信队列

在这里插入图片描述

创建dead-letter-exchange死信交换机，并绑定死信队列

在这里插入图片描述
在这里插入图片描述

创建普通队列和普通交换机并指定死信交换机

创建普通队列myQueue和普通交换机myExchange，交换机类型为Topic，并指定死信队列
在这里插入图片描述

SpringBoot集成RabbitMQ

添加maven依赖

<!--  RabbitMQ -->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-amqp</artifactId>
        </dependency>

在yml配置文件中的spring下添加RabbitMQ的连接信息

spring:
  rabbitmq:
    addresses: localhost:5672
    connection-timeout: 15000
    password: guest
    username: guest
    # 使用启用消息确认模式
#    publisher-confirms: true
	virtual-host: /

RabbitMQConfig


import org.springframework.amqp.core.*;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class RabbitMQConfig {

    // 普通队列
    public final static String QUEUE_NAME = "myQueue";
    // 普通交换机
    public final static String EXCHANGE_NAME = "myExchange";
    // 普通队列路由
    public final static String ROUTING_KEY = "myRoutingKey";

    // 死信交换机
    public static final String DEAD_LETTER_EXCHANGE = "dead-letter-exchange";
    // 死信队列
    public static final String DEAD_LETTER_QUEUE = "dead-letter-queue";
    // 死信路由
    public static final String DEAD_LETTER_ROUTING_KEY = "dead-letter-key";

    @Bean
    TopicExchange myExchange() {
        return new TopicExchange(EXCHANGE_NAME);
    }

    @Bean
    Binding binding(Queue myQueue, TopicExchange myExchange) {
        return BindingBuilder.bind(myQueue).to(myExchange).with(ROUTING_KEY);
    }

    /**
     * 定义死信交换机
     * @return DirectExchange
     */
    @Bean
    public DirectExchange deadLetterExchange() {
        return new DirectExchange(DEAD_LETTER_EXCHANGE);
    }

    /**
     * 定义死信队列
     * @return Queue
     */
    @Bean
    public Queue deadLetterQueue() {
        return new Queue(DEAD_LETTER_QUEUE,true,false,false,null);
    }

    /**
     * 死信队列绑定死信交换机
     * @param deadLetterQueue 死信队列
     * @param deadLetterExchange 死信交换机
     * @return Binding
     */
    @Bean
    public Binding deadLetterBinding(Queue deadLetterQueue, DirectExchange deadLetterExchange) {
        return BindingBuilder.bind(deadLetterQueue).to(deadLetterExchange).with(DEAD_LETTER_ROUTING_KEY);
    }

    /**
     * 普通队列声明指定死信交换机
     * @return
     */
    @Bean
    public Queue myQueue() {
        return QueueBuilder.durable(QUEUE_NAME)
                // 设置死信交换机
                .withArgument("x-dead-letter-exchange", DEAD_LETTER_EXCHANGE)
                // 设置死信路由键
                .withArgument("x-dead-letter-routing-key", DEAD_LETTER_ROUTING_KEY)
                // 设置队列最大长度
                // .withArgument("x-max-length", 5)
                .build();
    }


}

发送消息类RabbitMQService

import com.ruoyi.quartz.config.RabbitMQConfig;
import org.springframework.amqp.core.AmqpTemplate;
import org.springframework.amqp.core.Message;
import org.springframework.amqp.core.MessageBuilder;
import org.springframework.amqp.core.MessageProperties;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

@Service
public class RabbitMQService {
 
    @Autowired
    private AmqpTemplate rabbitTemplate;
 
    public void send(String message) {
        rabbitTemplate.convertAndSend(RabbitMQConfig.EXCHANGE_NAME, RabbitMQConfig.ROUTING_KEY, message);
    }

    /**
     * 发送消息并设置过期时间
     * @param exchange 交换机
     * @param routingKey 路由
     * @param messageBody 消息体
     * @param expirationTimeInMillis 过期时间，单位：毫秒
     */
    public void sendMessageWithExpiration(String exchange, String routingKey, String messageBody, int expirationTimeInMillis) {
        MessageProperties properties = new MessageProperties();
        // 设置消息的过期时间
        properties.setExpiration(String.valueOf(expirationTimeInMillis));

        Message message = MessageBuilder.withBody(messageBody.getBytes())
                .andProperties(properties)
                .build();

        rabbitTemplate.convertAndSend(exchange, routingKey, message);
    }
}

监听队列接收消息ReceiverService


import com.ruoyi.quartz.config.RabbitMQConfig;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Service;

import java.text.SimpleDateFormat;
import java.util.Date;

@Service
public class ReceiverService {

    /**
     * 监听队列消息 如果要测试死信队列，就不要监听此队列
     * @param message 消息
     */
//    @RabbitListener(queues = RabbitMQConfig.QUEUE_NAME)
    public void receive(String message) {
        System.out.println("Received <" + message + ">");
    }

    /**
     * 监听死信队列
     * @param message
     */
    @RabbitListener(queues = RabbitMQConfig.DEAD_LETTER_QUEUE)
    public void processDeadLetter(String message) {
        String time = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date());
        System.out.println("Received dead letter message: " + message + "，当前时间：" + time);
        // 处理死信队列中的消息
    }
}

测试死信队列

    @GetMapping("/sendMessageTtl/{message}")
    public void sendMessageTtl(@PathVariable String message){
        log.info("当前时间发送:{},发送5条消息给两个TTL队列:{}",new Date().toString(),message);
        for (int i = 0; i < 6; i++) {
            System.out.println("测试延迟队列======="+DateUtils.parseDateToStr(DateUtils.YYYY_MM_DD_HH_MM_SS,new Date()));
        	rabbitMQService.sendMessageWithExpiration(RabbitMQConfig.EXCHANGE_NAME,RabbitMQConfig.ROUTING_KEY,"测试5秒延迟==============》",5000);
        }
    }

5秒后私信队列收到消息

在这里插入图片描述

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

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

在 Three.js 中，`USDZExporter` 类用于将场景导出为 USDZ 格式，这是一种用于在 iOS 平台上显示增强现实（AR）内容的格式。

在 Three.js 中，`USDZExporter` 类用于将场景导出为 USDZ 格式，这是一种用于在 iOS 平台上显示增强现实（AR）内容的格式。

demo 案例 在 Three.js 中&#xff0c;USDZExporter 类用于将场景导出为 USDZ 格式&#xff0c;这是一种用于在 iOS 平台上显示增强现实&#xff08;AR&#xff09;内容的格式。下面是关于 USDZExporter 的入参、出参、方法和属性的讲解&#xff1a; 入参 (Parameters): sc…
阅读更多...
解决Quartus与modelsim联合仿真问题：# Error loading design解决，是tb文件中没加：`timescale 1ns/1ns

解决Quartus与modelsim联合仿真问题：# Error loading design解决，是tb文件中没加：`timescale 1ns/1ns

解决Quartus与modelsim联合仿真问题&#xff1a;# Error loading design解决&#xff0c;是tb文件中没加&#xff1a;timescale 1&#xff0c;一直走下来&#xff0c;在modelsim中出现了下面问题2&#xff0c;rtl文件、tb文件2.1&#xff0c;rtl代码2.2&#xff0c;tb测试2.3&a…
阅读更多...
C# WPF编程-Application类（生命周期、程序集资源、本地化）

C# WPF编程-Application类（生命周期、程序集资源、本地化）

C# WPF编程-Application类 应用程序的生命周期创建Application对象应用程序的关闭方式应用程序事件 Application类的任务显示初始界面处理命令行参数访问当前Application对象在窗口之间进行交互 程序集资源添加资源检索资源pack URI内容文件 本地化构建能够本地化的用户界面 每…
阅读更多...
Day5-

Day5-

Hive 窗口函数 案例 需求&#xff1a;连续三天登陆的用户数据 步骤&#xff1a; -- 建表 create table logins (username string,log_date string ) row format delimited fields terminated by ; -- 加载数据 load data local inpath /opt/hive_data/login into table log…
阅读更多...
封装表格组件，最后一列动态生成 vue3子组件通过slot传值向父组件

封装表格组件，最后一列动态生成 vue3子组件通过slot传值向父组件

将表格二次封装&#xff0c;方便以后开发中的复用。每次只需调用表格组件后&#xff0c;在父组件中往子组件标签上写入dataSource&#xff08;表格数据&#xff09;和columns&#xff08;表格列标题&#xff09;即可。 此案例中最后一列是删除按钮&#xff0c;动态生成&#xf…
阅读更多...
如何提高图片的分辨率？dpi修改工具推荐

如何提高图片的分辨率？dpi修改工具推荐

在调整分辨率之前&#xff0c;我们需要了解什么是dpi分辨率&#xff0c;简单来说&#xff0c;分辨率是指图像中包含的像素数量&#xff0c;分辨率越高&#xff0c;图像就越清晰&#xff0c;常见的分辨率包括72dpi、96dpi和300dpi等&#xff0c;在打印照片或者一些考试平台对图片…
阅读更多...
uniapp 开发之原生Android插件

uniapp 开发之原生Android插件

开发须知 在您阅读此文档时&#xff0c;我们假定您已经具备了相应Android应用开发经验&#xff0c;使用Android Studio开发过Android原生。也应该对HTML,JavaScript,CSS等有一定的了解, 并且熟悉在JavaScript和JAVA环境下的JSON格式数据操作等。 为了插件开发者更方便快捷的开…
阅读更多...
【论文阅读】DETR 论文逐段精读

【论文阅读】DETR 论文逐段精读

【论文阅读】DETR 论文逐段精读 文章目录 【论文阅读】DETR 论文逐段精读&#x1f4d6;DETR 论文精读【论文精读】&#x1f310;前言&#x1f4cb;摘要&#x1f4da;引言&#x1f9ec;相关工作&#x1f50d;方法&#x1f4a1;目标函数&#x1f4dc;模型结构⚙️代码 &#x1f4…
阅读更多...
Django源码之路由匹配（下）——图解逐步分析底层源码

Django源码之路由匹配（下）——图解逐步分析底层源码

目录 1. 前言 2. 路由匹配全过程分析 2.1 请求的入口 2.2 request的封装 2.3 response的源头 2.4 handler的获取 2.5 获取resolver对象 2.6 路由进行匹配 3. 小结 1. 前言 在上一篇文章中&#xff0c;我们谈到了路由的定义&#xff0c;通过URLPattern路由路径对象和Rou…
阅读更多...
c/c++ | socket tcp client server

c/c++ | socket tcp client server

突然想着&#xff0c;花一个socket tcp 客户-服务通信 这应该是很经典的流程了吧 感觉还是要训练这种随手画图的能力&#xff0c;毕竟文字的描述还是不及图片强烈 参考01
阅读更多...
基于深度学习的停车场车辆检测算法matlab仿真

基于深度学习的停车场车辆检测算法matlab仿真

目录 1.算法运行效果图预览 2.算法运行软件版本 3.部分核心程序 4.算法理论概述 5.算法完整程序工程 1.算法运行效果图预览 上图测试结果如下图所示&#xff1a; 2.算法运行软件版本 matlab2022a 3.部分核心程序 image imread(image_test\test.jpg); image2 image;%图…
阅读更多...
九河云携手华为云推出海外电商解决方案，一体化解决出海问题

九河云携手华为云推出海外电商解决方案，一体化解决出海问题

随着国内竞争的日益激烈&#xff0c;国内企业的出海热情正在逐步提高。国外尤其是东南亚等地区&#xff0c;正在成为企业营收的新增长点。九河云携手华为云为客户带来了海外电商部署方案。华为云作为增长最快的云服务提供商&#xff0c;秉持着为客户提供最优质服务的原则&#…
阅读更多...
Vue项目中引入html页面（vue.js中引入echarts数据大屏html [静态非数据传递!] ）

Vue项目中引入html页面（vue.js中引入echarts数据大屏html [静态非数据传递!] ）

在项目原有vue&#xff08;例如首页&#xff09;基础上引入html页面 1、存放位置 vue3原有public文件夹下 我这边是新建一个static文件夹 专门存放要用到的html文件 复制拖拽过来 index为html的首页 2、更改路径引入到vue中 这里用到的是 iframe 方法 不同于vue的 component…
阅读更多...
C#实现Word文档转Markdown格式（Doc、Docx、RTF、XML、WPS等）

C#实现Word文档转Markdown格式（Doc、Docx、RTF、XML、WPS等）

文档格式的多样性丰富了我们的信息交流手段&#xff0c;其中Word文档因其强大的功能性而广受欢迎。然而&#xff0c;在网络分享、版本控制、代码阅读及编写等方面&#xff0c;Markdown因其简洁、易于阅读和编辑的特性而展现出独特的优势。将Word文档转换为Markdown格式&#xf…
阅读更多...
vue改名为威优易？

vue改名为威优易？

文章目录 vue改名为威优易&#xff1f; 祝大家愚人节快乐哇&#xff01; 哈哈&#xff0c;大家愚人节快乐&#xff01;看来我刚刚的“爆料”确实把大家吓了一跳&#xff0c;Vue.js要改名为“威优易”&#xff1f;这纯粹是官方在这个愚人节使者开的一个小小玩笑啦&#xff01; …
阅读更多...
修改Gradio界面中按钮Submit、Clear，Flag为中文，修改additional_inputs标签。

修改Gradio界面中按钮Submit、Clear，Flag为中文，修改additional_inputs标签。

展示如图 Submit、Clear、additional_inputs标签 Submit、Clear修改 修改gradio库中interface.py additional_inputs标签 同一文件下 flag修改 flag展示
阅读更多...
vscode批量编辑行头行尾

vscode批量编辑行头行尾

ctrlf查找那儿将最后的星星选中即为正则表达式模式 ^ 表示行头$ 表示行尾 例如&#xff0c;在行首添加大括号{ &#xff1a; vsCode中可以使用正则表达式模式找到换行。指定字符替换成换行&#xff0c;在替换字符串里将换行用\n表示就可以了。 查找换行符也是在查找那儿使用\…
阅读更多...
【C语言进阶】- 内存函数

【C语言进阶】- 内存函数

内存函数 1.1 内存函数的使用1.2 memcpy函数的使用1.3 memcpy函数的模拟实现2.1 memmove函数的使用2.2 memmove函数的模拟实现2.3 memcmp函数的使用2.4 memset函数的使用 1.1 内存函数的使用 内存函数就是对内存中的数据进行操作的函数 1.2 memcpy函数的使用 void* memcpy ( …
阅读更多...
机器学习： 绪论（基础概念）

机器学习： 绪论（基础概念）

文章目录 一、机器学习做什么二、机器学习的基本术语2.1、数据相关2.1.1、数据集2.1.2、特征&#xff08;Feature&#xff09;2.1.3、样本空间&#xff08;Sample Space&#xff09; 2.2、任务相关2.2.1、分类2.2.2、回归2.2.3、聚类2.2.4、监督学习和无监督学习 三、机器学习思…
阅读更多...
在CentOS 8.5.2111下安装vncserver

在CentOS 8.5.2111下安装vncserver

# 参考&#xff1a; 如何在 CentOS 8/RHEL 8 上安装配置 VNC 服务器 安装CentOS 8.5.2111 及 vncserver # 标准安装步骤 安装GNOME桌面环境使用屏幕号:1。安装VNC服务器&#xff08;tigervnc-server tigervnc&#xff09;设置VNC密码设置VNC服务器配置文件开启vnc服务。开放防…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023