技术标签: spring boot 死信队列 订单过期自动取消 rabbit mq
用户下了订单之后,还未付款,在规定的期限内如果没有支付,则这个订单应该标记为取消。
如果实现过期自动取消,下面有几种解决方案
其实方案二和死信队列的原理差不多,但是MQ已经拥有类似的机制,所以我们直接沿用即可。
dead-letter-exchange
(dead message)
之后,它能被重新publish到另一个Exchange,这个Exchange就是DLX创建一个普通的队列(加入死信队列的一些属性),这个消息永远没有人消费,没人消费则过期,过期则通过之前的设置转发回调给另外一个队列
下面是基于Spring boot 的实际用例
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-amqp</artifactId>
</dependency>
/**
* 死信队列交换机标识符 属性值不能改,写死
*/
private static final String DEAD_LETTER_QUEUE_KEY = "x-dead-letter-exchange";
/**
* 死信队列交换机绑定键 标识符 属性值不能改,写死
*/
private static final String DEAD_LETTER_ROUTING_KEY = "x-dead-letter-routing-key";
/**
* deadLetterExchange(direct类型交换机)
*
* @return
*/
@Bean("deadLetterExchange")
public Exchange deadLetterExchange() {
return ExchangeBuilder.directExchange("DEAD_LETTER_EXCHANGE").durable(true).build();
}
/**
* 声明一个死信队列
* x-dead-letter-exchange 对应 死信交换机
* x-dead-letter-routing-key 对应 死信队列
*/
@Bean("deadLetterQueue")
public Queue deadLetterQueue() {
//应该像个普通队列,里面多设置了两个参数,这个队列没有被消费或者超时 则通过x-dead-letter-exchange 指明重新回到死信交换机 TEST_SIGN_EXCHANGE
//交换机
// 参数
Map<String, Object> args = new HashMap<>(2);
// 出现dead letter之后将dead letter重新发送到指定exchange
args.put(DEAD_LETTER_QUEUE_KEY, "DEAD_LETTER_EXCHANGE");
// 出现dead letter之后将dead letter重新按照指定的routing-key发送
args.put(DEAD_LETTER_ROUTING_KEY, "REDIRECT_KEY");
// name队列名字 durable是否持久化,true保证消息的不丢失, exclusive是否排他队列,如果一个队列被声明为排他队列,该队列仅对首次申明它的连接可见,并在连接断开时自动删除, autoDelete如果该队列没有任何订阅的消费者的话,该队列是否会被自动删除, arguments参数map
return new Queue("DEAD_LETTER_QUEUE", true, false, false, args);
}
/**
* 死信路由通过 DEAD_LETTER_KEY 绑定到死信队列上.
*/
@Bean
public Binding deadLetterBinding() {
return new Binding("DEAD_LETTER_QUEUE", Binding.DestinationType.QUEUE, "DEAD_LETTER_EXCHANGE", "DEAD_LETTER_KEY", null);
}
/**
* 死信路由通过 REDIRECT_KEY 绑定到转发队列上. 这个队列绑定的是当出现死信消息后 重新转发给的队列
*/
@Bean
public Binding redirectBinding() {
return new Binding("REDIRECT_QUEUE", Binding.DestinationType.QUEUE, "DEAD_LETTER_EXCHANGE", "REDIRECT_KEY", null);
}
/**
* 定义死信队列转发队列. (和普通队列一样,这个队列是为了原有的消息没有被消费重新转发给一个新的队列)
*/
@Bean("redirectQueue")
public Queue redirectQueue() {
return new Queue("REDIRECT_QUEUE", true, false, false);
}
@Component
public class TestMQConsumer {
/**
* 监听转发队列 死信队列重新转发回这里
*
*/
@RabbitListener(queues = {"REDIRECT_QUEUE"})
public void redirect(HashMap<String,Object> dataMap) throws IOException {
System.out.println(dataMap.get("msg"));
System.out.println("我是转发队列,这里执行逻辑业务");
}
}
@Test
public void testMq(){
//声明消息处理器 设置消息的编码以及消息的过期时间 时间毫秒值为字符串
MessagePostProcessor messagePostProcessor = message -> {
MessageProperties messageProperties = message.getMessageProperties();
messageProperties.setMessageId(UUID.randomUUID().toString().replaceAll("-", ""));
messageProperties.setContentEncoding("utf-8");
//超时时间10秒
messageProperties.setExpiration(String.valueOf(1000*10));
return message;
};
Map<String, Object> dataMap = new HashMap<>();
dataMap.put("msg","我是传递的消息");
rabbitTemplate.convertAndSend("DEAD_LETTER_EXCHANGE", "DEAD_LETTER_KEY",dataMap,messagePostProcessor);
}
执行效果:
DEAD_LETTER_QUEUE 执行后没有被消费,超过10秒钟后自动回调 REDIRECT_QUEUE
文章浏览阅读6.4k次。启动uni-app项目后我的微信开发者工具一直卡着不动了在这了_uni调试工具启动后一直卡在启动页面
文章浏览阅读389次。python输出python3中的输出python3中的输出使用函数print(),示例如下:>>> print('hello kitty')print()也可接受多个参数,使用逗号隔开:>>> print('hello','kitty')hello kitty可以看到字符串合并输出后,中间会模式使用逗号隔开~print函数除了可以接收字符串外,也可以接收其他的数据类型>>> print(1) ..._"python输入\"237846278\"和\"4\",输出\"237846278的第4位是6"
文章浏览阅读502次。/*中文题意:中文翻译:题目大意:解题思路:难点详解:关键点:解题人:解题时间:解题感受:*/_hdu 2051 bitset
文章浏览阅读9k次,点赞4次,收藏34次。转自:http://bbs.21dianyuan.com/thread-233723-1-1.html1.1.4 驱动线路(死区控制、隔离变压器)A.互补驱动(带死区控制)实现方式,UC3843的PWM输出用逻辑非门芯片取反,然后利用RCD做死区,经驱动IC HIP2101(仿真软件自带驱动芯片模型),得到两路带死区的互补驱动信号PWM1和PWM2,如下图所示:该电路可用来做同步Buck,同..._simplis
文章浏览阅读5.2k次。1、什么是构建你一定知道“构建(construction)”一次在软件开发领域以外的含义。“构建”就是“建筑工人(construction workers)”在建设一栋房屋,一所学校,乃至一座摩天大楼时所做的工作。在你年轻时,可能也曾用“硬纸板(construction paper)”构建过什么东西吧。按照一般的用法,“构建”是指建设的过程。构建过程可能包含有计划、设计、检查工作的一些方面,但..._软件构建是什么意思
文章浏览阅读9.4k次,点赞2次,收藏10次。问题描述安装好了centOS服务器,一直用Secure CRT工具通过ssh服务来远程连接linux,很方便的进行各种操作。今天偶然尝试了一下在非root的一般用户下执行重启服务器的命令,发现一般用户是没有权限执行重启的,果断使用sudo命令再次执行,终于重启成功,却发现Secure CRT再也连不上服务器了,郁闷不已,去网上查找各种资料总算有了一点粗浅的认识,记录下来,也让其他的linux beginner们能够少走些弯路吧。普通用户下执行重启命令:shutdown -r now 或者 _服务器重启reboot 无法连接
文章浏览阅读2.6k次。import tensorflow as tfimport numpy as npimport pandas as pdfrom sklearn.utils import shuffle from sklearn.preprocessing import scale import matplotlib.pyplot as plt%matplotlib inline获取数据和查看数..._x_train=tf.cast(scale(x_train),dtype=tf.float32)
文章浏览阅读7.1k次,点赞5次,收藏33次。一、欠拟合(Underfitting)模型在训练数据上不能获得很好的拟合,并且在测试数据集上也不能很好的拟合数据,这种现象称为欠拟合,即高偏差(high bias)。(模型过于简单)原因:模型不够复杂、拟合函数的能力不足,学习到的有用特征太少,导致拟合的函数无法满足训练集。二、过拟合(Overfitting)模型在训练数据上能够获得很好的拟合,但是在测试数据集上却不能很好的拟合数据..._欠拟合
文章浏览阅读2.4k次。先通过执行两条汇编语句得到执行两条汇编语句所使用的相对时间刻度,然后继续执行这两条汇编语句获取一个时间刻度减去先前的相对时间刻度就是CPU时钟频率。inline UINT64 CGetCPUTimeDlg::GetCount(){ _asm _emit 0x0f; _asm _emit 0x31;} // 获取CPU时钟频率CString CGetCPUTimeDlg::..._c++获取cpu频率
文章浏览阅读8.7k次,点赞9次,收藏55次。这里需要注意include的两种不同写法,#include<***.h> 和 #include"***.h"采用"< >"方式进行包含的头bai文件表示让编译器在编译器的预设标准路径下去搜索相应的头文件,如果找不到则报错。例如:VS2008的安装目录\Microsoft Visual Studio 9.0\VC\include下面就包含了标准库的头文件。第二种方式表示先在工程所在路径下搜索,如果失败,再到系统标准路径下搜索。所以,特别要注意的是,如果是标准库头文件,那么既_c++include
文章浏览阅读1.2k次。十分钟上手基于Core的Lua编程语言一、函数、变量二、数组、表(table)三、流程控制:if、elseif、else四、循环控制:for、while五、结语前言:无论您擅长什么语言,C、python、Java、Lua、或PHP,哪怕是刚入门的编程小白,只要您掌握了最基本的编程思想比如:if,else, for, while的用法,您基本就可以很快速的上手 Core 的编程开发了。在 Core上面的编程只会涉及到最基本的编程语法,而编程语言自带的一些高级特性在 Core 上您基本用不到,即使Cor
文章浏览阅读1.8w次,点赞32次,收藏232次。LDPC各类译码方法的MATLAB实现主要内容新的改变功能快捷键合理的创建标题,有助于目录的生成如何改变文本的样式插入链接与图片如何插入一段漂亮的代码片生成一个适合你的列表创建一个表格设定内容居中、居左、居右SmartyPants创建一个自定义列表如何创建一个注脚注释也是必不可少的KaTeX数学公式新的甘特图功能,丰富你的文章UML 图表FLowchart流程图导出与导入导出导入主要内容LDP..._最小和译码算法