源码分析Spring解决循环依赖的过程

news2025/1/1 22:19:54

循环依赖是之前很爱问的一个面试题,最近不咋问了,但是梳理Spring解决循环依赖的源码,会让我们对Spring创建bean的流程有一个清晰的认识,有必要搞一搞。开始搞之前,先参考了这个老哥写的文章,对Spring处理循环依赖有了一个基本的认识之后,然后开始进行源码debug,感谢这位老哥的分享:https://developer.aliyun.com/article/766880
我们搞一个简单的例子,先看看什么是循环依赖,我们只讲最简单的这种,set方法循环依赖,除此之外还有构造器循环依赖,我们讲最简单的这种,其实道理是一样的。
搞一个demo

@Data
@Component
public class TestA {

	@Autowired
	private TestB testB;

	public void getA(){
		System.out.println("我是getA方法");
	}
}
@Data
@Component
public class TestB {

	@Autowired
	private TestA testA;
}

A依赖B,B依赖A。这样就形成了一个简单的循环依赖。众所周知,Spring解决循环依赖的经典方法是三级缓存,当然还有其他的方法也可以处理,比如懒加载。今天我们只聊三级缓存,其他方式,感兴趣的话,可以自己查一些资料。
如果之前看过Spring的代码,我们就知道,Spring在创建bean之前都会先获取bean,如果获取不到,才会创建bean。所以我们从获取bean开始看起。
获取bean的入口在AbstractBeanFactory的doGetBean方法中。第一行代码,我们先看到从缓存获取bean的流程

// Eagerly check singleton cache for manually registered singletons.
Object sharedInstance = getSingleton(beanName);

这个方法里,我们想看的三级缓存就全了

protected Object getSingleton(String beanName, boolean allowEarlyReference) {
		//先从一级缓存取
		Object singletonObject = this.singletonObjects.get(beanName);
		if (singletonObject == null && isSingletonCurrentlyInCreation(beanName)) {
			synchronized (this.singletonObjects) {
				//一级缓存没有,从二级缓存取
				singletonObject = this.earlySingletonObjects.get(beanName);
				if (singletonObject == null && allowEarlyReference) {
					//二级缓存没有,从三级缓存取
					ObjectFactory<?> singletonFactory = this.singletonFactories.get(beanName);
					if (singletonFactory != null) {
						singletonObject = singletonFactory.getObject();
						//三级缓存取出来之后放入二级缓存
						this.earlySingletonObjects.put(beanName, singletonObject);
						//从三级缓存移除
						this.singletonFactories.remove(beanName);
					}
				}
			}
		}
		return singletonObject;
	}

刚开始,这三个缓存里,肯定都没有,父容器中也不会有。所以此时,需要创建A。
创建A的流程也在doGetBean方法里,我们向下看,有这样一段逻辑

// Create bean instance.
if (mbd.isSingleton()) {
	sharedInstance = getSingleton(beanName, () -> {
		try {
			return createBean(beanName, mbd, args);
		}
		catch (BeansException ex) {
			
		}
	});
}

createBean就是创建一个bean,但是这个createBean的过程是getSingleton方法的一个参数,是一个工厂方法,也就是说先执行getSingleton方法,某一个时机下,再触发工厂方法,我们看一下getSingleton的逻辑,我去掉了无关代码。先从一级缓存中获取,如果没有获取到,会触发createBean工厂方法的执行

public Object getSingleton(String beanName, ObjectFactory<?> singletonFactory) {
		
		synchronized (this.singletonObjects) {
		//从一级缓存中获取
			Object singletonObject = this.singletonObjects.get(beanName);
			if (singletonObject == null) {
				
				//一级缓存不存在,执行工厂方法创建bean
				singletonObject = singletonFactory.getObject();
				newSingleton = true;
				
				//bean创建成功,放入一级缓存
				if (newSingleton) {
					addSingleton(beanName, singletonObject);
				}
			}
			return singletonObject;
		}
	}
	//将创建完成的对象放入一级缓存中,也就是单例池中
	protected void addSingleton(String beanName, Object singletonObject) {
		synchronized (this.singletonObjects) {
			this.singletonObjects.put(beanName, singletonObject);
			this.singletonFactories.remove(beanName);
			this.earlySingletonObjects.remove(beanName);
			this.registeredSingletons.add(beanName);
		}
	}

从上面的逻辑,我们可以得到一个结论,一级缓存的bean已经是创建完成的bean,可以对外提供服务。
接下来,我们继续看工厂方法createBean的流程,创建bean的流程在AbstractAutowireCapableBeanFactory的doCreateBean方法中,我去掉了无关逻辑。

protected Object doCreateBean(final String beanName, final RootBeanDefinition mbd, final @Nullable Object[] args)
			throws BeanCreationException {

		//初始化bean,相当于new对象操作
		if (instanceWrapper == null) {
			instanceWrapper = createBeanInstance(beanName, mbd, args);
		}
		
		boolean earlySingletonExposure = (mbd.isSingleton() && this.allowCircularReferences &&
				isSingletonCurrentlyInCreation(beanName));
		//Spring解决循环依赖的核心逻辑
		if (earlySingletonExposure) {
			if (logger.isTraceEnabled()) {
				logger.trace("Eagerly caching bean '" + beanName +
						"' to allow for resolving potential circular references");
			}
			//放入三级缓存
			addSingletonFactory(beanName, () -> getEarlyBeanReference(beanName, mbd, bean));
		}

		// Initialize the bean instance.
		Object exposedObject = bean;
		
		//对当前bean进行依赖注入
		populateBean(beanName, mbd, instanceWrapper);
		//初始化bean,执行bean的一些初始化方法,比如各种aware、实现各种接口啥的。这个流程也有一个经典的面试题,bean的生命周期
		exposedObject = initializeBean(beanName, exposedObject, mbd);
	

		return exposedObject;
	}

上面就是创建A的具体逻辑,我们画个图梳理一下
在这里插入图片描述
创建A的流程中可以看到,在实例化A之后,就执行了放入三级缓存的动作。只要你没有禁止循环依赖,刚实例化的bean就会放入三级缓存。

protected void addSingletonFactory(String beanName, ObjectFactory<?> singletonFactory) {
		Assert.notNull(singletonFactory, "Singleton factory must not be null");
		synchronized (this.singletonObjects) {
			if (!this.singletonObjects.containsKey(beanName)) {
				this.singletonFactories.put(beanName, singletonFactory);
				this.earlySingletonObjects.remove(beanName);
				this.registeredSingletons.add(beanName);
			}
		}
	}

添加进三级缓存的是一个lambda表达式,() -> getEarlyBeanReference(beanName, mbd, bean),我们经常叫做工厂,那这个工厂方法又是什么时候触发呢?先按下不表,我们继续往下看,A进入三级缓存后,逻辑紧接着就要对A进行依赖注入,A需要依赖注入B,此时要去容器中获取B,获取B的流程和获取A的流程是一样的,获取入口也是AbstractBeanFactory的doGetBean方法,和获取A一样,也执行一遍三级缓存的获取操作,就是getSingleton方法。当然也是没有,所以需要创建B。
创建B的过程和创建A的过程一样。
实例化—>依赖注入—>初始化
我们把B的创建流程也画一下
在这里插入图片描述
B的依赖注入,需要注入A,我们需要先获取A,此时就又会走到AbstractBeanFactory的doGetBean的逻辑中。又会执行getSingleton逻辑。

protected Object getSingleton(String beanName, boolean allowEarlyReference) {
		//先从一级缓存取
		Object singletonObject = this.singletonObjects.get(beanName);
		if (singletonObject == null && isSingletonCurrentlyInCreation(beanName)) {
			synchronized (this.singletonObjects) {
				//一级缓存没有,从二级缓存取
				singletonObject = this.earlySingletonObjects.get(beanName);
				if (singletonObject == null && allowEarlyReference) {
					//二级缓存没有,从三级缓存取
					ObjectFactory<?> singletonFactory = this.singletonFactories.get(beanName);
					if (singletonFactory != null) {
						singletonObject = singletonFactory.getObject();
						//三级缓存取出来之后放入二级缓存
						this.earlySingletonObjects.put(beanName, singletonObject);
						//从三级缓存移除
						this.singletonFactories.remove(beanName);
					}
				}
			}
		}
		return singletonObject;
	}

一级缓存还是没有,二级缓存也没有,但是三级,此时就有了,因为我们创建A的过程中,已经把A先放入了三级缓存。此时从三级缓存中获取出来的工厂方法 “() -> getEarlyBeanReference(beanName, mbd, bean)” 就会触发,拿到A,然后将A放入二级缓存。我们看下这个工厂方法的逻辑里都干了啥

protected Object getEarlyBeanReference(String beanName, RootBeanDefinition mbd, Object bean) {
		Object exposedObject = bean;
		if (!mbd.isSynthetic() && hasInstantiationAwareBeanPostProcessors()) {
			for (BeanPostProcessor bp : getBeanPostProcessors()) {
				if (bp instanceof SmartInstantiationAwareBeanPostProcessor) {
					SmartInstantiationAwareBeanPostProcessor ibp = (SmartInstantiationAwareBeanPostProcessor) bp;
					exposedObject = ibp.getEarlyBeanReference(exposedObject, beanName);
				}
			}
		}
		return exposedObject;
	}

以上代码等价于

Object exposedObject = bean;
exposedObject = beanPostProcessor.getEarlyBeanReference(exposedObject, beanName);
return exposedObject;

processor虽然是一个集合,但是真正起作用的processor只有一个,就是AnnotationAwareAspectJAutoProxyCreator,它是通过@EnableAspectJAutoProxy注解导入到bean容器中的,从名字也能看到它是处理AOP的。我们看看这个processor的处理逻辑

@Override
	public Object getEarlyBeanReference(Object bean, String beanName) {
		Object cacheKey = getCacheKey(bean.getClass(), beanName);
		this.earlyProxyReferences.put(cacheKey, bean);
		//获取AOP代理对象
		return wrapIfNecessary(bean, beanName, cacheKey);
	}

实际上就是AOP代理的增强过程
但是,我们的业务代码,不一定都会用到AOP吧。那如果不用AOP的话,容器中就不会有AnnotationAwareAspectJAutoProxyCreator对象,那getEarlyBeanReference方法就可以简化为:

Object exposedObject = bean;
return exposedObject;

相当于工厂方法啥也没干。所以这就是为啥Spring放入三级缓存的是一个工厂方法,而不是立即获取代理对象放入三级缓存,因为在创建A的过程中,并不一定存在循环依赖,如果没有循环依赖,Spring处理AOP增强的逻辑统一在bean创建流程的末尾,就是initializeBean方法中

//对当前bean进行依赖注入
		populateBean(beanName, mbd, instanceWrapper);
		//初始化bean,执行bean的一些初始化方法,比如各种aware、实现各种接口啥的。这个流程也有一个经典的面试题,bean的生命周期
		exposedObject = initializeBean(beanName, exposedObject, mbd);

就是因为Spring也不确认依赖注入过程中是否会有循环依赖,它没办法,只能先暴露一个工厂方法,等到循环依赖真正产生的时候,再执行工厂方法,相当于把AOP增强过程延迟了。
至此,我们小结一下,我们完善一下创建A的流程
在这里插入图片描述
此时,我们就拿到了A,虽然不完美,但是已经可以让B的创建流程继续往下走,B创建完成后,将B放入单例池。然后,继续创建A。A完成,放入单例池,结束。Spring的循环依赖就是这样解决的。
下面,我们说2个经典的面试题
1、为什么需要三级缓存,二级缓存可以吗?
不但不可以,而且可能会破坏Spring的整体设计。我们说2种情况。
A是一个AOP对象,对A进行依赖注入前,Spring也不知道会不会存在循环依赖,只能先把A进行AOP增强,放入二级缓存,这样做明显是不合理的,如果后面不存在循环依赖,我们提前搞了一个代理对象,就做了无用功,并且也破坏了Spring的整体设计,因为Spring会在bean创建的末尾统一进行AOP增强,提前搞没有任何意义。有的同学会说,工厂方法确实有必要存在,那二级缓存有必要吗?我只保留一级和三级,不要二级可以吗?那就是下面这道面试题了。
2、只有一级和三级,没有二级可以吗?
猛地一看,二级缓存确实啥也没干,就是存取对象,真实的情况是这样吗?肯定不是的。抛开代码不说,就凭Spring的使用范围如此之广,不可能出现一段无用代码。那二级缓存的作用是什么呢?我举一个例子,你马上就明白了。下面这种场景,二级缓存必须得有。
在这里插入图片描述
A依赖B,B依赖A(三级缓存中获取A,将A加入二级缓存),B依赖C,C依赖A(二级缓存中获取A),如果没有二级缓存,那我们需要执行两次A的三级缓存工厂方法,如果依赖关系更复杂,可能需要执行多次工厂方法,显然是不合理的,所以Spring的二级缓存很重要。
我们画一下以上循环依赖的处理过程
我标注了序号,你可以按照序号来看一下整个过程,然后自己debug一遍代码,对二级缓存存在的必要会有一个更清洗的认识
在这里插入图片描述
我们总结一下Spring三级缓存的作用。
第一级缓存:存放完整的bean对象,这里面的bean已经可以对外提供服务
第二级缓存:已经进行了实例化,但是未完成依赖注入和初始化的对象
第三级缓存:存放工厂方法。提前暴露的一个对象,Spring解决循环依赖的核心所在

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

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈,一经查实,立即删除!

相关文章

4. Spring 之 AOP

文章目录1. AOP 简介2. AOP 入门案例3. AOP 工作流程&#xff08;略&#xff09;4. AOP 切入点表达式4.1 语法格式4.2 通配符4.3 书写技巧5. AOP 通知类型5.1 前置通知、后置通知5.2 环绕通知(重点)5.3 返回后通知(了解)5.4 抛出异常后通知(了解)6. 案例&#xff1a;业务层接口…

Elasticsearch为什么快?

1、搜索引擎为什么快&#xff1f;倒排索引核心原理概括的说&#xff0c;一个优秀的搜索引擎的设计&#xff0c;至少应该具备以下几点要求&#xff1a;高效的压缩算法快速的编码和解码算法合理的数据结构通用最小化算法结合以上几点&#xff0c;后面我将通过一个案例来讲解&…

MQ消息中间件常见题及解决办法

目录儿常见MQRocketMQ2、RocketMQ测试可用MQ常见问题1、幂等性问题2、如何保证消息不丢失3、消息积压问题4、事务消息设计分析常见MQ RocketMQ RocketMQ又四部分组成 NameServer 同步Broker服务信息&#xff0c;给消费者和生产者提供可用Broker的服务信息。Broker 消息存储业…

Python-第二天 Python基础语法

Python-第二天 Python基础语法一、 字面量1.1 常用的值类型1.1.1 字符串&#xff08;string&#xff09;二、注释2.1 注释的作用2.2 注释的分类三、变量3.1 什么是变量3.2 变量的特征四、数据类型4.1 数据类型4.2 type()语句4.3 type()语句的使用方式4.4 变量有类型吗&#xff…

【电商】后台订单生成

结合商品流转的电商系列介绍了一些了&#xff0c;商品已经采购入库、价格税率设置好了、活动及相关模板也已经准备完毕&#xff0c;下面就应该上架销售了&#xff0c;现在接着聊下订单的生成。 订单从产生到最终的关闭需要经历很多的环节&#xff0c;订单也是电商系统的核心数据…

Springcloud Alibaba 及各微服务组件整合梳理

Spring Cloud Alibaba 微服务各组件整合项目: 版本说明&#xff1a; <spring-boot.version>2.6.3</spring-boot.version><spring-cloud.version>2021.0.1</spring-cloud.version><spring-cloud-alibaba.version>2021.0.1.0</spring-cloud-a…

抖音的外卖行业入局,为中小外卖企业创业者的机会给了哪些机会?

一则关于抖音进入外卖市场的消息&#xff0c;让美团“非常受伤”。 2月8日&#xff0c;美团(03690.HK&#xff09;盘中跌幅超9%。截至收盘&#xff0c;美团报收153.1港元&#xff0c;跌幅6.48%。美团大幅下跌的根源就是前一天关于抖音外卖进展的消息传闻。 2月7日&#xff0c…

一站式 Elasticsearch 集群指标监控与运维管控平台

上篇文章写了一下消息运维管理平台&#xff0c;今天带来的是ES的监控和运维平台。目前初创企业&#xff0c;不像大型互联网公司&#xff0c;可以重复的造轮子。前期还是快速迭代试错阶段&#xff0c;方便拿到市场反馈&#xff0c;及时调整自己的战略和产品方向。让自己活下去&a…

大数据入门怎么学习

大数据学习不能停留在理论的层面上&#xff0c;大数据方向切入应是全方位的&#xff0c;基础语言的学习只是很小的一个方面&#xff0c;编程落实到最后到编程思想。学习前一定要对大数据有一个整体的认识。 大数据是数据量多吗&#xff1f;其实并不是&#xff0c;通过Hadoop其…

chatGPT 官网使用详细教程 (亲测可行)

文章目录1. chatGPT 介绍2. 进入官网3. 开始使用1. chatGPT 介绍 chatGPT 是一款由 OpenAI 开发的聊天机器人模型&#xff0c;它能够模拟人类的语言行为&#xff0c;与用户进行自然的交互。它的名称来源于它所使用的技术—— GPT-3架构&#xff0c;即生成式语言模型的第3代…

三极管-晶体管开关速度有两种方法

晶体管开关速度有两种方法可以考虑一下 1、使用加速电容 在基极限流电阻并联小容量的电容&#xff08;一般pF级别&#xff09;&#xff0c;当输入信号上升、下降时候能够使限流电阻瞬间被旁路并提供基极电流&#xff0c;所以在晶体管由导通状态变化到截止状态时能够迅速从基极…

【强训】Day13

努力经营当下&#xff0c;直至未来明朗&#xff01; 文章目录一、选择二、编程1. 参数解析2. ★跳石板答案1. 选择2. 编程普通小孩也要热爱生活&#xff01; 一、选择 一个关系数据库文件中的各条记录 &#xff08;&#xff09; A 前后顺序不能任意颠倒&#xff0c;一定要按照…

C语言typedef的用法详解

C语言允许为一个数据类型起一个新的别名&#xff0c;就像给人起“绰号”一样。起别名的目的不是为了提高程序运行效率&#xff0c;而是为了编码方便。例如有一个结构体的名字是 stu&#xff0c;要想定义一个结构体变量就得这样写&#xff1a;struct stu stu1;struct 看起来就是…

图解项目延期的原因及解决应对方案大全

项目管理中经常出现项目延期的情况&#xff0c;面对项目延期的风险如何应对是考验每个项目经理管理水平的时候&#xff0c;很多人纵然是工作多年也没有对延期的种种情况进行总结思考。咱们社区的小竹对大家常见的项目延期情况及处理方案进行了详细全面的总结&#xff0c;供大家…

微服务 分片 运维管理

微服务 分片 运维管理分片分片的概念分片案例环境搭建案例改造成任务分片Dataflow类型调度代码示例运维管理事件追踪运维平台搭建步骤使用步骤分片 分片的概念 当只有一台机器的情况下&#xff0c;给定时任务分片四个&#xff0c;在机器A启动四个线程&#xff0c;分别处理四个…

Python类型-语句-函数

文章目录类型动态类型:变量类型会随着程序的运行发生改变注释控制台控制台输入input()运算符算术关系逻辑赋值总结语句判断语句while循环for循环函数链式调用和嵌套调用递归关键字传参在C/java中&#xff0c;整数除以整数结果还是整数&#xff0c;并不会将小数部分舍弃&#xf…

线上CPU飙高诊断定位

1. 先准备一段java程序&#xff0c;后台运行 2. 使用 top命令查看cpu的进程使用情况 在这里看到了一个进程占据了99.3%的cpu利用率&#xff0c;这显然是出现了cpu飙升的情况&#xff0c;这会到期系统其他进程得不到cpu的使用权&#xff0c;从而出现卡顿&#xff0c;因此需要进行…

第五章——大数定律和中心极限定理

文章目录1、大数定律1.1、弱大数定理&#xff08;辛钦大数定理&#xff09;1.2、伯努利大数定理2、中心极限定理2.1、独立同分布的中心极限定理2.2、李雅普诺夫定理2.3、棣莫弗——拉普拉斯定理2.4、中心极限定理的应用2.4.1、独立同分布的中心极限定理的应用2.4.2、棣莫弗——…

文件同步是什么?解析6个最佳的文件同步应用软件

文件同步应用程序是一项服务或程序&#xff0c;它提供了一种便捷的方式来在多台计算机或移动设备上自动文件同步。在登录文件同步应用程序的任何地方&#xff0c;都可以使用相同的文件来打开&#xff0c;编辑&#xff0c;复制&#xff0c;流式传输等&#xff0c;就像在最初上传…

重磅!微软推出首款 ChatGPT 版搜索引擎!

微软近期推出了首款 ChatGPT 版搜索引擎&#xff0c;今天带大家一起来看一下。 一夜之间&#xff0c;全球最大的科技公司仿佛都回到了自己年轻时的样子。 在谷歌宣布「实验性对话式人工智能服务」Bard 之后仅 24 小时&#xff0c;北京时间 2 月 8 日凌晨两点&#xff0c;微软发…