百度360必应搜狗淘宝本站头条
当前位置:网站首页 > 编程网 > 正文

最全SpringBean初始化/销毁的各种方式

yuyutoo 2024-11-12 14:58 17 浏览 0 评论

  • 一、前言

日常开发过程有时需要在应用启动之后加载某些资源,或者在应用关闭之前释放资源。Spring 框架提供相关功能,围绕 Spring Bean 生命周期,可以在 Bean 创建过程初始化资源,以及销毁 Bean 过程释放资源。Spring 提供多种不同的方式初始化/销毁 Bean,如果同时使用这几种方式,Spring 如何处理这几者之间的顺序?

  • 二、姿势剖析

首先我们先来回顾一下 Spring 初始化/销毁 Bean 几种方式,分别为:

  • init-method/destroy-method
  • InitializingBean/DisposableBean
  • @PostConstruct/@PreDestroy
  • ContextStartedEvent/ContextClosedEvent

PS: 其实还有一种方式,就是继承 Spring Lifecycle 接口。不过这种方式比较繁琐,这里就不再分析。

  • 2.1、init-method/destroy-method

这种方式在配置文件文件指定初始化/销毁方法。XML 配置如下

<bean id="demoService" class="com.example.demo.bean.DemoService" destroy-method="close" init-method="initMethod"/>

或者也可以使用注解方式配置:

@Configuration
public class AppConfig {

 @Bean(initMethod = "init",destroyMethod = "destory")
 public Car sayHello(){
 System.out.println("I am sayHello method");
 return new Car();
 }
}

还记得刚开始接触学习 Spring 框架,使用就是这种方式。

  • 2.2、InitializingBean/DisposableBean

这种方式需要继承 Spring 接口 InitializingBean/DisposableBean,其中 InitializingBean 用于初始化动作,而 DisposableBean 用于销毁之前清理动作。使用方式如下:

@Service
public class HelloService implements InitializingBean, DisposableBean {

 @Override
 public void destroy() throws Exception {
 System.out.println(".......... HelloService destroy.........");
 }

 @Override
 public void afterPropertiesSet() throws Exception {
 System.out.println(".......... HelloService initialize.........");
 }
}
  • 2.3、@PostConstruct/@PreDestroy

这种方式相对于上面两种方式来说,使用方式最简单,只需要在相应的方法上使用注解即可。使用方式如下:

@Service
public class HiService {
 
 @PostConstruct
 public void init() {
 System.out.println("............hello @PostConstruct.............");
 }

 @PreDestroy
 public void PreDestroy() {
 System.out.println("...........hello @PreDestroy............");
 }
}

这里踩过一个坑,如果使用 JDK9 之后版本 ,@PostConstruct/@PreDestroy 需要使用 maven 单独引入 javax.annotation-api,否者注解不会生效。

  • 2.4、ContextStartedEvent/ContextClosedEvent

这种方式使用 Spring 事件机制,日常业务开发比较少见,常用与框架集成中。Spring 启动之后将会发送 ContextStartedEvent 事件,而关闭之前将会发送 ContextClosedEvent 事件。我们需要继承 Spring ApplicationListener 才能监听以上两种事件。

@Service
public class HelloListener implements ApplicationListener {

 @Override
 public void onApplicationEvent(ApplicationEvent event) {
 if(event instanceof ContextClosedEvent){
 System.out.println("hello ContextClosedEvent");
 }else if(event instanceof ContextStartedEvent){
 System.out.println("hello ContextStartedEvent");
 }

 }
}

也可以使用 @EventListener注解,使用方式如下:

public class HelloListenerV2 {
 
 @EventListener(value = {ContextClosedEvent.class, ContextStartedEvent.class})
 public void receiveEvents(ApplicationEvent event) {
 if (event instanceof ContextClosedEvent) {
 System.out.println("hello ContextClosedEvent");
 } else if (event instanceof ContextStartedEvent) {
 System.out.println("hello ContextStartedEvent");
 }
 }
}

PS:只有调用 ApplicationContext#start 才会发送 ContextStartedEvent。若不想这么麻烦,可以监听 ContextRefreshedEvent 事件代替。一旦 Spring 容器初始化完成,就会发送 ContextRefreshedEvent。

  • 三、综合使用

回顾完上面几种方式,这里我们综合使用上面的四种方式,来看下 Spring 内部的处理顺序。在看结果之前,各位读者大人可以猜测下这几种方式的执行顺序。

public class HelloService implements InitializingBean, DisposableBean {


 @PostConstruct
 public void init() {
 System.out.println("hello @PostConstruct");
 }

 @PreDestroy
 public void PreDestroy() {
 System.out.println("hello @PreDestroy");
 }

 @Override
 public void destroy() throws Exception {
 System.out.println("bye DisposableBean...");
 }

 @Override
 public void afterPropertiesSet() throws Exception {
 System.out.println("hello InitializingBean....");
 }

 public void xmlinit(){
 System.out.println("hello xml-init...");
 }

 public void xmlDestory(){
 System.out.println("bye xmlDestory...");
 }

 @EventListener(value = {ContextClosedEvent.class, ContextStartedEvent.class})
 public void receiveEvents(ApplicationEvent event) {
 if (event instanceof ContextClosedEvent) {
 System.out.println("bye ContextClosedEvent");
 } else if (event instanceof ContextStartedEvent) {
 System.out.println("hello ContextStartedEvent");
 }
 }

}

xml 配置方式如下:

 <context:annotation-config />
 <context:component-scan base-package="com.example.demo.bean"/>
 
 <bean class="com.example.demo.bean.HelloService" init-method="xmlinit" destroy-method="xmlDestory"/>

应用启动方法如下:

ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("spring/applicationContext-base.xml");
context.start();
context.close()

程序输出结果如下所示:

最后采用图示说明总结以上结果:

  • 四、源码解析

不知道各位读者有没有猜对这几种方式的执行顺序,下面我们就从源码角度解析 Spring 内部处理的顺序。

  • 4.1、初始化过程

使用 ClassPathXmlApplicationContext 启动 Spring 容器,将会调用 refresh 方法初始化容器。初始化过程将会创建 Bean 。最后当一切准备完毕,将会发送 ContextRefreshedEvent。当容器初始化完毕,调用 context.start() 就发送 ContextStartedEvent 事件。

refresh 方法源码如下:

public void refresh() throws BeansException, IllegalStateException {
 synchronized (this.startupShutdownMonitor) {
 //... 忽略无关代码

 // 初始化所有非延迟初始化的 Bean
 finishBeanFactoryInitialization(beanFactory);

 // 发送 ContextRefreshedEvent
 finishRefresh();

 //... 忽略无关代码
 }
}

一路跟踪 finishBeanFactoryInitialization 源码,直到 AbstractAutowireCapableBeanFactory#initializeBean,源码如下:

protected Object initializeBean(final String beanName, final Object bean, RootBeanDefinition mbd) {
 Object wrappedBean = bean;
 if (mbd == null || !mbd.isSynthetic()) {
 // 调用 BeanPostProcessor#postProcessBeforeInitialization 方法
 wrappedBean = applyBeanPostProcessorsBeforeInitialization(wrappedBean, beanName);
 }

 try {
 // 初始化 Bean
 invokeInitMethods(beanName, wrappedBean, mbd);
 }
 catch (Throwable ex) {
 throw new BeanCreationException(
 (mbd != null ? mbd.getResourceDescription() : null),
 beanName, "Invocation of init method failed", ex);
 }
}

BeanPostProcessor 将会起着拦截器的作用,一旦 Bean 符合条件,将会执行一些处理。这里带有 @PostConstruct 注解的 Bean 都将会被 CommonAnnotationBeanPostProcessor 类拦截,内部将会触发 @PostConstruct 标注的方法。

接着执行 invokeInitMethods ,方法如下:

protected void invokeInitMethods(String beanName, final Object bean, RootBeanDefinition mbd)
 throws Throwable {

 boolean isInitializingBean = (bean instanceof InitializingBean);
 if (isInitializingBean && (mbd == null || !mbd.isExternallyManagedInitMethod("afterPropertiesSet"))) {
 // 省略无关代码
 // 如果是 Bean 继承 InitializingBean,将会执行 afterPropertiesSet 方法
 ((InitializingBean) bean).afterPropertiesSet();
 }

 if (mbd != null) {
 String initMethodName = mbd.getInitMethodName();
 if (initMethodName != null && !(isInitializingBean && "afterPropertiesSet".equals(initMethodName)) &&
 !mbd.isExternallyManagedInitMethod(initMethodName)) {
 // 执行 XML 定义 init-method
 invokeCustomInitMethod(beanName, bean, mbd);
 }
 }
}

如果 Bean 继承 InitializingBean 接口,将会执行 afterPropertiesSet 方法,另外如果在 XML 中指定了 init-method ,也将会触发。

上面源码其实都是围绕着 Bean 创建的过程,当所有 Bean 创建完成之后,调用 context#start 将会发送 ContextStartedEvent 。这里源码比较简单,如下:

public void start() {
 getLifecycleProcessor().start();
 publishEvent(new ContextStartedEvent(this));
}
  • 4.2、销毁过程

调用 ClassPathXmlApplicationContext#close 方法将会关闭容器,具体逻辑将会在 doClose 方法执行。

doClose 这个方法首先发送 ContextClosedEvent,然再后开始销毁 Bean。

灵魂拷问:如果我们颠倒上面两者顺序,结果会一样吗?

doClose 源码如下:

protected void doClose() {
 if (this.active.get() && this.closed.compareAndSet(false, true)) {
 // 省略无关代码

 try {
 // Publish shutdown event.
 publishEvent(new ContextClosedEvent(this));
 }
 catch (Throwable ex) {
 logger.warn("Exception thrown from ApplicationListener handling ContextClosedEvent", ex);
 }


 // 销毁 Bean
 destroyBeans();

 // 省略无关代码
 }
}

destroyBeans 最终将会执行 DisposableBeanAdapter#destroy,@PreDestroy、DisposableBean、destroy-method 三者定义的方法都将会在内部被执行。

首先执行 DestructionAwareBeanPostProcessor#postProcessBeforeDestruction,这里方法类似与上面 BeanPostProcessor。

@PreDestroy 注解将会被 CommonAnnotationBeanPostProcessor 拦截,这里类同时也继承了 DestructionAwareBeanPostProcessor。

最后如果 Bean 为 DisposableBean 的子类,将会执行 destroy 方法,如果在 xml 定义了 destroy-method方法,该方法也会被执行。

public void destroy() {
 if (!CollectionUtils.isEmpty(this.beanPostProcessors)) {
 for (DestructionAwareBeanPostProcessor processor : this.beanPostProcessors) {
 processor.postProcessBeforeDestruction(this.bean, this.beanName);
 }
 }

 if (this.invokeDisposableBean) {
 // 省略无关代码
 // 如果 Bean 继承 DisposableBean,执行 destroy 方法
 ((DisposableBean) bean).destroy();
 
 }

 if (this.destroyMethod != null) {
 // 执行 xml 指定的 destroy-method 方法
 invokeCustomDestroyMethod(this.destroyMethod);
 }
 else if (this.destroyMethodName != null) {
 Method methodToCall = determineDestroyMethod();
 if (methodToCall != null) {
 invokeCustomDestroyMethod(methodToCall);
 }
 }
}
  • 五、总结

init-method/destroy-method 这种方式需要使用 XML 配置文件或单独注解配置类,相对来说比较繁琐。而InitializingBean/DisposableBean 这种方式需要单独继承 Spring 的接口实现相关方法。@PostConstruct/@PreDestroy 这种注解方式使用方式简单,代码清晰,比较推荐使用这种方式。

另外 ContextStartedEvent/ContextClosedEvent 这种方式比较适合在一些集成框架使用,比如 Dubbo 2.6.X 优雅停机就是用改机制。


本文首发于: https://studyidea.cn/articles/2019/11/16/1573900549564.html

相关推荐

对volatile,synchronized,AQS的加锁解锁原理的一些理解

一、为什么要加锁,要实现同步多线程编程中,有可能会出现多个线程同时访问同一个共享、可变资源的情况,这个资源我们称之其为临界资源;这种资源可能是:对象、变量、文件等。...

注意,不能错过的CAS+volatile实现同步代码块

前言:最近看到有人说可以使用CAS+volatile实现同步代码块。心想,确实是可以实现的呀!因为AbstractQueuedSynchronizer(简称AQS)内部就是通过CAS+...

面试并发volatile关键字时,我们应该具备哪些谈资?

提前发现更多精彩内容,请访问https://dayarch.top/提前发现更多精彩内容,请访问https://dayarch.top/提前发现更多精彩内容,请访问https://dayarch...

无锁同步-JAVA之Volatile、Atomic和CAS

1、概要本文是无锁同步系列文章的第二篇,主要探讨JAVA中的原子操作,以及如何进行无锁同步。关于JAVA中的原子操作,我们很容易想到的是Volatile变量、java.util.concurrent....

C/C++面试题(二):std::atomic与volatile

volatile是C/C++中的一个关键字,用于告知编译器某个变量的值可能会在程序的控制之外被意外修改(例如被硬件、中断服务程序、多线程环境或其他外部代理)。为了防止编译器对代码进行某些可能破坏...

VOCs(Volatile Organic Compounds)挥发性有机化合物及测试方法

经常看到一些三防漆、涂料、油漆类产品的介绍中提到VOC、VOCs等概念,那么什么是VOC、VOCs和TVOC,VOCs主要包括哪些物质?VOCs的来源有哪些?VOCs的危害及国家标准是什么?一、V...

对volatile 及happen—before的理解

happen—before规则介绍Java...

这一篇我们来了解Synchronized、Volatile、Final关键字

题外话:蓝银王觉醒了!!--来自于一个斗罗大陆动漫爱好者(鹅,打钱!)湿兄这两天回家了,办了点大事,回来的时候我弟弟还舍不得我,哭着不愿意让我回京(我弟还是小学),我也心里很不舍,但是还是要回京奋斗...

关于 Java 关键字 volatile 的总结

1什么是volatilevolatile是Java的一个关键字,它提供了一种轻量级的同步机制。相比于重量级锁synchronized,volatile更为轻量级,因为它不会引起线程上下文...

大白话聊聊Java并发面试问题之volatile到底是什么?

用最简单的大白话,加上多张图给大家说一下,volatile到底是什么?...

为什么要有volatile关键字(volatile 关键字为什么不能保证原子性)

在嵌入式编程和多线程编程中,我们常会见到volatile关键字声明的变量。下面说一下volatile关键字的作用:1.保持变量内存可见简而言之就是用volatile声明的变量会告诉编译器和处理器,这个...

Java的volatile到底怎么理解?(java volatitle)

我们都知道,在Java中有很多的关键字,比如synchronize比如volatile,这些都是一些比较关键的,还有final,今天我们就来聊一下这个volatile因为这个vo...

Java多线程编程中的volatile关键字:解密神秘的共享内存

Java多线程编程中的volatile关键字:解密神秘的共享内存在Java多线程编程的世界里,volatile关键字就像一位低调却至关重要的守护者。它默默无闻地站岗放哨,确保多个线程之间能够正确地共享...

你了解volatile关键字的作用吗?(关键字volatile有什么含意?并举出三个不同的例子?)

【死记硬背】volatile关键字主要用于保持内存的变量可见性和禁止重排序。变量可见性:当一个线程改变了变量的值,那么新的值对于其他线程也是可以立即获取到的。禁止重排序:...

谈谈你对volatile 关键字作用和原理的理解

一位6年工作经验的小伙伴,在某里二面的时候被问到“volatile”关键字。然后,就没有然后了…同样,还有一位4年的小伙伴,去某团面试也被问到“volatile关键字“。然后,也没有然后了…...

取消回复欢迎 发表评论: