SpringBoot关闭过程中销毁DisposableBean解读

 更新时间:2023年12月05日 11:25:54   作者:流烟默  
这篇文章主要介绍了SpringBoot关闭过程中销毁DisposableBean解读,一个bean的生命周期,指的是 bean 从创建,初始化,一系列使用,销毁的过程,今天来讲讲 bean 的初始化和销毁的方法,需要的朋友可以参考下

DisposableBean的destroy过程

DefaultSingletonBeanRegistry的destroySingleton方法。

public void destroySingleton(String beanName) {
	// Remove a registered singleton of the given name, if any.
	// 从缓存中移除当前beanName
	removeSingleton(beanName);
	// Destroy the corresponding DisposableBean instance.
	// 从disposableBeans集合中移除当前 beanName
	DisposableBean disposableBean;
	synchronized (this.disposableBeans) {
		disposableBean = (DisposableBean) this.disposableBeans.remove(beanName);
	}
	// 这是核心方法
	destroyBean(beanName, disposableBean);
}

disposableBeans里面存放的是beanName以及对应的DisposableBeanAdapter实例。其他方法我们过一下即可,这里我们着重分析destroyBean(beanName, disposableBean);。

核心方法DefaultSingletonBeanRegistry的destroyBean

// DefaultSingletonBeanRegistry
protected void destroyBean(String beanName, @Nullable DisposableBean bean) {
	// Trigger destruction of dependent beans first...
	Set<String> dependencies;
	//dependentBeanMap存放的是哪些bean依赖于key
	synchronized (this.dependentBeanMap) {
		// Within full synchronization in order to guarantee a disconnected Set
		dependencies = this.dependentBeanMap.remove(beanName);
	}
	// 首先触发那些依赖于当前beanName的bean的销毁流程
	if (dependencies != null) {
		if (logger.isTraceEnabled()) {
			logger.trace("Retrieved dependent beans for bean '" + beanName + "': " + dependencies);
		}
		for (String dependentBeanName : dependencies) {
			destroySingleton(dependentBeanName);
		}
	}
	// Actually destroy the bean now...
	// bean销毁的过程入口,触发DisposableBeanAdapter的destroy方法
	if (bean != null) {
		try {
			bean.destroy();
		}
		catch (Throwable ex) {
			if (logger.isWarnEnabled()) {
				logger.warn("Destruction of bean with name '" + beanName + "' threw an exception", ex);
			}
		}
	}
	// Trigger destruction of contained beans...
	// 获取当前beanName对应的containedBeans,如果有,则遍历触发销毁流程
	Set<String> containedBeans;
	synchronized (this.containedBeanMap) {
		// Within full synchronization in order to guarantee a disconnected Set
		containedBeans = this.containedBeanMap.remove(beanName);
	}
	if (containedBeans != null) {
		for (String containedBeanName : containedBeans) {
			destroySingleton(containedBeanName);
		}
	}
	// Remove destroyed bean from other beans' dependencies.
	// 遍历dependentBeanMap的value,移除掉当前beanName。
	//之后如果value为空,其从dependentBeanMap移除掉当前entry
	synchronized (this.dependentBeanMap) {
		for (Iterator<Map.Entry<String, Set<String>>> it = this.dependentBeanMap.entrySet().iterator(); it.hasNext();) {
			Map.Entry<String, Set<String>> entry = it.next();
			Set<String> dependenciesToClean = entry.getValue();
			dependenciesToClean.remove(beanName);
			if (dependenciesToClean.isEmpty()) {
				it.remove();
			}
		}
	}
	// Remove destroyed bean's prepared dependency information.
	// 从 dependenciesForBeanMap中移除当前beanName对应的entry
	this.dependenciesForBeanMap.remove(beanName);
}

方法逻辑梳理如下:

  • 首先触发那些依赖于当前beanName的bean的销毁流程
  • bean.destroy();触发DisposableBeanAdapter的destroy方法
  • 获取当前实例维护的DestructionAwareBeanPostProcessor 触发其postProcessBeforeDestruction方法,如果有@PreDestroy注解的方法,这时会被触发。
  • 根据invokeDisposableBean判断是否触发destroy方法
  • 尝试触发其自定义destroy method
  • 获取当前beanName对应的containedBeans,如果有,则遍历触发销毁流程
  • 遍历dependentBeanMap的value,移除掉当前beanName。之后如果value为空,其从dependentBeanMap移除掉当前entry
  • 从 dependenciesForBeanMap中移除当前beanName对应的entry

DisposableBeanAdapter

上面提到了bean.destroy();触发DisposableBeanAdapter的destroy方法,方法如下所示:

@Override
public void destroy() {
//获取当前实例维护的DestructionAwareBeanPostProcessor 触发其postProcessBeforeDestruction方法
	if (!CollectionUtils.isEmpty(this.beanPostProcessors)) {
		for (DestructionAwareBeanPostProcessor processor : this.beanPostProcessors) {
			processor.postProcessBeforeDestruction(this.bean, this.beanName);
		}
	}
// 是否触发destroy方法
	if (this.invokeDisposableBean) {
		if (logger.isTraceEnabled()) {
			logger.trace("Invoking destroy() on bean with name '" + this.beanName + "'");
		}
		try {
			if (System.getSecurityManager() != null) {
				AccessController.doPrivileged((PrivilegedExceptionAction<Object>) () -> {
					((DisposableBean) this.bean).destroy();
					return null;
				}, this.acc);
			}
			else {
				((DisposableBean) this.bean).destroy();
			}
		}
		catch (Throwable ex) {
			String msg = "Invocation of destroy method failed on bean with name '" + this.beanName + "'";
			if (logger.isDebugEnabled()) {
				logger.warn(msg, ex);
			}
			else {
				logger.warn(msg + ": " + ex);
			}
		}
	}
// 如果destroyMethod 不为null,则触发自定义销毁方法
	if (this.destroyMethod != null) {
		invokeCustomDestroyMethod(this.destroyMethod);
	}
	else if (this.destroyMethodName != null) {
	// 如果destroyMethodName 不为null,则获取并触发自定义销毁方法
		Method methodToInvoke = determineDestroyMethod(this.destroyMethodName);
		if (methodToInvoke != null) {
			invokeCustomDestroyMethod(ClassUtils.getInterfaceMethodIfPossible(methodToInvoke));
		}
	}
}

方法流程

获取当前实例维护的DestructionAwareBeanPostProcessor 触发其postProcessBeforeDestruction方法,如果有@PreDestroy注解的方法,这时会被触发。

根据invokeDisposableBean判断是否触发destroy方法

尝试触发其自定义destroy method

到此这篇关于SpringBoot关闭过程中销毁DisposableBean解读的文章就介绍到这了,更多相关SpringBoot销毁DisposableBean内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家!

相关文章

  • Java中常见延时队列的实现方案小结(建议收藏)

    Java中常见延时队列的实现方案小结(建议收藏)

    延时队列它要具有队列的特性,再给它附加一个延迟消费队列消息的功能,也就是说可以指定队列中的消息在哪个时间点被消费,这篇文章主要介绍了Java中常见延时队列的实现方案总结,需要的朋友可以参考下
    2024-04-04
  • 详解Spring Boot实现日志记录 SLF4J

    详解Spring Boot实现日志记录 SLF4J

    本篇文章主要介绍了详解Spring Boot实现日志记录 SLF4J,小编觉得挺不错的,现在分享给大家,也给大家做个参考。一起跟随小编过来看看吧
    2017-05-05
  • jdbc和mybatis的流式查询使用方法

    jdbc和mybatis的流式查询使用方法

    有些时候我们所需要查询的数据量比较大,但是jvm内存又是有限制的,数据量过大会导致内存溢出。这个时候就可以使用流式查询,本文就主要介绍了jdbc和mybatis的流式查询,感兴趣的可以了解一下
    2021-11-11
  • 浅谈java中六大时间类的使用和区别

    浅谈java中六大时间类的使用和区别

    下面小编就为大家带来一篇浅谈java中六大时间类的使用和区别。小编觉得挺不错的,现在就分享给大家,也给大家做个参考。一起跟随小编过来看看吧
    2017-01-01
  • maven helper jar包冲突的几种解决方法

    maven helper jar包冲突的几种解决方法

    maven Helper是排查jar包冲突的一大利器,jar包冲突大部分是由于引用了同一个jar的不同版本而导致的,本文主要介绍了maven helper jar包冲突的几种解决方法,感兴趣的可以了解一下
    2024-03-03
  • java多线程模拟抢红包功能

    java多线程模拟抢红包功能

    这篇文章主要为大家详细介绍了java多线程模拟抢红包功能,文中示例代码介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2017-12-12
  • Java设置Map过期时间的的几种方法举例详解

    Java设置Map过期时间的的几种方法举例详解

    本文详细介绍了Java中使用轻量级缓存组件ExpiringMap以及Guava的LoadingCache缓存机制,ExpiringMap提供了Map自动过期、监听事件等功能,而LoadingCache提供了缓存回收、数据加载等高级功能,两者为Java项目提供了有效的数据管理和缓存解决方案,需要的朋友可以参考下
    2024-10-10
  • Spring AOP注解案例及基本原理详解

    Spring AOP注解案例及基本原理详解

    这篇文章主要介绍了Spring AOP注解案例及基本原理详解,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
    2020-06-06
  • Dubbo在Spring和Spring Boot中的使用详解

    Dubbo在Spring和Spring Boot中的使用详解

    这篇文章主要介绍了Dubbo在Spring和Spring Boot中的使用详解,需要的朋友可以参考下
    2017-10-10
  • java实现高效下载文件的方法

    java实现高效下载文件的方法

    这篇文章主要为大家详细介绍了java实现高效下载文件的几种方法,文中示例代码介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2021-08-08

最新评论