SpringBoot整合RabbitMQ之典型应用场景实战三-低调大师

SpringBoot整合RabbitMQ之典型应用场景实战三

2018-11-29 866

实战前言

RabbitMQ 作为目前应用相当广泛的消息中间件，在企业级应用、微服务应用中充当着重要的角色。特别是在一些典型的应用场景以及业务模块中具有重要的作用，比如业务服务模块解耦、异步通信、高并发限流、超时业务、数据延迟处理等。前两篇博文我介绍分享了RabbitMQ在业务服务模块异步解耦以及通信的实战业务场景，感兴趣童鞋可以前往观看：
1.https://www.roncoo.com/article/detail/134309

2.https://www.roncoo.com/article/detail/134312

这篇博文我们继续介绍分享RabbitMQ死信队列实战以及在支付系统中支付过程超时则自动失效其下单记录这样的业务场景！

RabbitMQ 实战：死信队列认识与场景实战

死信队列认识

死信队列，又可以称之为“延迟/延时队列”，也是队列的一种，只不过与普通的队列最大的不同之处在于创建时的组成成分不同，创建死信队列的“成分”将不仅仅只是：名称、持久化、自动删除等基本属性，还包含了死信交换机、死信路由甚至还有TTL（Time-To-Live）即队列中消息可生存的时间。

死信队列其实最大的作用是可以实现消息或者数据延迟/延时处理，而且还可以动态的设定延迟的时间，即动态设定 TTL。典型的业务场景很多，在这里就不一一列举了，总之，凡是业务中需要延迟一定时间再处理的数据均可以将其压入死信队列中，等待一定的时间后再执行真正的处理逻辑！

下面是死信队列在创建、绑定、生产消息、消费消息过程的结构流程图，在这里其实已经很明确的指出死信队列的创建跟绑定逻辑以及真正监听消费处理消息的队列的绑定逻辑。图中问题的答案为：当入死信队列的消息TTL一到，它自然而然的将被路由到 死信交换机绑定的队列 中被真正消费处理！！！

死信队列场景实战

有了上面的流程图做指导，接下来，我们将用死信队列实战这样的一个业务场景：用户在商城下单成功并点击去支付后在指定时间未支付时自动失效！于是乎，我们需要创建两个消息模型，在 RabbitmqConfig 实施：

死信队列：用于设定指定的待支付的交易订单号在指定的 TTL（单位为 ms）后何去何从！
真正队列：用于监听消费处理指定的交易订单号，即判断该交易订单号是否已完成，如果否，则失效之！

接下来是我们的生产端的逻辑：用户商城下单的处理！

接下来是等待固定的 TTL：在这里设定的是 10s，当消息入死信队列 10s 后，将自然而然的将消息路由到下一个中转站，即真正的消费监听处理队列进行处理：判断该笔交易订单号是否已经付款，如果否，则失效之！

可以将该服务跑起来，然后发起 controller 的用户下单请求，会发现消息入死信队列后不会立马被消费，等待 10s 会，消息会被路由到真正的消费队列中进行处理，这一现象可以在 MQ 的后端控制台应用中看到！

总结：到此我们的死信队列已经实战完毕，回顾我们所介绍的历程，其实核心重点在于上面的那张 “死信队列的结构流程图”，理解了这个结构流程图中的相关组件及其流程，则在实战各种需要延时处理的业务场景将得心应手，包括如何创建死信队列，如何面向生产端绑定死信队列，如何面向消费端绑定真正的队列等等！而对于死信队列的实战场景，前面也介绍过了：凡是需要等待一定时间或者需要缓一缓特定时间的业务、数据均可以通过死信队列来实现！

可以将该服务跑起来，然后发起 controller 的用户下单请求，会发现消息入死信队列后不会立马被消费，等待 10s 会，消息会被路由到真正的消费队列中进行处理，这一现象可以在 MQ 的后端控制台应用中看到！

回顾与总结

RabbitMQ 的认识与实际业务场景的实战到此我都已经介绍完毕，总体而言，RabbitMQ 作为目前应用相当广泛的消息中间件，在我们实际系统的业务模块中具有重要的作用，特别是刚开始介绍的几种消息模型以及死信队列模型在微服务系统、分布式系统中均可充当重要的角色，其中我们实战的业务场景包括业务服务模块解耦异步通信（异步发送日志、异步发送邮件）；另外，我们还介绍了消息确认机制，这是一种 MQ 确保消息能被消费者消费的机制，对于一些业务模块也是有广泛的应用；除此之外，我们还模拟实战了秒杀系统、抢单系统这样的业务场景下 RabbitMQ 的作用：限流、排队缓压、减少数据库读写锁的发生等等！

彩蛋：本博文介绍了RabbitMQ死信队列及其业务场景的实战，此业务场景其实适用于任何需要“延迟一定时间处理”的业务，包括本博文介绍的 “支付系统-用户下单点击去支付后超时仍未支付成功时则需要暂时失效其下单记录”！另外，博主已将RabbitMQ相关技术以及场景实战的相关要点录制成了视频教程，感兴趣小伙伴可以前往学习观看：https://www.roncoo.com/course/view/95ffac8bd3aa4f2d8a0d83c32f46c69d

微信关注我们

原文链接：https://blog.roncoo.com/article/134316

转载内容版权归作者及来源网站所有！

低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。

大数据平台搭建（hadoop+spark）

一.基本信息 1. 服务器基本信息主机名 ip地址安装服务 spark-master 172.16.200.81 jdk、hadoop、spark、scala spark-slave01 172.16.200.82 jdk、hadoop、spark spark-slave02 172.16.200.83 jdk、hadoop、spark spark-slave03 172.16.200.84 jdk、hadoop、spark 2. 软件基本信息软件名版本安装路径 oracle jdk 1.8.0_111 /usr/local/jdk1.8.0_111 hadoop 2.7.1 /usr/local/hadoop-2.7.3 spark 2.0.2 /usr/local/spark-2.0.2 scala 2.12.1 usr/local/2.12.1 3.环境变量汇总 #############java############ exportJAVA_HOME=/usr/local/jdk1.8.0_111 exportPATH=$JAVA_HOME/bin:$PATH exp...

2018-11-29

527

资源下载

更多资源

优质分享App

近一个月的开发和优化，本站点的第一个app全新上线。该app采用极致压缩，本体才4.36MB。系统里面做了大量数据访问、缓存优化。方便用户在手机上查看文章。后续会推出HarmonyOS的适配版本。

Mario

马里奥是站在游戏界顶峰的超人气多面角色。马里奥靠吃蘑菇成长，特征是大鼻子、头戴帽子、身穿背带裤，还留着胡子。与他的双胞胎兄弟路易基一起，长年担任任天堂的招牌角色。

Spring

Spring框架（Spring Framework）是由Rod Johnson于2002年提出的开源Java企业级应用框架，旨在通过使用JavaBean替代传统EJB实现方式降低企业级编程开发的复杂性。该框架基于简单性、可测试性和松耦合性设计理念，提供核心容器、应用上下文、数据访问集成等模块，支持整合Hibernate、Struts等第三方框架，其适用范围不仅限于服务器端开发，绝大多数Java应用均可从中受益。

Rocky Linux

Rocky Linux（中文名：洛基）是由Gregory Kurtzer于2020年12月发起的企业级Linux发行版，作为CentOS稳定版停止维护后与RHEL（Red Hat Enterprise Linux）完全兼容的开源替代方案，由社区拥有并管理，支持x86_64、aarch64等架构。其通过重新编译RHEL源代码提供长期稳定性，采用模块化包装和SELinux安全架构，默认包含GNOME桌面环境及XFS文件系统，支持十年生命周期更新。