zoukankan      html  css  js  c++  java
  • Spring之循环依赖与解决方案

    GitHub:https://github.com/JDawnF/learning_note

    目录

    1. 什么是循环依赖

    2. 解决循环依赖

    2.1 getSingleton

    2.2 addSingletonFactory(二级缓存出处)

    2.3 addSingleton(一级缓存出处)

    3. 小结


    1. 什么是循环依赖

    循环依赖,其实就是循环引用,就是两个或者两个以上的 bean 互相引用对方,最终形成一个闭环,如 A 依赖 B,B 依赖 C,C 依赖 A。如下图所示:

    循环依赖,其实就是一个死循环的过程,在初始化 A 的时候发现引用了 B,这时就会去初始化 B,然后又发现 B 引用 C,跑去初始化 C,初始化 C 的时候发现引用了 A,则又会去初始化 A,依次循环永不退出,除非有终结条件

    Spring 循环依赖的场景有两种:

    1. 构造器的循环依赖。

      @Service
       public class A {  
           public A(B b) {  }
       }
       ​
       @Service
       public class B {  
           public B(C c) {  
           }
       }
       ​
       @Service
       public class C {  
           public C(A a) {  }
       }
      

      结果:项目启动失败,发现了一个cycle

    2. field 属性的循环依赖。

      1. scope为单例的时候:

        @Service
         public class A1 {  
             @Autowired  
             private B1 b1;
         }
         ​
         @Service
         public class B1 {  
             @Autowired  
             public C1 c1;
         }
         ​
         @Service
         public class C1 {  
             @Autowired  public A1 a1;
         }

        结果:项目启动成功

      2. scope为prototype的时候

        @Service
         @Scope("prototype")
         public class A1 {  
             @Autowired  
             private B1 b1;
         }
         ​
         @Service
         @Scope("prototype")
         public class B1 {  
             @Autowired  
             public C1 c1;
         }
         ​
         @Service
         @Scope("prototype")
         public class C1 {  
             @Autowired  public A1 a1;
         }

        结果:项目启动失败,发现了一个cycle

    对于构造器的循环依赖,Spring 是无法解决的,只能抛出 BeanCurrentlyInCreationException 异常表示循环依赖,所以下面我们分析的都是基于 field 属性的循环依赖。

    Spring 只解决 scope 为 singleton 的循环依赖。对于scope 为 prototype 的 bean ,Spring 无法解决,直接抛出 BeanCurrentlyInCreationException 异常。

    为什么 Spring 不处理 prototype bean 呢?其实如果理解 Spring 是如何解决 singleton bean 的循环依赖就明白了。这里先卖一个关子,我们先来关注 Spring 是如何解决 singleton bean 的循环依赖的。

    2. 解决循环依赖

    2.1 getSingleton

    我们先从加载 bean 最初始的方法 AbstractBeanFactorydoGetBean(final String name, final Class<T> requiredType, final Object[] args, boolean typeCheckOnly) 方法开始。

    doGetBean(...) 方法中,首先会根据 beanName 从单例 bean 缓存中获取,如果不为空则直接返回。代码如下:

    // AbstractBeanFactory.java
     ​
     Object sharedInstance = getSingleton(beanName);
    • 调用 getSingleton(String beanName, boolean allowEarlyReference) 方法,从单例缓存中获取。代码如下:

       
      // DefaultSingletonBeanRegistry.java
       @Nullable
       protected Object getSingleton(String beanName, boolean allowEarlyReference) {
           // 从单例缓冲中加载 bean
           Object singletonObject = this.singletonObjects.get(beanName);
           // 缓存中的 bean 为空,且当前 bean 正在创建
           if (singletonObject == null && isSingletonCurrentlyInCreation(beanName)) {
               // 加锁
               synchronized (this.singletonObjects) {
                   // 从 earlySingletonObjects 获取
                   singletonObject = this.earlySingletonObjects.get(beanName);
                   // earlySingletonObjects 中没有,且允许提前创建
                   if (singletonObject == null && allowEarlyReference) {
                       // 从 singletonFactories 中获取对应的 ObjectFactory
                       ObjectFactory<?> singletonFactory = this.singletonFactories.get(beanName);
                       if (singletonFactory != null) {
                           // 获得 bean
                           singletonObject = singletonFactory.getObject();
                           // 添加 bean 到 earlySingletonObjects 中
                           this.earlySingletonObjects.put(beanName, singletonObject);
                           // 从 singletonFactories 中移除对应的 ObjectFactory
                           this.singletonFactories.remove(beanName);
                       }
                   }
               }
           }
           return singletonObject;
       }
      • 这个方法主要是从三个缓存中获取,分别是:singletonObjectsearlySingletonObjectssingletonFactories 。三者定义如下: 

        // DefaultSingletonBeanRegistry.java
         /**
          * Cache of singleton objects: bean name to bean instance.
          * 一级缓存,保存所有的singletonBean的实例
          * 存放的是单例 bean 的映射。
          * 对应关系为 bean name --> bean instance
          */
         private final Map<String, Object> singletonObjects = new ConcurrentHashMap<>(256);
         ​
         /**
          * Cache of singleton factories: bean name to ObjectFactory.
          * 三级缓存,singletonBean的生产工厂
          * 存放的是【早期】的单例 bean 的映射。
          * 对应关系也是 bean name --> bean instance。
          *
          * 它与 {@link singletonObjects} 的区别区别在,于 earlySingletonObjects 中存放的 bean 不一定是完整的。
          *
          * 从 {@link getSingleton(String)} 方法中,中我们可以了解,bean 在创建过程中就已经加入到 earlySingletonObjects 中了,
          * 所以当在 bean 的创建过程中就可以通过 getBean() 方法获取。
          * 这个 Map 也是解决【循环依赖】的关键所在。
          **/
         private final Map<String, ObjectFactory<?>> singletonFactories = new HashMap<>(16);
         ​
         /**
          * Cache of early singleton objects: bean name to bean instance.
          * 二级缓存,保存所有早期创建的Bean对象,这个Bean还没有完成依赖注入 
          * 存放的是 ObjectFactory 的映射,可以理解为创建单例 bean 的 factory 。
          * 对应关系是 bean name --> ObjectFactory
          */
         private final Map<String, Object> earlySingletonObjects = new HashMap<>(16);
        • singletonObjects :单例对象的 Cache 。

        • singletonFactories : 单例对象工厂的 Cache 。

        • earlySingletonObjects提前曝光的单例对象的 Cache 。

    它们三,就是 Spring 解决 singleton bean 的关键因素所在,我称他们为三级缓存

    • 第一级为 singletonObjects

    • 第二级为 earlySingletonObjects

    • 第三级为 singletonFactories

    这里,我们已经通过 getSingleton(String beanName, boolean allowEarlyReference) 方法,看到他们是如何配合的。详细分析该方法之前,提下其中的 isSingletonCurrentlyInCreation(String beanName) 方法和 allowEarlyReference变量:

    • isSingletonCurrentlyInCreation(String beanName) 方法:判断当前 singleton bean 是否处于创建中。bean 处于创建中,也就是说 bean 在初始化但是没有完成初始化,有一个这样的过程其实和 Spring 解决 bean 循环依赖的理念相辅相成。因为 Spring 解决 singleton bean 的核心就在于提前曝光 bean

    • allowEarlyReference 变量:从字面意思上面理解就是允许提前拿到引用。其实真正的意思是,是否允许从 singletonFactories 缓存中通过 getObject() 方法,拿到对象。因为 singletonFactories 才是 Spring 解决 singleton bean 的诀窍所在

    getSingleton(String beanName, boolean allowEarlyReference) 方法,整个过程如下:

    • 首先,从一级缓存 singletonObjects 获取。

    • 如果,没有且当前指定的 beanName 正在创建,就再从二级缓存 earlySingletonObjects 中获取。

    • 如果,还是没有获取到且允许 singletonFactories 通过 getObject() 获取,则从三级缓存 singletonFactories 获取。如果获取到,则通过其 getObject() 方法,获取对象,并将其加入到二级缓存 earlySingletonObjects 中,并从三级缓存 singletonFactories 删除。代码如下:

       // DefaultSingletonBeanRegistry.java
       ​
       singletonObject = singletonFactory.getObject();
       this.earlySingletonObjects.put(beanName, singletonObject);
       this.singletonFactories.remove(beanName);
      • 这样,就从三级缓存升级到二级缓存了。

      • 所以,二级缓存存在的意义,就是缓存三级缓存中的 ObjectFactory 的 getObject() 方法的执行结果,提早曝光的单例 Bean 对象。

    2.2 addSingletonFactory(二级缓存出处)

    上面是从缓存中获取,但是缓存中的数据从哪里添加进来的呢?一直往下跟会发现在 AbstractAutowireCapableBeanFactory 的 doCreateBean(final String beanName, final RootBeanDefinition mbd, final Object[] args) 方法中,有这么一段代码:

    // AbstractAutowireCapableBeanFactory.java
     ​
     boolean earlySingletonExposure = (mbd.isSingleton() // 单例模式
             && this.allowCircularReferences // 运行循环依赖
             && isSingletonCurrentlyInCreation(beanName)); // 当前单例 bean 是否正在被创建
     if (earlySingletonExposure) {
         if (logger.isTraceEnabled()) {
             logger.trace("Eagerly caching bean '" + beanName +
                     "' to allow for resolving potential circular references");
         }
         // 提前将创建的 bean 实例加入到 singletonFactories 中
         // 这里是为了后期避免循环依赖
         addSingletonFactory(beanName, () -> getEarlyBeanReference(beanName, mbd, bean));
     }
    • 当一个 Bean 满足三个条件时,则调用addSingletonFactory(...)方法,将它添加到缓存中。三个条件如下:

      • 单例

      • 运行提前暴露 bean

      • 当前 bean 正在创建中

    • addSingletonFactory(String beanName, ObjectFactory<?> singletonFactory) 方法,代码如下:

      // DefaultSingletonBeanRegistry.java
       ​
       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);
               }
           }
       }
      • 从这段代码我们可以看出,singletonFactories 这个三级缓存才是解决 Spring Bean 循环依赖的诀窍所在。同时这段代码发生在 createBeanInstance(...) 方法之后,也就是说这个 bean 其实已经被创建出来了,但是它还不是很完美(没有进行属性填充和初始化),但是对于其他依赖它的对象而言已经足够了(可以根据对象引用定位到堆中对象),能够被认出来了。所以 Spring 在这个时候,选择将该对象提前曝光出来让大家认识认识。

    2.3 addSingleton(一级缓存出处)

    介绍到这里我们发现三级缓存 singletonFactories 和 二级缓存 earlySingletonObjects 中的值都有出处了,那一级缓存在哪里设置的呢?在类 DefaultSingletonBeanRegistry 中,可以发现这个 addSingleton(String beanName, Object singletonObject) 方法,代码如下:

    // DefaultSingletonBeanRegistry.java
     ​
     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);
         }
     }
    • 添加至一级缓存,同时从二级、三级缓存中删除。

    • 这个方法在 doGetBean(...) 方法中,处理不同 scope 时,如果是 singleton,则调用 getSingleton(...) 方法,如下图所示:

    • getSingleton(String beanName, ObjectFactory<?> singletonFactory) 方法,代码如下: 

      // AbstractBeanFactory.java
       ​
       public Object getSingleton(String beanName, ObjectFactory<?> singletonFactory) {
           Assert.notNull(beanName, "Bean name must not be null");
           synchronized (this.singletonObjects) {
               Object singletonObject = this.singletonObjects.get(beanName);
               if (singletonObject == null) {
                   //....
                   try {
                       singletonObject = singletonFactory.getObject();
                       newSingleton = true;
                   }
                   //.....
                   if (newSingleton) {
                       addSingleton(beanName, singletonObject);
                   }
               }
               return singletonObject;
           }
       }
      • 注意,此处的 getSingleton(String beanName, ObjectFactory<?> singletonFactory) 方法,在 AbstractBeanFactory 类中实现,和 上面的2.1 getSingleton不同

    3. 小结

     Spring 解决循环依赖的方案主要如下:

    • Spring 在创建 bean 的时候并不是等它完全完成,而是在创建过程中将创建中的 bean 的 ObjectFactory 提前曝光(即加入到 singletonFactories 缓存中)。

    • 这样,一旦下一个 bean 创建的时候需要依赖 bean ,则直接使用 ObjectFactory 的 getObject() 方法来获取了,也就是上面的2.1 getSingleton 小结中的方法中的代码片段了。

    到这里,关于 Spring 解决 bean 循环依赖就已经分析完毕了。最后来描述下就上面那个循环依赖 Spring 解决的过程:

    • 首先 A 完成初始化第一步并将自己提前曝光出来(通过 ObjectFactory 将自己提前曝光),在初始化的时候,发现自己依赖对象 B,此时就会去尝试 get(B),这个时候发现 B 还没有被创建出来

    • 然后 B 就走创建流程,在 B 初始化的时候,同样发现自己依赖 C,C 也没有被创建出来

    • 这个时候 C 又开始初始化进程,但是在初始化的过程中发现自己依赖 A,于是尝试 get(A),这个时候由于 A 已经添加至缓存中(一般都是添加至三级缓存 singletonFactories ),通过 ObjectFactory 提前曝光,所以可以通过 ObjectFactory的getObject() 方法来拿到 A 对象,C 拿到 A 对象后顺利完成初始化,然后将自己添加到一级缓存中

    • 回到 B ,B 也可以拿到 C 对象,完成初始化,A 可以顺利拿到 B 完成初始化。到这里整个链路就已经完成了初始化过程了

    如下是《Spring 源码深度解析》P114 页的一张图,非常有助于理解。

    参照:https://www.jianshu.com/p/8bb67ca11831

  • 相关阅读:
    简单工厂
    Java鲁棒性(健壮性)
    外部类,成员内部类,局部内部类能被哪些修饰符修饰
    Java枚举类的7种常用的方法
    同步,异步,阻塞,非阻塞
    对于面向对象的基本理解
    对于数组的一点理解
    类加载机制-双亲委派机制(三)
    架构- 数据库的优化
    python调用jenkinsapi
  • 原文地址:https://www.cnblogs.com/baichendongyang/p/13235446.html
Copyright © 2011-2022 走看看