多中间件优雅停机问题处理

article/2025/8/29 5:16:53

事情是这样的,小明是一个工作五年的老程序员,半秃着的头已经彰显了他深不可测的技术实力。

在这里插入图片描述

这一天,小明收到了领导给过来的一个需求。

领导对小明说:“小明啊,你工作五年了,这个需求我交给你一个人负责很是放心,你可要保质保量按时落地呀”
小明当即立下军令状,拍着胸脯说到:“放心领导,交给我了”

在这里插入图片描述

小明承诺之后就开始认真看起了需求,过了五分钟以后,小明一拍脑袋,发现这需求还蛮简单,就是异步发个RocketMQ然后再由下游系统消费去修改Redis的一些信息,于是小明三下五除二,没花几天就把这事给干完了,于是开启了快乐的摸鱼,等待发布的那一天…

在这里插入图片描述

发布上线的这一天在小明的摸鱼下很快到来了…
因为部署的服务器很多,然后需要保证兼容性发布,不能直接停机,所以小明采取的是与往日一贯的兼容性发布方案,也就是分批发布。
准备好所有环境数据以后小明就开始发布了。

在这里插入图片描述

在重启第一批机器时,令人意想不到的事发生了,生产疯狂打印如下报错信息

在这里插入图片描述

吓的小明直接就给回滚了,为此这件事还惊动到了领导,让领导给铺天盖地一顿哐哐哐
接收完领导的批评以后,小明开始认真复盘为什么会出现这样的问题。

在这里插入图片描述

于是小明先画了一个简单的事故回顾分析图来帮助自己分析
正常运行时,应用如下图所示

在这里插入图片描述

小明看着这幅图仔细思索,突然小明敏锐的察觉到,难道是Redis与RocketMQ的关闭顺序导致的吗?带着这个问题点,小明开启了对应的源码解析之路

小明先是分析了Redis关闭核心源码(注意:案例使用的都是标准的SpringBoot集成Redis)

在这里插入图片描述

紧接着小明继续分析了RocketMQ关闭的核心源码(注意:案例使用的都是标准的SpringBoot集成RocketMQ)

在这里插入图片描述

然后小明结合上面两个中间件,继而分析了Spring在进行容器关闭时是如何关闭各类bean的

在这里插入图片描述

果然就是这个问题导致的,我们再来画一个图来梳理一下这个事故

在这里插入图片描述

分析完原因后,小明就开始思考解决方案了,经过几个夜晚的抓耳挠腮以及对Spring源码的阅读,小明终于找到了解决方案

在这里插入图片描述

小明是这样来设计的
步骤一、Spring容器启动快完成时会发送一个ContextRefreshedEvent事件,可以通过这个事件把RocketMQ自己注册的DefaultRocketMQListenerContainer类型的bean取出,存放在一个自己装配的config当中,目的是为了可以自己来控制RocketMQ shutDown的时机
在这里插入图片描述

PS:这里是一定要通过这个事件来做的,不要想着通过@Bean去找或者通过实现ApplicationContextAware接口然后拿到ApplicationContext去getBean的方式获取,因为这个执行过程在RocketMQ自己注册DefaultRocketMQListenerContainer的步骤之前,所以你是拿不到的

拿不到的原因给大家看一下两张源码图
在这里插入图片描述
在这里插入图片描述

步骤二、在应用进行关闭时一般是接收到了kill -9
或者调用了exit方法,这个时候Spring会在关闭时发出closeEvent事件,而这个事件是在destoryBean之前发出来的,这个时候我们就可以提前主动对所有的DefaultRocketMQListenerContainer进行shutDown了

步骤三、Redis的shutDown这个时候就可以放心的交给Spring自己的destoryBean方法来执行了

最后直接给大家看解决方案的代码
在这里插入图片描述

做完这一系列改造之后,于是乎小明再一次信心满满的开始了发布之旅,这一次就很顺利啦,线上没有再出现该类报错问题,顺利的完成了领导布置的任务,经过这件事后小明的实力又变强了几分

在这里插入图片描述


http://chatgpt.dhexx.cn/article/0ci8bY7u.shtml

相关文章

图灵机停机问题的不可判定性

Turing Machine Halting Problem 停机问题:指判断任意一个程序是否能在有限的时间之内结束运行的问题。图灵机停机问题是不可判定的,意思即是不存在一个图灵机能够判定任意图灵机对于任意输入是否停机。 证明一: 参考链接:Turin…

服务优雅停机

优雅停机 ​ 什么是优雅停机 ​ 优雅停机指的是Java项目在停机时需要做好断后工作。如果直接使用kill -9 方式暴力的将项目停掉,可能会导致正常处理的请求、定时任务、RMI、注销注册中心等出现数据不一致问题。 ​ 如何解决优雅停机呢?大致需要解决如…

停机问题的理解

关于停机问题维基百科给出的定义是: 停机问题(halting problem)是逻辑数学中可计算性理论的一个问题。通俗的说,停机问题就是判断任意一个程序是否会在有限的时间之内结束运行的问题。该问题等价于如下的判定问题:给…

静态变量的使用

静态变量:即类中的静态变量 类变量被其他方法使用 不管是被自己类的方法使用,还是被其他类的方法使用 都可以直接使用,不需要实例化对象即可使用。通过类名调用。 (遵守访问修饰符) 类变量只能通过类方法初始化。 普通变量被其他方法使用 …

类变量/静态变量

类变量 引入类变量 案例引出类变量: 有几个小孩在玩游戏,不时会有其他的小孩加入一起玩。怎么统计一共有多少小孩在玩? 按照现有的知识,可以设计一个小孩类,定义一个加入的方法。然后在主程序类的main方法中&#xf…

变量、常量、静态变量、静态常量

1、变量 在JAVA中我们通过三个元素来描述变量:变量类型,变量名以及变量值。 String love“imooc”; 变量类型 变量名 值(其中String具有不可变性,重新赋值后会生成新的String对象,love变量名这实际是指向对象地址的引用…

类中静态变量

不能在类声明中 初始化静态变量,这是因为声明描述了如何分配内存,但并未实际分配内存。 对于静态类成员,无论这个类的对象有多少个,静态成员都只有一个 对于静态类成员,可以在类声明之外使用单独的语句来进行初始化。…

静态变量和实例变量的区别

静态变量和实例变量的区别 大家好,我是酷酷的韩~ 1.在语法定义上的区别: 静态变量前要加static关键字,而实例变量前则不加。 2.在程序运行时的区别: (1)实例变量属于某个对象的属性,必须创建了实例对象,其中的实例…

JAVA静态变量是什么

java静态变量是什么-Java基础-PHP中文网 在java中,静态变量指的是被static修饰的类的变量;静态变量被所有类实例对象所共享,在内存中只有一个副本,当且仅当在类初次加载时会被初始化。 本教程操作环境:windows7系统、j…

静态变量与动态变量

0.静态存储与动态存储 1)静态存储变量通常是在变量定义时就分定存储单元并一直保持不变,直至整个程序结束。静态变量,全局动态变量都是静态存储 2)动态存储变量是在程序执行过程中,使用它时才分配存储单元&#xff0…

C++之static,静态变量

目录 1.为什么要用静态变量 2.全局变量 3.静态局部变量 4.静态数据成员的空间开辟 5.静态数据成员 6.释放 7.总结 1.内存: 2.初始化: 3.最大的优点: 4.指针: 5.释放时机: 1.为什么要用静态变量 前面我们定义…

C++静态变量

静态变量(Static Variables)是在程序运行期间保持其存在和值的变量,不会随着函数的调用而销毁和重新创建。静态变量在内存中分配一次,并且在整个程序的生命周期中保持存在。 在 C 中,静态变量可以声明在函数内部、类内…

win10显示rpc服务器不可用,win10系统RpC服务器不可用的详细办法

win10系统使用久了,好多网友反馈说win10系统RpC服务器不可用的问题,非常不方便。有什么办法可以永久解决win10系统RpC服务器不可用的问题,面对win10系统RpC服务器不可用的图文步骤非常简单,只需要1、使用netsh interface ip add 添…

w7系统显示rpc服务器不可用,教你win7系统rpc服务器不可用怎么办

用户在使用电脑进行时间同步,安装打印机或者其它的操作的时候可能会遇到同样一个问题,那就是提示“RPC服务器不可用”,很多朋友可能对于RPC并不了解,更不知道如何解决,下面,小编就来跟大家讲解rpc服务器不可…

计算机无法登陆提示rpc服务器不可用,电脑rpc服务器不可用,教你电脑rpc服务器不可用怎么解决...

有网友表示进入磁盘管理对磁盘进行分区、更改盘符或压缩卷等操作的时候出现“RPC服务器不可用”的报错,rpc服务器不可用怎么办?很多朋友可能对于RPC并不了解,下面小编教你电脑rpc服务器不可用怎么解决吧。 rpc服务器不可用怎么办 打开“运行”窗口&…

rpc服务器不可用自动重启,rpc服务器不可用_详细解决方法,彻底修复

通过测试证明,“rpc服务器不可用”可能是由于中了冲击波和震荡波导致。 虽然这个是很老的病毒,但还是有小部分用户没有对系统没有进行升级导致出现“rpc服务不可用”情况。 电脑遭到冲击波可能会出现以下症状: 1、系统资源紧张,应用程序运行速度异常。 2、Word、Excel、Pow…

rpc服务器不可用桌面图标消失,rpc服务器不可用,教您rpc服务器不可用怎么办

有网友表示进入磁盘管理对磁盘进行分区、更改盘符或压缩卷等操作的时候出现“RPC服务器不可用”的报错,通常我们在安装打印机或者虚拟磁盘时,将出现此提示。下面,小编给大家介绍rpc服务器不可用的处理技巧。 用户在使用电脑进行时间同步&…

计算机无法登陆提示rpc服务器不可用,电脑提示RPC服务器不可用的解决方法

最近有Win7用户反映在使用打印机或使用电脑进行时间同步的时候,突然弹出“RPC服务器不可用”的提示,很多用户可能对于RPC并不了解,更不知道如何解决,现在小编就和大家分享Win7系统RPC服务器不可用的解决方法。 RPC服务器&#xff…

为什么我的电脑显示rpc服务器不可用,电脑提示RPC服务器不可用解决办法

电脑提示"RPC服务器不可用"解决办法 腾讯视频/爱奇艺/优酷/外卖 充值4折起 在使用电脑的过程中,有些小伙伴遇到了电脑提示“RPC服务器不可用”的情况。那么, 电脑提示“RPC服务器不可用”怎么办呢?下面,就和小编一起来看看吧。 原…

xp显示rpc服务器不可用,WinXP系统rpc服务器不可用怎么解决?

最近有WinXP系统用户反映,使用数据线直接将手机照片向电脑复制的时候,出现提示“rpc服务器不可用”,这让用户非常苦恼。那么,WinXP系统rpc服务器不可用怎么解决呢?下面,我们就一起往下看看WinXP系统rpc服务…