二刷Spring循环依赖源码(下)

简介: 二刷Spring循环依赖源码(下)

3.为啥需要三个缓存

Spring 为啥用三个缓存去解决循环依赖问题?

上面两个缓存的地方,我们只是没有考虑代理的情况。


代理的存在

Bean在创建的最后阶段,会检查是否需要创建代理,如果创建了代理,那么最终返回的就是代理实例的引用。我们通过beanname获取到最终是代理实例的引用

也就是说:上文中,假设A最终会创建代理,提前暴露A的引用, B填充属性时填充的是A的原始对象引用。A最终放入成品库里是代理的引用。那么B中依然是A的早期引用。这种结果最终会与我们的期望的大相径庭了。

怎么办???


Spring 是这么做的
=======AbstractAutowireCapableBeanFactory.doCreateBean
protected Object doCreateBean(final String beanName, final RootBeanDefinition mbd, final Object[] args)
            throws BeanCreationException {
        【1】Instantiate the bean.
        BeanWrapper instanceWrapper = null;
        if (mbd.isSingleton()) {
            instanceWrapper = this.factoryBeanInstanceCache.remove(beanName);
        }
        if (instanceWrapper == null) {
            instanceWrapper = createBeanInstance(beanName, mbd, args);
        }
        【早期引用】
        final Object bean = (instanceWrapper != null ? instanceWrapper.getWrappedInstance() : null);
        【2】在需要暴露早期引用的条件下
        boolean earlySingletonExposure = (mbd.isSingleton() && this.allowCircularReferences &&
                isSingletonCurrentlyInCreation(beanName));
        if (earlySingletonExposure) {
            【2.1】绑定当前Bean引用到ObjectFactory,注册到三级singletonFactories 
            addSingletonFactory(beanName, new ObjectFactory<Object>() {
                【重写getObject】
                @Override
                public Object getObject() throws BeansException {
                    return getEarlyBeanReference(beanName, mbd, bean);
                }
            });
        }
}
===AbstractAutowireCapableBeanFactory.doCreateBean--->DefaultSingletonBeanRegistry.getSingleton
protected void addSingletonFactory(String beanName, ObjectFactory<?> singletonFactory) {
        synchronized (this.singletonObjects) {
            if (!this.singletonObjects.containsKey(beanName)) {
                【3】放入到singletonFactories 缓存中,清除其他缓存
                this.singletonFactories.put(beanName, singletonFactory);
                this.earlySingletonObjects.remove(beanName);
                this.registeredSingletons.add(beanName);
            }
}
===========AbstractBeanFactory.doGetBean--->DefaultSingletonBeanRegistry.getSingleton
【4】按Beanname取Bean
protected Object getSingleton(String beanName, boolean allowEarlyReference) {
        【4.1】先尝试从成品缓存获取
        Object singletonObject = this.singletonObjects.get(beanName);
        【4.2】成品缓存没有,且正在创建,尝试从半成品缓存获取
        if (singletonObject == null && isSingletonCurrentlyInCreation(beanName)) {
            synchronized (this.singletonObjects) {
                singletonObject = this.earlySingletonObjects.get(beanName);
                if (singletonObject == null && allowEarlyReference) {
                    【4.3】半成品缓存没有,且允许早期引用,尝试从工厂缓存中查找有么此Bean的工厂类存在
                    ObjectFactory<?> singletonFactory = this.singletonFactories.get(beanName);
                    if (singletonFactory != null) {
                        【4.4】存在,执行getObject获取早期引用,放入到半成品缓存,并将工厂类从工厂缓存中移除
                        singletonObject = singletonFactory.getObject();
                        this.earlySingletonObjects.put(beanName, singletonObject);
                        this.singletonFactories.remove(beanName);
                    }
                }
            }
        }
        return (singletonObject != NULL_OBJECT ? singletonObject : null);
    }

注册 ObjectFactory工厂类到工厂缓存

singletonFactory.getObject();会调用重写getObject()调用getEarlyBeanReference的后续操作。

  • 如果后续操作没有创建代理,返回的依然是原始引用
  • 如果需要代理,在此处返回就是代理的引用
早期的扩展处理
protected Object getEarlyBeanReference(String beanName, RootBeanDefinition mbd, Object bean) {
        Object exposedObject = bean;
        if (bean != null && !mbd.isSynthetic() && hasInstantiationAwareBeanPostProcessors()) {
            for (BeanPostProcessor bp : getBeanPostProcessors()) {
                if (bp instanceof SmartInstantiationAwareBeanPostProcessor) {
                    SmartInstantiationAwareBeanPostProcessor ibp = (SmartInstantiationAwareBeanPostProcessor) bp;
                    exposedObject = ibp.getEarlyBeanReference(exposedObject, beanName);
                    if (exposedObject == null) {
                        return null;
                    }
                }
            }
        }
        return exposedObject;
    }

可以看出此处是执行扩展的操作。

AbstractAutoProxyCreator

【1】针对提前创建代理,返回代理引用
public Object getEarlyBeanReference(Object bean, String beanName) throws BeansException {
        Object cacheKey = getCacheKey(bean.getClass(), beanName);
        this.earlyProxyReferences.put(cacheKey, bean);
        return wrapIfNecessary(bean, beanName, cacheKey);
}
【2】针对不是提前创建代理的情况
public Object postProcessAfterInitialization(Object bean, String beanName) throws BeansException {
        if (bean != null) {
            Object cacheKey = getCacheKey(bean.getClass(), beanName);
            if (this.earlyProxyReferences.remove(cacheKey) != bean) {
                return wrapIfNecessary(bean, beanName, cacheKey);
            }
        }
        return bean;
}

可以看出singletonFactory工厂缓存,解决了代理问题的关键

大体流程如图

image.png


关键点:

  • A绑定到ObjectFactory 注册到工厂缓存singletonFactory中,
  • B在填充A时,先查成品缓存有没有,再查半成品缓存有没有,最后看工厂缓存有没有单例工厂类,有A的ObjectFactory。调用getObject ,执行扩展逻辑,可能返回的代理引用,也可能返回原始引用。
  • 成功获取到A的早期引用,将A放入到半成品缓存中,B填充A引用完毕。
  • 代理问题, 循环依赖问题都解决了。


四、额外思考的自问自答


在这之外,我还有一些思考,并提出自己的观点。

1:为啥不提前调用ObjectFactory.getObject ()直接执行扩展逻辑处理A的早期引用,得到半成品实例引用放入到earlySingletonObjects中,非要先放一个工厂类到工厂缓存中?使用三级缓存呢?

答:假设A只是依赖B 。如果提前执行A扩展操作,在A创建的后期,还会遍历一遍扩展点,岂不是浪费?

2.二级缓存存在意义是啥?

答:其实吧,我觉得  二级缓存earlySingletonObjects三级缓存singletonFactories 。都是为分工明确而生。

  • 一级缓存singletonObjects: 就是存的最终的成品
  • 二级缓存earlySingletonObjects  就是为存半成品Bean
  • 三级缓存singletonFactories: 就是为存bean工厂

因为是早期暴露,从工厂里创建完成后,是半成品,放入半成品缓存,全部流程执行完时是成品放入到成品缓存分工明确

这也为什么,我认为叫成品缓存,半成品缓存,单例工厂缓存 更加合适的原因

3.是不是走极端,让我设计此块,我非得设计成单个缓存。提前执行后续操作,把他放到singletonObjects

好像也没有问题,就是非常乱


五、总结


以上就是我对Spring循环依赖的一些理解与思考

循环依赖的关键点:提前暴露绑定A原始引用的工厂类到工厂缓存。等需要时触发后续操作处理A的早期引用,将处理结果放入二级缓存


相关文章
|
1月前
|
XML 缓存 Java
Spring源码之 Bean 的循环依赖
循环依赖是 Spring 中经典问题之一,那么到底什么是循环依赖?简单说就是对象之间相互引用, 如下图所示: 代码层面上很好理解,在 bean 创建过程中 class A 和 class B 又经历了怎样的过程呢? 可以看出形成了一个闭环,如果想解决这个问题,那么在属性填充时要保证不二次创建 A对象 的步骤,也就是必须保证从容器中能够直接获取到 B。 一、复现循环依赖问题 Spring 中默认允许循环依赖的存在,但在 Spring Boot 2.6.x 版本开始默认禁用了循环依赖 1. 基于xml复现循环依赖 定义实体 Bean java复制代码public class A {
|
1天前
|
XML 人工智能 Java
Spring Bean名称生成规则(含源码解析、自定义Spring Bean名称方式)
Spring Bean名称生成规则(含源码解析、自定义Spring Bean名称方式)
|
8天前
|
存储 缓存 Java
Spring解决循环依赖
Spring解决循环依赖
|
8天前
|
Java 关系型数据库 MySQL
一套java+ spring boot与vue+ mysql技术开发的UWB高精度工厂人员定位全套系统源码有应用案例
UWB (ULTRA WIDE BAND, UWB) 技术是一种无线载波通讯技术,它不采用正弦载波,而是利用纳秒级的非正弦波窄脉冲传输数据,因此其所占的频谱范围很宽。一套UWB精确定位系统,最高定位精度可达10cm,具有高精度,高动态,高容量,低功耗的应用。
一套java+ spring boot与vue+ mysql技术开发的UWB高精度工厂人员定位全套系统源码有应用案例
|
25天前
|
缓存 算法 Java
开发必懂的Spring循环依赖图解 Spring 循环依赖
开发必懂的Spring循环依赖图解 Spring 循环依赖
18 1
|
28天前
|
缓存 算法 Java
Spring解决循环依赖
Spring解决循环依赖
19 0
|
1月前
|
Java Spring
使用spring实现邮件的发送(含测试,源码,注释)
使用spring实现邮件的发送(含测试,源码,注释)
7 0
|
1月前
|
Java 开发者 Spring
【Java】Spring循环依赖:原因与解决方法
【Java】Spring循环依赖:原因与解决方法
39 0
|
1月前
|
Java Spring 容器
【Spring源码】单例创建期间进行同步可能会导致死锁?
通过这个标题我们就可以思考本次的阅读线索了,看起来可以学到不少东西。1. 旧代码的死锁是怎么产生的。2. 贡献者通过改变什么来解决本次PR的问题呢?而阅读线索2的答案也显而易见,就是上文提到的通过后台线程来创建Micrometer单例...
42 3
|
Java 关系型数据库 MySQL
06_spring_ 依赖注入| 学习笔记
快速学习 06_spring_ 依赖注入