面试题解答：Spring Lifecycle 和 SmartLifecycle 有何区别？

2023-10-19 13:44
文章标签 java 面试题 spring 区别 解答 lifecycle 有何 smartlifecycle

本文主要是介绍面试题解答：Spring Lifecycle 和 SmartLifecycle 有何区别？，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

当我们想在 Spring 容器启动或者关闭的时候，做一些初始化操作或者对象销毁操作，我们可以怎么做？

注意我这里说的是容器启动或者关闭的时候，不是某一个 Bean 初始化或者销毁的时候～

1. Lifecycle

对于上面提到的问题，如果小伙伴们稍微研究过 Spring，应该是了解其里边有一个 Lifecycle 接口，通过这个接口，我们可以在 Spring 容器启动或者关闭的时候，做一些自己需要的事情。

我们先来看下 Lifecycle 接口：

public interface Lifecycle {void start();void stop();boolean isRunning();
}

这个接口一共就三个方法：

  • start：启动组件，该方法在执行之前，先调用 isRunning 方法判断组件是否已经启动了，如果已经启动了，就不重复启动了。
  • stop：停止组件，该方法在执行之前，先调用 isRunning 方法判断组件是否已经停止运行了，如果已经停止运行了，就不再重复停止了。
  • isRunning：这个是返回组件是否已经处于运行状态了，对于容器来说，只有当容器中的所有适用组件都处于运行状态时，这个方法返回 true，否则返回 false。

如果我们想自定义一个 Lifecycle，方式如下：

@Component
public class MyLifeCycle implements Lifecycle {private volatile boolean running;@Overridepublic void start() {running = true;System.out.println("start");}@Overridepublic void stop() {running = false;System.out.println("stop");}@Overridepublic boolean isRunning() {return running;}
}

需要自定义一个 running 变量，该变量用来描述当前组件是否处于运行/停止状态，因为系统在调用 start 和 stop 方法的时候，都会先调用 isRunning 方法，用以确认是否需要真的调用 start/stop 方法。

接下来创建配置类，扫描上述组件：

@Configuration
@ComponentScan
public class JavaConfig {
}

最后我们启动容器：

public class Demo {public static void main(String[] args) {AnnotationConfigApplicationContext ctx = new AnnotationConfigApplicationContext(JavaConfig.class);ctx.start();ctx.stop();}
}

启动之后，我们就可以看到控制台打印出来的信息：

外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传

可以看到，在容器启动和停止的时候，相应的方法会被触发。

不过 Lifecycle 有一个问题，就是必须显式的调用 start 或者 stop 方法才会触发 Lifecycle 中的方法。当然，如果你没有调用 stop 方法，而是调用了 close 方法，那么在 close 方法内部也会触发 stop 方法。

如果我们想要 start 方法被自动触发呢？那就得一个更加智能的 Lifecycle 了— SmartLifecycle。

2. SmartLifecycle

相比于 LifeCycle，SmartLifecycle 中多了几个方法：

public interface SmartLifecycle extends Lifecycle, Phased {int DEFAULT_PHASE = Integer.MAX_VALUE;default boolean isAutoStartup() {return true;}default void stop(Runnable callback) {stop();callback.run();}@Overridedefault int getPhase() {return DEFAULT_PHASE;}}

大家看一下，这里首先多了一个 isAutoStartup 方法，这个方法就表示是否自动执行 startup 方法，这个方法返回 true，则 startup 方法会被自动触发，这个方法要是返回 false，则 startup 方法就不会被自动触发（那么效果就等同于 LifeCycle 了）。

这里多了一个重载的 stop 方法，这个重载的 stop 方法会传入一个线程对象，然后在 stop 中触发，这个 callback 回调是为了告诉容器，我们销毁组件的工作已经完成了。如果使用了 SmartLifecycle，那么 Lifecycle 中的 stop 方法就不会被直接触发了，除非我们在 SmartLifecycle#stop 中手动去触发 Lifecycle#stop 方法。

另外这里还有一个 getPhase 方法，这个当存在多个 SmartLifecycle 实例的时候，我们需要为其执行顺序排序，getPhase 方法就是返回执行顺序，数字越小，优先级越高，默认优先级最小。

我们来写一个 SmartLifecycle 的案例来试下：

@Component
public class MyLifeCycle implements SmartLifecycle {private volatile boolean running;@Overridepublic void start() {running = true;System.out.println("start");}@Overridepublic void stop() {running = false;System.out.println("stop");}@Overridepublic boolean isRunning() {return running;}@Overridepublic boolean isAutoStartup() {return SmartLifecycle.super.isAutoStartup();}@Overridepublic void stop(Runnable callback) {stop();callback.run();}@Overridepublic int getPhase() {return 0;}
}

3. 原理分析

那么 Lifecycle 到底是如何被触发的呢？我们来分析一下源码。

由于系统中可能存在多个 Lifecycle，因此这多个 Lifecycle 需要一个统一的管理，这个管理者就是 LifecycleProcessor，这也是一个接口，这个接口中只有两个方法：

public interface LifecycleProcessor extends Lifecycle {void onRefresh();void onClose();
}
  • onRefresh：这个是在上下文刷新的时候被触发，例如在容器启动的时候这个方法被触发。
  • onClose：这个是在上下文关闭的时候被触发，例如在容器停止运行的时候这个方法被触发。

LifecycleProcessor 只有一个实现类 DefaultLifecycleProcessor，所以很好分析，这个 DefaultLifecycleProcessor 中，重写了上面的 onRefresh 和 onClose 两个方法：

@Override
public void onRefresh() {startBeans(true);this.running = true;
}
@Override
public void onClose() {stopBeans();this.running = false;
}

3.1 start

小伙伴们看到，在容器启动的时候，这里会去调用 startBeans 方法，在这个方法中就会触发 Lifecycle#start 方法：

private void startBeans(boolean autoStartupOnly) {Map<String, Lifecycle> lifecycleBeans = getLifecycleBeans();Map<Integer, LifecycleGroup> phases = new TreeMap<>();lifecycleBeans.forEach((beanName, bean) -> {if (!autoStartupOnly || (bean instanceof SmartLifecycle smartLifecycle && smartLifecycle.isAutoStartup())) {int phase = getPhase(bean);phases.computeIfAbsent(phase,p -> new LifecycleGroup(phase, this.timeoutPerShutdownPhase, lifecycleBeans, autoStartupOnly)).add(beanName, bean);}});if (!phases.isEmpty()) {phases.values().forEach(LifecycleGroup::start);}
}

在这个方法中，首先调用 getLifecycleBeans 方法，这个方法的作用是去 Spring 容器中查找所有 Lifecycle 类型的 Bean，并把查找结果封装到一个 Map 集合中返回。

接下来就去遍历这个 Map，遍历的时候由于 autoStartupOnly 变量传进来的时候是 true，取反之后就是 false 了，所以就会去判断这个 Bean 是否为 SmartLifecycle 类型，如果是该类型并且 isAutoStartup 方法返回 true，就表示要自动执行 start 方法。

如果确定是 SmartLifecycle 类型的 Bean，那么就调用 getPhase 方法获取其 phase，这个表示执行的优先级，然后将之存入到 phases 集合中，存储的时候，phase 是 key，value 则是一个 LifecycleGroup，phases 是一个 TreeMap，小伙伴们知道，TreeMap 是有序的，也就是存入进去的数据，会自动按照 phase 进行排序。LifecycleGroup 是将 phase 相同的 SmartLifecycle 分组之后的对象。

经过上面的分析，相信大家已经明白了为什么直接实现 Lifecycle 接口，就一定需要手动调用 start 方法（因为上面 if 中的条件不满足）。

最后就是遍历 phases，调用每一个 LifecycleGroup 中的 start 方法。

public void start() {if (this.members.isEmpty()) {return;}Collections.sort(this.members);for (LifecycleGroupMember member : this.members) {doStart(this.lifecycleBeans, member.name, this.autoStartupOnly);}
}
private void doStart(Map<String, ? extends Lifecycle> lifecycleBeans, String beanName, boolean autoStartupOnly) {Lifecycle bean = lifecycleBeans.remove(beanName);if (bean != null && bean != this) {String[] dependenciesForBean = getBeanFactory().getDependenciesForBean(beanName);for (String dependency : dependenciesForBean) {doStart(lifecycleBeans, dependency, autoStartupOnly);}if (!bean.isRunning() &&(!autoStartupOnly || !(bean instanceof SmartLifecycle smartLifecycle) || smartLifecycle.isAutoStartup())) {bean.start();}}
}

在 doStart 方法中，从集合中取出来 Lifecycle，然后查找一下该 Lifecycle 是否有依赖的 Bean，如果有，就继续递归调用 doStart 方法。否则，在 isRunning 返回 false（即该组件还没有运行），且 bean 不是 SmartLifecycle 类型（那就只能是 Lifecycle 类型）或者 bean 是 SmartLifecycle 类型且 isAutoStartup 方法为 true 的情况下，调用 bean 的 start 方法。

小伙伴们注意，上面的分析是从 onRefresh 方法开始的，该方法中调用 startBeans 的时候，传入的参数是 true，也就是上面这个判断里边 autoStartupOnly 为 true，取反之后这个条件就不满足了，如果是我们手动调用 start 方法的话，这个参数默认传入的是 false，取反之后上面这个条件就满足了，也就是无论是手动还是自动，最终都是在这个地方触发 start 方法的。

3.2 stop

再来看 stop 方法的逻辑。从 onClose 方法开始，也是先调用 stopBeans 方法：

private void stopBeans() {Map<String, Lifecycle> lifecycleBeans = getLifecycleBeans();Map<Integer, LifecycleGroup> phases = new HashMap<>();lifecycleBeans.forEach((beanName, bean) -> {int shutdownPhase = getPhase(bean);LifecycleGroup group = phases.get(shutdownPhase);if (group == null) {group = new LifecycleGroup(shutdownPhase, this.timeoutPerShutdownPhase, lifecycleBeans, false);phases.put(shutdownPhase, group);}group.add(beanName, bean);});if (!phases.isEmpty()) {List<Integer> keys = new ArrayList<>(phases.keySet());keys.sort(Collections.reverseOrder());for (Integer key : keys) {phases.get(key).stop();}}
}

这块的逻辑跟 start 差不多，就是排序的方案有一些差别。这里用了 HashMap，没有用 TreeMap，然后在具体调用的时候，再去给 key 排序的。

这里调用到的也是 LifecycleGroup 的 stop 方法，我们来看下：

public void stop() {if (this.members.isEmpty()) {return;}this.members.sort(Collections.reverseOrder());CountDownLatch latch = new CountDownLatch(this.smartMemberCount);Set<String> countDownBeanNames = Collections.synchronizedSet(new LinkedHashSet<>());Set<String> lifecycleBeanNames = new HashSet<>(this.lifecycleBeans.keySet());for (LifecycleGroupMember member : this.members) {if (lifecycleBeanNames.contains(member.name)) {doStop(this.lifecycleBeans, member.name, latch, countDownBeanNames);}else if (member.bean instanceof SmartLifecycle) {// Already removed: must have been a dependent bean from another phaselatch.countDown();}}try {latch.await(this.timeout, TimeUnit.MILLISECONDS);if (latch.getCount() > 0 && !countDownBeanNames.isEmpty() && logger.isInfoEnabled()) {logger.info("Failed to shut down " + countDownBeanNames.size() + " bean" +(countDownBeanNames.size() > 1 ? "s" : "") + " with phase value " +this.phase + " within timeout of " + this.timeout + "ms: " + countDownBeanNames);}}catch (InterruptedException ex) {Thread.currentThread().interrupt();}
}

大家看一下，这里的 doStop 方法，最终就会触发到 Lifecycle 的 stop，这个里边的代码简单，我们就不去细看了。需要提醒大家的时候，这里使用到了这样一个计数器，初始值就是 members 的数量，每当调用一个 member 的 stop 方法之后，这个计数器减一，这样，到下面调用 await 的时候，就刚刚好不用等。

await 方法的等待时间是 this.timeout，这个属性默认值是 30s，也就是如果 stop 方法在子线程中执行，那么执行时间不能超过 30s，否则就会抛出异常。

如果我们想要自定义这个超时时间，可以自己在 Spring 容器中提供如下 Bean：

@Configuration
@ComponentScan
public class JavaConfig {@BeanDefaultLifecycleProcessor lifecycleProcessor() {DefaultLifecycleProcessor processor = new DefaultLifecycleProcessor();processor.setTimeoutPerShutdownPhase(2000);return processor;}
}

上面这个案例中设置了超时时间为 2s。

好啦，这就是关于 Lifecycle 的整体触发流程。

接下来我们来看下自动触发和手动触发分别是在哪里触发的。

3.3 自动触发

先来看自动触发。

经过前面的讲解，现在小伙伴们都知道，Spring 容器初始化的时候，会调用到 refresh 方法，这个刷新要做的事情比较多，其中最后一件事情是调用 finishRefresh 方法，如下：

protected void finishRefresh() {// Clear context-level resource caches (such as ASM metadata from scanning).clearResourceCaches();// Initialize lifecycle processor for this context.initLifecycleProcessor();// Propagate refresh to lifecycle processor first.getLifecycleProcessor().onRefresh();// Publish the final event.publishEvent(new ContextRefreshedEvent(this));
}

这里有两个方法跟本文相关，一个是 initLifecycleProcessor，这个是初始化 LifecycleProcessor，就是去 Spring 容器中查找 LifecycleProcessor，找到就用，没找到就创建新的。

然后就是 getLifecycleProcessor().onRefresh(); 方法，这个就是触发了 DefaultLifecycleProcessor#onRefresh 方法，而关于该方法的逻辑，松哥在前面已经介绍过了。

来看下 initLifecycleProcessor 方法是如何做初始化操作的：

protected void initLifecycleProcessor() {ConfigurableListableBeanFactory beanFactory = getBeanFactory();if (beanFactory.containsLocalBean(LIFECYCLE_PROCESSOR_BEAN_NAME)) {this.lifecycleProcessor =beanFactory.getBean(LIFECYCLE_PROCESSOR_BEAN_NAME, LifecycleProcessor.class);}else {DefaultLifecycleProcessor defaultProcessor = new DefaultLifecycleProcessor();defaultProcessor.setBeanFactory(beanFactory);this.lifecycleProcessor = defaultProcessor;beanFactory.registerSingleton(LIFECYCLE_PROCESSOR_BEAN_NAME, this.lifecycleProcessor);}
}

大家注意，LIFECYCLE_PROCESSOR_BEAN_NAME 常量的值是 lifecycleProcessor，为什么要强调这个，如果我们是自定义 DefaultLifecycleProcessor，那么 beanName 必须是 lifecycleProcessor，否则系统会以为我们没有自定义 DefaultLifecycleProcessor。

那么这里的逻辑就是如果用户自定义了 DefaultLifecycleProcessor，那么就使用用户自定义的 DefaultLifecycleProcessor，否则就创建一个新的 DefaultLifecycleProcessor，并注册到 Spring 容器中。

这就是自动触发的逻辑。

3.4 手动触发

手动触发需要我们自己调用 start 方法，start 方法如下：

@Override
public void start() {getLifecycleProcessor().start();publishEvent(new ContextStartedEvent(this));
}

相当于直接调用了 DefaultLifecycleProcessor 的 start 方法：

@Override
public void start() {startBeans(false);this.running = true;
}

这个跟 DefaultLifecycleProcessor 的 onRefresh 方法内容基本一致，唯一的区别在于调用 startBeans 的时候，传入的参数为 false，这个参数带来的变化，这个松哥在前面的内容中已经分析过了，这里就不再啰嗦啦。

4. 小结

好啦，这就是松哥和大家分享的 Spring Lifecycle 和 SmartLifecycle 的区别。老实说，我们自己开发需要自定义这两个的场景其实并不多，但是在 Spring Boot 中，SmartLifecycle 的应用还是比较多的，有了今天这个内容作基础，将来小伙伴们分析 Spring Boot 的时候就会容易很多了。

这篇关于面试题解答：Spring Lifecycle 和 SmartLifecycle 有何区别？的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/240171。

相关文章

SpringBoot中四种AOP实战应用场景及代码实现

SpringBoot中四种AOP实战应用场景及代码实现

《SpringBoot中四种AOP实战应用场景及代码实现》面向切面编程(AOP)是Spring框架的核心功能之一,它通过预编译和运行期动态代理实现程序功能的统一维护,在SpringBoot应用中,AO... 目录引言场景一：日志记录与性能监控业务需求实现方案使用示例扩展：MDC实现请求跟踪场景二：权限控制与
阅读更多...
Java NoClassDefFoundError运行时错误分析解决

Java NoClassDefFoundError运行时错误分析解决

《JavaNoClassDefFoundError运行时错误分析解决》在Java开发中,NoClassDefFoundError是一种常见的运行时错误,它通常表明Java虚拟机在尝试加载一个类时未能... 目录前言一、问题分析二、报错原因三、解决思路检查类路径配置检查依赖库检查类文件调试类加载器问题四、常见
阅读更多...
Java注解之超越Javadoc的元数据利器详解

Java注解之超越Javadoc的元数据利器详解

《Java注解之超越Javadoc的元数据利器详解》本文将深入探讨Java注解的定义、类型、内置注解、自定义注解、保留策略、实际应用场景及最佳实践,无论是初学者还是资深开发者,都能通过本文了解如何利用... 目录什么是注解？注解的类型内置注编程解自定义注解注解的保留策略实际用例最佳实践总结在 Java 编程
阅读更多...
Java 实用工具类Spring 的 AnnotationUtils详解

Java 实用工具类Spring 的 AnnotationUtils详解

《Java实用工具类Spring的AnnotationUtils详解》Spring框架提供了一个强大的注解工具类org.springframework.core.annotation.Annot... 目录前言一、AnnotationUtils 的常用方法二、常见应用场景三、与 JDK 原生注解 API 的
阅读更多...
Java controller接口出入参时间序列化转换操作方法(两种)

Java controller接口出入参时间序列化转换操作方法(两种)

《Javacontroller接口出入参时间序列化转换操作方法(两种)》：本文主要介绍Javacontroller接口出入参时间序列化转换操作方法,本文给大家列举两种简单方法,感兴趣的朋友一起看... 目录方式一、使用注解方式二、统一配置场景：在controller编写的接口，在前后端交互过程中一般都会涉及
阅读更多...
Java中的StringBuilder之如何高效构建字符串

Java中的StringBuilder之如何高效构建字符串

《Java中的StringBuilder之如何高效构建字符串》本文将深入浅出地介绍StringBuilder的使用方法、性能优势以及相关字符串处理技术,结合代码示例帮助读者更好地理解和应用,希望对大家... 目录关键点什么是 StringBuilder？为什么需要 StringBuilder？如何使用 St
阅读更多...
使用Java将各种数据写入Excel表格的操作示例

使用Java将各种数据写入Excel表格的操作示例

《使用Java将各种数据写入Excel表格的操作示例》在数据处理与管理领域,Excel凭借其强大的功能和广泛的应用,成为了数据存储与展示的重要工具,在Java开发过程中,常常需要将不同类型的数据,本文... 目录前言安装免费Java库1. 写入文本、或数值到 Excel单元格2. 写入数组到 Excel表格
阅读更多...
Java并发编程之如何优雅关闭钩子Shutdown Hook

Java并发编程之如何优雅关闭钩子Shutdown Hook

《Java并发编程之如何优雅关闭钩子ShutdownHook》这篇文章主要为大家详细介绍了Java如何实现优雅关闭钩子ShutdownHook,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起... 目录关闭钩子简介关闭钩子应用场景数据库连接实战演示使用关闭钩子的注意事项开源框架中的关闭钩子机制1.
阅读更多...
Maven中引入 springboot 相关依赖的方式(最新推荐)

Maven中引入 springboot 相关依赖的方式(最新推荐)

《Maven中引入springboot相关依赖的方式(最新推荐)》：本文主要介绍Maven中引入springboot相关依赖的方式(最新推荐),本文给大家介绍的非常详细,对大家的学习或工作具有... 目录Maven中引入 springboot 相关依赖的方式1. 不使用版本管理（不推荐）2、使用版本管理（推
阅读更多...
Java 中的 @SneakyThrows 注解使用方法(简化异常处理的利与弊)

Java 中的 @SneakyThrows 注解使用方法(简化异常处理的利与弊)

《Java中的@SneakyThrows注解使用方法(简化异常处理的利与弊)》为了简化异常处理,Lombok提供了一个强大的注解@SneakyThrows,本文将详细介绍@SneakyThro... 目录1. @SneakyThrows 简介 1.1 什么是 Lombok？2. @SneakyThrows
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2