Spring是怎么解决循环依赖的

news2024/9/23 5:25:39

1.什么是循环依赖:

这里给大家举个简单的例子,相信看了上一篇文章大家都知道了解了spring的生命周期创建流程。那么在Spring在生命周期的哪一步会出现循环依赖呢?

第一阶段:实例化阶段 Instantiation
第二阶段:属性赋值 Populate
第三阶段:初始化阶段 Initialization
第四阶段:销毁阶段 Destruction

首先在第一阶段实例化阶段,会出现循环依赖。

@Component
public class TestService {

   private OrderService orderService;
    
    public void TestService(OrderService orderService){
        this.orderService=orderService;
    }   
}

-----------------------------------
@Component
public class OrderService {

   private TestService testService;
    
    public void OrderService (TestService testService){
        this.testService=testService;
    }   
}

Spring在实例化阶段创建我们对象的时候,是通过反射调用我们的构造方法进行创建。如果你没有写无参构造方法,写了有参构造方法。那么spring就会调用你的有参构造方法进行创建对象。那么这个时候问题就来了,

1.首先TestService 它的有参对象是OrderService,这个时候spring就会对我的有参对象进行属性注入,它就会去创建我们的OrderService 。

2.在创建OrderService 的时候发现orderService的构造方法有参是TestService ,它又会去创建我们的TestService 。这个时候就会出现循环依赖,TestService 依赖OrderService , OrderService 依赖TestService 。

其次在第二阶属性赋值阶段,也会出现循环依赖。

@Component
public class TestService {

    @Autowired
   private OrderService orderService;
  
}
-----------------------------------

@Component
public class OrderService {

    @Autowired
    private TestService testService;
}

Spring在调用我们构造方法进行创建对象后,就会进行属性赋值。

  1. 当我们注入TestService 时,发现OrderService属性不在单例池中,就会去创建OrderService。
  2. 创建OrderService时,发现OrderService也有属性需要注入,就会去注入TestService 。这个时候也会出现魂环依赖问题。那么对于Spring来说,它是怎么去解决这些循环依赖问题的呢?

2.解决思路:

下路就是循环依赖我画的简单流程图,如果要解决循环依赖。我们怎么去解决呢?
在这里插入图片描述
思路一: 既然每次都要查看单例池存不存在,那我实例化的时候就放入单例池中吗。这样不就可以解决循环依赖了吗。

假如你现在有两个线程,在实例化阶段完成后你就把TestService放入单例池中,这个时候线程二去单例池中获取TestService对象。线程二获取的是完整的spring对象吗?并不是,这个时候我们的TestService他没有走完我们的生命周期,线程二它获取的会是TestService的普通对象,如果在后面阶段TestService需要AOP呢,Spring给它生成了代理对象。这个时候线程二就拿不到TestService的代理对象了。

在这里插入图片描述

思路二:不能直接放入单例池中,那么我就搞一个Set 集合,每次实例化对象的时候就把BeanName存入集合当中,表示这个对象正在创建中。为了解决代理对象问题,我在生成一个map我们叫他earlySingletonObjects 。它用来存储我们的代理对象。

其实这样就可以解决循环依赖的问题了,但是Spring在这方面没有这样实现。而是采用了另一种方法。因为这样违背了Spring设计原则。
Spring结合AOP跟Bean的生命周期,是在Bean创建完全之后通过AnnotationAwareAspectJAutoProxyCreator这个后置处理器来完成的,在这个后置处理的postProcessAfterInitialization方法中对初始化后的Bean完成AOP代理。如果出现了循环依赖,那没有办法,只有给Bean先创建代理,但是没有出现循环依赖的情况下,设计之初就是让Bean在生命周期的最后一步完成代理而不是在实例化后就立马完成代理。

思路三:在实例化后,我在加入一个Map<String, ObjectFactory<?>> singletonFactories 的map,每次实例化之后就把当前类存入map中,等后面产生循环依赖时,我先从earlySingletonObjects 中去找,没有找到的话。我在去singletonFactories 中去找。

在这里插入图片描述

3.源码分析:

首先在我们spring中有三级缓存

	// 从上至下 分表代表这“三级缓存”
	//一级缓存 用于存放完全初始化好的 bean,从该缓存中取出的 bean 可以直接使用
	private final Map<String, Object> singletonObjects = new ConcurrentHashMap<>(256); 
	//二级缓存 提前曝光的单例对象的cache,存放原始的 bean 对象(尚未填充属性),用于解决循环依赖
	private final Map<String, Object> earlySingletonObjects = new HashMap<>(16); 
	// 三级缓存 单例对象工厂的cache,存放 bean 工厂对象,用于解决循环依赖
	private final Map<String, ObjectFactory<?>> singletonFactories = new HashMap<>(16); 

1. 在构造Bean对象之后,将对象提前曝光到三级缓存中,这时候曝光的对象仅仅是构造完成,还没注入属性和初始化

public abstract class AbstractAutowireCapableBeanFactory extends AbstractBeanFactory
        implements AutowireCapableBeanFactory {
    protected Object doCreateBean(final String beanName, final RootBeanDefinition mbd, final @Nullable Object[] args)
           ''''''
            throws BeanCreationException {            
         // 这里就是调用你的构造方法,进行创建对象
         		if (instanceWrapper == null) {
			instanceWrapper = createBeanInstance(beanName, mbd, args);
		}
		Object bean = instanceWrapper.getWrappedInstance();
         '''''''
        // mbd.isSingleton() 判断对象是否是单例的
        // 当前对象是否允许循环依赖 this.allowCircularReferences 默认是true
        // isSingletonCurrentlyInCreation(beanName) 当前对象是否在创建中
        boolean earlySingletonExposure = (mbd.isSingleton() && this.allowCircularReferences &&
                isSingletonCurrentlyInCreation(beanName));
        if (earlySingletonExposure) {
            if (logger.isTraceEnabled()) {
                logger.trace("Eagerly caching bean '" + beanName +
                        "' to allow for resolving potential circular references");
            }
            // 循环依赖-添加到三级缓存中。value是lambda表达式,这个时候并未执行
            addSingletonFactory(beanName, () -> getEarlyBeanReference(beanName, mbd, bean));
        }
        ……
    }   
}     

2. 提前曝光的对象被放入Map<String, ObjectFactory<?>> singletonFactories缓存中,这里并不是直接将Bean放入缓存,而是包装成ObjectFactory对象再放入。

	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);
				// 从二级缓存中移除,因为在spring中bean是单例的,防止后面出现bug导致不是单例
				this.earlySingletonObjects.remove(beanName);
				// 将当前bean加入到set当中
				this.registeredSingletons.add(beanName);
			}
		}
	}

3. 为什么要包装一层ObjectFactory对象?

这里也就是Spring为什么采用第三级缓存的主要原因。

如果创建的Bean有对应的代理,那其他对象注入时,注入的应该是对应的代理对象;但是Spring无法提前知道这个对象是不是有循环依赖的情况,而正常情况下(没有循环依赖情况),Spring都是在创建好完成品Bean之后才创建对应的代理。这时候Spring有两个选择:
1.不管有没有循环依赖,都提前创建好代理对象,并将代理对象放入缓存,出现循环依赖时,其他对象直接就可以取到代理对象并注入。
2.不提前创建好代理对象,在出现循环依赖被其他对象注入时,才实时生成代理对象。这样在没有循环依赖的情况下,Bean就可以按着Spring设计原则的步骤来创建。

Spring选择了第二种方式,那怎么做到提前曝光对象而又不生成代理呢?
Spring就是在对象外面包一层ObjectFactory,提前曝光的是ObjectFactory对象,在被注入时才在ObjectFactory.getObject方式内实时生成代理对象,并将生成好的代理对象放入到第二级缓存Map<String, Object> earlySingletonObjects。

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

为了防止对象在后面的初始化(init)时重复代理,在创建代理时,earlyProxyReferences缓存会记录已代理的对象。

	@Override
	public Object getEarlyBeanReference(Object bean, String beanName) {
		Object cacheKey = getCacheKey(bean.getClass(), beanName);
		this.earlyProxyReferences.put(cacheKey, bean);
		return wrapIfNecessary(bean, beanName, cacheKey);
	}

在这里spring会创建对象,判断你是否需要代理,是否创建代理对象。

	protected Object wrapIfNecessary(Object bean, String beanName, Object cacheKey) {
		if (StringUtils.hasLength(beanName) && this.targetSourcedBeans.contains(beanName)) {
			return bean;
		}
		if (Boolean.FALSE.equals(this.advisedBeans.get(cacheKey))) {
			return bean;
		}
		if (isInfrastructureClass(bean.getClass()) || shouldSkip(bean.getClass(), beanName)) {
			this.advisedBeans.put(cacheKey, Boolean.FALSE);
			return bean;
		}

		// Create proxy if we have advice.
		Object[] specificInterceptors = getAdvicesAndAdvisorsForBean(bean.getClass(), beanName, null);
		if (specificInterceptors != DO_NOT_PROXY) {
			this.advisedBeans.put(cacheKey, Boolean.TRUE);
			Object proxy = createProxy(
					bean.getClass(), beanName, specificInterceptors, new SingletonTargetSource(bean));
			this.proxyTypes.put(cacheKey, proxy.getClass());
			return proxy;
		}

		this.advisedBeans.put(cacheKey, Boolean.FALSE);
		return bean;
	}

也可以理解为三级缓存的ObjectFactory其实在做的是一种缓存机制,当我们后面初始化需要代理时,Spring就会先从这个缓存中去拿代理对象,拿得到就不创建代理对象,而是使用这个代理对象。

4. 注入属性和初始化

Spring会调用populateBean()进行属性注入,然后该对象在单例池中,就直接从单例池拿,不在就进行对象的创建并注入。

public abstract class AbstractAutowireCapableBeanFactory extends AbstractBeanFactory
        implements AutowireCapableBeanFactory {
    protected Object doCreateBean(final String beanName, final RootBeanDefinition mbd, final @Nullable Object[] args)
            throws BeanCreationException {
        ……
        // Initialize the bean instance.
        Object exposedObject = bean;
        try {
        // 注入属性
            populateBean(beanName, mbd, instanceWrapper);
            exposedObject = initializeBean(beanName, exposedObject, mbd);
        }
        catch (Throwable ex) {
            if (ex instanceof BeanCreationException && beanName.equals(((BeanCreationException) ex).getBeanName())) {
                throw (BeanCreationException) ex;
            }
            else {
                throw new BeanCreationException(
                        mbd.getResourceDescription(), beanName, "Initialization of bean failed", ex);
            }
        }
        ……
    }        
}    

在进行对象创建过程中会调用getSingleton方法从缓存中获取注入对象



// 获取要注入的对象
	protected Object getSingleton(String beanName, boolean allowEarlyReference) {
		// 先从单例池一级缓存中拿,看能不能获取bean
		Object singletonObject = this.singletonObjects.get(beanName);
		// 如果单例池拿的是空,并且正在创建中
		if (singletonObject == null && isSingletonCurrentlyInCreation(beanName)) {
			// 那么就在从二级缓存中去拿
			singletonObject = this.earlySingletonObjects.get(beanName);
			// 如果二级缓存中没有,就加锁在进行判断
			if (singletonObject == null && allowEarlyReference) {
				synchronized (this.singletonObjects) {
					// 如果一级缓存还是没有
					singletonObject = this.singletonObjects.get(beanName);
					if (singletonObject == null) {
						// 就找二级缓存 
						singletonObject = this.earlySingletonObjects.get(beanName);
						if (singletonObject == null) {
						 // 二级缓存还是没有就找三级缓存
							ObjectFactory<?> singletonFactory = this.singletonFactories.get(beanName);
							if (singletonFactory != null) {
							   // 三级缓存获取到了,(这时三级缓存会执行lambad表达式并创建普通对象或者代理对象)
								singletonObject = singletonFactory.getObject();
								// 把获取到的对象放入二级缓存中
								this.earlySingletonObjects.put(beanName, singletonObject);
								// 从三级缓存删除该对象,防止lambad表达式重复执行,防止出现bug让spring不能保证单例
								this.singletonFactories.remove(beanName);
							}
						}
					}
				}
			}
		}
		return singletonObject;
	}

5.放入已完成创建的单例缓存中
最终Spring会通过addSingleton方法将最终生成的可用的Bean放入到单例缓存里。


	/**
	 * Add the given singleton object to the singleton cache of this factory.
	 * <p>To be called for eager registration of singletons.
	 * @param beanName the name of the bean
	 * @param singletonObject the singleton object
	 */
	protected void addSingleton(String beanName, Object singletonObject) {
		synchronized (this.singletonObjects) {
			// 将创建好的bean放入一级缓存,单例池中
			this.singletonObjects.put(beanName, singletonObject);
			// 删除三级缓存
			this.singletonFactories.remove(beanName);
			// 删除二级缓存
			this.earlySingletonObjects.remove(beanName);
			// 放入已注册实例的Set集合当中
			this.registeredSingletons.add(beanName);
		}
	}

总结:

1.Spring有哪三级缓存

	// 从上至下 分表代表这“三级缓存”
	//一级缓存 用于存放完全初始化好的 bean,从该缓存中取出的 bean 可以直接使用
	private final Map<String, Object> singletonObjects = new ConcurrentHashMap<>(256); 
	//二级缓存 提前曝光的单例对象的cache,存放原始的 bean 对象(尚未填充属性),用于解决循环依赖
	private final Map<String, Object> earlySingletonObjects = new HashMap<>(16); 
	// 三级缓存 单例对象工厂的cache,存放 bean 工厂对象,用于解决循环依赖
	private final Map<String, ObjectFactory<?>> singletonFactories = new HashMap<>(16); 

2.只要二级缓存,不要三级缓存可不可以

其实我试验过,用二级缓存也可以达到和三级缓存同样的效果。只不过为了不违背Spring设计原则,Spring采用了三级缓存。
Spring结合AOP跟Bean的生命周期,是在Bean创建完全之后通过AnnotationAwareAspectJAutoProxyCreator这个后置处理器来完成的,在这个后置处理的postProcessAfterInitialization方法中对初始化后的Bean完成AOP代理。如果出现了循环依赖,那没有办法,只有给Bean先创建代理,但是没有出现循环依赖的情况下,设计之初就是让Bean在生命周期的最后一步完成代理而不是在实例化后就立马完成代理。

3. Spring三级缓存完整流程思路
在这里插入图片描述

  1. 实例化普通对象UserService (对象U),将普通对象U加入Set集合(判断是不是在创建中),将对象U加入三级缓存

  2. U注入属性OrderService(对象O),发现O不在创建中,实例化普通对象OrderService (对象O))将对象O加入Set集合(用于判断是不是在创建中),将对象O加入三级缓存。

  3. O注入属性U,发现对象U在创建中(循环依赖),在一级缓存中找(没找到),在二级缓存中找(没找到),在三级缓存中(找到了),创建对象U的代理对象。将代理对象加入二级缓存,并在三级缓存中进行remove,将U的代理对象注入给O

  4. 注入完属性后,就进行初始化等操作,完成对象的创建。将O注入到一级缓存中,从二级,三级缓存删除O对象。

  5. O对象创建完成后,U对象就注入属性O的代理对象,U在完成初始化等操作,最后将U注入到一级缓存中,从二级,三级缓存删除O对象。


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

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

相关文章

代码随想录 NO52 | 动态规划_leetcode 647. 回文子串 516.最长回文子序列

动态规划_leetcode 647. 回文子串 516.最长回文子序列今天是动态规划最后一天的题了&#xff0c;整个过程已经接近尾声了&#xff01; 647. 回文子串 确定dp数组&#xff08;dp table&#xff09;以及下标的含义 本题如果我们定义&#xff0c;dp[i] 为 下标i结尾的字符串有 dp…

【改进灰狼优化算法】改进收敛因子和比例权重的灰狼优化算法【期刊论文完美复现】(Matlab代码实现)

&#x1f468;‍&#x1f393;个人主页&#xff1a;研学社的博客&#x1f4a5;&#x1f4a5;&#x1f49e;&#x1f49e;欢迎来到本博客❤️❤️&#x1f4a5;&#x1f4a5;&#x1f3c6;博主优势&#xff1a;&#x1f31e;&#x1f31e;&#x1f31e;博客内容尽量做到思维缜密…

【Hello Linux】进程概念

作者&#xff1a;小萌新 专栏&#xff1a;Linux 作者简介&#xff1a;大二学生 希望能和大家一起进步&#xff01; 本篇博客简介&#xff1a;简单介绍下进程的概念 进程基本概念PCB 程序控制块task_struct是什么task_struct里面有什么查看进程通过系统目录查看进程通过ps指令查…

22.2.26打卡 Codeforces Round #853 (Div. 2)

A题极端考虑, 只要存在一个前缀数组的最大公约数小于等于2, 将其放在数组最前端, 那么保证能够满足题目要求数据范围这么小, 果断暴力Serval and Mochas Array题目描述Mocha likes arrays, and Serval gave her an array consisting of positive integers as a gift.Mocha thin…

ARM Context synchronization event和Instruction Synchronization Barrier

在Arm architecture里&#xff0c;经常提到Context synchronization event(CSE)和Explicit synchronization&#xff0c;Context synchronization events在之前是叫作context synchronization operations。Explicit synchronization是Context synchronization event的结果&…

C++9:优先级队列以及仿函数和反向迭代器

目录 优先级队列的基本增删查改实现 仿函数 反向迭代器 优先级队列的本质其实是一个堆&#xff0c;具体到底层的数据结构其实是有数学关系所形成的一个类似二叉树的结构 至于其优先级的这个特性&#xff0c;跟大堆小堆的性质是相同的&#xff0c;只不过它使用了仿函数来控制…

bool与引用类型

bool与引用类型bool类型介绍与使用bool(布尔类型)大小&#xff1a;1个字节返回值有两个&#xff1a;1(true)&#xff0c;0(false)#include<iostream>using namespace std;int main() {bool a false;bool b true;cout << "a " << a << end…

Lighthouse组合Puppeteer检测页面

如上一篇文章lighthouse的介绍和基本使用方法结尾提到的一样&#xff0c;我们在实际使用Lighthouse检测页面性能时&#xff0c;通常需要一定的业务前置条件&#xff0c;比如最常见的登录操作、如果没有登录态就没有办法访问其他页面。再比如有一些页面是需要进行一系列的操作&a…

从编年史角度看大数据兴起

开源大数据编年史大数据发展的各阶段大数据诞生初期大数据百花齐放的发展之路追求性能的大数据成熟期大数据发展的各阶段 开源大数据的编年史的话&#xff0c;实际上分为三个阶段。一般来说它分为初期、发展期、成熟期。 初期就是大数据刚开始萌芽的一个阶段&#xff0c;它从…

java 8 中的实用技巧

1 判断2个对象是否相等Objects.equals(a, b)(1) 比较时&#xff0c; 若a 和 b 都是null, 则返回 true, 如果a 和 b 其中一个是null, 另一个不是null, 则返回false。注意&#xff1a;不会抛出空指针异常。(2) a 和 b 如果都是空值字符串&#xff1a;"", 则 a.equals(b…

深入浅出解析ChatGPT引领的科技浪潮【AI行研商业价值分析】

Rocky Ding写在前面 【AI行研&商业价值分析】栏目专注于分享AI行业中最新热点/风口的思考与判断。也欢迎大家提出宝贵的意见或优化ideas&#xff0c;一起交流学习&#x1f4aa; 大家好&#xff0c;我是Rocky。 2022年底&#xff0c;ChatGPT横空出世&#xff0c;火爆全网&a…

CXL互联标准简介及相关资料

毕设是实现CXL的type3扩展内存设备&#xff0c;因为CXL技术非常新&#xff0c;2019年推出&#xff0c;本专栏也是记录CXL的相关知识与一些浅薄的理解 文章目录CXL出现的背景CXL是什么其他互联总线介绍CXL胜出的原因CXL内容简介包含三种协议 CXL.io/cache/memory支持三种设备类型…

SQL注入原理及漏洞利用(入门级)

文章目录一、什么是SQL注入漏洞&#xff1f;二、 SQL查询语句三、SQL注入分类数字型&#xff08;整型&#xff09;注入字符型注入搜索型注入四、SQL注入漏洞形成原因一、什么是SQL注入漏洞&#xff1f; 攻击者利用Web应用程序对用户输入验证上的疏忽&#xff0c;在输入的数据中…

基于Istio的高级流量管理二(Envoy流量劫持、Istio架构、高级流量管理)

文章目录一、Envoy流量劫持机制&#xff08;Iptables规则流转&#xff09;1、流量出向劫持流程&#xff08;1&#xff09;envoy怎样劫持入向流量&#xff1f;&#xff08;2&#xff09;Envoy劫持到流量之后&#xff0c;干什么&#xff1f;&#xff08;查询目的地&#xff09;&a…

tess4j简单使用入门

tess4j下载 下载地址: https://sourceforge.net/projects/tess4j/ 不要直接下载,点击files,然后下载最新版 下载解压后放到指定的目录即可,这里放到d:\jar目录下 tess4j根目录: d:\jar\tess4j tess4j使用 把test4j项目目录中dist和lib目录下的所有jar包导入到需要的项目中…

【云原生】k8s 离线部署讲解和实战操作

文章目录一、概述二、前期准备1&#xff09;节点信息2&#xff09;修改主机名和配置hosts3&#xff09;配置ssh互信4&#xff09;时间同步5&#xff09;关闭防火墙6&#xff09;关闭 swap7&#xff09;禁用SELinux8&#xff09;允许 iptables 检查桥接流量三、开始部署1&#x…

【OC】块初识

Block简介 Blocks是C语言的扩充功能。可以用一句话来表示Blocks的扩充功能&#xff1a;带有自动变量的匿名函数。 匿名函数 所谓匿名函数就是不带有名称的函数。C语言的标准不允许存在这样的函数。例&#xff1a; int func(int count);它声明了名称为func的函数。下面的源代…

STM32 ROS控制器底层代码讲解

本文主要对控制器底层代码的整天架构进行讲解。控制器由两部分组成一部分是BootLoader,另一部分是APP&#xff1b;BootLoader主要用于固件升级&#xff0c;APP则作为应用程序。BootLoader的地址为:0x8000000~0x8008000App的地址为:0x8010000~0x8FFFFFF参数保存地址为&#xff1…

基本密码技术

AESAES取代DES&#xff0c;是一种对称加密技术&#xff0c;分为AES-128/192/256, 其分组长度固定为128b&#xff0c;若最后一个分组长度不够&#xff0c;需要补全至128b长度。所支持的秘钥长度分别为128b/192b/256b.分组密码模式AES是对明文进行分组之后逐块进行加密&#xff0…

2023年软考高级网络规划设计师

网络规划设计师是软考高级考试科目之一&#xff0c;也是比较难的科目&#xff0c;据官方数据统计网规每年的通过率很低&#xff0c;而且每年只有下半年11月份考一次&#xff0c;如果是直接裸考&#xff0c;估计很悬哦~ 但是你参加考试获得证书的过程就是一个学习网络规划系统知…