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

死信队列

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:5672connection-timeout: 15000password: guestusername: guest# 使用启用消息确认模式
#    publisher-confirms: truevirtual-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";@BeanTopicExchange myExchange() {return new TopicExchange(EXCHANGE_NAME);}@BeanBinding binding(Queue myQueue, TopicExchange myExchange) {return BindingBuilder.bind(myQueue).to(myExchange).with(ROUTING_KEY);}/*** 定义死信交换机* @return DirectExchange*/@Beanpublic DirectExchange deadLetterExchange() {return new DirectExchange(DEAD_LETTER_EXCHANGE);}/*** 定义死信队列* @return Queue*/@Beanpublic Queue deadLetterQueue() {return new Queue(DEAD_LETTER_QUEUE,true,false,false,null);}/*** 死信队列绑定死信交换机* @param deadLetterQueue 死信队列* @param deadLetterExchange 死信交换机* @return Binding*/@Beanpublic Binding deadLetterBinding(Queue deadLetterQueue, DirectExchange deadLetterExchange) {return BindingBuilder.bind(deadLetterQueue).to(deadLetterExchange).with(DEAD_LETTER_ROUTING_KEY);}/*** 普通队列声明指定死信交换机* @return*/@Beanpublic 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 {@Autowiredprivate 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.mzph.cn/news/786280.shtml

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

相关文章

1236. 递增三元组：做题笔记

1236. 递增三元组：做题笔记

目录 暴力 代码 二分 代码 前缀和 代码 推荐视频讲解 暴力 这道题说的是有三个元素数量相同的数组&#xff0c;想知道有多少个三元组满足&#xff1a;三个数分别来自 A B C数组且呈现递增。 我想的是既然要求递增&#xff0c;那就先把数组数据都排一下序&#xff0c;…
阅读更多...
springCloudAlibaba集成gateWay实战（详解）

springCloudAlibaba集成gateWay实战（详解）

一、初识网关&#xff1f; 1、网关介绍 ​ 在微服务架构中&#xff0c;一个系统会被拆分为很多个微服务。那么作为客户端要如何去调用这么多的微服务呢&#xff1f;如果没有网关的存在&#xff0c;我们只能在客户端记录每个微服务的地址&#xff0c;然后分别去调用。这样的话…
阅读更多...
SpringMVC源码分析(九)--返回值解析器

SpringMVC源码分析(九)--返回值解析器

1.返回值解析器介绍 返回值解析器用于解析Hanlder执行方法后的返回结果，例如将方法上标注有@ResponseBody注解的返回值解析成JSON、将方法返回的字符串作为视图名等 SpringMVC中默认的返回值解析器见RequestMappingHandlerAdapter#getDefaultReturnValueHandlers private L…
阅读更多...
灵活的云计算：可移植性架构的多维优势

灵活的云计算：可移植性架构的多维优势

Bottom of Form 从敏捷开发的视角来看&#xff0c;大多数场景下&#xff0c;我们在构建应用程序时&#xff0c;都会希望实现快速开发、缩短上线周期&#xff0c;并充分利用云提供商的成型组件服务&#xff0c;来获得更好的稳定性。若想要达成理想成果&#xff0c;我们在具体过…
阅读更多...
【opencv】教程代码 —features2D（8）AKAZE 特征点匹配和图像拼接

【opencv】教程代码 —features2D（8）AKAZE 特征点匹配和图像拼接

graf1.png graf3.png <?xml version"1.0"?> <opencv_storage> <H13 type_id"opencv-matrix"><rows>3</rows><cols>3</cols><dt>d</dt><data>7.6285898e-01 -2.9922929e-01 2.2567123e02…
阅读更多...
matlab碰撞检测

matlab碰撞检测

文章目录 碰撞对象collisionCylindercollisionBoxcollisionMeshcollisionSpherecollisionCapsulecheckCollisionfitCollisionCapsuleshowCollisionArraycapsuleApproximationaddCapsuleremoveCapsuleconvertToCollisionMesh碰撞对象 函数功能checkCollision检测两几何体是否存在…
阅读更多...
【WPF应用26】C#中的CheckBox控件详解与应用示例

【WPF应用26】C#中的CheckBox控件详解与应用示例

在WPF&#xff08;Windows Presentation Foundation&#xff09;应用中&#xff0c;C#中的CheckBox控件是一种常用的用户界面元素&#xff0c;允许用户从多个选项中选择一个或多个选项。本文将详细介绍CheckBox控件的功能、使用方法以及在应用程序中的具体应用示例。 1. Check…
阅读更多...
前端之CSS——网页的皮肤！！

前端之CSS——网页的皮肤！！

目录 一、CSS简单介绍 二、css内容 2.1 css的编写方式 2.2 css选择器 2.3 样式属性 2.4 css包围盒 2.5 css中的display 2.6 css中的定位 2.7 css中的浮动与清除 2.7 弹性容器 2.8 字体图标 2.9 …
阅读更多...
Databricks声称DBRX为开源大型语言模型设定了“一个新标准”

Databricks声称DBRX为开源大型语言模型设定了“一个新标准”

Databricks宣布推出DBRX&#xff0c;这是一款强大的新开源大型语言模型&#xff0c;据称它通过在行业基准测试中超越了像GPT-3.5这样的既定选项&#xff0c;为开放模型设定了新的标准。 该公司表示&#xff0c;具有1320亿参数的DBRX模型在语言理解、编程和数学任务上超越了流行…
阅读更多...
如何在 xcode 中使用 string catalogs

如何在 xcode 中使用 string catalogs

在iOS开发中&#xff0c;xcstrings和strings文件在本质上是相似的&#xff0c;但在Xcode 15中引入的Strings Catalogs中有一些重要区别。 xcstrings文件是Strings Catalogs的一部分&#xff0c;它们可以作为单个源文件包含应用程序的所有本地化字符串内容&#xff0c;包括常规…
阅读更多...
1.5编写一个程序，输入梯形的上底，下底和高，输出梯形的面积。

1.5编写一个程序，输入梯形的上底，下底和高，输出梯形的面积。

1、编写一个程序，输入梯形的上底，下底和高，输出梯形的面积。 package com.kangning.web.controller.system;import java.util.Scanner;/*** 编写一个程序，输入梯形的上底，下底和高，输出梯形的面积。*/ public class CountArea {public static void main(String[] args) …
阅读更多...
面向对象编程中的StringBuffer类详解

面向对象编程中的StringBuffer类详解

咦咦咦&#xff0c;各位小可爱&#xff0c;我是你们的好伙伴——bug菌&#xff0c;今天又来给大家普及Java SE相关知识点了&#xff0c;别躲起来啊&#xff0c;听我讲干货还不快点赞&#xff0c;赞多了我就有动力讲得更嗨啦&#xff01;所以呀&#xff0c;养成先点赞后阅读的好…
阅读更多...
【Linux 驱动基础】设备树驱动

【Linux 驱动基础】设备树驱动

# 前置知识 在图中&#xff0c;树的主干就是系统总线&#xff0c; IIC 控制器、 SPI 控制器等都是接到系统主线上的分支。其中 IIC1 上接了 AT24C02这个 IIC 设备&#xff0c; DTS 文件的主要功能就是按照图所示的结构来描述板子上的设备信息。 1. Device格式 DTS文件格式 …
阅读更多...
【论文阅读】ELA: Efficient Local Attention for Deep Convolutional Neural Networks

【论文阅读】ELA: Efficient Local Attention for Deep Convolutional Neural Networks

&#xff08;ELA&#xff09;Efficient Local Attention for Deep Convolutional Neural Networks 论文链接&#xff1a;ELA: Efficient Local Attention for Deep Convolutional Neural Networks (arxiv.org) 作者&#xff1a;Wei Xu, Yi Wan 单位&#xff1a;兰州大学信息…
阅读更多...
IDEA 打包jar

IDEA 打包jar

IDEA MAVEN项目打包成jar包的两种简单方式_idea maven打包jar-CSDN博客
阅读更多...
基于架构的软件开发方法_1.概述和相关概念及术语

基于架构的软件开发方法_1.概述和相关概念及术语

1.体系结构的设计方法概述 基于体系结构的软件设计&#xff08;Architecture-Based Software Design&#xff0c;ABSD&#xff09;方法。ABSD方法是由体系结构驱动的&#xff0c;即指由构成体系结构的商业、质量和功能需求的组合驱动的。 使用ABSD方法&#xff0c;设计活动可以…
阅读更多...
C++项目——集群聊天服务器项目(十一）服务器异常退出与添加好友业务

C++项目——集群聊天服务器项目(十一）服务器异常退出与添加好友业务

本节来实现C集群聊天服务器项目中的服务器异常退出与添加好友业务&#xff0c;一起来试试吧 一、服务器异常退出 在Linux环境下&#xff0c;我们在服务器端使用CTRLC结束程序执行&#xff0c;即使用CTRLC让服务器异常退出&#xff0c;这样的后果是本应登录服务器的用户在数据库…
阅读更多...
vsCode 刷 leetcode 使用 Cookie 登录

vsCode 刷 leetcode 使用 Cookie 登录

1. 安装插件 打开 vsCode&#xff0c;选择扩展&#xff0c;搜索 leetcode&#xff0c;选择第一个&#xff0c;带有中文力扣字样&#xff0c;安装后重启 2. 切换终端 插件安装成功之后&#xff0c;侧边栏选择 leetcode 菜单&#xff0c;切换终端&#xff0c;选择中文版本&…
阅读更多...
jvm 调优的方式

jvm 调优的方式

jvm调优 什么是jvm JVM&#xff08;Java虚拟机&#xff09;是Java编程语言的运行环境&#xff0c;它是一个虚拟的计算机&#xff0c;能够将Java字节码&#xff08;.class文件&#xff09;转换为机器码并执行。JVM是Java应用程序和Java平台之间的中间层&#xff0c;它提供了内…
阅读更多...
HarmonyOS 应用开发之XML生成、解析与转换

HarmonyOS 应用开发之XML生成、解析与转换

XML&#xff08;可扩展标记语言&#xff09;是一种用于描述数据的标记语言&#xff0c;旨在提供一种通用的方式来传输和存储数据&#xff0c;特别是Web应用程序中经常使用的数据。XML并不预定义标记。因此&#xff0c;XML更加灵活&#xff0c;并且可以适用于广泛的应用领域。 …
阅读更多...
最新文章

Copyright @ 2022~2023