devbox
IT小白
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

【十七】RabbitMQ基础篇（延迟队列和死信队列实战）_mqumd

作者：IT小白 | 2024-08-05 00:51:05

赞

踩

mqumd

互相交流入口地址 

整体目录：

【一】springboot整合swagger

【二】springboot整合自定义swagger

【三】springboot整合token

【四】springboot整合mybatis-plus

【五】springboot整合mybatis-plus

【六】springboot整合redis

【七】springboot整合AOP实现日志操作

【八】springboot整合定时任务

【九】springboot整合redis实现启动服务时热点数据保存在全局和缓存

【十】springboot整合quartz实现定时任务优化

【十一】springboot整合异步调用并获取返回值

【十二】springboot整合WebService

【十三】springboot整合WebService关于传参数

【十四】springboot整合WebSocket

【十五】springboot整合WebSocket实现聊天室

【十六】RabbitMQ基础篇（下载安装并基础使用，内含各种坑问题）

【十七】RabbitMQ基础篇（延迟队列和死信队列实战）

【十八】springboot实现自定义全局异常处理

【十九】初学Kafka并实战整合SpringCloudStream进行使用

【二十】springboot整合ElasticSearch实战（万字篇）

【二十一】springboot整合过滤器实战

【二十二】springboot整合拦截器实战并对比过滤器

【二十三】springboot整合activiti7（1）实战演示篇

【二十四】springboot整合spring事务详解以及实战

【二十五】springboot使用EasyExcel和线程池实现多线程导入Excel数据

【二十六】springboot整合jedis和redisson布隆过滤器处理缓存穿透

【二十七】springboot实现多线程事务处理

【二十八】springboot之threadLocal参数解析器实现session一样保存当前登录功能 

【二十九】springboot整合logback实现日志管理

【三十】springboot项目上高并发解决示例

目录

一、分析例子

二、编写前端代码

三、整理模块

四、改造common公共模块

五、改造provider服务提供方

六、改造consumer服务消费方

七、演示

        本章将通过学习rabbitMQ基础中的延时队列和死信队列，然后写一个demo实现一个小例子，在商城购物时，先下单创建订单记录，然后可以选择进行立即支付或者不支付，若30秒后不支付，则删除订单。下面针对这个例子进行学习。

watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBA5bCPeuKZgA==,size_20,color_FFFFFF,t_70,g_se,x_16

首先展示一下最终效果，并进行效果讲解，如下所示：

  • 正常购买流程

73770f44d71741b5894023aa8d56788f.gif

 描述：点击购买，创建订单记录，在倒计时内支付成功的话，正常完成购买流程。

  • 未支付流程

8f69d31704b84a4ebc807114f62228d4.gif

 描述：点击购买，创建订单记录，在倒计时内未支付成功的话，删除该笔订单。

        下面为了满足上述效果，进行实现。

一、分析例子

        为了满足上面的效果，可以通过很多方法实现，最简单的就是定时任务，创建一个定时任务，定时去请求数据，查看状态为未支付的订单，并删除。当然还可以通过redis或者其他办法，本章当然是通过RabbitMQ的方式实现，将通过延时队列和死信队列实现，逻辑关系如下：

watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBA5bCPeuKZgA==,size_20,color_FFFFFF,t_70,g_se,x_16

所以需要创建如下几个东西：

  • 延时交换机
  • 延时队列
  • 延时队列绑定关系
  • 死信交换机
  • 死信队列
  • 死信队列绑定关系 
  • 消费者端死信队列监听器
  • 生产者端创建订单接口（内含发送消息到延时队列）
  • 生产者端支付订单接口

 分析完毕，下面开整。

建表语句

  1. CREATE TABLE `dingdan` (
  2.   `id` varchar(255) COLLATE utf8_bin NOT NULL,
  3.   `name` varchar(255) COLLATE utf8_bin DEFAULT NULL,
  4.   `type` int DEFAULT NULL COMMENT '0：未支付，1：已支付，默认0',
  5.   PRIMARY KEY (`id`)
  6. ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb3 COLLATE=utf8_bin;

二、编写前端代码

        上面测试效果是随便整的，过于简便，代码我直接贴出来：

watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBA5bCPeuKZgA==,size_14,color_FFFFFF,t_70,g_se,x_16

  1. <!DOCTYPE html>
  2. <html>
  3. 	<head>
  4. 		<meta charset="utf-8">
  5. 		<title>订单</title>
  6. 	</head>
  7. 	<link rel="stylesheet" href="https://stackpath.bootstrapcdn.com/bootstrap/4.3.1/css/bootstrap.min.css" integrity="sha384-ggOyR0iXCbMQv3Xipma34MD+dH/1fQ784/j6cY/iJTQUOhcWr7x9JvoRxT2MZw1T" crossorigin="anonymous">
  8. 	<script src="https://cdn.bootcdn.net/ajax/libs/jquery/3.5.1/jquery.js"></script>
  9. 	<script src="https://cdnjs.cloudflare.com/ajax/libs/popper.js/1.14.7/umd/popper.min.js" integrity="sha384-UO2eT0CpHqdSJQ6hJty5KVphtPhzWj9WO1clHTMGa3JDZwrnQq4sF86dIHNDz0W1" crossorigin="anonymous"></script>
  10. 	<script src="https://stackpath.bootstrapcdn.com/bootstrap/4.3.1/js/bootstrap.min.js" integrity="sha384-JjSmVgyd0p3pXB1rRibZUAYoIIy6OrQ6VrjIEaFf/nJGzIxFDsf4x0xIM+B07jRM" crossorigin="anonymous"></script>
  11. 	
  12. 	<body>
  13. 		<div style="width: 100%;height: 300px;display: flex;justify-content: center;margin-top: 200px;">
  14. 			<div class="card" style="width: 15rem;">
  15. 			  <img class="card-img-top" style="" src="./img/apple.jpg" alt="Card image cap">
  16. 			  <div class="card-body">
  17. 			    <h5 class="card-title">苹果售价：100￥</h5>
  18. 			    <a onclick="fun1()" style="margin-top: 20px;margin-left: 70px;" class="btn btn-primary">购买</a>
  19. 			  </div>
  20. 			</div>
  21. 		</div>
  22. 	</body>
  23. 	
  24. 	<script type="text/javascript">
  25. 		function fun1(){
  26. 			console.log("点击");
  27. 				
  28. 			$.ajax({
  29. 				url:"http://localhost:7778/dingdanController/insertDingdan",
  30. 				data:null,
  31. 				type:"post",
  32. 				dataType: "json",
  33. 				success: function(data) { 
  34. 					console.log("返回值："+data.id);
  35. 					window.location.href="支付.html?id="+data.id
  36. 				}
  37. 			});
  38. 		}
  39. 	</script>
  40. </html>
  1. <!DOCTYPE html>
  2. <html>
  3. 	<head>
  4. 		<meta charset="utf-8">
  5. 		<title>支付</title>
  6. 	</head>
  7. 	<link rel="stylesheet" href="https://stackpath.bootstrapcdn.com/bootstrap/4.3.1/css/bootstrap.min.css" integrity="sha384-ggOyR0iXCbMQv3Xipma34MD+dH/1fQ784/j6cY/iJTQUOhcWr7x9JvoRxT2MZw1T" crossorigin="anonymous">
  8. 	<script src="https://cdn.bootcdn.net/ajax/libs/jquery/3.5.1/jquery.js"></script>
  9. 	<script src="https://cdnjs.cloudflare.com/ajax/libs/popper.js/1.14.7/umd/popper.min.js" integrity="sha384-UO2eT0CpHqdSJQ6hJty5KVphtPhzWj9WO1clHTMGa3JDZwrnQq4sF86dIHNDz0W1" crossorigin="anonymous"></script>
  10. 	<script src="https://stackpath.bootstrapcdn.com/bootstrap/4.3.1/js/bootstrap.min.js" integrity="sha384-JjSmVgyd0p3pXB1rRibZUAYoIIy6OrQ6VrjIEaFf/nJGzIxFDsf4x0xIM+B07jRM" crossorigin="anonymous"></script>
  11. 	
  12. 	<body>
  13. 		<div style="width: 100px;height: 30px;text-align: center;line-height: 30px;margin-top: 100px;margin-left: 50%;background-color: aliceblue;">
  14. 			支付倒计时：
  15. 		</div>
  16. 		<div id="time" style="width: 100px;height: 30px;text-align: center;line-height: 30px;margin-top: 10px;margin-left: 50%;background-color: aliceblue;">
  17. 			
  18. 		</div>
  19. 		<button onclick="fun1()" style="margin-top: 10px;margin-left: 50%;" type="button" class="btn btn-primary">确定支付</button>
  20. 	</body>
  21. 	<script type="text/javascript">
  22. 		
  23. 		var id = getid('id');
  24. 		console.log(id);
  25. 		// alert(id);
  26. 		
  27. 		var i=15;
  28. 		$("#time").html(i);
  29. 		var time1 =setInterval(function(){
  30. 			if(i>0){
  31. 				i=i-1;
  32. 				$("#time").html(i);
  33. 			}else{
  34. 				clearInterval(time1);
  35. 			}
  36. 		},1000)
  37. 		
  38. 		var time2 = setInterval(function(){
  39. 			var i = $("#time").html();
  40. 			if(i==0){
  41. 				window.location.href="订单.html"
  42. 			}
  43. 		},1000)
  44. 		
  45. 		//支付
  46. 		function fun1(){
  47. 			alert("支付成功");
  48. 			clearInterval(time1);
  49. 			clearInterval(time2);
  50. 			$.ajax({
  51. 				url:"http://localhost:7778/dingdanController/pay",
  52. 				data:{id:id},
  53. 				type:"post",
  54. 				dataType: "json",
  55. 				success: function(data) { 
  56. 					
  57. 				}
  58. 			});
  59. 			
  60. 		}
  61. 		//取值
  62. 		function getid(names, urls) {
  63. 			urls = urls || window.location.href;
  64. 			urls && urls.indexOf("?") > -1 ? urls = urls
  65. 					.substring(urls.indexOf("?") + 1) : "";
  66. 			var reg = new RegExp("(^|&)" + names + "=([^&]*)(&|$)", "i");
  67. 			var r = urls ? urls.match(reg) : window.location.search.substr(1)
  68. 					.match(reg);
  69. 			if (r != null && r[2] != "")
  70. 				return unescape(r[2]);
  71. 			return null;
  72. 		};
  73. 	</script>
  74. </html>

用的ajax和bootstrap。

三、整理模块

        下面开始本章的核心改造，首先补一下前面章节的坑，建立父子工程时，直接在父工程的maven进行打包会出异常，因为其中含有一个common公共模块，其他服务有使用commo模块的东西，为了避免编译整个父工程时再报错，在功能模块代码的pom文件，增加如下代码：

watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBA5bCPeuKZgA==,size_20,color_FFFFFF,t_70,g_se,x_16

        这样，下次在父工程直接编译就不会再找不到各个模块对commom模块的依赖了。

watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBA5bCPeuKZgA==,size_20,color_FFFFFF,t_70,g_se,x_16

        然后本次测试会涉及到数据库的操作，所以直接引入mybatis-plus，便于操作，关于mybatis-plus的操作，前面springboot整合篇有讲到。

此处再简单讲一下整合mybatis-plus简要步骤：

  1. 导入依赖到父工程watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBA5bCPeuKZgA==,size_20,color_FFFFFF,t_70,g_se,x_16
  2. 修改provider模块和consumer模块业务模块的配置类yml文件watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBA5bCPeuKZgA==,size_20,color_FFFFFF,t_70,g_se,x_16两个模块的yml配置文件记得都要修改。
  3. 关于报错，数据库版本问题可能导致依赖版本存在一些不一致，会出现一系列问题，根据报错百度一下即可解决。

四、改造common公共模块

        接下来改造common模块，为了方便管理，每个模块公用的东西都放到了common子工程，上一章有将topic主题模式消息队列涉及到的常量放到common的RabbitMQConstant类中，但是本章为了方便看，就直接不将常量信息放到其中。

  1. 创建实体类  watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBA5bCPeuKZgA==,size_20,color_FFFFFF,t_70,g_se,x_16id使用mybatis-plus的UUID雪花算法自动生成。
  2. 本来想将mapper也放到其中，但是放到其中后，其他模块使用时会导致接口无法访问，问题还未解决。 

五、改造provider服务提供方

        还是展示一下改造后的provider服务的最终目录结构，如下：

watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBA5bCPeuKZgA==,size_20,color_FFFFFF,t_70,g_se,x_16

框选部分为新增代码，下面开整。

  1. 新增mapper类watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBA5bCPeuKZgA==,size_20,color_FFFFFF,t_70,g_se,x_16
  2. 新增订单操作接口watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBA5bCPeuKZgA==,size_20,color_FFFFFF,t_70,g_se,x_16

简要描述：

        1、创建一个支付接口，一个创建订单接口。

        2、创建订单接口：创建订单记录，并发送消息（传订单id）到延时交换机，并将id返回前端方便前端调用支付接口。

        3、支付接口：根据订单id，改变订单已支付状态，避免被消息监听器处理。 

六、改造consumer服务消费方

        接着改造consumer服务，最终目录结构如下：

watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBA5bCPeuKZgA==,size_20,color_FFFFFF,t_70,g_se,x_16

框选处为新增代码。

  1. 新增mapper，和生产者服务一样，本来应该可以放到common，但是我还未解决问题，只能先这样处理。watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBA5bCPeuKZgA==,size_20,color_FFFFFF,t_70,g_se,x_16
  2. 新增延时队列和死信队列的配置类TopicDelayConfig。watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBA5bCPeuKZgA==,size_20,color_FFFFFF,t_70,g_se,x_16

简要描述：

        类似原来的主题模式的常规配置，只不过此处的延时队列创建时有所不同，需要先设置好各个参数再创建，注释有说明，此处为了方便操作，直接使用的路由模式，没有使用主题模式。       

  1. 创建延时交换机
  2. 创建死信交换机
  3. 创建延时队列，并设置延时时间以及，成为死信后进入哪一个交换机并设置路由键
  4. 创建死信队列
  5. 创建死信队列和死信交换机的绑定关系
  6. 创建延时队列和延时交换机的绑定关系

    3. 新增死信队列监听器         watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBA5bCPeuKZgA==,size_20,color_FFFFFF,t_70,g_se,x_16

简要描述：

        根据从队列接收到的消息处理具体的逻辑，根据订单id查询订单记录，若存在则判断是否已支付，若未支付则删除。

七、演示

        演示效果如本章开篇所展示的一致，此处就不展示了，感兴趣的朋友可以尝试一下，over。

——————————————————完毕——————————————————

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/IT小白/article/detail/930180
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

  

闽ICP备14008679号