RabbitMQ死信队列

RabbitMQ死信队列

1、过期时间TTL

过期时间TTL表示可以对消息设置预期的时间，在这个时间内都可以被消费者接收获取；过了之后消息将自动被

删除。RabbitMQ可以对消息和队列设置TTL，目前有两种方法可以设置：

  • 第一种方法是通过队列属性设置，队列中所有消息都有相同的过期时间。

  • 第二种方法是对消息进行单独设置，每条消息TTL可以不同。

如果上述两种方法同时使用，则消息的过期时间以两者TTL较小的那个数值为准。消息在队列的生存时间一旦超

过设置的TTL值，就称为dead message被投递到死信队列，消费者将无法再收到该消息。

1.1 设置队列TTL

pom依赖

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd"><modelVersion>4.0.0</modelVersion><parent><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-parent</artifactId><version>2.5.4</version><relativePath/></parent><groupId>com.example</groupId><artifactId>spring-boot-rabbitmq-ttl</artifactId><version>0.0.1-SNAPSHOT</version><name>spring-boot-rabbitmq-ttl</name><description>spring-boot-rabbitmq-ttl</description><properties><java.version>1.8</java.version></properties><dependencies><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-test</artifactId><scope>test</scope></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-amqp</artifactId></dependency><dependency><groupId>junit</groupId><artifactId>junit</artifactId><scope>test</scope></dependency></dependencies><build><plugins><plugin><groupId>org.springframework.boot</groupId><artifactId>spring-boot-maven-plugin</artifactId></plugin></plugins></build></project>

配置类

package com.example.config;import org.springframework.amqp.core.Binding;
import org.springframework.amqp.core.BindingBuilder;
import org.springframework.amqp.core.DirectExchange;
import org.springframework.amqp.core.Queue;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;import java.util.HashMap;
import java.util.Map;@Configuration
public class TTLRabbitMQConfiguration {// 1.声明注册direct模式的交换机@Beanpublic DirectExchange ttldirectExchange() {return new DirectExchange("ttl_direct_exchange", true, false);}// 2.队列的过期时间@Beanpublic Queue directttlQueue() {//设置过期时间Map<String, Object> args = new HashMap<>();//这里一定是int类型args.put("x-message-ttl", 5000);return new Queue("ttl.direct.queue", true, false, false, args);}@Beanpublic Binding ttlBingding() {return BindingBuilder.bind(directttlQueue()).to(ttldirectExchange()).with("ttl");}
}

Service

package com.example.service;import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;import java.util.UUID;@Service
public class OrderService {@Autowiredprivate RabbitTemplate rabbitTemplate;//模拟用户下单public void makeOrder() {//1.根据商品id查询库存是否足够//2.保存订单String orderId = UUID.randomUUID().toString();System.out.println("订单生产成功：" + orderId);//3.通过MQ来完成消息的分发//参数1：交换机 参数2：路由key/queue队列名称 参数3：消息内容String exchangeName = "ttl_direct_exchange";String routingKey = "ttl";// 队列中会产生一条消息并且5秒钟后会消失rabbitTemplate.convertAndSend(exchangeName, routingKey, orderId);}
}

启动类

package com.example;import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;@SpringBootApplication
public class RabbitmqDemoApplication {public static void main(String[] args) {SpringApplication.run(RabbitmqDemoApplication.class, args);}}

配置文件

# RabbitMQ基本配置
# RabbitMQ的主机地址(默认为:localhost)
spring.rabbitmq.host=localhost
# 指定该用户要连接到的虚拟host端(注:如果不指定,那么默认虚拟host为“/”)
spring.rabbitmq.virtual-host = /
# amqp协议端口号:5672; 集群端口号:25672;http端口号:15672;
spring.rabbitmq.port=5672
# 登录到RabbitMQ的用户名、密码
spring.rabbitmq.username=zsx242030
spring.rabbitmq.password=zsx242030

测试

package com.example;import com.example.service.OrderService;
import com.example.service.OrderService1;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit4.SpringRunner;@SpringBootTest(classes = RabbitmqDemoApplication.class)
@RunWith(SpringRunner.class)
public class MessageProducerTest {@Autowiredprivate OrderService orderService;@Testpublic void test() {orderService.makeOrder();}}

订单生产成功：8a965457-330b-4e2b-9087-a40cbfdee033

在这里插入图片描述

在这里插入图片描述

1.2 设置消息TTL

配置类

package com.example.config;import org.springframework.amqp.core.Binding;
import org.springframework.amqp.core.BindingBuilder;
import org.springframework.amqp.core.DirectExchange;
import org.springframework.amqp.core.Queue;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;@Configuration
public class TTLRabbitMQConfiguration1 {//1.声明注册direct模式的交换机@Beanpublic DirectExchange ttlMessageDirectExchange() {return new DirectExchange("ttl_message_direct_exchange", true, false);}@Beanpublic Queue directttlMessageQueue() {return new Queue("ttl.message.direct.queue", true, false, false);}@Beanpublic Binding ttlMessageBingding() {return BindingBuilder.bind(directttlMessageQueue()).to(ttlMessageDirectExchange()).with("ttlmessage");}
}

Service

package com.example.service;import org.springframework.amqp.core.Message;
import org.springframework.amqp.core.MessagePostProcessor;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;import java.util.UUID;@Service
public class OrderService1 {@Autowiredprivate RabbitTemplate rabbitTemplate;//模拟用户下单public void makeOrder() {//1.根据商品id查询库存是否足够//2.保存订单String orderId = UUID.randomUUID().toString();System.out.println("订单生产成功：" + orderId);//3.通过MQ来完成消息的分发//参数1：交换机 参数2：路由key/queue队列名称 参数3：消息内容String exchangeName = "ttl_message_direct_exchange";String routingKey = "ttlmessage";//给消息设置过期时间MessagePostProcessor messagePostProcessor = new MessagePostProcessor() {public Message postProcessMessage(Message message) {//这里就是字符串message.getMessageProperties().setExpiration("5000");message.getMessageProperties().setContentEncoding("UTF-8");return message;}};rabbitTemplate.convertAndSend(exchangeName, routingKey, orderId, messagePostProcessor);}
}

测试类

package com.example;import com.example.service.OrderService1;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit4.SpringRunner;@SpringBootTest(classes = RabbitmqDemoApplication.class)
@RunWith(SpringRunner.class)
public class MessageProducerTest1 {@Autowiredprivate OrderService1 orderService1;@Testpublic void test1() {orderService1.makeOrder();}}

订单生产成功：9eb9e120-1379-4e54-bc43-1944b3c22713

在这里插入图片描述

在这里插入图片描述

2、死信队列

DLX，全称 Dead-Letter-Exchange，可以称之为死信交换机，也有人称之为死信邮箱。当消息在一个队列中变

成死信之后，它能被重新发送到另一个交换机中，这个交换机就是DLX，绑定DLX的队列就称之为死信队列。消

息变成死信，可能是由于以下原因：

  • 消息被拒绝

  • 消息过期

  • 队列达到最大长度

DLX也是一个正常的交换机，和一般的交换机没有区别，它能在任何的队列上被指定，实际上就是设置某一个队

列的属性，当这个队列中存在死信时，RabbitMQ就会自动地将这个消息重新发布到设置的DLX上去，进而被路由

到另一个队列，即死信队列。

要想使用死信队列，只需要在定义队列的时候设置队列参数x-dead-letter-exchange指定交换机即可。

pom依赖

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd"><modelVersion>4.0.0</modelVersion><parent><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-parent</artifactId><version>2.5.4</version><relativePath/></parent><groupId>com.example</groupId><artifactId>spring-boot-rabbitmq-dlx</artifactId><version>0.0.1-SNAPSHOT</version><name>spring-boot-rabbitmq-dlx</name><description>spring-boot-rabbitmq-dlx</description><properties><java.version>1.8</java.version></properties><dependencies><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-test</artifactId><scope>test</scope></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-amqp</artifactId></dependency><dependency><groupId>junit</groupId><artifactId>junit</artifactId><scope>test</scope></dependency></dependencies><build><plugins><plugin><groupId>org.springframework.boot</groupId><artifactId>spring-boot-maven-plugin</artifactId></plugin></plugins></build></project>

配置类

package com.example.config;import org.springframework.amqp.core.Binding;
import org.springframework.amqp.core.BindingBuilder;
import org.springframework.amqp.core.DirectExchange;
import org.springframework.amqp.core.Queue;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;@Configuration
public class DeadRabbitMqConfiguration {//1.声明注册direct模式的交换机@Beanpublic DirectExchange deadDirect() {return new DirectExchange("dead_direct_exchange", true, false);}//2.队列的过期时间@Beanpublic Queue deadQueue() {return new Queue("dead.direct.queue", true);}@Beanpublic Binding deadbinds() {return BindingBuilder.bind(deadQueue()).to(deadDirect()).with("dead");}
}

package com.example.config;import org.springframework.amqp.core.Binding;
import org.springframework.amqp.core.BindingBuilder;
import org.springframework.amqp.core.DirectExchange;
import org.springframework.amqp.core.Queue;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;import java.util.HashMap;
import java.util.Map;@Configuration
public class TTLRabbitMQConfiguration {//1.声明注册direct模式的交换机@Beanpublic DirectExchange ttldirectExchange() {return new DirectExchange("ttl_direct_exchange", true, false);}//2.队列的过期时间@Beanpublic Queue directttlQueue() {//设置过期时间Map<String, Object> args = new HashMap<>();// ttl队列最大可以接受5条消息,超过的条数也是会被移入死信队列,过期之后依然会被移入死信队列// args.put("x-max-length",5);// 这里一定是int类型args.put("x-message-ttl", 5000);// 死信队列的交换机args.put("x-dead-letter-exchange", "dead_direct_exchange");// fanout不需要配置// 路由args.put("x-dead-letter-routing-key", "dead");return new Queue("ttl.direct.queue", true, false, false, args);}@Beanpublic Binding ttlBingding() {return BindingBuilder.bind(directttlQueue()).to(ttldirectExchange()).with("ttl");}}

Service

package com.example.service;import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;import java.util.UUID;@Service
public class OrderService {@Autowiredprivate RabbitTemplate rabbitTemplate;//模拟用户下单public void makeOrder() {//1.根据商品id查询库存是否足够//2.保存订单String orderId = UUID.randomUUID().toString();System.out.println("订单生产成功：" + orderId);//3.通过MQ来完成消息的分发//参数1：交换机 参数2：路由key/queue队列名称 参数3：消息内容String exchangeName = "ttl_direct_exchange";String routingKey = "ttl";// 队列中会产生一条消息并且5秒钟后会消失rabbitTemplate.convertAndSend(exchangeName, routingKey, orderId);}
}

启动类

package com.example;import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;@SpringBootApplication
public class RabbitmqDemoApplication {public static void main(String[] args) {SpringApplication.run(RabbitmqDemoApplication.class, args);}}

配置文件

# RabbitMQ基本配置
# RabbitMQ的主机地址(默认为:localhost)
spring.rabbitmq.host=localhost
# 指定该用户要连接到的虚拟host端(注:如果不指定,那么默认虚拟host为“/”)
spring.rabbitmq.virtual-host = /
# amqp协议端口号:5672; 集群端口号:25672;http端口号:15672;
spring.rabbitmq.port=5672
# 登录到RabbitMQ的用户名、密码
spring.rabbitmq.username=zsx242030
spring.rabbitmq.password=zsx242030

测试类

package com.example;import com.example.service.OrderService;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit4.SpringRunner;@SpringBootTest(classes = RabbitmqDemoApplication.class)
@RunWith(SpringRunner.class)
public class MessageProducerTest {@Autowiredprivate OrderService orderService;@Testpublic void test() {orderService.makeOrder();}}

订单生产成功：74adb096-734c-4484-8947-032ef1ee7c5d

在这里插入图片描述

在这里插入图片描述

在这里插入图片描述

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

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

相关文章

Oracle修改字符集为SIMPLIFIED CHINESE_CHINA.ZHS16GBK

Oracle修改字符集为SIMPLIFIED CHINESE_CHINA.ZHS16GBK

查询字符集 select userenv(language) from dual;修改前字符集为&#xff1a;SIMPLIFIED CHINESE_CHINA.AL32UTF8 SQL> shutdown immediate; Database closed. Database dismounted. ORACLE instance shut down. SQL> startup mount; ORACLE instance started. Total …
阅读更多...
【C语言】文件操作 -- 详解

【C语言】文件操作 -- 详解

一、什么是文件 磁盘上的文件是文件。 1、为什么要使用文件 举个例子&#xff0c;当我们想实现一个 “通讯录” 程序时&#xff0c;在通讯录中新建联系人、删除联系人等一系列操作&#xff0c;此时的数据存储于内存中&#xff0c;程序退出后所有数据都会随之消失。为了让通讯录…
阅读更多...
R语言04-R语言中的列表

R语言04-R语言中的列表

概念 在R语言中&#xff0c;列表&#xff08;List&#xff09;是一种复杂的数据结构&#xff0c;用于存储不同类型的元素&#xff0c;包括向量、矩阵、数据框、函数等。列表是一种非常灵活的数据结构&#xff0c;可以将不同类型的数据组合在一起&#xff0c;类似于Python中的字…
阅读更多...
第60步 深度学习图像识别：误判病例分析（Pytorch）

第60步 深度学习图像识别：误判病例分析（Pytorch）

基于WIN10的64位系统演示 一、写在前面 上期内容基于Tensorflow环境做了误判病例分析&#xff08;传送门&#xff09;&#xff0c;考虑到不少模型在Tensorflow环境没有迁移学习的预训练模型&#xff0c;因此有必要在Pytorch环境也搞搞误判病例分析。 本期以SqueezeNet模型为…
阅读更多...
窗口看门狗

窗口看门狗

从下往上看: 1. 时钟设置 RCC_APB1PeriphClockCmd(RCC_APB1Periph_WWDG,ENABLE);//使能独立看门狗时钟 WWDG_SetPrescaler(WWDG_Prescaler_8);//看门狗预分频器WWDG counter clock (PCLK1/4096)/8 2.设置窗口值 实际就是设置WWDG_CR的低七位值, 但是这个值要大于0x40(也就是…
阅读更多...
【分享】小型园区组网场景

【分享】小型园区组网场景

小型园区组网图 在小型园区中&#xff0c;S2700&S3700通常部署在网络的接入层&#xff0c;S5700&S6700通常部署在网络的核心&#xff0c;出口路由器一般选用AR系列路由器。 接入交换机与核心交换机通过Eth-Trunk组网保证可靠性。 每个部门业务划分到一个VLAN中&#…
阅读更多...
【Go 基础篇】Go语言分支结构：掌握 if 和 switch，灵活控制程序逻辑

【Go 基础篇】Go语言分支结构：掌握 if 和 switch，灵活控制程序逻辑

介绍 在编程中&#xff0c;分支结构是一种重要的控制流程&#xff0c;它允许程序根据不同的条件选择不同的执行路径。Go语言提供了两种主要的分支结构&#xff1a;if 和 switch&#xff0c;用于在程序中实现条件判断和多重选择。本篇博客将深入探讨Go语言中的if和switch分支结…
阅读更多...
Vulnhub: DriftingBlues: 2靶机

Vulnhub: DriftingBlues: 2靶机

kali&#xff1a;192.168.111.111 靶机&#xff1a;192.168.111.207 信息收集 端口扫描 nmap -A -sC -v -sV -T5 -p- --scripthttp-enum 192.168.111.207 80端口的/blog目录为wordpress wpscan收集wordpress用户和爆破密码 wpscan --url http://driftingblues.box/blog -e…
阅读更多...
SpringBoot-yml配置文件的使用与优势

SpringBoot-yml配置文件的使用与优势

目录 一、什么是yml配置文件&#xff1f; 二、如何在SpringBoot中使用yml配置文件&#xff1f; 三、如何在SpringBoot中注入yml配置文件的属性&#xff1f; Value注解 ConfigurationProperties注解 四、yml配置文件与properties配置文件的区别和优势 区别 优势 五、总结…
阅读更多...
非凸联合创始人李佐凡受邀出席复旦DSBA项目座谈会

非凸联合创始人李佐凡受邀出席复旦DSBA项目座谈会

8月17日&#xff0c;非凸科技联合创始人&CTO李佐凡受邀参加复旦管院数据科学与商业分析专业硕士&#xff08;DS&BA&#xff09;项目发展座谈会&#xff0c;与学校教授、老师在生源背景、课程教学、职业发展、学生培养和企业合作方面进行深入交流&#xff0c;旨在更好地…
阅读更多...
【C++练习】普通方法+利用this 设置一个矩形类(Rectangle), 包含私有成员长(length)、 宽(width), 定义一下成员函数

【C++练习】普通方法+利用this 设置一个矩形类(Rectangle), 包含私有成员长(length)、 宽(width), 定义一下成员函数

题目 设置一个矩形类(Rectangle), 包含私有成员长(length)、 宽(width), 定义成员函数: void set_ len(int l); //设置长度 设置宽度void set_ wid(int w); 获取长度: int get len(); 获取宽度: int get _wid); 显示周长和面积: v…
阅读更多...
如何用Python实现从pdf文件精准抓取数据生成数据库！

如何用Python实现从pdf文件精准抓取数据生成数据库！

要从PDF文件中提取数据并生成数据库&#xff0c;你可以使用Python中的一些库和工具来实现。 1、安装必要的库&#xff1a;确保已安装所需的库。除了之前提到的PyPDF2、pdfminer.six和pdftotext之外&#xff0c;你可能还需要其他的库来处理提取的数据和数据库操作。例如&#x…
阅读更多...
民族传统文化分享系统uniapp 微信小程序

民族传统文化分享系统uniapp 微信小程序

管理员、用户可通过Android系统手机打开系统&#xff0c;注册登录后可进行管理员后端&#xff1b;首页、个人中心、用户管理、知识分类管理、知识资源管理、用户分享管理、意见反馈、系统管理&#xff0c;用户前端&#xff1b;首页、知识资源、用户分享、我的等。 本系统的使用…
阅读更多...
GO-vscode远程开发和调试

GO-vscode远程开发和调试

本文内容主要包括&#xff1a; 概述&#xff1a; 主要就是把代码放到服务器上然后远程去开发和调试 工具&#xff1a; vscode 远程端&#xff1a; linux 一.安装远程插件 vscode安装Remote - SSH&#xff0c;Remote Explorer&#xff0c;Remote Development&#xff0c…
阅读更多...
4.8 C++ Boost 应用JSON解析库

4.8 C++ Boost 应用JSON解析库

property_tree 是 Boost 库中的一个头文件库&#xff0c;用于处理和解析基于 XML、Json 或者 INFO 格式的数据。 property_tree 可以提供一个轻量级的、灵活的、基于二叉数的通用容器&#xff0c;可以处理包括简单值&#xff08;如 int、float&#xff09;和复杂数据结构&#…
阅读更多...
C++最易读手撸神经网络两隐藏层(任意Nodes每层)梯度下降230820a

C++最易读手撸神经网络两隐藏层(任意Nodes每层)梯度下降230820a

这是史上最简单、清晰&#xff0c;最易读的…… C语言编写的 带正向传播、反向传播(Forward ……和Back Propagation&#xff09;……任意Nodes数的人工神经元神经网络……。 大一学生、甚至中学生可以读懂。 适合于&#xff0c;没学过高数的程序员……照猫画虎编写人工智能、…
阅读更多...
矿井水处理技术离子交换树脂法

矿井水处理技术离子交换树脂法

矿井水除氟的要求一般是处理后水中的含氟量≤1.0mg/L。氟化物含量高的原水往往呈偏碱性&#xff0c;pH值常大于7.5。利用阴离子交换树脂上的可交换阴离子&#xff0c;去交换水中的氟离子&#xff0c;达到除氟目的。氟离子的选择交换性较大&#xff0c;树脂上的SO42-、Cl-等阴离…
阅读更多...
卷积过程详细讲解

卷积过程详细讲解

1&#xff1a;单通道卷积 以单通道卷积为例&#xff0c;输入为&#xff08;1,5,5&#xff09;&#xff0c;分别表示1个通道&#xff0c;宽为5&#xff0c;高为5。假设卷积核大小为3x3&#xff0c;padding0&#xff0c;stride1。 卷积过程如下&#xff1a; 相应的卷积核不断…
阅读更多...
企微配置回调服务

企微配置回调服务

1、企微配置可信域名 2、企微获取成员userID 3、企微获取用户敏感数据 4、企微配置回调服务 文章目录 一、简介1、概述2、相关文档地址 二、企微配置消息服务器1、配置消息接收参数2、参数解析3、参数拼接规则 三、代码编写—使用已有库1、代码下载2、代码修改3、服务代码编写 …
阅读更多...
基于swing的超市信息管理系统java jsp仓库进销存mysql源代码

基于swing的超市信息管理系统java jsp仓库进销存mysql源代码

本项目为前几天收费帮学妹做的一个项目&#xff0c;Java EE JSP项目&#xff0c;在工作环境中基本使用不到&#xff0c;但是很多学校把这个当作编程入门的项目来做&#xff0c;故分享出本项目供初学者参考。 一、项目描述 基于swing的超市信息管理系统 系统有1权限&#xff1…
阅读更多...
最新文章

Copyright @ 2022~2023