SpringIOCDI循环依赖实例详解

/** 记录已将创建的单例 */
  private final Map singletonObjects = new ConcurrentHashMap<>(256);

  /** 记录singletonFactory singeletonFactory中存放beanName和上面的①阶段的bean：Bean实例化实例对象（还未初始化DI）*/
  private final Map> singletonFactories = new HashMap<>(16);

  /** 记录早期的singletonBean 存放的也是① */
  private final Map earlySingletonObjects = new HashMap<>(16);

  /** 存放已经初始化后的beanName，有序 */
  private final Set registeredSingletons = new LinkedHashSet<>(256);

  /** 记录正在初始化的bean的beanName */
  private final Set singletonsCurrentlyInCreation = Collections.newSetFromMap(new ConcurrentHashMap<>(16));

/* org.springframework.beans.factory.support.DefaultSingletonBeanRegistry#getSingleton(java.lang.String, org.springframework.beans.factory.ObjectFactory<?>) */
  public Object getSingleton(String beanName, ObjectFactory<?> singletonFactory) {
    ...
    //循环依赖相关：初始化前先singletonsCurrentlyInCreation.add(beanName)
    beforeSingletonCreation(beanName);
    ...
    //lamda表达式：其实是调用createBean(beanName, mbd, args):Bean初始化
    singletonObject = singletonFactory.getObject();
    ...
    //循环依赖相关：初始化后singletonsCurrentlyInCreation.remove(beanName)
    afterSingletonCreation(beanName);
    ...//初始化完后
    //this.singletonObjects.put(beanName, singletonObject);放入到单例容器中
    //this.singletonFactories.remove(beanName);清空循环依赖的两个打标
    //this.earlySingletonObjects.remove(beanName);
    //this.registeredSingletons.add(beanName);放入单例beanName容器中
    addSingleton(beanName, singletonObject);
    ...
    }
  }

/* org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory#doCreateBean */
  protected Object doCreateBean(final String beanName, final RootBeanDefinition mbd, final @Nullable Object[] args)
      throws BeanCreationException {
    ...
    //循环依赖相关逻辑：
    //this.singletonFactories.put(beanName, singletonFactory);
    //将实例化bean（①阶段）、beanName组装成singletonFactory装入singletonFactories容器
    //this.earlySingletonObjects.remove(beanName);
    //删除earlySingletonObjects中beanName
    addSingletonFactory(beanName, () -> getEarlyBeanReference(beanName, mbd, bean));
    ...
    //实例初始化 就是在这里面实现依赖注入DI的:反射实现
    //调用AutowiredAnnotationBeanPostProcessor.postProcessProperties
    populateBean(beanName, mbd, instanceWrapper);
    ...
  }

/* org.springframework.beans.factory.support.DefaultSingletonBeanRegistry#getSingleton(java.lang.String, boolean) */
  protected Object getSingleton(String beanName, boolean allowEarlyReference) {
    Object singletonObject = this.singletonObjects.get(beanName);
　　　　 //循环依赖核心就在于这个判断，由于打标+记录了①阶段的bean，
    //循环依赖第二次调用getBean("a")时，这里会直接返回第一次调用getBean("a")创建的①阶段的bean
    //而不会调用createBean("a")再次bean初始化（造成两个bean的循环创建）
    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;
  }

/* org.springframework.beans.factory.support.AbstractBeanFactory#doGetBean */
  protected  T doGetBean(final String name, @Nullable final Class requiredType,
      @Nullable final Object[] args, boolean typeCheckOnly) throws BeansException {
    ...
    //假设A、B互相依赖
    //第一次getBean(A)，sharedInstance == null,走else,createBean
    //A正在创建打标，①中beforeSingletonCreation()
    //A实例化后保存到singletonFactories中②中addSingletonFactory(beanName,singletonFactory)
    //DI依赖注入：②中populateBean(beanName,mbd,instanceWrapper),发现依赖B，调用getBean(B)初始化B的单例
    //调用getBean(B)重复上面步骤，DI依赖注入发现依赖A，调用getBean(A)
    //第二次getBean(A),③中if(singletonObject == null && isSingletonCurrentlyInCreation(A))由于打标了所以返回singleFactory.getObject()
    //下面if条件直接返回bean,没有走else破坏了循环
    Object sharedInstance = getSingleton(beanName);
    if (sharedInstance != null && args == null) {
      //
      bean = getObjectForBeanInstance(sharedInstance, name, beanName, null);
    }

    else {
      ...
      //
      createBean(beanName, mbd, args);
      bean = getObjectForBeanInstance(sharedInstance, name, beanName, null);
    }
    return bean;      
  }