使用RabbitMQ实现延时消息自动取消的简单案例

一、流程图

二、导包

<!--消息队列 AMQP依赖,包含RabbitMQ-->
<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-amqp</artifactId>
</dependency>

三、配置文件

#消息队列
spring:rabbitmq:host: 192.168.88.130port: 5672virtual-host: my_vhost #使用的虚拟主机username: rootpassword: rootlistener:simple:acknowledge-mode: manual #开启手动应答

四、配置类

import org.springframework.amqp.core.*;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;import java.util.HashMap;
import java.util.Map;@Configuration
public class RabbitMQConfig {/*** 订单交换机*/public static final String ORDER_EXCHANGE = "order_exchange";/*** 订单队列*/public static final String ORDER_QUEUE = "order_queue";/*** 订单路由键*/public static final String ORDER_ROUTING = "order_routing";/*** 死信交换机*/public static final String ORDER_DEAD_EXCHANGE = "order_dead_exchange";/*** 死信队列*/public static final String ORDER_DEAD_QUEUE = "order_dead_queue";/*** 死信路由键*/public static final String ORDER_DEAD_ROUTING = "order_dead_routing";/*** 订单交换机*/@Bean("orderExchange")public Exchange getOrderExchange() {return new DirectExchange(ORDER_EXCHANGE);}/*** 订单队列*/@Bean("orderQueue")public Queue getOrderQueue() {Map<String, Object> map = new HashMap<>(3);map.put("x-dead-letter-exchange", ORDER_DEAD_EXCHANGE);//死信交换机map.put("x-dead-letter-routing-key", ORDER_DEAD_ROUTING);//死信路由键map.put("x-message-ttl", 1000 * 60 * 15);//队列过期时间return QueueBuilder.durable(ORDER_QUEUE).withArguments(map).build();}/*** 将订单交换机与订单队列绑定*/@BeanBinding orderExchangeBindingOrder(@Qualifier("orderExchange") Exchange exchange,@Qualifier("orderQueue") Queue queue) {return BindingBuilder.bind(queue).to(exchange).with(ORDER_ROUTING).noargs();}/*** 死信交换机*/@Bean("orderDeadExchange")public Exchange getOrderDeadExchange() {return new DirectExchange(ORDER_DEAD_EXCHANGE);}/*** 死信队列*/@Bean("orderDeadQueue")public Queue getOrderDeadQueue() {return new Queue(ORDER_DEAD_QUEUE,//队列名true,//是否持久化false,//是否具有排他性,只在首次声明时可见,不允许其他用户访问,连接断开时自动删除false,//是否自动删除,经历过至少一次连接后,所有消费者都断开了连接,此队列会自动删除null);}/*** 将死信交换机与死信队列绑定*/@BeanBinding deadExchangeBindingDeadQueue(@Qualifier("orderDeadExchange") Exchange exchange,@Qualifier("orderDeadQueue") Queue queue) {return BindingBuilder.bind(queue).to(exchange).with(ORDER_DEAD_ROUTING).noargs();}
}

五、发送消息的类

import com.sky.configuration.RabbitMQConfig;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;/*** 消息队列发送消息*/
@Component
public class SendRabbitMQ {@Autowiredprivate RabbitTemplate rabbitTemplate;/*** @param orderId 15分钟后要检查的订单编号*/public void sendDelayOrder(Long orderId) {rabbitTemplate.convertAndSend(RabbitMQConfig.ORDER_EXCHANGE,//订单交换机RabbitMQConfig.ORDER_ROUTING,//订单路由键orderId//要取消的订单编号);}
}

六、接收消息的类

import com.rabbitmq.client.Channel;
import com.sky.configuration.RabbitMQConfig;
import com.sky.mapper.OrderMapper;
import org.springframework.amqp.core.Message;
import org.springframework.amqp.rabbit.annotation.RabbitListener;/*** 消息队列接收消息*/
@Component
public class ReceiveRabbitMQ {@Autowiredprivate OrderMapper orderMapper;/*** @param orderId 要取消的订单的编号* @param msg     包含了要回复的队列* @param channel 有回复功能的参数*/@RabbitListener(queues = RabbitMQConfig.ORDER_DEAD_QUEUE)public void ReceiveDeadOrder(Long orderId, Channel channel, Message msg) throws IOException {orderMapper.delCancelOrder(orderId);//查询数据库,订单是否付款,未付款:改为已取消channel.basicAck(msg.getMessageProperties().getDeliveryTag(),//应答的消息false//是否批量应答);}
}

七、在业务代码中注入发送类,并调用发送类的发送方法

@Service
public class OrderServiceImpl implements OrderService {@Autowiredprivate SendRabbitMQ sendRabbitMQ;/*** 用户下单*/public void submitOrder(OrdersSubmitDTO ordersSubmitDTO) {sendRabbitMQ.sendDelayOrder(order.getId());//发送延迟消息到消息队列}
}

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

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

相关文章

【微信】实战Adnroid上的小程序调试

▒ 目录 ▒ &#x1f6eb; 导读需求开发环境 1️⃣ XWeb 内核准备工作连接手机设备到电脑上查看效果 2️⃣ X5 内核(遗弃了&#xff1f;)vConsole操作步骤 &#x1f6ec; 文章小结&#x1f4d6; 参考资料 &#x1f6eb; 导读 需求 如今小程序得到了越来越广泛的应用&#xff0…

运维知识点-ACCESS

ACCESS access 扫出后缀为asp的数据库文件 迅雷下载&#xff0c;直接改后缀为.mdbMicrosoft Office Access是由微软发布的关系数据库管理系统。它结合了 MicrosoftJet Database Engine 和 图形用户界面两项特点&#xff0c;是 Microsoft Office 的系统程序之一。 Microsoft Off…

【图形学中的数学】GAMES001

目录 0 引言1 线性代数基础1.1 向量&#xff08;Vector&#xff09;1.2 向量空间&#xff08;Vector Space&#xff09;1.3 线性组合1.4 图形学研究的维度1.5 矩阵&#xff08;Matrix&#xff09;1.5.1 矩阵单目运算1.5.2 低维变换矩阵 1.6 齐次坐标 &#x1f64b;‍♂️ 作者&…

Java利器Jakarta Commons

Commons Lang这一组API主要是提供一些基础的、通用的操作和处理&#xff0c;如自动生成toString()的结果、自动实现hashCode()和equals()方法、数组操作、枚举、日期和时间的处理等等。 ArrayUtils – 用于对数组的操作&#xff0c;如添加、查找、删除、子数组、倒序、元素类型…

可配置输入参数的接口如何设计

个人博客&#xff1a;无奈何杨&#xff08;wnhyang&#xff09; 个人语雀&#xff1a;wnhyang 共享语雀&#xff1a;在线知识共享 Github&#xff1a;wnhyang - Overview 作为程序员&#xff0c;我们绝大多数场景需要根据业务需求来设计系统&#xff0c;开发后端接口&#x…

[Ubuntu 20.04] 创建一个开机服务(systemd服务单元文件)

例如用于创建一个名为my_network_app.service的systemd服务,该服务将在系统启动时运行一个网络应用程序。 1. 创建应用程序的启动脚本 首先,你需要一个启动你的网络应用程序的脚本。这个脚本可以是任何语言编写的,只要它能正确地启动你的应用程序。例如,假设你有一个名为…

想要节省成本,哪个品牌的https证书值得考虑?

为了确保网站数据传输安全&#xff0c;启用HTTPS加密是关键步骤。在众多SSL证书供应商中&#xff0c;如何找到价格合理且品质优良的HTTPS加密证书呢&#xff1f;本文将探讨这个问题&#xff0c;并重点关注具有高性价比优势的沃通CA。 沃通CA作为业内知名的SSL证书服务商&#x…

MySQL数据管理二

1.数据库的完整性 数据库中的数据是从外界输入的&#xff0c;而数据的输入由于种种原因&#xff0c;会发生输入无效或错误信息。保证输入的数据符合规定&#xff0c;成为了数据库系统&#xff0c;尤其是多用户的关系数据库系统首要关注的问题。 它是应防止数据库中存在不符合语…

双证知音中国社科院与英国斯特灵大学创新与领导力博士

对于博士阶段来说&#xff0c;由于科研任务繁重&#xff0c;需要自主学习的内容以及接受的挑战也相对较多&#xff0c;所以对于晋升读博这件事并不那么容易。无论是考博还是读中外合作办学博士&#xff0c;上课语言、博导、论文这些关都是要一一闯过的。能遇见优秀的导师是我们…

CYQ.Data 支持 DaMeng 达梦数据库

DaMeng 达梦数据库介绍: 达梦数据库(DMDB)是中国自主研发的关系型数据库管理系统,由达梦科技股份有限公司开发。 达梦数据库提供了企业级的数据库解决方案,广泛应用于金融、电信、政府、制造等行业领域。 达梦数据库具有以下特点和优势: 高性能:具备高性能的并发处理…

滑窗问题【Leetcode3最长子串/438找出所有异位词】

3. 无重复字符的最长子串 给定一个字符串 s &#xff0c;请你找出其中不含有重复字符的 最长子串 的长度。 请注意&#xff0c;你的答案必须是 子串 的长度&#xff0c;子序列不是子串。 思路&#xff1a;滑窗范围[pl, pr)&#xff0c;用cnt数组维护滑窗内的每个字符的出现次数…

React 的入门介绍

React 是什么 React是一个用于构建用户界面的JavaScript库。它由Facebook开发&#xff0c;并于2013年首次发布。React将用户界面拆分为小的可重用组件&#xff0c;每个组件都有自己的状态&#xff0c;并根据状态的变化来更新界面。 React使用了虚拟DOM&#xff08;Virtual DO…

RabbitMQ如何实现消费端限流

什么是消费端限流&#xff0c;这个一种保护消费者的手段&#xff0c;假如说&#xff0c;现在是业务高峰期了&#xff0c;消息有大量堆积&#xff0c;导致MQ消费需要不断的进行消息消费&#xff0c;很容易被打挂&#xff0c;甚至重启之后还是会被大量消息涌入&#xff0c;继续被…

Xilinx 7系列FPGA配置(ug470)

Xilinx 7系列FPGA配置&#xff08;ug470&#xff09; 配置模式串行配置模式接口从-连接方式主-连接方式串行菊花链&#xff08;非同时配置&#xff09;串行配置&#xff08;同时配置&#xff09;时序 主SPI配置模式SPIx1/x2 连接图SPIx1模式时序SPIx4 连接图SPI操作指令操作fla…

FC-AE-1553 协议

FC-AE-1553 协议 MIL-STD-1553B总线协议总线结构字格式消息传输方式 FC协议FC协议栈拓扑结构服务类型帧/序列/交换FC帧格式 FC-AE-1553网络构成帧类型命令帧状态帧数据帧 Information UnitsNC1NC2NC3-4NC5-7NT1-7 传输模式1. NC-NT2. NT-NC3. NT-NT4. 无数据字的模式命令5. 带数…

python并发编程之多进程、多线程、异步和协程详解

在Python中&#xff0c;有多种并发编程的方式可供选择&#xff0c;包括多进程、多线程、异步和协程。下面将对这些方式进行详细解释。 多进程&#xff1a;多进程是通过创建多个进程来实现并发的方式。每个进程都有自己独立的内存空间&#xff0c;可以并行执行任务。Python中的m…

detectron2 DiffusionDet 训练自己的数据集

配环境 git clone https://github.com/ShoufaChen/DiffusionDet# 创建环境 conda create -n diffusion python3.9 conda activate diffusion conda install pytorch1.11.0 torchvision0.12.0 torchaudio0.11.0 cudatoolkit11.3 -c pytorch pip install opencv-python# 安装det…

STM32CubeMX学习笔记12 ---低功耗模式

在实际使用中很多产品都需要考虑低功耗的问题&#xff0c;STM32F10X提供了三种低功耗模式&#xff1a;睡眠模式&#xff08;Sleep mode&#xff09;、停机模式&#xff08;Stop mode&#xff09;和待机模式&#xff08;Standby mode&#xff09;。这些低功耗模式可以有效减少系…

jnitrace的用法(查看jni的执行流程,方便unidbg补环境)

一、简单执行 jnitrace -l <要trace的so库> <包名> jnitrace -l libxxx.so com.xxx.app二、插入js脚本执行 jnitrace -p E:\kill_sll.js -l libxxx.so com.xxx.app三、attach模式执行 默认使用spawn执行&#xff0c;attach模式可能有有时bug没反应 jnitrace -l li…

Casper Network(CSPR)即将迎来两项重大升级,以实现功能上的进一步完善

Casper Network&#xff08;CSPR&#xff09;即将实现更加完备的功能升级&#xff0c;现已进入倒计时阶段。 Casper Network&#xff08;CSPR&#xff09;将升级到其最先进以及更全的版本&#xff0c;即“功能完备”的版本&#xff0c;让Casper Network&#xff08;CSPR&#…