堂妹让我聊:Spring循环依赖

时间:2022-03-05 06:36:18

堂妹让我聊:Spring循环依赖

在跟学弟学妹们聊完Spring IOC之后,有学弟反馈他们面试经常会遇到面试官询问Spring 里面的循环依赖问题。

而作为面试者的他们来说就只能答出用三层缓存处理,而不清楚为什么是三层缓存。基于以上问题还是再跟学弟学妹们分析一下Spring中的循环依赖问题。

什么是循环依赖?

  • 假设现在有一个对象A里面有一个属性Class B,同样的Class B对象中有一个Class A 的对象属性,那么这两个对象能相互创建成功吗?

堂妹让我聊:Spring循环依赖

可能一般的普通代码来说肯定是可以实现:

  1. A a = new A() 
  2. B b = new B() 
  3. a.setB(b) 
  4. b.setA (a) 

看过之前讲的IOC的同学应该知道Spring官方是推荐使用构造器注入的,所以如果是通过构造器注入那就会产生一个无限循环注入的问题了,如下图所示,永远出来不?

  1. A a = new A( new B( new A(new B(......)))) 

所以面试过程中的循环依赖问题其实都是问Setter方式内部如何解决循环依赖的?而不是问的构造器。

比较初级的回答可能会说 是通过三层缓存,再好一点的回加上 三层缓存加上 提前暴露对象的方式(半成品)解决循环依赖问题

那什么是提前暴露对象呢?说白了就是spring IOC 容器的启动过程 bean 的整个生命周期过程处理的逻辑。之前跟大家聊SpringIOC的过程已经跟大家详细分享过了,就不再啰嗦了,还不了解的可以再去复习一下。

这里就直接再画一个流程图,大家针对这个图做一下回归复习:

堂妹让我聊:Spring循环依赖

上面的这张图其实就是给大家说明了我们创建对象的时候可以分为两个大步骤,一个实例化,一个初始化。

同样的现在接着回到上面的问题,Setter是在哪一步处理缓存依赖的呢?

回顾整个流程我们大致可以按照这个思路来:

一个对象的创建 -> 实例化 -> 初始化(设置属性值)

那构造器的那种方式在流程中怎么体现出这个环呢?给大家画了一个图如下:

堂妹让我聊:Spring循环依赖

  • springIOC容器中的bean默认都是单例的,这个大家应该清楚的。所以在设置属性的时候可以直接在容器中获取,按照上面的创建流程那整个循环依赖就产生了。
  • 三层缓存依赖,其实就是先把实例化的对象,放置在缓存中,等后续在根据A对象的引用完成赋值操作。

处理完的流程就是如下所示了:

堂妹让我聊:Spring循环依赖

在改进的图中其实已经可以发现,环 已经被打开了。整个可以如下几步:

在实例化A对象之后就向容器中添加一个缓存,存放一个实例化但未初始化完成的对象(半成品对象)。

在第一次创建A对象中容器已经有一个A对象,但是没有B对象,所以在开始创建B对象时,在完成B对象的实例化之后,开始初始化属性赋值时,此时容器中已经有A对象,所以可以直接通过A的属性赋值,同样的B对象完成初始化之后也就可以再接着完成初始化A对象了,那整个A对象和B对象的创建过程就完成了。

废话不多说了还是直接看下Spring中源码来解析一下:

  1. * @author Juergen Hoeller 
  2. * @since 2.0 
  3. * @see #registerSingleton 
  4. * @see #registerDisposableBean 
  5. * @see org.springframework.beans.factory.DisposableBean 
  6. * @see org.springframework.beans.factory.config.ConfigurableBeanFactory 
  7. */ 
  8. ublic class DefaultSingletonBeanRegistry extends SimpleAliasRegistry implements SingletonBeanRegistry { 
  9.  
  10. /** Cache of singleton objects: bean name to bean instance. */ 
  11. private final Map<String, Object> singletonObjects = new ConcurrentHashMap<>(256); 
  12.  
  13. /** Cache of singleton factories: bean name to ObjectFactory. */ 
  14. private final Map<String, ObjectFactory<?>> singletonFactories = new HashMap<>(16); 
  15.  
  16. /** Cache of early singleton objects: bean name to bean instance. */ 
  17. private final Map<String, Object> earlySingletonObjects = new HashMap<>(16); 
  18.   
  19.  // 省略其他的一些方法。。。 
  • 一级缓存:singletonObjects
  • 二级缓存:earlySingletonObjects
  • 三级缓存:singletonFactories,第三级缓存存放的是ObjectFactory-》FunctionalInterface 即函数式接口

那么Spring中是怎么使用这三级缓存去处理依赖呢?

为了搞明白这个过程只能是debug源码了,因为整个过程比较长,没办法做成动图的形式,所以只能给大家一步一步说明了。

之前跟大家讲SpringIOC中的有个关键方法refresh(),这里面包含了13个核心的子方法,不了解的同学可以去复习一下前面讲的SpringIOC启动过程。

在13个子方法中有一个finishBeanFactoryInitialization(beanFactory) ;初始化剩下的单实例(非懒加载的)方法。这个就是开始入口了。

  1. public void refresh() throws BeansException, IllegalStateException { 
  2.    //   添加一个synchronized 防止出现refresh还没有完成出现其他的操作(启动,或者销毁)  
  3.    synchronized (this.startupShutdownMonitor) { 
  4.       // 1.准备工作 
  5.       // 记录下容器的启动时间、 
  6.       // 标记“已启动”状态,关闭状态为false、 
  7.       // 加载当前系统属性到环境对象中 
  8.       // 准备一系列监听器以及事件集合对象 
  9.        prepareRefresh(); 
  10.  
  11.       // 2. 创建容器对象:DefaultListableBeanFactory,加载XML配置文件的属性到当前的工厂中(默认用命名空间来解析),就是上面说的BeanDefinition(bean的定义信息)这里还没有初始化,只是配置信息都提取出来了,(包含里面的value值其实都只是占位符) 
  12.       ConfigurableListableBeanFactory beanFactory = obtainFreshBeanFactory(); 
  13.  
  14.       // 3. BeanFactory的准备工作,设置BeanFactory的类加载器,添加几个BeanPostProcessor,手动注册几个特殊的bean等 
  15.       prepareBeanFactory(beanFactory); 
  16.       try { 
  17.          // 4.子类的覆盖方法做额外的处理,就是我们刚开始说的 BeanFactoryPostProcessor ,具体的子类可以在这步的时候添加一些特殊的BeanFactoryPostProcessor完成对beanFactory修改或者扩展。 
  18.          // 到这里的时候,所有的Bean都加载、注册完成了,但是都还没有初始化 
  19.          postProcessBeanFactory(beanFactory); 
  20.          // 5.调用 BeanFactoryPostProcessor 各个实现类的 postProcessBeanFactory(factory) 方法 
  21.          invokeBeanFactoryPostProcessors(beanFactory); 
  22.  
  23.          // 6.注册 BeanPostProcessor  处理器 这里只是注册功能,真正的调用的是getBean方法 
  24.         registerBeanPostProcessors(beanFactory); 
  25.  
  26.          // 7.初始化当前 ApplicationContext 的 MessageSource,即国际化处理 
  27.          initMessageSource(); 
  28.  
  29.          // 8.初始化当前 ApplicationContext 的事件广播器, 
  30.          initApplicationEventMulticaster(); 
  31.  
  32.          // 9.从方法名就可以知道,典型的模板方法(钩子方法),感兴趣的同学还可以再去复习一下之前写的设计模式中的-模版方法模式 
  33.          //  具体的子类可以在这里初始化一些特殊的Bean(在初始化 singleton beans 之前) 
  34.          onRefresh(); 
  35.  
  36.          // 10.注册事件监听器,监听器需要实现 ApplicationListener 接口。这也不是我们的重点,过 
  37.          registerListeners(); 
  38.  
  39.          // 11.初始化所有的 singleton beans(lazy-init 的除外),重点关注 
  40.          finishBeanFactoryInitialization(beanFactory); 
  41.  
  42.          // 12.广播事件,ApplicationContext 初始化完成 
  43.          finishRefresh(); 
  44.       } 
  45.       catch (BeansException ex) { 
  46.          if (logger.isWarnEnabled()) { 
  47.             logger.warn("Exception encountered during context initialization - " + 
  48.                   "cancelling refresh attempt: " + ex); 
  49.          } 
  50.          // 13.销毁已经初始化的 singleton 的 Beans,以免有些 bean 会一直占用资源 
  51.          destroyBeans(); 
  52.          cancelRefresh(ex); 
  53.          // 把异常往外抛 
  54.          throw ex; 
  55.       } 
  56.       finally { 
  57.          // Reset common introspection caches in Spring's core, since we 
  58.          // might not ever need metadata for singleton beans anymore... 
  59.          resetCommonCaches(); 
  60.       } 
  61.    } 

1.因为IOC作为Spring的容器,且默认的都是单例的,所以在我们创建bean之前都会去getBean一把,判断当前是否有,当没有时才会去创建。

所以进入finishBeanFactoryInitialization方法中找到 beanFactory.preInstantiateSingletons();

  1. protected void finishBeanFactoryInitialization(ConfigurableListableBeanFactory beanFactory) { 
  2.  // 省略其他干扰代码(判断逻辑)。。。 
  3.    
  4.  
  5.  // Instantiate all remaining (non-lazy-init) singletons. 
  6.    // 实例化剩下的所有的单例对象(非懒加载的) 
  7.  beanFactory.preInstantiateSingletons(); 

进入到 preInstantiateSingletons 方法中,可以看到通过beanDefinitionNames(bean的定义信息)来判断当前需要创建的bean信息,所以开始通过beanName循环开始走创建流程。

因为是我们创建的普通的bean实例,所以肯定会走到最下面的getBean(beanName);方法中,如下代码所示:

  1. @Override 
  2. public void preInstantiateSingletons() throws BeansException { 
  3.  if (logger.isTraceEnabled()) { 
  4.   logger.trace("Pre-instantiating singletons in " + this); 
  5.  } 
  6.  
  7.  // Iterate over a copy to allow for init methods which in turn register new bean definitions. 
  8.  // While this may not be part of the regular factory bootstrap, it does otherwise work fine. 
  9.  List<String> beanNames = new ArrayList<>(this.beanDefinitionNames); 
  10.  
  11.  // Trigger initialization of all non-lazy singleton beans... 
  12.  for (String beanName : beanNames) { 
  13.   RootBeanDefinition bd = getMergedLocalBeanDefinition(beanName); 
  14.   if (!bd.isAbstract() && bd.isSingleton() && !bd.isLazyInit()) { 
  15.        // 判断是否是工厂bean 
  16.    if (isFactoryBean(beanName)) { 
  17.     Object bean = getBean(FACTORY_BEAN_PREFIX + beanName); 
  18.     if (bean instanceof FactoryBean) { 
  19.      final FactoryBean<?> factory = (FactoryBean<?>) bean; 
  20.      boolean isEagerInit; 
  21.      if (System.getSecurityManager() != null && factory instanceof SmartFactoryBean) { 
  22.       isEagerInit = AccessController.doPrivileged((PrivilegedAction<Boolean>) 
  23.           ((SmartFactoryBean<?>) factory)::isEagerInit, 
  24.         getAccessControlContext()); 
  25.      } 
  26.      else { 
  27.       isEagerInit = (factory instanceof SmartFactoryBean && 
  28.         ((SmartFactoryBean<?>) factory).isEagerInit()); 
  29.      } 
  30.      if (isEagerInit) { 
  31.       getBean(beanName); 
  32.      } 
  33.     } 
  34.    } 
  35.    else { 
  36.          // 如果当前beanName对应的bean不是工厂bean,则通过beanName来获取bean的实例 
  37.     getBean(beanName); 
  38.    } 
  39.   } 
  40.  } 
  41.  } 

进入到这个getBean(beanName);方法中有一个doGetBean方法,在Spring源码中真正开始干活做事情的都一定会打上do的前缀方法。

  1. @Override 
  2. public Object getBean(String name) throws BeansException { 
  3.    // 实际获取bean的方法,触发依赖注入方法 
  4.  return doGetBean(namenullnullfalse); 

所以在进到doGetBean的方法中,还是会默认先去获取一把,没有则开始创建进入createBean(beanName, mbd, args)方法。

  1. protected <T> T doGetBean(final String name, @Nullable final Class<T> requiredType, 
  2.   @Nullable final Object[] args, boolean typeCheckOnly) throws BeansException { 
  3.  
  4.  final String beanName = transformedBeanName(name); 
  5.  Object bean; 
  6.  
  7.  // Eagerly check singleton cache for manually registered singletons. 
  8.    // 确认一下容器中是否已经有了当前bean实例 
  9.  Object sharedInstance = getSingleton(beanName); 
  10.  if (sharedInstance != null && args == null) { 
  11.   if (logger.isTraceEnabled()) { 
  12.    if (isSingletonCurrentlyInCreation(beanName)) { 
  13.     logger.trace("Returning eagerly cached instance of singleton bean '" + beanName + 
  14.       "' that is not fully initialized yet - a consequence of a circular reference"); 
  15.    } 
  16.    else { 
  17.     logger.trace("Returning cached instance of singleton bean '" + beanName + "'"); 
  18.    } 
  19.   } 
  20.   bean = getObjectForBeanInstance(sharedInstance, name, beanName, null); 
  21.  } 
  22.     
  23.  // 省略其他逻辑代码。。。 
  24.  
  25.    // Create bean instance. 
  26.      // 创建Bean的实例对象 
  27.    if (mbd.isSingleton()) { 
  28.          // 返回以beanName的单例对象,如果没有注册,则使用singletonFactory创建并且注册一个。 
  29.     sharedInstance = getSingleton(beanName, () -> { 
  30.      try { 
  31.              // 为给定的BeanDefinition(和参数)创建一个Bean的实例 重点 
  32.       return createBean(beanName, mbd, args); 
  33.      } 
  34.      catch (BeansException ex) { 
  35.       // Explicitly remove instance from singleton cache: It might have been put there 
  36.       // eagerly by the creation process, to allow for circular reference resolution. 
  37.       // Also remove any beans that received a temporary reference to the bean. 
  38.       destroySingleton(beanName); 
  39.       throw ex; 
  40.      } 
  41.     }); 
  42.     bean = getObjectForBeanInstance(sharedInstance, name, beanName, mbd); 
  43.    } 
  44.         
  45.   // 省略其他逻辑代码。。。 
  46.  return (T) bean; 

在上面没有获取到bean时候则开始创建bean了,所以直接进到createBean的方法中,因为是容器初始化启动所以肯定是没有的,顾一定会进入createBean的方法中,所以再进入createBean的方法中。

  1. @Override 
  2.  protected Object createBean(String beanName, RootBeanDefinition mbd, @Nullable Object[] args) 
  3.    throws BeanCreationException { 
  4.   // 省略其他相关代码。。。。。 
  5.  
  6.   try { 
  7.       // 实际创建Bean的调用 重点 
  8.    Object beanInstance = doCreateBean(beanName, mbdToUse, args); 
  9.    if (logger.isTraceEnabled()) { 
  10.     logger.trace("Finished creating instance of bean '" + beanName + "'"); 
  11.    } 
  12.    return beanInstance; 
  13.   } 
  14.   catch (BeanCreationException | ImplicitlyAppearedSingletonException ex) { 
  15.    // A previously detected exception with proper bean creation context already, 
  16.    // or illegal singleton state to be communicated up to DefaultSingletonBeanRegistry. 
  17.    throw ex; 
  18.   } 
  19.   catch (Throwable ex) { 
  20.    throw new BeanCreationException( 
  21.      mbdToUse.getResourceDescription(), beanName, "Unexpected exception during bean creation", ex); 
  22.   } 
  23.  } 

看到doCreateBean方法那说明要开始真正的创建Bean了。

  1. protected Object doCreateBean(final String beanName, final RootBeanDefinition mbd, final @Nullable Object[] args) 
  2.   throws BeanCreationException { 
  3.  
  4.  // Instantiate the bean. 
  5.  BeanWrapper instanceWrapper = null
  6.  if (mbd.isSingleton()) { 
  7.      // 判断如果是单例对象,则从factoryBean实例缓存汇总移除当前Bean的定义信息 
  8.   instanceWrapper = this.factoryBeanInstanceCache.remove(beanName); 
  9.  } 
  10.  if (instanceWrapper == null) { 
  11.      // 根据执行的bean使用的对应的策略创建新的实例。也可以理解实例化对象,在内存总开辟空间 
  12.   instanceWrapper = createBeanInstance(beanName, mbd, args); 
  13.  } 
  14.  final Object bean = instanceWrapper.getWrappedInstance(); 
  15.  Class<?> beanType = instanceWrapper.getWrappedClass(); 
  16.  if (beanType != NullBean.class) { 
  17.   mbd.resolvedTargetType = beanType; 
  18.  } 
  19.  
  20.  // 省略其他的相关代码。。。。。 
  21.     
  22.    // Eagerly cache singletons to be able to resolve circular references 
  23.  // even when triggered by lifecycle interfaces like BeanFactoryAware. 
  24.    // 判断当前bean是否需要提前曝光,单例&允许循环依赖&当前bean正在创建,检测循环依赖 
  25.     boolean earlySingletonExposure = (mbd.isSingleton() && this.allowCircularReferences && 
  26.    isSingletonCurrentlyInCreation(beanName)); 
  27.  if (earlySingletonExposure) { 
  28.   if (logger.isTraceEnabled()) { 
  29.    logger.trace("Eagerly caching bean '" + beanName + 
  30.      "' to allow for resolving potential circular references"); 
  31.   } 
  32.      // 在bean的初始化完成之前将创建的实例加入ObjectFactory(添加三级缓存),主要是为了防止后期的循环依赖。。。。重点 
  33.   addSingletonFactory(beanName, () -> getEarlyBeanReference(beanName, mbd, bean)); 
  34.  } 
  35.     
  36.    Object exposedObject = bean; 
  37.  try { 
  38.      // 填充bean属性,假设其中存在依赖于其他的bean的属性,则会递归初始化依赖的bean 
  39.   populateBean(beanName, mbd, instanceWrapper); 
  40.      //执行初始化逻辑 
  41.   exposedObject = initializeBean(beanName, exposedObject, mbd); 
  42.  } 
  43.  catch (Throwable ex) { 
  44.   if (ex instanceof BeanCreationException && beanName.equals(((BeanCreationException) ex).getBeanName())) { 
  45.    throw (BeanCreationException) ex; 
  46.   } 
  47.   else { 
  48.    throw new BeanCreationException( 
  49.      mbd.getResourceDescription(), beanName, "Initialization of bean failed", ex); 
  50.   } 
  51.  } 
  52.     
  53.  return exposedObject; 

进入到doCreateBean中首先需要核心看的一个方法createBeanInstance,这个方法就是真正的创建bean实例例,也就是在内存中开辟空间(实例化),完事之后就开始看第二个重点添加缓存。

  • addSingletonFactory(beanName, () -> getEarlyBeanReference(beanName, mbd, bean));
  • 这个方法点进去,其实就是能发现开始添加到第三级缓存中,value值就是一个函数方法getEarlyBeanReference,不熟悉的同学可以看下JDK1.8的新特性。同时也标注了当前bean正在注册中。

实例化完bean按照bean的生命周期流程那肯定就是开始初始化bean了,填充属性,接着向下看有一个populateBean(填充bean属性)。

  1. populateBean(beanName, mbd, instanceWrapper); 

在populateBean这个过程中就有很大的逻辑在里面了,比如说获取属性名称,属性值等等一系列操作。但是核心的还是需要看applyPropertyValues方法属性赋值,如下所示:

  1. protected void populateBean(String beanName, RootBeanDefinition mbd, @Nullable BeanWrapper bw) { 
  2.   // 省略一堆其他判断校验逻辑代码,直接看到最后。。。 
  3.   if (pvs != null) { 
  4.       // 应用给定的属性值,解决任何在这个bean工厂运行时其他的bean的调用(就是设置属性值) 
  5.    applyPropertyValues(beanName, mbd, bw, pvs); 
  6.   } 
  7.  } 

同样的进入applyPropertyValues方法。

 

  1. protected void applyPropertyValues(String beanName, BeanDefinition mbd, BeanWrapper bw, PropertyValues pvs) { 
  2.   // 省略其他的一些校验代码。。。。。 
  3.  
  4.  // Create a deep copy, resolving any references for values
  5.  List<PropertyValue> deepCopy = new ArrayList<>(original.size()); 
  6.  boolean resolveNecessary = false
  7.    // 便利属性,将属性转换为对应类的对应属性类型 
  8.  for (PropertyValue pv : original) { 
  9.      // 判断当前属性是否已经解析过 
  10.   if (pv.isConverted()) { 
  11.    deepCopy.add(pv); 
  12.   } 
  13.   else { 
  14.        // 获取属性明层 
  15.    String propertyName = pv.getName(); 
  16.        // 获取属性值 
  17.    Object originalValue = pv.getValue(); 
  18.        // valueResolver处理pv解析出的originalValue封装的对象(是否必要开始去处理属性值了)重点 
  19.    Object resolvedValue = valueResolver.resolveValueIfNecessary(pv, originalValue); 
  20.    // 默认转换后的值等于解析出来的值    
  21.        Object convertedValue = resolvedValue; 
  22.        // 判断转换标记  
  23.    boolean convertible = bw.isWritableProperty(propertyName) && 
  24.      !PropertyAccessorUtils.isNestedOrIndexedProperty(propertyName); 
  25.    if (convertible) { 
  26.     convertedValue = convertForProperty(resolvedValue, propertyName, bw, converter); 
  27.    } 
  28.    // 省略其他的代码逻辑。。。。 

applyPropertyValues方法中需要注意的是valueResolver.resolveValueIfNecessary值处理器。

  • Object resolvedValue = valueResolver.resolveValueIfNecessary(pv, originalValue);

这一步主要是判断属性值是否需要处理,因为之前这个value值是存方法接口方法

堂妹让我聊:Spring循环依赖

所以在执行valueResolver.resolveValueIfNecessary方法时,一定会去处理,那再看看里面又处理什么逻辑?

  1. public Object resolveValueIfNecessary(Object argName, @Nullable Object value) { 
  2.   // We must check each value to see whether it requires a runtime reference 
  3.   // to another bean to be resolved. 
  4.   // 如果value是RuntimeBeanReference实例 则处理 
  5.   if (value instanceof RuntimeBeanReference) { 
  6.    RuntimeBeanReference ref = (RuntimeBeanReference) value; 
  7.       // 解析出对应的ref 所封装的Bean元信息(Bean的名称,Bean的类型) 的对象 
  8.    return resolveReference(argName, ref); 
  9.   } 
  10.      // 省略其他的逻辑代码 
  11.   } 

面的断点的截图已经可以明确的看到value值是RuntimeBeanReference实例,所以接下来就一定会去调用resolveReference方法解析ref所封装的bean信息,那就再接着进入resolveReference方法看看干了什么?

  1. @Nullable 
  2. private Object resolveReference(Object argName, RuntimeBeanReference ref) { 
  3.  try { 
  4.   Object bean; 
  5.   String refName = ref.getBeanName(); 
  6.   refName = String.valueOf(doEvaluate(refName)); 
  7.   if (ref.isToParent()) { 
  8.    if (this.beanFactory.getParentBeanFactory() == null) { 
  9.     throw new BeanCreationException( 
  10.       this.beanDefinition.getResourceDescription(), this.beanName, 
  11.       "Can't resolve reference to bean '" + refName + 
  12.       "' in parent factory: no parent factory available"); 
  13.    } 
  14.    bean = this.beanFactory.getParentBeanFactory().getBean(refName); 
  15.   } 
  16.   else { 
  17.        // 获取resolvedName的Bean对象 重点 
  18.    bean = this.beanFactory.getBean(refName); 
  19.        // 注册beanName到dependentBeanName的依赖关系到Bean的工中 
  20.    this.beanFactory.registerDependentBean(refName, this.beanName); 
  21.   } 
  22.   if (bean instanceof NullBean) { 
  23.    bean = null
  24.   } 
  25.      // 返回解析出来的对用的ref所封装的Bean对象 
  26.   return bean; 
  27.  } 
  28.  catch (BeansException ex) { 
  29.   throw new BeanCreationException( 
  30.     this.beanDefinition.getResourceDescription(), this.beanName, 
  31.     "Cannot resolve reference to bean '" + ref.getBeanName() + "' while setting " + argName, ex); 
  32.  } 

上面已经进入到resolveReference来处理ref中所以引用的Bean对象,又因为SpringIOC默认都是单例Bean,所以肯定还是在beanFactory中去获取Bean。

  • bean = this.beanFactory.getBean(refName);

至此又开始循环创建循环依赖的对象,假设还是一开始的A和B两个对象来说,那么开始是创建A对象时,在设置B属性的时候,没有B属性,那么现在刚好就是开始创建B属性了。同样的B对象又开始填充属性A。

细心的同学应发现问题了,这不就是无限循环了吗?还怎么处理循环啊?这不是扯淡吗?

其实不是的,其实创建B对象想的时候,去获取A的Bean信息时,因为A还是在创建中,所以在接下来中从新走流程中会有一个新的发现,进入缓存中获取对象,如下:

  1. bean = this.beanFactory.getBean(refName) ->  doGetBean(namenullnullfalse) -> sharedInstance = getSingleton(beanName) -> getSingleton(beanName, true)  
  2.    // 具体点 getSingleton 方法的内部实现 
  3.    // 进入getSingleton方法中 isSingletonCurrentlyInCreation 当前的Bean正在创建中 
  4.    protected Object getSingleton(String beanName, boolean allowEarlyReference) { 
  5.    // 从一级缓存获取BeanName对应的单例对象 
  6.   Object singletonObject = this.singletonObjects.get(beanName); 
  7.    // 如果没有获取到,但是当前 BeanName对应的单例对象又处于创建中 
  8.   if (singletonObject == null && isSingletonCurrentlyInCreation(beanName)) { 
  9.    synchronized (this.singletonObjects) { 
  10.         // 从二级缓存中获取当前BeanName对应的单例对象 
  11.     singletonObject = this.earlySingletonObjects.get(beanName); 
  12.         // 二级缓存中没有,但是allowEarlyReference为true,在doCreateBean方法中已经设置,所以这里为true 
  13.     if (singletonObject == null && allowEarlyReference) { 
  14.           // 从三级缓存中获取 
  15.      ObjectFactory<?> singletonFactory = this.singletonFactories.get(beanName); 
  16.      if (singletonFactory != null) { 
  17.             // 这里就是三级缓存函数方法,同过Factory创建一个单例对象 
  18.       singletonObject = singletonFactory.getObject(); 
  19.             // 添加到二级缓存中,半成品对象 
  20.       this.earlySingletonObjects.put(beanName, singletonObject); 
  21.             // 同时删除三级缓存 
  22.       this.singletonFactories.remove(beanName); 
  23.      } 
  24.     } 
  25.    } 
  26.   } 
  27.    // 返回当前半成品对象 
  28.   return singletonObject; 
  29.  } 

现在整个流程中二级缓存已经存放了一个半成品A的对象,因此在创建B对象时,获取A属性填充值从容器缓存中已经可以获取到A对象的单例Bean,对B对象来说其实就是一个完整的单例Bean实例,因此再次getSingleton Bean时候会有一个判断,如果有一个新的完成的单例Bean则会添加到一级缓存中,源码如下:

  1. public Object getSingleton(String beanName, ObjectFactory<?> singletonFactory) { 
  2.  Assert.notNull(beanName, "Bean name must not be null"); 
  3.  synchronized (this.singletonObjects) { 
  4.   Object singletonObject = this.singletonObjects.get(beanName); 
  5.   if (singletonObject == null) { 
  6.    if (this.singletonsCurrentlyInDestruction) { 
  7.     throw new BeanCreationNotAllowedException(beanName, 
  8.       "Singleton bean creation not allowed while singletons of this factory are in destruction " + 
  9.       "(Do not request a bean from a BeanFactory in a destroy method implementation!)"); 
  10.    } 
  11.    if (logger.isDebugEnabled()) { 
  12.     logger.debug("Creating shared instance of singleton bean '" + beanName + "'"); 
  13.    } 
  14.    beforeSingletonCreation(beanName); 
  15.    boolean newSingleton = false
  16.    boolean recordSuppressedExceptions = (this.suppressedExceptions == null); 
  17.    if (recordSuppressedExceptions) { 
  18.     this.suppressedExceptions = new LinkedHashSet<>(); 
  19.    } 
  20.    try { 
  21.     singletonObject = singletonFactory.getObject(); 
  22.     newSingleton = true
  23.    } 
  24.        // 省略其他的代码逻辑 
  25.         
  26.    //判断生成了新的单例对象 
  27.    if (newSingleton) { 
  28.          // 将添加BeanName和 singletonObject 添加到一级缓存中去 
  29.     addSingleton(beanName, singletonObject); 
  30.    } 
  31.   } 
  32.   return singletonObject; 
  33.  } 

上面聊到当新的单例对象生成会再调用addSingleton方法。

  1. protected void addSingleton(String beanName, Object singletonObject) { 
  2.  synchronized (this.singletonObjects) { 
  3.      // 添加到一级缓存中 
  4.   this.singletonObjects.put(beanName, singletonObject); 
  5.      // 移除二级缓存中的内容 
  6.   this.singletonFactories.remove(beanName); 
  7.      // 移除三级缓存中的内容 
  8.   this.earlySingletonObjects.remove(beanName); 
  9.      // 将完成的BeanName添加到已经注册的单例集合中 
  10.   this.registeredSingletons.add(beanName); 
  11.  } 

自此整个Spring的循环依赖过程就已经结束了。

还是用开始的A,B两个对象来总结一个流程吧

  • 当开始创建A对象时,实例化后,添加一步三级缓存,针对属性赋值,因为此时还没有B对象的实例,所以在获取到A对象的B属性的值的ref引用对象B,触发创建B对象的创建,因此在B对象实例化后,在属性赋值时,获取到A属性的ref引用对象,而因为之前A对象已经完成实例化,并且添加到了三级缓存中,所以在B属性创建设置A属性时,因为此时A属性正在被创建,所以可以从第三级缓存中获取到值,同时把获取到的值添加到二级缓存中,同时删除第三级缓存的A对象。
  • 在创建B对象中已经能获取到A属性值(半成品),所以B对象可以完成赋值状态,变成一个完整的B对象的实例。所以当新的单例对象生成会再调用addSingleton方法添加到一级缓存中,同时删除 二级 三级缓存的值,所以回过头来接着 A对象获取B属性值的时候已经能在一级缓存中获取到。所以也就可以完成属性赋值,自此循环依赖完全打开。

循环依赖问题已经跟大家聊完了,在看源码的过程中大家一定要注意以下的6个方法:

堂妹让我聊:Spring循环依赖

这六个方法是核心处理流程,按照这个流程,以及我上面执行的步骤一步一步断点多走几遍就能加深自己的理解了。

不要问我为啥知道这么多都是熬夜学习找资料肝出来的!!!

总结

还是之前的老步骤聊完之后跟大家介绍几个比较常见的面试题来加深一个理解,也方便学弟学妹们面试。

一级二级 三级缓存中分别存放的是什么状态的对象?

完整的看完这个文章的同学应该是没啥问题吧

  • 一级:完整的成品的对象
  • 二级:非完整的半成品对象
  • 三级:lambada表达式

假设只设计二级缓存能否解决循环依赖?

  • 只用二级缓存是可以解决缓存依赖的,(废弃第三级,保留第一第二)但是会有一个问题,在配置AOP切面的时候会出错,因为无法生成代理对象。
  • 所以三级缓存是为了处理AOP中的循环依赖。因为当配置了切面之后,在getEarlyBeanReference方法中,有可能会把之前的原始对象替换成代理对象,导致Bean的版本不是最终的版本,所以报错。

我是敖丙,你知道的越多,你不知道的越多,下期见。

原文链接:https://mp.weixin.qq.com/s/u29hMRkfTj_1RHNSukDtEw