13、Spring5.x源码之旅十三finishBeanFactoryInitialization和getMergedLocalBeanDefinition

  • 完成BeanFactory的初始化
    • DefaultListableBeanFactory的preInstantiateSingletons
    • FactoryBean实战例子
    • getMergedLocalBeanDefinition合并bean定义
    • 什么时候需要设置合并呢
    • 合并总结

完成BeanFactory的初始化

前面已经分析完invokeBeanFactoryPostProcessorsregisterBeanPostProcessors了,然后中间的一些不是核心的暂时略过,最后剩下最核心的一块,这里面是进行单例的bean创建了,也是最核心的地方,我们慢慢分析吧,省略了非核心代码,其实就只剩一句代码了。

protected void finishBeanFactoryInitialization(ConfigurableListableBeanFactory beanFactory) {
   
     
		...
		//准备实例化单例
		// Instantiate all remaining (non-lazy-init) singletons.
		beanFactory.preInstantiateSingletons();
	}

DefaultListableBeanFactory的preInstantiateSingletons

首先会获取所有的beanDefinitionNames,然后创建一个副本,避免在使用的时候有改变。然后遍历bean名字,如果非抽象,非懒加载的单例实例,如果是FactoryBean的话,就获取FactoryBean实例,如果获取到了这个实例,就判断是否需要立即加载FactoryBean中创建的实例,默认是不创建的,需要的时候创建。这里要注意获取FactoryBean自身的名字是beanName前面加&符号,如果是获取FactoryBean创建的实例,名字就是beanName。如果不是FactoryBean类型的,就直接去获取。
*
获取完成后,所有单例还要进行处理器处理,如果是SmartInitializingSingleton 类型的,就进行afterSingletonsInstantiated的调用。

@Override
	public void preInstantiateSingletons() throws BeansException {
   
     
		...
		List<String> beanNames = new ArrayList<>(this.beanDefinitionNames);//创建一个副本,让原始的还能继续注册bean定义
		//触发非懒加载的单例bean初始化
		for (String beanName : beanNames) {
   
     
			RootBeanDefinition bd = getMergedLocalBeanDefinition(beanName);//合并父类的bean定义
			if (!bd.isAbstract() && bd.isSingleton() && !bd.isLazyInit()) {
   
     //非抽象,单例,非懒加载
				if (isFactoryBean(beanName)) {
   
     //是否是FactoryBean类型的,是的话要加前缀获取
					Object bean = getBean(FACTORY_BEAN_PREFIX + beanName);//获取FactoryBean
					if (bean instanceof FactoryBean) {
   
     
						final FactoryBean<?> factory = (FactoryBean<?>) bean;
						boolean isEagerInit;//是否需要立即创建FactoryBean中的bean
						if (System.getSecurityManager() != null && factory instanceof SmartFactoryBean) {
   
     
							isEagerInit = AccessController.doPrivileged((PrivilegedAction<Boolean>)
											((SmartFactoryBean<?>) factory)::isEagerInit,
									getAccessControlContext());
						}
						else {
   
     
							isEagerInit = (factory instanceof SmartFactoryBean &&
									((SmartFactoryBean<?>) factory).isEagerInit());
						}
						if (isEagerInit) {
   
     
							getBean(beanName);
						}
					}
				}
				else {
   
     //非FactoryBean
					getBean(beanName);
				}
			}
		}
		//所有单例的还要进行处理器处理
		for (String beanName : beanNames) {
   
     
			Object singletonInstance = getSingleton(beanName);
			if (singletonInstance instanceof SmartInitializingSingleton) {
   
     
				final SmartInitializingSingleton smartSingleton = (SmartInitializingSingleton) singletonInstance;
				if (System.getSecurityManager() != null) {
   
     
					AccessController.doPrivileged((PrivilegedAction<Object>) () -> {
						smartSingleton.afterSingletonsInstantiated();
						return null;
					}, getAccessControlContext());
				}
				else {
   
     
					smartSingleton.afterSingletonsInstantiated();
				}
			}
		}
	}

FactoryBean实战例子

创建一个FactoryBean类,UserDao就是一个接口,UserDaoImple是实现类。

@Component
public class TestFactoryBean implements FactoryBean<UserDao> {
   
     
	@Override
	public UserDao getObject() throws Exception {
   
     
		return new UserDaoImple();
	}

	@Override
	public Class<?> getObjectType() {
   
     
		return UserDao.class;
	}
}

测试一–获取testFactoryBean,获取的是TestFactoryBeangetObject()创建的实例:

 @Test
    public void FactoryBeanTest() {
   
     
        AnnotationConfigApplicationContext applicationContext = new AnnotationConfigApplicationContext();
        applicationContext.register(TestFactoryBean.class);
        applicationContext.refresh();
        Object obj=  applicationContext.getBean("testFactoryBean");
        System.out.println(obj);
    }

*
测试二–获取&testFactoryBean,获取TestFactoryBean自身:

 @Test
    public void FactoryBeanTest() {
   
     
        AnnotationConfigApplicationContext applicationContext = new AnnotationConfigApplicationContext();
        applicationContext.register(TestFactoryBean.class);
        applicationContext.refresh();
        Object obj=  applicationContext.getBean("&testFactoryBean");
        System.out.println(obj);
    }

*

getMergedLocalBeanDefinition合并bean定义

其实这个很早就有了,前面没讲,现在讲比较合适。为什么要有这个,不是都有bean定义了么,我想这个可能是为了要统一处理,很多地方都是获取合并后bean定义的来处理的,因为bean定义可能会被修改,处理的时候又想处理最新的,那就需要将可能修改的bean定义再一次合并成统一的RootBeanDefinition。因为BeanDefinition有不同的实现类,但是肯定会有一个比较全面的子类,就是RootBeanDefinition,而且他还提供了深拷贝的构造函数和克隆方法,可以传入其他BeanDefinition子类并创建一个新的RootBeanDefinition来进行属性的深拷贝。
*
*
我们来看这个方法的源码,先从合并的定义中获取,如果发现存在,且不需要合并了就直接返回,否则就进行合并。stale属性表示是否要进行合并,默认是需要的。

	protected RootBeanDefinition getMergedLocalBeanDefinition(String beanName) throws BeansException {
   
     
		// Quick check on the concurrent map first, with minimal locking.
		RootBeanDefinition mbd = this.mergedBeanDefinitions.get(beanName);
		if (mbd != null && !mbd.stale) {
   
     //存在且不需要合并的话就直接返回
			return mbd;
		}
		return getMergedBeanDefinition(beanName, getBeanDefinition(beanName));
	}

什么时候需要设置合并呢

那什么时候stale=true呢,也就是说是需要进行合并,我们来看看,首先是AbstractBeanFactoryclearMergedBeanDefinition
*
那他在哪里被用到呢,在AbstractBeanFactorymarkBeanAsCreated,而且这里注释说了,让他重新合并一下,因为我们为统一处理,都是那合并的来判断的,所以这个时候要进行创建了,得需要最新的bean定义,所以要进行合并一次,获取到最新的bean定义:
*
另外一个地方是invokeBeanFactoryPostProcessors的最后:
*
*
*
也就是说BeanFactoryPostProcessor处理器完之后,bean定义可能会有变化,所以我需要重新合并,以保证合并的是最新的

合并总结

总结下为什么要合并,简单的说就是spring希望处理bean的定义能统一,但是很多bean定义是不同的子类实现类,而且可能被处理器修改,所以spring就需要在访问bean定义的时候进行合并,一方面合并最新的定义,一方面可以统一处理,其实是我猜的。

写了那么多,好像就讲了几个放大,惭愧啊,不过没关系,能理解就好,也不算我白写了,后面的我们下次继续吧。

好了,今天就到这里了,希望对学习理解有帮助,大神看见勿喷,仅为自己的学习理解,能力有限,请多包涵。