------------------2020.7.27
bean 创建的三步走:
org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory createBean() --> doCreateBean() 1. createBeanInstance() // 通过反射创建 bean 的实例 2. populateBean() // 填充 bean 里面的属性值,包括 @AutoWired、@Resource、@Value 标记的属性 3. initializeBean() // 对 bean 进行初始化工作,包括一些初始化方法的执行,如:awareMethods、BeanPostProcessor、initMethods // 参考方法:AbstractAutowireCapableBeanFactory#initializeBean() // 其中,@ConfigurationProperties 标记的 bean 的属性注入,就选择了使用 BeanPostProcessor 来处理 // 具体的处理可查看 ConfigurationPropertiesBindingPostProcessor#postProcessBeforeInitialization()
-------------------2020.1.6
Spring Bean 的初始化是在 Spring 容器 refresh() 时进行的。
Spring 容器 refresh 时会调用 finishBeanFactoryInitialization() 来初始化所有非延迟加载的 bean。
1 org.springframework.context.support.AbstractApplicationContext.refresh() 2 --> org.springframework.context.support.AbstractApplicationContext.finishBeanFactoryInitialization // 初始化bean(延迟加载除外) 3 --> org.springframework.beans.factory.config.ConfigurableListableBeanFactory.preInstantiateSingletons() 4 --> org.springframework.beans.factory.support.AbstractBeanFactory.getBean 5 --> org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean 6 --> org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBean // 创建 bean(实例化 bean)
1. org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean
0. pre: 如果 bean 已经注册过,就从缓存中获取 bean 的实例
1. 在 parentBeanFactory 中如果存在 beanName,则直接返回父容器里面的 bean
2. 初始化当前 bean 依赖的 bean
3. 创建 bean 的实例
3.1 单例类型的 bean 创建
3.2 原型类型的 bean 创建
3.3 其他 scope 类型(request、session等)的 bean 创建
4. 将新创建的 bean 的实例保存到缓存 singletonObjects 中
1 protected <T> T doGetBean(final String name, @Nullable final Class<T> requiredType, @Nullable final Object[] args, boolean typeCheckOnly) throws BeansException { 2 3 final String beanName = transformedBeanName(name); 4 Object bean; 5 6 // Eagerly check singleton cache for manually registered singletons. 7 // 从缓存中获取 bean 的实例(已经注册过的 bean 都保存在 singletonObjects 中) 8 Object sharedInstance = getSingleton(beanName); 9 if (sharedInstance != null && args == null) { 10 bean = getObjectForBeanInstance(sharedInstance, name, beanName, null); 11 } else { 12 13 // Check if bean definition exists in this factory. 14 // 1. 在 parentBeanFactory 中如果存在 beanName,则直接返回父容器里面的 bean 15 BeanFactory parentBeanFactory = getParentBeanFactory(); 16 if (parentBeanFactory != null && !containsBeanDefinition(beanName)) { 17 // Not found -> check parent. 18 String nameToLookup = originalBeanName(name); 19 if (parentBeanFactory instanceof AbstractBeanFactory) { 20 return ((AbstractBeanFactory) parentBeanFactory).doGetBean( 21 nameToLookup, requiredType, args, typeCheckOnly); 22 } else if (args != null) { 23 // Delegation to parent with explicit args. 24 return (T) parentBeanFactory.getBean(nameToLookup, args); 25 } else if (requiredType != null) { 26 // No args -> delegate to standard getBean method. 27 return parentBeanFactory.getBean(nameToLookup, requiredType); 28 } else { 29 return (T) parentBeanFactory.getBean(nameToLookup); 30 } 31 } 32 33 try { 34 final RootBeanDefinition mbd = getMergedLocalBeanDefinition(beanName); 35 checkMergedBeanDefinition(mbd, beanName, args); 36 37 // Guarantee initialization of beans that the current bean depends on. 38 // 2. 初始化当前 bean 依赖的 bean 39 String[] dependsOn = mbd.getDependsOn(); 40 if (dependsOn != null) { 41 for (String dep : dependsOn) { 42 if (isDependent(beanName, dep)) { 43 throw new BeanCreationException(mbd.getResourceDescription(), beanName, "Circular depends-on relationship between '" + beanName + "' and '" + dep + "'"); 44 } 45 registerDependentBean(dep, beanName); 46 try { 47 // getBean() 会再递归调用 doGetBean(),以确保所依赖的 bean 全部初始化 48 getBean(dep); 49 } 50 catch (NoSuchBeanDefinitionException ex) { 51 throw new BeanCreationException(mbd.getResourceDescription(), beanName, "'" + beanName + "' depends on missing bean '" + dep + "'", ex); 52 } 53 } 54 } 55 56 // Create bean instance. 57 // 3. 创建 bean 的实例 58 if (mbd.isSingleton()) { // 单例类型的 bean 59 sharedInstance = getSingleton(beanName, () -> { 60 try { 61 // 创建 bean 的实例 62 return createBean(beanName, mbd, args); 63 } catch (BeansException ex) { 64 destroySingleton(beanName); 65 throw ex; 66 } 67 }); 68 // 如果 bean 为 FactoryBean 的话,则调用 FactoryBean.getObject() 来创建 bean 实例 69 bean = getObjectForBeanInstance(sharedInstance, name, beanName, mbd); 70 } else if (mbd.isPrototype()) { // 原型类型的 bean 71 // It's a prototype -> create a new instance. 72 Object prototypeInstance = null; 73 try { 74 beforePrototypeCreation(beanName); 75 prototypeInstance = createBean(beanName, mbd, args); 76 } finally { 77 afterPrototypeCreation(beanName); 78 } 79 bean = getObjectForBeanInstance(prototypeInstance, name, beanName, mbd); 80 } else { // 其他 scope 类型的 bean 81 String scopeName = mbd.getScope(); 82 final Scope scope = this.scopes.get(scopeName); 83 if (scope == null) { 84 throw new IllegalStateException("No Scope registered for scope name '" + scopeName + "'"); 85 } 86 try { 87 Object scopedInstance = scope.get(beanName, () -> { 88 beforePrototypeCreation(beanName); 89 try { 90 return createBean(beanName, mbd, args); 91 } finally { 92 afterPrototypeCreation(beanName); 93 } 94 }); 95 bean = getObjectForBeanInstance(scopedInstance, name, beanName, mbd); 96 } catch (IllegalStateException ex) { 97 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); 98 } 99 } 100 } 101 catch (BeansException ex) { 102 cleanupAfterBeanCreationFailure(beanName); 103 throw ex; 104 } 105 } 106 107 ...... 108 return (T) bean; 109 }
2. org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBean
1 protected Object createBean(String beanName, RootBeanDefinition mbd, @Nullable Object[] args) 2 throws BeanCreationException { 3 4 RootBeanDefinition mbdToUse = mbd; 5 ...... 6 7 // Give BeanPostProcessors a chance to return a proxy instead of the target bean instance. 8 // BeanPostProcessor 可以创建一个代理 bean 返回 9 // 执行 InstantiationAwareBeanPostProcessor.postProcessBeforeInstantiation -- bean 实例化前置处理 10 // 执行 InstantiationAwareBeanPostProcessor.postProcessAfterInitialization -- bean 初始化后置处理 11 Object bean = resolveBeforeInstantiation(beanName, mbdToUse); 12 if (bean != null) { 13 return bean; 14 } 15 16 // 创建 bean 17 Object beanInstance = doCreateBean(beanName, mbdToUse, args); 18 return beanInstance; 19 }
代理 bean 是通过 AbstractAutoProxyCreator 来创建的:
org.springframework.aop.framework.autoproxy.AbstractAutoProxyCreator.postProcessBeforeInstantiation(Class<?> beanClass, String beanName)
1 public Object postProcessBeforeInstantiation(Class<?> beanClass, String beanName) { 2 Object cacheKey = getCacheKey(beanClass, beanName); 3 4 if (!StringUtils.hasLength(beanName) || !this.targetSourcedBeans.contains(beanName)) { 5 if (this.advisedBeans.containsKey(cacheKey)) { 6 return null; 7 } 8 if (isInfrastructureClass(beanClass) || shouldSkip(beanClass, beanName)) { 9 this.advisedBeans.put(cacheKey, Boolean.FALSE); 10 return null; 11 } 12 } 13 14 // Create proxy here if we have a custom TargetSource. 15 // Suppresses unnecessary default instantiation of the target bean: 16 // The TargetSource will handle target instances in a custom fashion. 17 TargetSource targetSource = getCustomTargetSource(beanClass, beanName); 18 if (targetSource != null) { 19 if (StringUtils.hasLength(beanName)) { 20 this.targetSourcedBeans.add(beanName); 21 } 22 Object[] specificInterceptors = getAdvicesAndAdvisorsForBean(beanClass, beanName, targetSource); 23 Object proxy = createProxy(beanClass, beanName, specificInterceptors, targetSource); 24 this.proxyTypes.put(cacheKey, proxy.getClass()); 25 return proxy; 26 } 27 28 return null; 29 }