Spring bean的加载 Spring的bean加载

• Spring的容器架构
  [Spring容器架构]
  文章图片
  

finishBeanFactoryInitialization()，注释上面写着 **Instantiate all remaining (non-lazy-init) singletons**，意味着非延迟加载的类，将在这一步实例化，完成类的加载。
加载流程：

• 从开始的getbean入口进行分析
  

  ApplicationContext context = new ClassPathXmlApplicationContext("配置文件xml"); context.getBean("bean名字");

  
  
• 1、先获取bean，调用AbstractBeanFactory的doGetBean
  doGetBean有四个参数：
  name：bean的名称
  requiredType： 返回的类型
  args： 传递的构造参数
  typeCheckOnly： 检查类型
  

  protected T doGetBean(final String name, @Nullable final Class requiredType, @Nullable final Object[] args, boolean typeCheckOnly) throws BeansException { //获取beanName，这边有三种形式，一个是原始的beanName，一个是加了&的，一个是别名 final String beanName = transformedBeanName(name); Object bean; // Eagerly check singleton cache for manually registered singletons. // 是否已经创建了 Object sharedInstance = getSingleton(beanName); //已经创建了，且没有构造参数，进入这个方法，如果有构造参数，往else走，也就是说不从获取bean，而直接创建bean if (sharedInstance != null && args == null) { if (logger.isTraceEnabled()) { if (isSingletonCurrentlyInCreation(beanName)) { logger.trace("Returning eagerly cached instance of singleton bean '" + beanName + "' that is not fully initialized yet - a consequence of a circular reference"); } else { logger.trace("Returning cached instance of singleton bean '" + beanName + "'"); } } // 如果是普通bean，直接返回，是FactoryBean，返回他的getObject bean = getObjectForBeanInstance(sharedInstance, name, beanName, null); }else { // Fail if we're already creating this bean instance: // We're assumably within a circular reference. // 没创建过bean或者是多例的情况或者有参数的情况 // 创建过Prototype的bean，会循环引用，抛出异常，单例才尝试解决循环依赖的问题 if (isPrototypeCurrentlyInCreation(beanName)) { throw new BeanCurrentlyInCreationException(beanName); }// Check if bean definition exists in this factory. BeanFactory parentBeanFactory = getParentBeanFactory(); // 父容器存在，本地没有当前beanName，从父容器取 if (parentBeanFactory != null && !containsBeanDefinition(beanName)) { // Not found -> check parent. // 处理后，如果是加&，就补上& String nameToLookup = originalBeanName(name); if (parentBeanFactory instanceof AbstractBeanFactory) { return ((AbstractBeanFactory) parentBeanFactory).doGetBean( nameToLookup, requiredType, args, typeCheckOnly); } else if (args != null) { // Delegation to parent with explicit args. return (T) parentBeanFactory.getBean(nameToLookup, args); } else if (requiredType != null) { // No args -> delegate to standard getBean method. return parentBeanFactory.getBean(nameToLookup, requiredType); } else { return (T) parentBeanFactory.getBean(nameToLookup); } }if (!typeCheckOnly) { // typeCheckOnly为false，将beanName放入alreadyCreated中 markBeanAsCreated(beanName); }try { // 获取BeanDefinition final RootBeanDefinition mbd = getMergedLocalBeanDefinition(beanName); // 抽象类检查 checkMergedBeanDefinition(mbd, beanName, args); // Guarantee initialization of beans that the current bean depends on. // 如果有依赖的情况，先初始化依赖的bean String[] dependsOn = mbd.getDependsOn(); if (dependsOn != null) { for (String dep : dependsOn) { // 检查是否循环依赖，a依赖b，b依赖a。包括传递的依赖，比如a依赖b，b依赖c，c依赖a if (isDependent(beanName, dep)) { throw new BeanCreationException(mbd.getResourceDescription(), beanName, "Circular depends-on relationship between '" + beanName + "' and '" + dep + "'"); } // 注册依赖关系 registerDependentBean(dep, beanName); try { // 初始化依赖的bean getBean(dep); } catch (NoSuchBeanDefinitionException ex) { throw new BeanCreationException(mbd.getResourceDescription(), beanName, "'" + beanName + "' depends on missing bean '" + dep + "'", ex); } } }// Create bean instance. // 如果是单例 if (mbd.isSingleton()) { sharedInstance = getSingleton(beanName, () -> { try { // 创建bean return createBean(beanName, mbd, args); } catch (BeansException ex) { // Explicitly remove instance from singleton cache: It might have been put there // eagerly by the creation process, to allow for circular reference resolution. // Also remove any beans that received a temporary reference to the bean. destroySingleton(beanName); throw ex; } }); // 如果是普通bean，直接返回，是FactoryBean，返回他的getObject bean = getObjectForBeanInstance(sharedInstance, name, beanName, mbd); }else if (mbd.isPrototype()) { // It's a prototype -> create a new instance. Object prototypeInstance = null; try { // 加入prototypesCurrentlyInCreation，说明正在创建 beforePrototypeCreation(beanName); //创建bean prototypeInstance = createBean(beanName, mbd, args); } finally { // 移除prototypesCurrentlyInCreation，说明已经创建结束 afterPrototypeCreation(beanName); } // 如果是普通bean，直接返回，是FactoryBean，返回他的getObject bean = getObjectForBeanInstance(prototypeInstance, name, beanName, mbd); }else { String scopeName = mbd.getScope(); final Scope scope = this.scopes.get(scopeName); if (scope == null) { throw new IllegalStateException("No Scope registered for scope name '" + scopeName + "'"); } try { Object scopedInstance = scope.get(beanName, () -> { beforePrototypeCreation(beanName); try { return createBean(beanName, mbd, args); } finally { afterPrototypeCreation(beanName); } }); bean = getObjectForBeanInstance(scopedInstance, name, beanName, mbd); } catch (IllegalStateException ex) { throw new BeanCreationException(beanName, "Scope '" + scopeName + "' is not active for the current thread; consider " + "defining a scoped proxy for this bean if you intend to refer to it from a singleton", ex); } } } catch (BeansException ex) { cleanupAfterBeanCreationFailure(beanName); throw ex; } }// Check if required type matches the type of the actual bean instance. if (requiredType != null && !requiredType.isInstance(bean)) { try { T convertedBean = getTypeConverter().convertIfNecessary(bean, requiredType); if (convertedBean == null) { throw new BeanNotOfRequiredTypeException(name, requiredType, bean.getClass()); } return convertedBean; } catch (TypeMismatchException ex) { if (logger.isTraceEnabled()) { logger.trace("Failed to convert bean '" + name + "' to required type '" + ClassUtils.getQualifiedName(requiredType) + "'", ex); } throw new BeanNotOfRequiredTypeException(name, requiredType, bean.getClass()); } } return (T) bean; }

  
  
• 2、获取beanName然后转换名称
  解析完配置后创建的 Map，使用的是 beanName 作为 key。见 DefaultListableBeanFactory：
  

  /** Map of bean definition objects, keyed by bean name */ private final Map beanDefinitionMap = new ConcurrentHashMap(256);

  
  BeanFactory.getBean中传入的那么，有可能是这几种情况：
  
  • 1.bean name，可以直接获取到定义 BeanDefinition。
    

    //转化bean protected T doGetBean(String name, @Nullable Class requiredType, @Nullable Object[] args, boolean typeCheckOnly) throws BeansException { String beanName = this.transformedBeanName(name); Object sharedInstance = this.getSingleton(beanName); Object bean; .......

    
    
  • 2.alias name，别名，需要转化。
    如果是 alias name，在解析阶段，alias name 和 bean name 的映射关系被注册到 SimpleAliasRegistry 中。从该注册器中取到 beanName。见 SimpleAliasRegistry.canonicalName：
    

    public String canonicalName(String name) { String canonicalName = name; String resolvedName; do { resolvedName = (String)this.aliasMap.get(canonicalName); if (resolvedName != null) { canonicalName = resolvedName; } } while(resolvedName != null); return canonicalName; }

    
    
  • 3.factorybean name, 带 & 前缀，通过它获取 BeanDefinition 的时候需要去除 & 前缀。
    如果是 factorybean name，表示这是个工厂 bean，有携带前缀修饰符 & 的，直接把前缀去掉。见 BeanFactoryUtils.transformedBeanName :
    

    public static String transformedBeanName(String name) { Assert.notNull(name, "'name' must not be null"); return !name.startsWith("&") ? name : (String)transformedBeanNameCache.computeIfAbsent(name, (beanName) -> { do { beanName = beanName.substring("&".length()); } while(beanName.startsWith("&")); return beanName; }); }

    
    
  
  文章图片
  
  
• 3、合并RootBeanDefinition（合并本地的bean）
  从配置文件读取的BeanDefinition是 GenericBeanDefinition它的记录了一些当前类声明的属性或构造参数，但是对于父类只用了一个 parentName 来记录。
  

  public class GenericBeanDefinition extends AbstractBeanDefinition { ... private String parentName; ... }

  
  实例化 Bean 的时候，使用的 BeanDefinition 是 RootBeanDefinition 类型而非 GenericBeanDefinition。
  
  • GenericBeanDefinition 在有继承关系的情况下，定义的信息不足：
    如果不存在继承关系，GenericBeanDefinition 存储的信息是完整的，可以直接转化为 RootBeanDefinition。
    如果存在继承关系，GenericBeanDefinition 存储的是 增量信息 而不是 全量信息。
    
    文章图片
    
    
    • 实际上干活的还是AbstractBeanFactory.doGetBean
      

      protected T doGetBean ... { ...// 合并父类定义 final RootBeanDefinition mbd = getMergedLocalBeanDefinition(beanName); ...// 使用合并后的定义进行实例化 bean = getObjectForBeanInstance(prototypeInstance, name, beanName, mbd); ... }

      
      
    • 在判断 parentName 存在的情况下，说明存在父类定义，启动合并。如果父类还有父类，递归调用，继续合并。
      

      protected RootBeanDefinition getMergedBeanDefinition( String beanName, BeanDefinition bd, BeanDefinition containingBd) throws BeanDefinitionStoreException {...String parentBeanName = transformedBeanName(bd.getParentName()); ...// 递归调用，继续合并父类定义 pbd = getMergedBeanDefinition(parentBeanName); ...// 使用合并后的完整定义，创建 RootBeanDefinition mbd = new RootBeanDefinition(pbd); // 使用当前定义，对 RootBeanDefinition 进行覆盖 mbd.overrideFrom(bd); ... return mbd; }

      
      每次合并完父类定义后，都会调用 RootBeanDefinition.overrideFrom 对父类的定义进行覆盖，获取到当前类能够正确实例化的 全量信息。
      
  • 解决循环依赖的问题（暂时说一下，以后详细分析）
    假设TestA中需要注入TestB，TestB中需要注入TestA。
    对象创建成功后，会在singletonFactories中保存一个对象工厂ObjectFactory，调用这个ObjectFactory的getObject()就可以在任何地方获取刚创建的对象。
    这样当TestB在获取TestA的时候，发现singletonFactories中有个工厂可以获取到TestA，那么就直接调用他，最后会进入下面这个方法
    

    protected Object getEarlyBeanReference(String beanName, RootBeanDefinition mbd, Object bean) { Object exposedObject = bean; if (!mbd.isSynthetic() && hasInstantiationAwareBeanPostProcessors()) { List smartInstantiationAware = getBeanPostProcessorCache().smartInstantiationAware; for (SmartInstantiationAwareBeanPostProcessor bp : getBeanPostProcessorCache().smartInstantiationAware) { exposedObject = bp.getEarlyBeanReference(exposedObject, beanName); } } return exposedObject; }

    
    所有实现了SmartInstantiationAwareBeanPostProcessor接口类的getEarlyBeanReference()尝试做最后的修改，这个方法返回的只是传递过来的对象。
    这样依赖循环就解决了。
    
• 4、创建实例
  获取到完整的 RootBeanDefintion 后，就可以拿这份定义信息来实例具体的 Bean。（创建实例由AbstractAutowireCapableBeanFactory接手，在spring容器架构里面有具体内容）
  源码解析：具体实例创建见 AbstractAutowireCapableBeanFactory.createBeanInstance
  

  //调用解析方法解析转进来的Bean Class beanClass = this.resolveBeanClass(mbd, beanName, new Class[0]); //如果传入的不为空并且修饰符不是公开的（获取两个对象的修饰权限）也就是不为空的时判断是否有他们的访问权限 if (beanClass != null && !Modifier.isPublic(beanClass.getModifiers()) && !mbd.isNonPublicAccessAllowed()) { throw new BeanCreationException(mbd.getResourceDescription(), beanName, "Bean class isn't public, and non-public access not allowed: " + beanClass.getName()); } else { //是否有其他的类将本地bean实例了 Supplier instanceSupplier = mbd.getInstanceSupplier(); //如果不为空就就意味着他已经被实例化直接返回已经被其他调用者实例化方法 if (instanceSupplier != null) { return this.obtainFromSupplier(instanceSupplier, beanName); //如果不为空就意味着被工厂方法调用实例化直接返回方法，被工厂方法使用实例化了 } else if (mbd.getFactoryMethodName() != null) { return this.instantiateUsingFactoryMethod(beanName, mbd, args); } else { // 判断是否已经解析过了 boolean resolved = false; // 为false说明无参，true有参 boolean autowireNecessary = false; if (args == null) { synchronized(mbd.constructorArgumentLock) { //如果已经被解析过了 if (mbd.resolvedConstructorOrFactoryMethod != null) { resolved = true; autowireNecessary = mbd.constructorArgumentsResolved; } } } // 解析过了，根据是否有参数选择无参构造还是有参构造 if (resolved) { return autowireNecessary ? this.autowireConstructor(beanName, mbd, (Constructor[])null, (Object[])null) : this.instantiateBean(beanName, mbd); } // 根据bean的定义解析参数 else { Constructor[] ctors = this.determineConstructorsFromBeanPostProcessors(beanClass, beanName); if (ctors == null && mbd.getResolvedAutowireMode() != 3 && !mbd.hasConstructorArgumentValues() && ObjectUtils.isEmpty(args)) { ctors = mbd.getPreferredConstructors(); return ctors != null ? this.autowireConstructor(beanName, mbd, ctors, (Object[])null) : this.instantiateBean(beanName, mbd); } //构造器注入 else { return this.autowireConstructor(beanName, mbd, ctors, args); } } } } }

  
  
  • 返回 Bean 的包装类 BeanWrapper，一共有三种策略：
    
    • 使用工厂方法创建，instantiateUsingFactoryMethod 。
      使用工厂方法创建，会先使用 getBean 获取工厂类，然后通过参数找到匹配的工厂方法，调用实例化方法实现实例化，具体见ConstructorResolver.instantiateUsingFactoryMethod ：
      

      public BeanWrapper instantiateUsingFactoryMethod ... ( ... String factoryBeanName = mbd.getFactoryBeanName(); ... factoryBean = this.beanFactory.getBean(factoryBeanName); ... // 匹配正确的工厂方法 ... beanInstance = this.beanFactory.getInstantiationStrategy().instantiate(...); ... bw.setBeanInstance(beanInstance); return bw; }

      
      
    • 使用无参构造函数创建，instantiateBean。
      使用无参构造函数创建是最简单的方式，见 AbstractAutowireCapableBeanFactory.instantiateBean:
      

      protected BeanWrapper instantiateBean(final String beanName, final RootBeanDefinition mbd) { try { Object beanInstance; final BeanFactory parent = this; if (System.getSecurityManager() != null) { beanInstance = AccessController.doPrivileged((PrivilegedAction