135-1821-9792

关于Spring中GetBean的全流程源码解析

本文转载自微信公众号「bugstack虫洞栈」，作者小傅哥 。转载本文请联系bugstack虫洞栈公众号。

一、前言

你提出问题，就要给出解决方案!

最近有粉丝小伙伴反馈，与自己的上级沟通总是遇到障碍，感觉不被理解。大部分时候他提出来的事情都可能会被领导说：“我没get到你的点”、“你想做的这个项目没有业务价值”、“你提出问题，就要给出解决方案”，等等诸如此类的回答。

鉴于具体情况要具体分析，可能我们并不一定能判断出是谁的问题，导致在每次的交谈中出现的分歧。可能是leader有leader的苦衷和视角，也可能是员工有员工的理解和想法，所以最终没有达成一致。

但就带团队来讲，有效沟通很重要。就像：如果你说的都对，那我为什么和你争吵呢?与其压制遇到的矛盾点，不如都摊开了聊，谁的视角和心胸更大，谁就多有一些同理心。

如果尖锐的批评完全消失，温和的批评将会变得刺耳。

如果温和的批评也不被允许，沉默将被认为居心叵测。

如果沉默也不再允许，赞扬不够卖力将是一种罪行。

如果只允许一种声音存在，那么，唯一存在的那个声音就是谎言。

二、面试题

谢飞机，小记!，总感觉 Spring 也没啥看的，怎么面试官一问就能问出花?

面试官：Spring 的 getBean 中，transformedBeanName 的作用是什么?

谢飞机：不知道呀，看单词意思好像是改变Bean名称。

面试官：那这么说，你的 Bean 如果有 alias 别名，Spring 在获取 Bean 时候要怎么处理?

谢飞机：这!

面试官：那如果用了 depends-on 呢?

谢飞机：啊， 我没用过 depends-on 我不知道!

面试官：那你调试代码时候，看见过BeanName前面有 & 的情况吗，为啥会出现?

谢飞机：我不配知道!再见!

三、Bean 的获取过程

对于刚接触看 Spring 源码的伙伴来说，可能很疑惑于怎么就获取一个 Bean 就这么多流程呢?

  • 可能有 Bean 可能有别名、可能有依赖、也可能是被 BeanFactory 包装过，所以会有 transformedBeanName 来处理这些差异化行为。
  • 有没有循环依赖、有没有父工厂、是单例还是原型、是懒加载还是预加载、在不在缓冲区，所以就有各种组合判断来做不同的流程。
  • 提早暴漏对象、三级缓存、后置标记清楚，所有的优化处理都是为了让整个 Bean 的获取更加高效。

所以，它为了适应各类的需求，变得越来越复杂了。而这部分知识的深入学习绝对不只是为了应付八股文，更多的是考虑到在日常的 Spring 使用中遇到复杂问题时有没有一个大致知晓的流程，可以快速定位问题，以及此类需求的技术实现方案是否能在以后的应用开发中起到一定的指导作用，因为它是一种设计方案的具体实现。

1. getBean 核心流程图

小傅哥，getBean 核心流程图

  • 整张图就是 getBean 过程中涉及到的类和核心流程用到的方法以及操作的内容。如果你能把整张图全理解了，那么基本也就看懂了 getBean 的全过程。
  • 本张图可能会因为网络压缩变得不清晰，可以通过关注公众号：bugstack虫洞栈，回复：图稿，获取。

接下来，我们就依次的把关于获取 Bean 实例的重点代码列举出来做分析，读者伙伴也可以结合流程图一起看，这样会更方便理解。

2. getBean 从哪开始读源码

 
 
 
 
    
  
  
  
  
  1. @Test 
    2. 
  
  
  
  
  2. public void test_getBean() { 
    3. 
  
  
  
  
  3.     BeanFactory beanFactory = new ClassPathXmlApplicationContext("spring-config.xml"); 
    4. 
  
  
  
  
  4.     UserDao userDao = beanFactory.getBean("userDao", UserDao.class); 
    5. 
  
  
  
  
  5.     logger.info("获取 Bean：{}", userDao); 
    6. 
  
  
  
  
  6. } 
    7.

在日常应用到 Spring 的开发中基本都是基于注解，几乎不会自己去使用 beanFactory.getBean 的方式去获取一个 Bean 实例。

所以在你学习的时候如果找不到查看 getBean 源码的入口，也不方便调试熟悉源码时，可以写这样一个单元测试类，点入到 getBean 就可以阅读源码了。

3. getBean 源码全局预览

源码位置：AbstractBeanFactory -> getBean() -> doGetBean()

 
 
 
 
    
  
  
  
  
  1. @Override 
    2. 
  
  
  
  
  2. public  T getBean(String name, Class requiredType) throws BeansException {  
    3. 
  
  
  
  
  3.     // getBean 就像你的领导其实没做啥，都在 doGetBean 里 
    4. 
  
  
  
  
  4.  return doGetBean(name, requiredType, null, false); 
    5. 
  
  
  
  
  5. } 
    6. 
 
 
 
 
 
 
 
 
    
  
  
  
  
  1. protected  T doGetBean(final String name, final Class requiredType, final Object[] args, boolean typeCheckOnly) 
    2. 
  
  
  
  
  2.   throws BeansException {      
    3. 
  
  
  
  
  3.      
    4. 
  
  
  
  
  4.     // 处理别名BeanName、处理带&符的工厂BeanName 
    5. 
  
  
  
  
  5.  final String beanName = transformedBeanName(name); 
    6. 
  
  
  
  
  6.  Object bean;   
    7. 
  
  
  
  
  7.  
    8. 
  
  
  
  
  8.  // 先尝试从缓存中获取Bean实例，这个位置就是三级缓存解决循环依赖的方法 
    9. 
  
  
  
  
  9.  Object sharedInstance = getSingleton(beanName);    
    10. 
  
  
  
  
  10.  
    11. 
  
  
  
  
  11.  if (sharedInstance != null && args == null) { 
    12. 
  
  
  
  
  12.   if (logger.isDebugEnabled()) { 
    13. 
  
  
  
  
  13.    if (isSingletonCurrentlyInCreation(beanName)) { 
    14. 
  
  
  
  
  14.     logger.debug("Returning eagerly cached instance of singleton bean '" + beanName + 
    15. 
  
  
  
  
  15.       "' that is not fully initialized yet - a consequence of a circular reference"); 
    16. 
  
  
  
  
  16.    } 
    17. 
  
  
  
  
  17.    else { 
    18. 
  
  
  
  
  18.     logger.debug("Returning cached instance of singleton bean '" + beanName + "'"); 
    19. 
  
  
  
  
  19.    } 
    20. 
  
  
  
  
  20.   }         
    21. 
  
  
  
  
  21.          
    22. 
  
  
  
  
  22.         // 1. 如果 sharedInstance 是普通的 Bean 实例，则下面的方法会直接返回 
    23. 
  
  
  
  
  23.         // 2. 如果 sharedInstance 是工厂Bean类型，则需要获取 getObject 方法，可以参考关于 FactoryBean 的实现类  
    24. 
  
  
  
  
  24.   bean = getObjectForBeanInstance(sharedInstance, name, beanName, null); 
    25. 
  
  
  
  
  25.  } 
    26. 
  
  
  
  
  26.  else { 
    27. 
  
  
  
  
  27.    
    28. 
  
  
  
  
  28.         // 循环依赖有三种，setter注入、多实例和构造函数，Spring 只能解决 setter 注入，所以这里是 Prototype 则会抛出异常 
    29. 
  
  
  
  
  29.   if (isPrototypeCurrentlyInCreation(beanName)) { 
    30. 
  
  
  
  
  30.    throw new BeanCurrentlyInCreationException(beanName); 
    31. 
  
  
  
  
  31.   }     
    32. 
  
  
  
  
  32.  
    33. 
  
  
  
  
  33.   // 1. 父 bean 工厂存在 
    34. 
  
  
  
  
  34.         // 2. 当前 bean 不存在于当前bean工厂，则到父工厂查找 bean 实例 
    35. 
  
  
  
  
  35.   BeanFactory parentBeanFactory = getParentBeanFactory(); 
    36. 
  
  
  
  
  36.   if (parentBeanFactory != null && !containsBeanDefinition(beanName)) { 
    37. 
  
  
  
  
  37.    // 获取 name 对应的 beanName，如果 name 是以 & 开头，则返回 & + beanName 
    38. 
  
  
  
  
  38.    String nameToLookup = originalBeanName(name);          
    39. 
  
  
  
  
  39.              
    40. 
  
  
  
  
  40.             // 根据 args 参数是否为空，调用不同的父容器方法获取 bean 实例 
    41. 
  
  
  
  
  41.    if (args != null) { 
    42. 
  
  
  
  
  42.     return (T) parentBeanFactory.getBean(nameToLookup, args); 
    43. 
  
  
  
  
  43.    } 
    44. 
  
  
  
  
  44.    else { 
    45. 
  
  
  
  
  45.     return parentBeanFactory.getBean(nameToLookup, requiredType); 
    46. 
  
  
  
  
  46.    } 
    47. 
  
  
  
  
  47.   }        
    48. 
  
  
  
  
  48.  
    49. 
  
  
  
  
  49.         // 1. typeCheckOnly，用于判断调用 getBean 方法时，是否仅是做类型检查 
    50. 
  
  
  
  
  50.         // 2. 如果不是只做类型检查，就会调用 markBeanAsCreated 进行记录 
    51. 
  
  
  
  
  51.   if (!typeCheckOnly) { 
    52. 
  
  
  
  
  52.    markBeanAsCreated(beanName); 
    53. 
  
  
  
  
  53.   } 
    54. 
  
  
  
  
  54.   try {     
    55. 
  
  
  
  
  55.      
    56. 
  
  
  
  
  56.             // 从容器 getMergedLocalBeanDefinition 获取 beanName 对应的 GenericBeanDefinition，转换为 RootBeanDefinition 
    57. 
  
  
  
  
  57.    final RootBeanDefinition mbd = getMergedLocalBeanDefinition(beanName);  
    58. 
  
  
  
  
  58.             // 检查当前创建的 bean 定义是否为抽象 bean 定义 
    59. 
  
  
  
  
  59.    checkMergedBeanDefinition(mbd, beanName, args); 
    60. 
  
  
  
  
  60.     
    61. 
  
  
  
  
  61.             // 处理使用了 depends-on 注解的依赖创建 bean 实例 
    62. 
  
  
  
  
  62.    String[] dependsOn = mbd.getDependsOn(); 
    63. 
  
  
  
  
  63.    if (dependsOn != null) { 
    64. 
  
  
  
  
  64.     for (String dep : dependsOn) {    
    65. 
  
  
  
  
  65.                     // 监测是否存在 depends-on 循环依赖，若存在则会抛出异常 
    66. 
  
  
  
  
  66.      if (isDependent(beanName, dep)) { 
    67. 
  
  
  
  
  67.       throw new BeanCreationException(mbd.getResourceDescription(), beanName, 
    68. 
  
  
  
  
  68.         "Circular depends-on relationship between '" + beanName + "' and '" + dep + "'"); 
    69. 
  
  
  
  
  69.      }        
    70. 
  
  
  
  
  70.                      
    71. 
  
  
  
  
  71.                     // 注册依赖记录 
    72. 
  
  
  
  
  72.      registerDependentBean(dep, beanName); 
    73. 
  
  
  
  
  73.      try {     
    74. 
  
  
  
  
  74.          // 加载 depends-on 依赖（dep 是 depends-on 缩写） 
    75. 
  
  
  
  
  75.       getBean(dep); 
    76. 
  
  
  
  
  76.      } 
    77. 
  
  
  
  
  77.      catch (NoSuchBeanDefinitionException ex) { 
    78. 
  
  
  
  
  78.       throw new BeanCreationException(mbd.getResourceDescription(), beanName, 
    79. 
  
  
  
  
  79.         "'" + beanName + "' depends on missing bean '" + dep + "'", ex); 
    80. 
  
  
  
  
  80.      } 
    81. 
  
  
  
  
  81.     } 
    82. 
  
  
  
  
  82.    }   
    83. 
  
  
  
  
  83.  
    84. 
  
  
  
  
  84.    // 创建单例 bean 实例 
    85. 
  
  
  
  
  85.    if (mbd.isSingleton()) {     
    86. 
  
  
  
  
  86.  
    87. 
  
  
  
  
  87.        // 把 beanName 和 new ObjectFactory 匿名内部类传入回调 
    88. 
  
  
  
  
  88.     sharedInstance = getSingleton(beanName, new ObjectFactory() { 
  
  
  
  
  89.      @Override 
    90. 
  
  
  
  
  90.      public Object getObject() throws BeansException { 
    91. 
  
  
  
  
  91.       try {     
    92. 
  
  
  
  
  92.                             // 创建 bean 
    93. 
  
  
  
  
  93.        return createBean(beanName, mbd, args); 
    94. 
  
  
  
  
  94.       } 
    95. 
  
  
  
  
  95.       catch (BeansException ex) { 
    96. 
  
  
  
  
  96.        // 创建失败则销毁 
    97. 
  
  
  
  
  97.        destroySingleton(beanName); 
    98. 
  
  
  
  
  98.        throw ex; 
    99. 
  
  
  
  
  99.       } 
    100. 
  
  
  
  
  100.      } 
    101. 
  
  
  
  
  101.     }); 
    102. 
  
  
  
  
  102.     bean = getObjectForBeanInstance(sharedInstance, name, beanName, mbd); 
    103. 
  
  
  
  
  103.    }       
    104. 
  
  
  
  
  104.             // 创建其他类型的 bean 实例 
    105. 
  
  
  
  
  105.    else if (mbd.isPrototype()) { 
    106. 
  
  
  
  
  106.     // It's a prototype -> create a new instance. 
    107. 
  
  
  
  
  107.     Object prototypeInstance = null; 
    108. 
  
  
  
  
  108.     try { 
    109. 
  
  
  
  
  109.      beforePrototypeCreation(beanName); 
    110. 
  
  
  
  
  110.      prototypeInstance = createBean(beanName, mbd, args); 
    111. 
  
  
  
  
  111.     } 
    112. 
  
  
  
  
  112.     finally { 
    113. 
  
  
  
  
  113.      afterPrototypeCreation(beanName); 
    114. 
  
  
  
  
  114.     } 
    115. 
  
  
  
  
  115.     bean = getObjectForBeanInstance(prototypeInstance, name, beanName, mbd); 
    116. 
  
  
  
  
  116.    } 
    117. 
  
  
  
  
  117.    else { 
    118. 
  
  
  
  
  118.     String scopeName = mbd.getScope(); 
    119. 
  
  
  
  
  119.     final Scope scope = this.scopes.get(scopeName); 
    120. 
  
  
  
  
  120.     if (scope == null) { 
    121. 
  
  
  
  
  121.      throw new IllegalStateException("No Scope registered for scope name '" + scopeName + "'"); 
    122. 
  
  
  
  
  122.     } 
    123. 
  
  
  
  
  123.     try { 
    124. 
  
  
  
  
  124.      Object scopedInstance = scope.get(beanName, new ObjectFactory() { 
  
  
  
  
  125.       @Override 
    126. 
  
  
  
  
  126.       public Object getObject() throws BeansException { 
    127. 
  
  
  
  
  127.        beforePrototypeCreation(beanName); 
    128. 
  
  
  
  
  128.        try { 
    129. 
  
  
  
  
  129.         return createBean(beanName, mbd, args); 
    130. 
  
  
  
  
  130.        } 
    131. 
  
  
  
  
  131.        finally { 
    132. 
  
  
  
  
  132.         afterPrototypeCreation(beanName); 
    133. 
  
  
  
  
  133.        } 
    134. 
  
  
  
  
  134.       } 
    135. 
  
  
  
  
  135.      }); 
    136. 
  
  
  
  
  136.      bean = getObjectForBeanInstance(scopedInstance, name, beanName, mbd); 
    137. 
  
  
  
  
  137.     } 
    138. 
  
  
  
  
  138.     catch (IllegalStateException ex) { 
    139. 
  
  
  
  
  139.      throw new BeanCreationException(beanName, 
    140. 
  
  
  
  
  140.        "Scope '" + scopeName + "' is not active for the current thread; consider " + 
    141. 
  
  
  
  
  141.        "defining a scoped proxy for this bean if you intend to refer to it from a singleton", 
    142. 
  
  
  
  
  142.        ex); 
    143. 
  
  
  
  
  143.     } 
    144. 
  
  
  
  
  144.    } 
    145. 
  
  
  
  
  145.   } 
    146. 
  
  
  
  
  146.   catch (BeansException ex) { 
    147. 
  
  
  
  
  147.    cleanupAfterBeanCreationFailure(beanName); 
    148. 
  
  
  
  
  148.    throw ex; 
    149. 
  
  
  
  
  149.   } 
    150. 
  
  
  
  
  150.  } 
    151. 
  
  
  
  
  151.  // 如果需要类型转换，这里会进行操作 
    152. 
  
  
  
  
  152.  if (requiredType != null && bean != null && !requiredType.isInstance(bean)) { 
    153. 
  
  
  
  
  153.   try { 
    154. 
  
  
  
  
  154.    return getTypeConverter().convertIfNecessary(bean, requiredType); 
    155. 
  
  
  
  
  155.   } 
    156. 
  
  
  
  
  156.   catch (TypeMismatchException ex) { 
    157. 
  
  
  
  
  157.    if (logger.isDebugEnabled()) { 
    158. 
  
  
  
  
  158.     logger.debug("Failed to convert bean '" + name + "' to required type '" + 
    159. 
  
  
  
  
  159.       ClassUtils.getQualifiedName(requiredType) + "'", ex); 
    160. 
  
  
  
  
  160.    } 
    161. 
  
  
  
  
  161.    throw new BeanNotOfRequiredTypeException(name, requiredType, bean.getClass()); 
    162. 
  
  
  
  
  162.   } 
    163. 
  
  
  
  
  163.  }     
    164. 
  
  
  
  
  164.  
    165. 
  
  
  
  
  165.     // 返回 Bean 
    166. 
  
  
  
  
  166.  return (T) bean; 
    167. 
  
  
  
  
  167. } 
    168. 
 
 
 
 
    综上基本就是 getBean 过程涉及到的核心处理方法，基本包括;
    • transformedBeanName，处理别名BeanName、处理带&符的工厂BeanName。
      • 

    • getSingleton，先尝试从缓存中获取Bean实例，这个位置就是三级缓存解决循环依赖的方法。
      • 

    • getObjectForBeanInstance，如果 sharedInstance 是普通的 Bean 实例，则下面的方法会直接返回。另外 sharedInstance 是工厂Bean类型，则需要获取 getObject 方法，可以参考关于 FactoryBean 的实现类。
      • 

    • isPrototypeCurrentlyInCreation，循环依赖有三种，setter注入、多实例和构造函数，Spring 只能解决 setter 注入，所以这里是 Prototype 则会抛出异常。
      • 

    • getParentBeanFactory，父 bean 工厂存在，当前 bean 不存在于当前bean工厂，则到父工厂查找 bean 实例。
      • 

    • originalBeanName，获取 name 对应的 beanName，如果 name 是以 & 开头，则返回 & + beanName
      • 

    • args != null，根据 args 参数是否为空，调用不同的父容器方法获取 bean 实例
      • 

    • !typeCheckOnly，typeCheckOnly，用于判断调用 getBean 方法时，是否仅是做类型检查，如果不是只做类型检查，就会调用 markBeanAsCreated 进行记录
      • 

    • mbd.getDependsOn，处理使用了 depends-on 注解的依赖创建 bean 实例
      • 

    • isDependent，监测是否存在 depends-on 循环依赖，若存在则会抛出异常
      • 

    • registerDependentBean，注册依赖记录
      • 

    • getBean(dep)，加载 depends-on 依赖(dep 是 depends-on 缩写)
      • 

    • mbd.isSingleton()，创建单例 bean 实例
      • 

    • mbd.isPrototype()，创建其他类型的 bean 实例
      • 

    • return (T) bean，返回 Bean 实例
    

    4. beanName 转换操作
    

    处理 & 符：transformedBeanName() -> BeanFactoryUtils.transformedBeanName(name)
    

     
 
 
 
      
  
  
  
  
    1. public static String transformedBeanName(String name) { 
      2. 
  
  
  
  
    2.  Assert.notNull(name, "'name' must not be null"); 
      3. 
  
  
  
  
    3.  String beanName = name; 
      4. 
  
  
  
  
    4.  while (beanName.startsWith(BeanFactory.FACTORY_BEAN_PREFIX)) { 
      5. 
  
  
  
  
    5.   beanName = beanName.substring(BeanFactory.FACTORY_BEAN_PREFIX.length()); 
      6. 
  
  
  
  
    6.  } 
      7. 
  
  
  
  
    7.  return beanName; 
      8. 
  
  
  
  
    8. } 
      9. 
 
 
 
 
    

    • 使用 FactoryBean 创建出的对象，会在 DefaultListableBeanFactory 初始化的时候，使用 getBean(FACTORY_BEAN_PREFIX + beanName) 给 beanName 加上 & (String FACTORY_BEAN_PREFIX = "&")
      • 

    • 这里是使用 while 循环逐步的把 & 去掉，只要截取首个字符是 & 符，就继续循环截取。&&&userService -> &&userService -> &userService -> userService
    

    别名转换：transformedBeanName() -> canonicalName
    

     
 
 
 
      
  
  
  
  
    1. public String canonicalName(String name) { 
      2. 
  
  
  
  
    2.  String canonicalName = name; 
      3. 
  
  
  
  
    3.  // Handle aliasing... 
      4. 
  
  
  
  
    4.  String resolvedName; 
      5. 
  
  
  
  
    5.  do { 
      6. 
  
  
  
  
    6.   resolvedName = this.aliasMap.get(canonicalName); 
      7. 
  
  
  
  
    7.   if (resolvedName != null) { 
      8. 
  
  
  
  
    8.    canonicalName = resolvedName; 
      9. 
  
  
  
  
    9.   } 
      10. 
  
  
  
  
    10.  } 
      11. 
  
  
  
  
    11.  while (resolvedName != null); 
      12. 
  
  
  
  
    12.  return canonicalName; 
      13. 
  
  
  
  
    13. }
      14. 
 
 
 
 
    

     
 
 
 
      
  
  
  
  
    1.  
      2. 
  
  
  
  
    2.  
      3. 
  
  
  
  
    3.  
      4. 
 
 
 
 
    首先 Spring 对 Bean 的存放并不会使用别名作为Map中的key，所以遇到所有别名获取 Bean 都需要查到对应原来名字，才可以。如果你知道这个事，是不遇到此类问题时，就知道从哪下手查了
    do...while 循环会依次像链条一样不断的寻找别名对应的名称，直到当前这个名称没有别名了，就返回对应 BeanName
    

    5. depends-on 依赖 Bean
    

     
 
 
 
      
  
  
  
  
    1. protected boolean isDependent(String beanName, String dependentBeanName) { 
      2. 
  
  
  
  
    2.  synchronized (this.dependentBeanMap) { 
      3. 
  
  
  
  
    3.   return isDependent(beanName, dependentBeanName, null); 
      4. 
  
  
  
  
    4.  } 
      5. 
  
  
  
  
    5.  
      6. 
  
  
  
  
    6.  
      7. 
  
  
  
  
    7.  
      8. 
 
 
 
 
    

    isDependent 处理的是使用了 depends-on 配置的 Bean 定义。
    

     
 
 
 
      
  
  
  
  
    1. private boolean isDependent(String beanName, String dependentBeanName, Set alread 
      2. 
  
  
  
  
    2.  if (alreadySeen != null && alreadySeen.contains(beanName)) { 
      3. 
  
  
  
  
    3.   return false; 
      4. 
  
  
  
  
    4.  } 
      5. 
  
  
  
  
    5.  String canonicalName = canonicalName(beanName); 
      6. 
  
  
  
  
    6.  Set dependentBeans = this.dependentBeanMap.get(canonicalName); 
      7. 
  
  
  
  
    7.  if (dependentBeans == null) { 
      8. 
  
  
  
  
    8.   return false; 
      9. 
  
  
  
  
    9.  } 
      10. 
  
  
  
  
    10.  if (dependentBeans.contains(dependentBeanName)) { 
      11. 
  
  
  
  
    11.   return true; 
      12. 
  
  
  
  
    12.  } 
      13. 
  
  
  
  
    13.  for (String transitiveDependency : dependentBeans) { 
      14. 
  
  
  
  
    14.   if (alreadySeen == null) { 
      15. 
  
  
  
  
    15.    alreadySeen = new HashSet(); 
      16. 
  
  
  
  
    16.   } 
      17. 
  
  
  
  
    17.   alreadySeen.add(beanName); 
      18. 
  
  
  
  
    18.   if (isDependent(transitiveDependency, dependentBeanName, alreadySeen)) { 
      19. 
  
  
  
  
    19.    return true; 
      20. 
  
  
  
  
    20.   } 
      21. 
  
  
  
  
    21.  } 
      22. 
  
  
  
  
    22.  return false; 
      23. 
  
  
  
  
    23. } 
      24. 
 
 
 
 
    

    • alreadySeen != null，监测已经依赖的 Bean
      • 

    • canonicalName，处理别名配置，找到最原来是的 BeanName
      • 

    • SetdependentBeans，获取依赖的 Bean 集合
      • 

    • for 循环递归检测依赖的 Bean，并添加到 alreadySeen 中
    

    AbstractBeanFactory -> registerDependentBean(dep, beanName) -> DefaultSingletonBeanRegistry
    

     
 
 
 
      
  
  
  
  
    1. public void registerDependentBean(String beanName, String dependentBeanName) { 
      2. 
  
  
  
  
    2.  String canonicalName = canonicalName(beanName);   
      3. 
  
  
  
  
    3.  
      4. 
  
  
  
  
    4.  synchronized (this.dependentBeanMap) { 
      5. 
  
  
  
  
    5.   Set dependentBeans = this.dependentBeanMap.get(canonicalName); 
      6. 
  
  
  
  
    6.   if (dependentBeans == null) { 
      7. 
  
  
  
  
    7.    dependentBeans = new LinkedHashSet(8); 
      8. 
  
  
  
  
    8.    this.dependentBeanMap.put(canonicalName, dependentBeans); 
      9. 
  
  
  
  
    9.   } 
      10. 
  
  
  
  
    10.   dependentBeans.add(dependentBeanName); 
      11. 
  
  
  
  
    11.  }    
      12. 
  
  
  
  
    12.  
      13. 
  
  
  
  
    13.  synchronized (this.dependenciesForBeanMap) { 
      14. 
  
  
  
  
    14.   Set dependenciesForBean = this.dependenciesForBeanMap.get(dependentBeanName 
      15. 
  
  
  
  
    15.   if (dependenciesForBean == null) { 
      16. 
  
  
  
  
    16.    dependenciesForBean = new LinkedHashSet(8); 
      17. 
  
  
  
  
    17.    this.dependenciesForBeanMap.put(dependentBeanName, dependenciesForBean); 
      18. 
  
  
  
  
    18.   } 
      19. 
  
  
  
  
    19.   dependenciesForBean.add(canonicalName); 
      20. 
  
  
  
  
    20.  } 
      21. 
  
  
  
  
    21. } 
      22. 
 
 
 
 
    

    • canonicalName(beanName)，获取原始的 beanName
      • 

    • synchronized (this.dependentBeanMap)，添加
      • 

    • synchronized (this.dependenciesForBeanMap)，添加
    

    最后：getBean(dep)，就可以获取到 depends-on 依赖的 Bean 了
    

    6. 处理单实例 Bean
    

    AbstractBeanFactory -> mbd.isSingleton()
    

     
 
 
 
      
  
  
  
  
    1. if (mbd.isSingleton()) { 
      2. 
  
  
  
  
    2.  sharedInstance = getSingleton(beanName, new ObjectFactory() { 
  
  
  
  
    3.   @Override 
      4. 
  
  
  
  
    4.   public Object getObject() throws BeansException { 
      5. 
  
  
  
  
    5.    try { 
      6. 
  
  
  
  
    6.     return createBean(beanName, mbd, args); 
      7. 
  
  
  
  
    7.    } 
      8. 
  
  
  
  
    8.    catch (BeansException ex) { 
      9. 
  
  
  
  
    9.     destroySingleton(beanName); 
      10. 
  
  
  
  
    10.     throw ex; 
      11. 
  
  
  
  
    11.    } 
      12. 
  
  
  
  
    12.   } 
      13. 
  
  
  
  
    13.  }); 
      14. 
  
  
  
  
    14.  bean = getObjectForBeanInstance(sharedInstance, name, beanName, mbd); 
      15. 
  
  
  
  
    15. } 
      16. 
 
 
 
 
      这一部分是使用 beanName 和 singletonFactory 匿名内部类传入等待回调的方式创建单实例 Bean 实例
      

       
 
 
 
        
  
  
  
  
      1. public Object getSingleton(String beanName, ObjectFactory singletonFactory) { 
        2. 
  
  
  
  
      2.  Assert.notNull(beanName, "'beanName' must not be null"); 
        3. 
  
  
  
  
      3.  synchronized (this.singletonObjects) { 
        4. 
  
  
  
  
      4.   Object singletonObject = this.singletonObjects.get(beanName); 
        5. 
  
  
  
  
      5.   if (singletonObject == null) { 
        6. 
  
  
  
  
      6.    if (this.singletonsCurrentlyInDestruction) { 
        7. 
  
  
  
  
      7.     throw new BeanCreationNotAllowedException(beanName, 
        8. 
  
  
  
  
      8.       "Singleton bean creation not allowed while singletons of this factory are in destruction " + 
        9. 
  
  
  
  
      9.       "(Do not request a bean from a BeanFactory in a destroy method implementation!)"); 
        10. 
  
  
  
  
      10.    } 
        11. 
  
  
  
  
      11.    if (logger.isDebugEnabled()) { 
        12. 
  
  
  
  
      12.     logger.debug("Creating shared instance of singleton bean '" + beanName + "'"); 
        13. 
  
  
  
  
      13.    } 
        14. 
  
  
  
  
      14.    beforeSingletonCreation(beanName); 
        15. 
  
  
  
  
      15.    boolean newSingleton = false; 
        16. 
  
  
  
  
      16.    boolean recordSuppressedExceptions = (this.suppressedExceptions == null); 
        17. 
  
  
  
  
      17.    if (recordSuppressedExceptions) { 
        18. 
  
  
  
  
      18.     this.suppressedExceptions = new LinkedHashSet(); 
        19. 
  
  
  
  
      19.    } 
        20. 
  
  
  
  
      20.    try { 
        21. 
  
  
  
  
      21.     singletonObject = singletonFactory.getObject(); 
        22. 
  
  
  
  
      22.     newSingleton = true; 
        23. 
  
  
  
  
      23.    } 
        24. 
  
  
  
  
      24.    catch (IllegalStateException ex) { 
        25. 
  
  
  
  
      25.     singletonObject = this.singletonObjects.get(beanName); 
        26. 
  
  
  
  
      26.     if (singletonObject == null) { 
        27. 
  
  
  
  
      27.      throw ex; 
        28. 
  
  
  
  
      28.     } 
        29. 
  
  
  
  
      29.    } 
        30. 
  
  
  
  
      30.    catch (BeanCreationException ex) { 
        31. 
  
  
  
  
      31.     if (recordSuppressedExceptions) { 
        32. 
  
  
  
  
      32.      for (Exception suppressedException : this.suppressedExceptions) { 
        33. 
  
  
  
  
      33.       ex.addRelatedCause(suppressedException); 
        34. 
  
  
  
  
      34.      } 
        35. 
  
  
  
  
      35.     } 
        36. 
  
  
  
  
      36.     throw ex; 
        37. 
  
  
  
  
      37.    } 
        38. 
  
  
  
  
      38.    finally { 
        39. 
  
  
  
  
      39.     if (recordSuppressedExceptions) { 
        40. 
  
  
  
  
      40.      this.suppressedExceptions = null; 
        41. 
  
  
  
  
      41.     } 
        42. 
  
  
  
  
      42.     afterSingletonCreation(beanName); 
        43. 
  
  
  
  
      43.    } 
        44. 
  
  
  
  
      44.    if (newSingleton) { 
        45. 
  
  
  
  
      45.     addSingleton(beanName, singletonObject); 
        46. 
  
  
  
  
      46.    } 
        47. 
  
  
  
  
      47.   } 
        48. 
  
  
  
  
      48.   return (singletonObject != NULL_OBJECT ? singletonObject : null); 
        49. 
  
  
  
  
      49.  } 
        50. 
  
  
  
  
      50. } 
        51. 
 
 
 
 
      

      • this.singletonObjects.get(beanName)，先尝试从缓存池中获取对象，没有就继续往下执行
        • 

      • beforeSingletonCreation(beanName)，标记当前 bean 被创建，如果有构造函数注入的循环依赖会报错
        • 

      • singletonObject = singletonFactory.getObject()，创建 bean 过程就是调用 createBean() 方法
        • 

      • afterSingletonCreation(beanName)，最后把标记从集合中移除
        • 

      • addSingleton(beanName, singletonObject)，新创建的会加入缓存集合
      

      7. 从缓存中获取 bean 实例
      

      doCreateBean -> if (earlySingletonExposure) -> getSingleton(beanName, false)
      

       
 
 
 
        
  
  
  
  
      1. protected Object getSingleton(String beanName, boolean allowEarlyReference) { 
        2. 
  
  
  
  
      2.     // 从 singletonObjects 获取实例，singletonObjects 中缓存的实例都是完全实例化好的 bean，可以直接使用 
        3. 
  
  
  
  
      3.  Object singletonObject = this.singletonObjects.get(beanName); 
        4. 
  
  
  
  
      4.     // 如果 singletonObject 为空，则没有创建或创建中 
        5. 
  
  
  
  
      5.  if (singletonObject == null && isSingletonCurrentlyInCreation(beanName)) { 
        6. 
  
  
  
  
      6.         // 加锁 
        7. 
  
  
  
  
      7.   synchronized (this.singletonObjects) { 
        8. 
  
  
  
  
      8.             // 单例缓存池中，没有当前beanName 
        9. 
  
  
  
  
      9.    singletonObject = this.earlySingletonObjects.get(beanName); 
        10. 
  
  
  
  
      10.    if (singletonObject == null && allowEarlyReference) { 
        11. 
  
  
  
  
      11.     ObjectFactory singletonFactory = this.singletonFactories.get(beanName); 
        12. 
  
  
  
  
      12.     if (singletonFactory != null) { 
        13. 
  
  
  
  
      13.                     // 加入到三级缓存，暴漏早期对象用于解决三级缓存 
        14. 
  
  
  
  
      14.      singletonObject = singletonFactory.getObject();   
        15. 
  
  
  
  
      15.      this.earlySingletonObjects.put(beanName, singletonObject); 
        16. 
  
  
  
  
      16.      this.singletonFactories.remove(beanName); 
        17. 
  
  
  
  
      17.     } 
        18. 
  
  
  
  
      18.    } 
        19. 
  
  
  
  
      19.   } 
        20. 
  
  
  
  
      20.  } 
        21. 
  
  
  
  
      21.  return (singletonObject != NULL_OBJECT ? singletonObject : null); 
        22. 
  
  
  
  
      22. } 
        23. 
 
 
 
 
      

      • 其实这一段代码主要就是使用三级缓存解决set注入循环依赖的，后面会单独列一个章节对循环依赖做相关实验验证
        • 

      • singletonObjects，用于存放初始化好的 bean 实例。
        • 

      • earlySingletonObjects，用于存放初始化中的 bean，来解决循环依赖。
        • 

      • singletonFactories，用于存放 bean 工厂，bean 工厂所生成的 bean 还没有完成初始化 bean。
      

      8. FactoryBean 中获取 bean 实例
      

      AbstractBeanFactory -> getObjectForBeanInstance(sharedInstance, name, beanName, null)
      

       
 
 
 
        
  
  
  
  
      1. protected Object getObjectForBeanInstance(Object beanInstance, String name, String beanName, RootBeanDefinition mbd) { 
        2. 
  
  
  
  
      2.      
        3. 
  
  
  
  
      3.     // 如果 beanName 以 & 开头，但 beanInstance 却不是 FactoryBean，则会抛出异常 
        4. 
  
  
  
  
      4.  if (BeanFactoryUtils.isFactoryDereference(name) && !(beanInstance instanceof FactoryBean)) { 
        5. 
  
  
  
  
      5.   throw new BeanIsNotAFactoryException(transformedBeanName(name), beanInstance.getClass()); 
        6. 
  
  
  
  
      6.  } 
        7. 
  
  
  
  
      7.  
        8. 
  
  
  
  
      8.     // 这里判断就是这个 bean 是不是 FactoryBean，不是就直接返回了 
        9. 
  
  
  
  
      9.  if (!(beanInstance instanceof FactoryBean) || BeanFactoryUtils.isFactoryDereference(name)) { 
        10. 
  
  
  
  
      10.   return beanInstance; 
        11. 
  
  
  
  
      11.  }    
        12. 
  
  
  
  
      12.  
        13. 
  
  
  
  
      13.  Object object = null; 
        14. 
  
  
  
  
      14.  if (mbd == null) {     
        15. 
  
  
  
  
      15.         // 如果 mbd 为空，则从缓存加载 bean（FactoryBean 生成的单例 bean 实例会缓存到 factoryBeanObjectCache 集合中，方便使用） 
        16. 
  
  
  
  
      16.   object = getCachedObjectForFactoryBean(beanName); 
        17. 
  
  
  
  
      17.  }    
        18. 
  
  
  
  
      18.  
        19. 
  
  
  
  
      19.  if (object == null) { 
        20. 
  
  
  
  
      20.   // 到这，beanInstance 是 FactoryBean 类型，所以就强转了 
        21. 
  
  
  
  
      21.   FactoryBean factory = (FactoryBean) beanInstance; 
        22. 
  
  
  
  
      22.   // mbd 为空且判断 containsBeanDefinition 是否包含 beanName 
        23. 
  
  
  
  
      23.   if (mbd == null && containsBeanDefinition(beanName)) {     
        24. 
  
  
  
  
      24.             // 合并 BeanDefinition 
        25. 
  
  
  
  
      25.    mbd = getMergedLocalBeanDefinition(beanName); 
        26. 
  
  
  
  
      26.   }     
        27. 
  
  
  
  
      27.   boolean synthetic = (mbd != null && mbd.isSynthetic());    
        28. 
  
  
  
  
      28.         // 调用 getObjectFromFactoryBean 获取实例  
        29. 
  
  
  
  
      29.   object = getObjectFromFactoryBean(factory, beanName, !synthetic); 
        30. 
  
  
  
  
      30.  } 
        31. 
  
  
  
  
      31.  return object; 
        32. 
  
  
  
  
      32. } 
        33. 
 
 
 
 
      

      • (!(beanInstance instanceof FactoryBean)，这里判断就是这个 bean 是不是 FactoryBean，不是就直接返回了
        • 

      • 如果 mbd 为空，则从缓存加载 bean(FactoryBean 生成的单例 bean 实例会缓存到 factoryBeanObjectCache 集合中，方便使用)
        • 

      • 调用 getObjectFromFactoryBean 获取实例，这里会包括一部分对单例以及非单例的处理，以及最终返回 factory.getObject(); 对应的 Bean 实例
      

      四、测试案例
      1. 别名
      

       
 
 
 
        
  
  
  
  
      1.  
        2. 
  
  
  
  
      2.  
        3. 
  
  
  
  
      3.  
        4. 
  
  
  
  
      4.  
        5. 
  
  
  
  
      5.  
        6. 
  
  
  
  
      6. @Test 
        7. 
  
  
  
  
      7. public void test_alias() { 
        8. 
  
  
  
  
      8.     BeanFactory beanFactory = new ClassPathXmlApplicationContext("spring-config-alias.xml"); 
        9. 
  
  
  
  
      9.     UserService userService = beanFactory.getBean("userService-alias02", UserService.class); 
        10. 
  
  
  
  
      10.     logger.info("获取 Bean 通过别名：{}", userService); 
        11. 
  
  
  
  
      11. } 
        12. 
 
 
 
 
      

      

      在单元测试 getBean 的时候，会看到它会把别名逐步处理掉，最终获取到原有的 BeanName
      

      2. 依赖
      

       
 
 
 
        
  
  
  
  
      1.  
        2. 
  
  
  
  
      2.  
        3. 
  
  
  
  
      3. @Test 
        4. 
  
  
  
  
      4. public void test_depends_on() { 
        5. 
  
  
  
  
      5.     BeanFactory beanFactory = new ClassPathXmlApplicationContext("spring-config-depends-on.xml"); 
        6. 
  
  
  
  
      6.     UserService userService = beanFactory.getBean(UserService.class, "userService"); 
        7. 
  
  
  
  
      7.     logger.info("获取 Bean：{}", userService.getUserDao()); 
        8. 
  
  
  
  
      8. } 
        9. 
 
 
 
 
      

      

      • 涉及到依赖会走到 dependsOn != null 下，获取到依赖的 Bean 实例。
      

      3. BeanFactory
      

       
 
 
 
        
  
  
  
  
      1.  
        2. 
  
  
  
  
      2. @Test 
        3. 
  
  
  
  
      3. public void test_factory_bean() { 
        4. 
  
  
  
  
      4.     BeanFactory beanFactory = new ClassPathXmlApplicationContext("spring-config-factory-bean.xml"); 
        5. 
  
  
  
  
      5.     UserDao userDao = beanFactory.getBean("userDao", UserDao.class); 
        6. 
  
  
  
  
      6.     logger.info("获取 Bean：{}", userDao); 
        7. 
  
  
  
  
      7. } 
        8. 
 
 
 
 
      

      

      实现 FactoryBean 的类会需要实现 getObject 方法，所有此类的 Bean 最终都是获取 getObject
      

      五、总结
      • 到这里关于 Spring IOC 获取 Bean 的核心流程基本就全部介绍完了，整个篇章让我们看到获取一个 Bean 的流程也是非常复杂的，涉及到了非常多的分支流程。之所有会有这么多的流程，就是我们前面介绍到的，因为 Spring 的 Bean 获取需要满足很多种情况。
        • 

      • 在学习的过程可以优先按照 GetBean 流程图进行梳理，之后对照源码按步骤分析，这样的过程几乎会消耗你1~2天的时间，但整个过程学习完，基本也就对 GetBean 没有什么陌生了。
        • 

      • 学习几乎就是一个慢慢磨的过程，就像走迷宫一样，虽然有时候会走错路，但那些错了的路也是知识学习的一部分。在编程的学习中不只是看结果，过程是更重要的，学会学习的方式更有意义。
      
            
      
            文章名称：关于Spring中GetBean的全流程源码解析            
      
            标题链接：http://wtcwzsj.com/article/ccceiss.html
        
    
    
      
        
      其他资讯
      
        
    
      



      



      
    

      

      
    
        
        
      • 温岭网站建设
            
        温岭网站建设
        
        
        • 
        
        •