Spring 之 Lifecycle 及 SmartLifecycle

2024-06-04 00:20

本文主要是介绍Spring 之 Lifecycle 及 SmartLifecycle,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

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

关于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()方法

这篇关于Spring 之 Lifecycle 及 SmartLifecycle的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/1028530

相关文章

JVM 的类初始化机制

前言 当你在 Java 程序中new对象时,有没有考虑过 JVM 是如何把静态的字节码(byte code)转化为运行时对象的呢,这个问题看似简单,但清楚的同学相信也不会太多,这篇文章首先介绍 JVM 类初始化的机制,然后给出几个易出错的实例来分析,帮助大家更好理解这个知识点。 JVM 将字节码转化为运行时对象分为三个阶段,分别是:loading 、Linking、initialization

Spring Security 基于表达式的权限控制

前言 spring security 3.0已经可以使用spring el表达式来控制授权,允许在表达式中使用复杂的布尔逻辑来控制访问的权限。 常见的表达式 Spring Security可用表达式对象的基类是SecurityExpressionRoot。 表达式描述hasRole([role])用户拥有制定的角色时返回true (Spring security默认会带有ROLE_前缀),去

浅析Spring Security认证过程

类图 为了方便理解Spring Security认证流程,特意画了如下的类图,包含相关的核心认证类 概述 核心验证器 AuthenticationManager 该对象提供了认证方法的入口,接收一个Authentiaton对象作为参数; public interface AuthenticationManager {Authentication authenticate(Authenti

Spring Security--Architecture Overview

1 核心组件 这一节主要介绍一些在Spring Security中常见且核心的Java类,它们之间的依赖,构建起了整个框架。想要理解整个架构,最起码得对这些类眼熟。 1.1 SecurityContextHolder SecurityContextHolder用于存储安全上下文(security context)的信息。当前操作的用户是谁,该用户是否已经被认证,他拥有哪些角色权限…这些都被保

Spring Security基于数据库验证流程详解

Spring Security 校验流程图 相关解释说明(认真看哦) AbstractAuthenticationProcessingFilter 抽象类 /*** 调用 #requiresAuthentication(HttpServletRequest, HttpServletResponse) 决定是否需要进行验证操作。* 如果需要验证,则会调用 #attemptAuthentica

Spring Security 从入门到进阶系列教程

Spring Security 入门系列 《保护 Web 应用的安全》 《Spring-Security-入门(一):登录与退出》 《Spring-Security-入门(二):基于数据库验证》 《Spring-Security-入门(三):密码加密》 《Spring-Security-入门(四):自定义-Filter》 《Spring-Security-入门(五):在 Sprin

Java架构师知识体认识

源码分析 常用设计模式 Proxy代理模式Factory工厂模式Singleton单例模式Delegate委派模式Strategy策略模式Prototype原型模式Template模板模式 Spring5 beans 接口实例化代理Bean操作 Context Ioc容器设计原理及高级特性Aop设计原理Factorybean与Beanfactory Transaction 声明式事物

Java进阶13讲__第12讲_1/2

多线程、线程池 1.  线程概念 1.1  什么是线程 1.2  线程的好处 2.   创建线程的三种方式 注意事项 2.1  继承Thread类 2.1.1 认识  2.1.2  编码实现  package cn.hdc.oop10.Thread;import org.slf4j.Logger;import org.slf4j.LoggerFactory

JAVA智听未来一站式有声阅读平台听书系统小程序源码

智听未来,一站式有声阅读平台听书系统 🌟&nbsp;开篇:遇见未来,从“智听”开始 在这个快节奏的时代,你是否渴望在忙碌的间隙,找到一片属于自己的宁静角落?是否梦想着能随时随地,沉浸在知识的海洋,或是故事的奇幻世界里?今天,就让我带你一起探索“智听未来”——这一站式有声阅读平台听书系统,它正悄悄改变着我们的阅读方式,让未来触手可及! 📚&nbsp;第一站:海量资源,应有尽有 走进“智听

在cscode中通过maven创建java项目

在cscode中创建java项目 可以通过博客完成maven的导入 建立maven项目 使用快捷键 Ctrl + Shift + P 建立一个 Maven 项目 1 Ctrl + Shift + P 打开输入框2 输入 "> java create"3 选择 maven4 选择 No Archetype5 输入 域名6 输入项目名称7 建立一个文件目录存放项目,文件名一般为项目名8 确定