Spring 之 Lifecycle 及 SmartLifecycle

最近在看Eureka源码，本想快速解决这场没有硝烟的战役，不曾想阻塞性问题一个接一个。为正确理解这个框架，我不得不耐着性子，慢慢梳理这些让人困惑的点。譬如本章要梳理的Lifecycle和SmartLifecycle。它们均为接口，其中后者继承于前者，他们的类图如下所示：

关于Lifecycle，网络平台给出的解释是这样的：它是Spring框架中的一个基础接口，用于简化管理有状态的组件（譬如连接池、定时任务等）的初始化、启动、停止等生命周期过程。它定义了以下核心方法：

  1. start()：启动组件。这通常涉及初始化必要的资源，使组件处于可操作状态。
  2. stop()：停止组件。执行必要的清理工作，释放资源，使组件处于不可操作状态。
  3. isRunning()：该方法用于检查组件当前是否正在运行。返回true表示组件已启动且正在运行，返回false则表示未启动或已停止。

与SmartLifecycle相比，Lifecycle接口较为简单，不涉及启动顺序控制、自动启动配置或生命周期回调等功能。它是更基础的生命周期管理接口，适用于那些不需要复杂生命周期管理逻辑的组件。

下面就一起看一下Spring的这个组件是如何使用的，其实非常简单，就是实现这个接口且实现其中定义的接口方法，比如下面这个自定义实现类：

package org.com.chinasoft.lifecycle;import org.springframework.context.Lifecycle;
import org.springframework.context.annotation.Configuration;@Configuration
public class MyLifecycle implements Lifecycle {/*** A 组件的运行状态*/private volatile boolean running = false;/*** 容器启动后调用*/@Overridepublic void start() {System.out.println("lifecycle 容器启动完成,启动A组件...");running = true;}/*** 容器停止时调用*/@Overridepublic void stop() {System.out.println("lifecycle 收到关闭容器的信号,关闭A组件...");running = false;}/*** 检查此组件是否正在运行。* 1. 只有该方法返回false时，start方法才会被执行。* 2. 只有该方法返回true时，stop(Runnable callback)或stop()方法才会被执行。*/@Overridepublic boolean isRunning() {System.out.println("lifecycle 检查A组件的运行状态：" + running);return running;}
}

那这个类是如何使用的呢？通过显式调用ConfigurableApplicationContext上的start()/stop()方法实现的。具体可以看一下下面这个类：

package org.com.chinasoft;import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.autoconfigure.kafka.KafkaAutoConfiguration;
import org.springframework.context.ApplicationContext;
import org.springframework.context.ConfigurableApplicationContext;@SpringBootApplication(exclude = KafkaAutoConfiguration.class)
public class EurekaServiceApplication {public static void main(String[] args) {ConfigurableApplicationContext ctx = SpringApplication.run(EurekaServiceApplication.class, args);ctx.start();ctx.stop();}}

为什么可以这样呢？这是由于ConfigurableApplicationContext接口继承了Lifecycle接口，关于这个接口的继承结构可以看一下下面这幅图：

从图中可以很清楚的看到ConfigurableApplicationContext接口继承了Lifecycle接口，由此所有实现该接口的类都拥有了Lifecycle的功能。就像案例中写的那样，为了演示Lifecycle接口的用法，我们显式的调用了ConfigurableApplicationContext对象上的start()和stop()方法。执行结果如下图所示：

这里既然提到了显式调用，那如果不显式调用是不是会不一样？（网络资料是这样讲的：如果不显式调用不会有图片中的输出）。注释上述调用代码后的执行结果如下图所示：

个人觉得这里就有点意思了，实际应用过程中，我们会显式调用这个吗？如果不会，这个调用的逻辑又在哪里呢？为了了解这个过程，还是先来看一下显式调用的执行流程（红色加粗加下划线的部分即为实际的执行流程）：

  1. AbstractApplicationContext#start()【这个实现方法来自于其实现的Lifecycle接口】
  2. AbstractApplicationContext#getLifecycleProcessor()【调用这个方法的主要目的是获取Lifecycleprocessor对象，这个对象的实际类型为DefaultLifecycleProcessor】
  3. DefaultLifecycleProcessor#start()【调用该类中的start()方法。这个start()方法接着会调用DefaultLifecycleProcessor类上的startBeans()方法。这个方法首先从容器中拿到所有实现Lifecycle的bean，然后遍历这个集合，将拿到的bean对象包装到Map<Integer, LifecycleGrop>集合中（这个集合的value是一个LifecycleGroup对象），接着会不断调用LifecycleGroup对象的add()方法将Lifecycle对象的名字及对象添加到LifecycleGroup对象中实际类型为List的members集合中，注意这个集合中元素的实际类型为LifecycleGroupMember。最后遍历Map<Integer, LifecycleGrop>集合，然后调用LifecycleGroup对象上名为start()的方法，这个方法首先判断members元素是否为空，如果不为空则排序，然后遍历集合对象中的元素（LifecycleGroupMember），这个遍历会首先对要处理的元素进行检查，看其是否在LifecycleGroup对象上的lifecycleBeans集合中，如果在，则调用DefaultLifecycleProcessor类上的doStart()方法，如果一切顺利最后就调用Lifecycle实现类上的start()方法。这个处理方法的具体实现逻辑如下所示：
private void doStart(Map<String, ? extends Lifecycle> lifecycleBeans, String beanName, boolean autoStartupOnly) {Lifecycle bean = lifecycleBeans.remove(beanName);if (bean != null && !this.equals(bean)) {String[] dependenciesForBean = this.beanFactory.getDependenciesForBean(beanName);for (String dependency : dependenciesForBean) {doStart(lifecycleBeans, dependency, autoStartupOnly);}if (!bean.isRunning() &&(!autoStartupOnly || !(bean instanceof SmartLifecycle) || ((SmartLifecycle) bean).isAutoStartup())) {if (logger.isDebugEnabled()) {logger.debug("Starting bean '" + beanName + "' of type [" + bean.getClass() + "]");}try {bean.start();}catch (Throwable ex) {throw new ApplicationContextException("Failed to start bean '" + beanName + "'", ex);}if (logger.isDebugEnabled()) {logger.debug("Successfully started bean '" + beanName + "'");}}}
}

实际调用跟踪过程中发现，这个方法中Lifecycle类型的对象bean是一个代理对象。难道说所有实现该Lifecycle接口的对象都是通过动态代理的方式注入到了Spring容器中？关于这个问题暂且不表，先来看一下这个处理过程中用到的几个类：

  1. DefaultLifecycleProcessor，这是一个实现了LifecycleProcessor接口（这个接口继承了Lifecycle接口）和BeanFactoryAware接口的类。就测试案例中的操作来说：容器中所有对Lifecycle对象的操作都是通过这个类实现的。个人理解这个类的主要作用是：处理Spring Bean的生命周期。（大模型给出的解释：该类是一个实现LifecycleProcessor和BeanFactoryAware接口的Java类。LifecycleProcessor接口定义了在Spring应用程序上下文中处理生命周期方法的策略，BeanFactoryAware接口允许类在被Spring容器实例化时获取对BeanFactory的引用。这个类的作用是处理Spring Bean的生命周期。）
  2. LifecycleGroup，它是DefaultLifecycleProcessor类中的一个私有内部类，其拥有的属性非常清晰：int类型的phase、long类型的timeout、boolean类型的autoStartupOnly、int类型的smartMemberCount、Map<String, ? extneds Lifecycle>类型的lifecycleBeans以及List<LifecycleGroupMember>类型的members。其中members用于存放包装了Lifecycle对象的LifecycleGroupMember对象。另外这个类上还有add(String name, Lifecycle bean)方法、start()方法和stop()方法。其中第一个方法用于将Lifecycle对象添加到members集合中，这个方法在添加前会判断这个对象是否是SmartLifecycle类型，如果是则将smartMemberCount的值自增1。start()方法的作用是在真正调用Lifecycle对象的start()方法前，做一些特殊处理，比如校验（this.members.isEmpty()）、对集合进行排序（Collections.sort(this.members)）、遍历members集合（调用DefaultLifecycleProcessor类上的doStart()方法，触发Lifecycle对象上start()方法的调用）。stop()方法的处理逻辑与start()方法基本类似，有兴趣的可以看一下源码。个人理解这个类的主要作用就是对Lifecycle类型的对象做个分组，以方便管理，实现一些特殊功能。
  3. LifecycleGroupMember，它与LifecycleGroup类似，都是DefaultLifecycleProcessor类中的一个私有内部类，这个类实现了Comparable接口，可以实现排序。这个类中有两个属性，一个为String类型的name，一个是Lifecycle类型的bean，其中只有一个compareTo()方法，这个方法是实现排序的关键。个人理解这个类的作用就是让系统中的Lifecycle对象具有排序功能。

现在让我们一起回过头来看一下这个问题：实际应用过程中，我们会显式调用这个吗？如果不会，这个调用的逻辑又在哪里呢？注意这个问题中提到的显式调用，说的是Lifecycle接口中的start()及stop()，为了寻找这两个方法的调用起点，我们可以利用一下拥有强大查找功能的集成工具idea。通过idea的查找工具，我们可以发现调用Lifecycle接口中的start()及stop()方法的地方有以下几个：

  1. AbstractDiscoveryLifecycle的第243行this.start()：AbstractDiscoveryLifecycle类实现了DiscoveryLifecycle接口（这个接口继承了SmartLifecycle接口，其中SmartLifecycle接口又继承了Lifecycle接口）。因此这里调用的就是AbstractDiscoveryLifecycle类中的start()方法，而这个方法的源调用方即ApplicationListener接口实现类AbstractDiscoveryLifecycle中的onApplicationEvent()方法
  2. RestartEndpoint的第203行this.context.start()：ConfigurableApplicationContext类对象是RestartEndpoint中的属性，而这个类又实现了Lifecycle接口，所以这一行调用的其实就是ConfigurableApplicationContext类父类AbstractApplicationContext中的start()方法
  3. EurekaDiscoveryClientConfiguration的第76行this.autoRegistration.start()：这个调用最终调用的是EurekaAutoServiceRegistration类中的start()方法（这个类实现了SmartLifecycle接口）
  4. EurekaAutoServiceRegistration的第126行start()：EurekaAutoServiceRegistration类实现了SmartLifecycle接口，所以这个start()方法中做了一些自己的逻辑
  5. AbstractApplicationContext的第1303行getLifecycleProcessor().start()：这个就是前面梳理的哪个处理逻辑
  6. DefaultLifecycleProcessor的第175行bean.start()：这个前面也梳理过，调用的就是Lifecycle实现类上的start()方法

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

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

相关文章

mysql的锁（全局锁）

mysql的锁（全局锁）

文章目录 mysql按照锁的粒度分类全局锁概念&#xff1a;全局锁使用场景&#xff1a;全局锁备份案例&#xff1a; mysql按照锁的粒度分类 全局锁 概念&#xff1a; 全局锁就是对整个数据库实例加锁。MySQL 提供了一个加全局读锁的方法&#xff0c;命令是: Flush tables with…
阅读更多...
排序算法——归并排序以及非递归实现

排序算法——归并排序以及非递归实现

一、归并排序思想 归并排序&#xff08;MERGE-SORT&#xff09;是建立在归并操作上的一种有效的排序算法,该算法是采用分治法&#xff08;Divide andConquer&#xff09;的一个非常典型的应用。将已有序的子序列合并&#xff0c;得到完全有序的序列&#xff1b;即先使每个子序列…
阅读更多...
重新ysyx

重新ysyx

一、克隆仓库 1.创建ssh key ssh-keygen -t rsa cd ~/.ssh ls 查看里面是否有id_rsa id_rsa.pub ssh-keygen -t rsa -C "xiantong15834753336outlook.com" cat id_rsa.pub***********查看里面的内容&#xff0c;复制到下图中绿色的按钮 git init ssh -T g…
阅读更多...
Marin说PCB之Max parallel知多少？

Marin说PCB之Max parallel知多少？

今天是个阳光明媚&#xff0c;万里乌云的好日子。小编我一如既往地到家打开电脑准备看腾讯视频的五十公里桃花坞的第四季&#xff0c;在看到汪苏泷汪台说650电台要解散的时候小编我差点也哭了。650电台之于桃花坞就像乐队的鼓手一样&#xff0c;都是一个团队的灵感啊&#xff0…
阅读更多...
C语言分支和循环（2）

C语言分支和循环（2）

我的相关博客&#xff1a; C语言的分支与循环&#xff08;1&#xff09; 1.switch语句 除了 if 语句外&#xff0c;C语⾔还提供了 switch 语句来实现分⽀结构。 switch 语句是⼀种特殊形式的 的 if...else 结构&#xff0c;⽤于判断条件有多个结果的情况。它把多重 else if…
阅读更多...
亿发：制造型企业信息化规划——从破冰到全面落地

亿发：制造型企业信息化规划——从破冰到全面落地

在制造型企业中&#xff0c;信息化规划的落地是一个复杂而关键的过程。尽管规划和蓝图可能已经制定完毕&#xff0c;但如何成功地实施信息化才是关键所在。本文将详细介绍制造型企业信息化规划的落地过程&#xff0c;通过三个周期逐步推进&#xff0c;最终实现信息化与自动化的…
阅读更多...
深度学习知识与心得

深度学习知识与心得

目录 深度学习简介 传统机器学习 深度学习发展 感知机 前馈神经网络 前馈神经网络&#xff08;BP网络&#xff09; 深度学习框架讲解 深度学习框架 TensorFlow 一个简单的线性函数拟合过程 卷积神经网络CNN&#xff08;计算机视觉&#xff09; 自然语言处理NLP Wo…
阅读更多...
OpenAI助手API接入-问答对自动生成

OpenAI助手API接入-问答对自动生成

支持GPT-3.5-Turbo, GPT-4o, GPT-4-Turbo import json import openai from pathlib import Path import os client openai.OpenAI(base_urlbase_url, api_keyapi_key) file client.files.create( fileopen("H3.pdf", "rb"), purposeassistants ) …
阅读更多...
成功解决“ModuleNotFoundError: No Module Named ‘utils’”错误的全面指南

成功解决“ModuleNotFoundError: No Module Named ‘utils’”错误的全面指南

成功解决“ModuleNotFoundError: No Module Named ‘utils’”错误的全面指南 在Python编程中&#xff0c;遇到ModuleNotFoundError: No Module Named utils这样的错误通常意味着Python解释器无法找到名为utils的模块。这可能是由于多种原因造成的&#xff0c;比如模块确实不存…
阅读更多...
念念不忘，必有回响 的 echo

念念不忘，必有回响 的 echo

念念不忘&#xff0c;必有回响 的 echo 念念不忘&#xff0c;必有回响 的 echo几个示例更多信息 念念不忘&#xff0c;必有回响 的 echo echo命令用于在终端设备上输出字符串或变量的值&#xff0c;类似于Python的print和C语言的printf&#xff0c;是Linux系统中最常用的命令…
阅读更多...
深度学习笔记：0.cuda安装，成功

深度学习笔记：0.cuda安装，成功

B站上说&#xff1a;cs上骗子太多。文章太久&#xff0c;我深以为然。用了一天。才装好。其实很简单。 CUDA安装教程&#xff08;超详细&#xff09;-CSDN博客文章浏览阅读1w次&#xff0c;点赞5次&#xff0c;收藏56次。windows10 版本安装 CUDA &#xff0c;首先需要下载两个…
阅读更多...
【并发程序设计】总篇集(八万字)

【并发程序设计】总篇集(八万字)

11_Concurrent_Programing 1.进程概念 在Linux中&#xff0c;进程是操作系统分配资源和调度运行的基本单位。 Linux中的进程有以下用处&#xff1a; 提高CPU利用率&#xff1a;通过进程的并发执行&#xff0c;可以让多个程序同时利用计算机的资源&#xff0c;这样每个用户都…
阅读更多...
部署metrics-server

部署metrics-server

kubeadm部署metrics-server 需求&#xff1a;生产环境是kubeadm部署的v1.22.2版本的k8s&#xff0c;统计资源时发现这套环境没有部署metrics-server这个服务&#xff0c;今天来部署一下 1、在github社区找到这个项目并下载 rootjumpserver-cmcc:~# wget https://github.com/…
阅读更多...
你需要知道关于 Java 线程一些最基本的事情

你需要知道关于 Java 线程一些最基本的事情

你好&#xff0c;我是 shengjk1&#xff0c;多年大厂经验&#xff0c;努力构建 通俗易懂的、好玩的编程语言教程。 欢迎关注&#xff01;你会有如下收益&#xff1a; 了解大厂经验拥有和大厂相匹配的技术等 希望看什么&#xff0c;评论或者私信告诉我&#xff01; 文章目录 一…
阅读更多...
《SpringBoot3+Vue3实战》系列文章目录

《SpringBoot3+Vue3实战》系列文章目录

前后端分离&#xff08;Frontend-Backend Separation&#xff09;是一种软件架构设计模式&#xff0c;它将传统的Web应用中的前端&#xff08;用户界面&#xff09;和后端&#xff08;服务器逻辑和数据存储&#xff09;从应用层面进行解耦&#xff0c;使得两者可以独立地开发、…
阅读更多...
Linux CFS调度器简介

Linux CFS调度器简介

文章目录 前言一、概要二、实现2.1 简介2.2 算法实现2.3 内核源码 三、特点四、调度策略五、调度类参考资料 前言 早期的Linux调度器采用了简化的设计&#xff0c;显然并不针对具有许多处理器甚至超线程的大规模架构。Linux 1.2调度器使用循环队列对可运行任务进行管理&#x…
阅读更多...
昆仑万维官宣开源2000亿稀疏大模型Skywork-MoE

昆仑万维官宣开源2000亿稀疏大模型Skywork-MoE

6月3日&#xff0c;昆仑万维宣布开源2千亿稀疏大模型Skywork-MoE&#xff0c;性能强劲&#xff0c;同时推理成本更低。 据「TMT星球」了解&#xff0c;Skywork-MoE基于之前昆仑万维开源的Skywork-13B模型中间checkpoint扩展而来&#xff0c;是首个完整将MoE Upcycling技术应用…
阅读更多...
北京Profinet转Modbus网关配置调试详解

北京Profinet转Modbus网关配置调试详解

一、背景&#xff1a;在工业自动化系统中&#xff0c;PLC&#xff08;可编程逻辑控制器&#xff09;与流量计之间的通信是非常重要的&#xff0c;以确保数据准确传输并实现控制功能。然而&#xff0c;由于PLC和流量计可能采用不同的通信协议&#xff08;如Profinet和Modbus&…
阅读更多...
探索Java的DNA-JVM字节码深度解析

探索Java的DNA-JVM字节码深度解析

引言 在Java的世界里&#xff0c;JVM&#xff08;Java虚拟机&#xff09;是我们程序运行的心脏。而字节码&#xff0c;作为JVM的血液&#xff0c;携带着程序的执行指令。今天&#xff0c;我们将深入探索Java字节码的奥秘&#xff0c;一窥JVM如何将人类可读的代码转化为机器可执…
阅读更多...
【小白向】微信小程序解密反编译教程

【小白向】微信小程序解密反编译教程

# 前言 最近笔者有做到微信小程序的渗透测试&#xff0c;其中有一个环节就是对微信小程序的反编译进行源码分析&#xff0c;所谓微信小程序反编译&#xff0c;就是将访问的小程序进行反向编译拿到部分源码&#xff0c;然后对源码进行安全审计&#xff0c;分析出其中可能存在的…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023