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;然后分别去调用。这样的话…
阅读更多...
【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检测两几何体是否存在…
阅读更多...
前端之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 …
阅读更多...
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;兰州大学信息…
阅读更多...
基于架构的软件开发方法_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;选择中文版本&…
阅读更多...
海康摄像头插件嵌入iframe时视频播放插件位置问题

海康摄像头插件嵌入iframe时视频播放插件位置问题

参考&#xff1a;https://juejin.cn/post/6857670423971758094 原因&#xff1a;没有按照iframe相对位置计算视频插件位置。 解决&#xff1a; $(window).on(resize, resize);function resize(){// 解决iframe中嵌入海康插件初始化问题:// 1. 获取iframe相比于窗口的偏移量;c…
阅读更多...
Flutter仿Boss-2.启动页、引导页

Flutter仿Boss-2.启动页、引导页

简述 在移动应用开发中&#xff0c;启动页和引导页是用户初次接触应用时的重要组成部分&#xff0c;能够提升用户体验和导航用户了解应用功能。本文将介绍如何使用Flutter实现启动页和引导页&#xff0c;并展示相关代码实现。 启动页 启动页是应用的第一个页面&#xff0c;首…
阅读更多...
Jenkins首次安装选择推荐插件时出现”No such plugin cloudbees-folder”解决方案

Jenkins首次安装选择推荐插件时出现”No such plugin cloudbees-folder”解决方案

安装Jenkins成功之后&#xff0c;首次启动Jenkins后台管理&#xff0c;进入到安装插件的步骤&#xff0c;选择"推荐安装"&#xff0c;继续下一步的时候出现错误提示&#xff1a; 出现一个错误 安装过程中出现一个错误&#xff1a;No such plugin&#xff1a;cloudb…
阅读更多...
【大数据存储】实验二 HDFS操作实验

【大数据存储】实验二 HDFS操作实验

实验二 HDFS操作实验 启动Hadoop&#xff0c;执行jps&#xff0c;检查Hadoop相关进程是否启动成功 启动hadoop 执行jps,可以看到名称节点和数据节点&#xff0c;第二名称节点都打开了&#xff0c;则hadoop相关进程启动成功 在本地文件系统“/home”下新建两个文件夹&#xff…
阅读更多...
Dapr(一) 基于云原生了解Dapr

Dapr(一) 基于云原生了解Dapr

(这期先了解Dapr&#xff0c;之后在推出如何搭建Dapr&#xff0c;以及如何使用。) 目录 引言&#xff1a; Service Mesh定义 Service Mesh解决的痛点 Istio介绍 Service Mesh遇到的挑战 分布式应用的需求 Multiple Runtime 理念推导 Dapr 介绍 Dapr 特性 Dapr 核心…
阅读更多...
前后台分离nodejs+vue租房信息网站express-94sk3.

前后台分离nodejs+vue租房信息网站express-94sk3.

本租房管理系统有管理员&#xff0c;租客&#xff0c;屋主三个角色。管理员功能有个人中心&#xff0c;租客管理&#xff0c;屋主管理&#xff0c;房源信息管理&#xff0c;订单信息管理&#xff0c;屋主申诉管理&#xff0c;通知公告管理&#xff0c;留言板管理&#xff0c;系…
阅读更多...
Electron的学习

Electron的学习

目录 项目初始化可以看官网非常详细根路径创建.vscode文件夹主进程和渲染进程之前的通信ipcRenderer.send和ipcMain.on的使用ipcRenderer.invoke和ipcMain.handle的使用 切换主题模式文件拖放保存消息通知进度展示图标闪烁自定义菜单自定义右键菜单 项目初始化可以看官网非常详…
阅读更多...
基于PSO优化的CNN-LSTM-Attention的时间序列回归预测matlab仿真

基于PSO优化的CNN-LSTM-Attention的时间序列回归预测matlab仿真

目录 1.算法运行效果图预览 2.算法运行软件版本 3.部分核心程序 4.算法理论概述 4.1卷积神经网络&#xff08;CNN&#xff09;在时间序列中的应用 4.2 长短时记忆网络&#xff08;LSTM&#xff09;处理序列依赖关系 4.3 注意力机制&#xff08;Attention&#xff09; 5…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023