项目实战之RabbitMQ死信队列应用

🧑‍💻作者名称:DaenCode
🎤作者简介:啥技术都喜欢捣鼓捣鼓,喜欢分享技术、经验、生活。
😎人生感悟:尝尽人生百味,方知世间冷暖。


在这里插入图片描述


文章目录

  • 🌟架构图
  • 🌟application.yml文件
  • 🌟RabbitMQ配置
  • 🌟消息发送、消费
  • 🌟写在最后

🌟架构图

  1. 死信队列架构图
    在这里插入图片描述
  2. 本地消息表
    在这里插入图片描述

🌟application.yml文件

mqconfig:#延迟队列,不能被监听消费stock_release_delay_queue: stock.release.delay.queue#延迟队列的消息过期后转发的队列stock_release_queue: stock.release.queue#交换机stock_event_exchange: stock.event.exchange#进入延迟队列的路由keystock_release_delay_routing_key: stock.release.delay.routing.key#消息过期,进入释放队列的keystock_release_routing_key: stock.release.routing.key#消息过期时间,毫秒,测试改为15秒ttl: 360000

🌟RabbitMQ配置

@Configuration
@Data
public class RabbitMQConfig {/*** 交换机*/@Value("${mqconfig.stock_event_exchange}")private String eventExchange;/*** 第一个队列延迟队列,*/@Value("${mqconfig.stock_release_delay_queue}")private String stockReleaseDelayQueue;/*** 第一个队列的路由key* 进入队列的路由key*/@Value("${mqconfig.stock_release_delay_routing_key}")private String stockReleaseDelayRoutingKey;/*** 第二个队列,被监听恢复库存的队列*/@Value("${mqconfig.stock_release_queue}")private String stockReleaseQueue;/*** 第二个队列的路由key** 即进入死信队列的路由key*/@Value("${mqconfig.stock_release_routing_key}")private String stockReleaseRoutingKey;/*** 过期时间*/@Value("${mqconfig.ttl}")private Integer ttl;/*** 消息转换器* @return*/@Beanpublic MessageConverter messageConverter(){return new Jackson2JsonMessageConverter();}/*** 创建topic交换机* 一个微服务一个交换机* @return*/@Beanpublic Exchange stockEventExchange(){return new TopicExchange(eventExchange,true,false);}/*** 延迟队列* @return*/@Beanpublic Queue stockReleaseDelayQueue(){Map<String,Object> args=new HashMap<>();args.put("x-message-ttl",ttl);args.put("x-dead-letter-routing-key",stockReleaseRoutingKey);args.put("x-dead-letter-exchange",eventExchange);return new Queue(stockReleaseDelayQueue,true,false,false,args);}/*** 死信队列,用于被监听*/@Beanpublic Queue stockReleaseQueue(){return new Queue(stockReleaseQueue,true,false,false);}/*** 死信队列绑定关系* @return*/@Beanpublic Binding stockReleaseBinding(){return new Binding(stockReleaseQueue,Binding.DestinationType.QUEUE,eventExchange,stockReleaseRoutingKey,null);}/*** 延迟队列绑定关系* @return*/@Beanpublic Binding stockReleaseDelayBinding(){return new Binding(stockReleaseDelayQueue,Binding.DestinationType.QUEUE,eventExchange,stockReleaseDelayRoutingKey,null);}
}

🌟消息发送、消费

  1. 接受到订单服务大哥锁定库存请求时,进行锁定库存消息的发送。
  2. 发送消息的同时,在本地消息表插入记录。
  3. 消息消费时,找订单服务大哥查询订单状态即可。
  4. 根据订单状态,进行后续处理。

🌟写在最后

RabbitMQ项目实战之死信队列应用到此就结束啦!感谢大家的阅读,欢迎大家在评论区进行交流。


请添加图片描述

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

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

相关文章

Linux---网络时间服务器

本章主要介绍网络时间服务器。 使用chrony配置时间服务器配置chrony客户端向服务器同步时间 时间同步的必要性 一些服务对时间要求非常严格&#xff0c;例如&#xff0c;下图所示的由三台服务器搭建的ceph集群。 这三台服务器的时间必须保持一致&#xff0c;如果不一致&am…

Linux——操作系统与进程的基础概念

操作系统与进程的基础概念 本章思维导图&#xff1a; 注&#xff1a;思维导图对应的.xmind和.png文件都已同步导入至资源 1. 操作系统&#xff08;OS&#xff09; 操作系统的基本概念&#xff1a; 操作系统(operator system)简称OS&#xff0c;是一个管理软硬件资源的软件 1.…

redis查看统计信息

查看统计信息 在cli下使用info来查看统计信息 >info# Serverredis_version:6.2.1 #redis版本号redis_git_sha1:00000000 #git SHA1redis_git_dirty:0 redis_build_id:b1484a8552b715dbredis_mode:standalone #redis运行模式os:Darwin 19.6.0 x86_64 # os版本号arch_bits:64…

Maven基础知识

Maven是一款用于管理和构建Java项目的工具 Maven的作用&#xff1a; 依赖管理&#xff1a;方便快捷的管理项目依赖的jar包&#xff0c;避免版本冲突问题统一项目结构&#xff1a;提供标准统一的项目结构项目构建&#xff1a;标准跨平台的自动化项目构建方式 maven创建的工程…

Linux下的I2C驱动框架以及代码实现

参考资料&#xff1a; 1、Linux IIC 驱动分析 — 框架分析 - 知乎 (zhihu.com) 2、《Linux驱动开发指南》第十一章 3、《正点原子 I.MX6U嵌入式Linux驱动开发指南 V1.6》 4、《Linux设备驱动开发详解》 代码版本&#xff1a;Linux4.1.15 阅读本文需要先有一定的I2C基础以及Linu…

【UE5】瞬移+马赛克过渡效果

效果 步骤 1. 新建一个工程&#xff0c;创建一个Basic关卡 2. 添加第三人称游戏资源到内容浏览器 3. 新建一个材质&#xff0c;这里命名为“M_Pixel” 打开“M_Pixel”&#xff0c;设置材质域为“后期处理” 在材质图表中添加如下节点 此时效果如下&#xff0c;已经有马赛克的…

git 常用部分方法

git init // 初始化 在工作路径上创建主分支 git clone 地址 // 克隆远程仓库 git clone -b 分支名 地址 // 克隆分支的代码到本地 git status // 查看状态 git add 文件名 // 将某个文件存入暂存区 git checkout -- file // 撤销工作区的修改 例如git checkout -- readMe…

华为云安全组规则

初始发布cce,快被安全组搞死了。现在把自己的研究成果综合一下,在这里给自己留痕,希望对迷惑的朋友有帮助。 先搞懂安全组是个啥东东: 安全组规则 操作场景 安全组实际是网络流量访问策略,通过访问策略可以控制流量入方向规则和出方向规则,通过这些规则可以为加入安全组…

聊聊AsyncHttpClient的ChannelPool

序 本文主要研究一下AsyncHttpClient的ChannelPool ChannelPool org/asynchttpclient/channel/ChannelPool.java public interface ChannelPool {/*** Add a channel to the pool** param channel an I/O channel* param partitionKey a key used to retrieve the cac…

java对文件夹,文件操作

1、使用Java自带的File类来创建文件夹 String dirName "/data/file/temporaryfiles/"; File dir new File(dirName); if (!dir.exists()) {try {dir.mkdir();} catch (SecurityException se) {System.out.println("文件创建失败");}} else {System.out.…

视频处理关键知识

1 引言 视频技术发展到现在已经有100多年的历史&#xff0c;虽然比照相技术历史时间短&#xff0c;但在过去很长一段时间之内都是最重要的媒体。由于互联网在新世纪的崛起&#xff0c;使得传统的媒体技术有了更好的发展平台&#xff0c;应运而生了新的多媒体技术。而多媒体技术…

【android开发-21】android中调用系统摄像头camera拍照和相册的用法详解

1&#xff0c;调用摄像头 在Android中&#xff0c;调用系统摄像头拍照需要使用Intent来启动Camera应用&#xff0c;并在应用中设置相应的权限。下面是一个简单的例子&#xff1a; // 创建一个Intent对象&#xff0c;指定要执行的动作是拍照 Intent intent new Intent(Medi…

FITC-Dextran标记的抗体-科研

FITC-Dextran标记的抗体是一种将FITC&#xff08;荧光素异硫氰酸酯&#xff09;共价连接到抗体分子上的生物标记方法。这种标记使抗体具有荧光性质&#xff0c;可以用于免疫组化、流式细胞仪分析、荧光显微镜观察等各种应用中。以下是制备FITC-Dextran标记的抗体的基本步骤&…

php 导入excel

if($_FILES[files]){ $uploadfile$_FILES[files]; $name$uploadfile[name];//文件原名 $type$uploadfile[type]; $tmp_name$uploadfile[tmp_name]; $size$uploadfile[size]; $error$uploadfile[error]; // $uploadurl../../../d/uploads/; //上传路径 $path./uploads/; //上传路…

【教程】逻辑回归怎么做多分类

目录 一、逻辑回归模型介绍 1.1 逻辑回归模型简介 1.2 逻辑回归二分类模型 1.3 逻辑回归多分类模型 二、如何实现逻辑回归二分类 2.1 逻辑回归二分类例子 2.2 逻辑回归二分类实现代码 三、如何实现一个逻辑回归多分类 3.1 逻辑回归多分类问题 3.1 逻辑回归多分类的代…

Leetcode—198.打家劫舍【中等】

2023每日刷题&#xff08;五十二&#xff09; Leetcode—198.打家劫舍 算法思想 具体思路 首先&#xff0c;我们从上面的题目描述中抽象出题意。 ● 从一个非负整数数组中找到一个子序列&#xff0c;并且该子序列的和最大 ● 子序列中每个数的位置不能够相邻。举例来讲&…

Leetcode—1466.重新规划路线【中等】

2023每日刷题&#xff08;五十二&#xff09; Leetcode—1466.重新规划路线 算法思想 实现代码 class Solution { public:int minReorder(int n, vector<vector<int>>& connections) {vector<pair<int, int>> g[n];for(auto e: connections) {in…

JS的变量提升ES6基础

JS的变量提升&ES6基础 变量var关键字var声明作用域实例一实例二多个变量 变量提升 let关键字暂时性死区全局声明for循环中使用let const关键字 变量 ECMAScript变量时松散类型的&#xff0c;意思是变量可以用于保存任何类型的数据。 声明变量&#xff1a;var 、const、let …

阶梯电价1_分支结构 C语言xdoj27

题目&#xff1a;阶梯电价计费 类别&#xff1a;流程控制 时间限制&#xff1a;2S 内存限制&#xff1a;10000Kb 问题描述&#xff1a; 电价分三个档次&#xff0c;[0,110]度电&#xff0c;每度电0.5元&#xff1b;(110,210]度电&#xff0c;超出110部分每度电0.55元&…

git-vscode

git-vscode ctrlshiftp 创建分支 create branch 直接切到新的分支了 切换分支 直接点左下角自己选择 vscode中配置仓库 https://blog.csdn.net/zora_55/article/details/129709251 推送tag tag作用就是在 Git 中&#xff0c;标记存储库历史记录中特定提交的一种方式。t…