当前位置 博文首页 > bugstack虫洞栈:关于 Spring 中 getBean 的全流程源码解析

    bugstack虫洞栈:关于 Spring 中 getBean 的全流程源码解析

    作者:[db:作者] 时间:2021-08-12 15:09


    作者:小傅哥
    博客:https://bugstack.cn

    沉淀、分享、成长,让自己和他人都能有所收获!😄

    一、前言

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

    最近有粉丝小伙伴反馈,与自己的上级沟通总是遇到障碍,感觉不被理解。大部分时候他提出来的事情都可能会被领导说:“我没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 从哪开始读源码

    @Test
    public void test_getBean() {
        BeanFactory beanFactory = new ClassPathXmlApplicationContext("spring-config.xml");
        UserDao userDao = beanFactory.getBean("userDao", UserDao.class);
        logger.info("获取 Bean:{}", userDao);
    }
    
    • 在日常应用到 Spring 的开发中基本都是基于注解,几乎不会自己去使用 beanFactory.getBean 的方式去获取一个 Bean 实例。
    • 所以在你学习的时候如果找不到查看 getBean 源码的入口,也不方便调试熟悉源码时,可以写这样一个单元测试类,点入到 getBean 就可以阅读源码了。

    3. getBean 源码全局预览

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

    @Override
    public <T> T getBean(String name, Class<T> requiredType) throws BeansException { 
        // getBean 就像你的领导其实没做啥,都在 doGetBean 里
    	return doGetBean(name, requiredType, null, false);
    }
    
    protected <T> T doGetBean(final String name, final Class<T> requiredType, final Object[] args, boolean typeCheckOnly)
    		throws BeansException {     
        
        // 处理别名BeanName、处理带&符的工厂BeanName
    	final String beanName = transformedBeanName(name);
    	Object bean;  
    
    	// 先尝试从缓存中获取Bean实例,这个位置就是三级缓存解决循环依赖的方法
    	Object sharedInstance = getSingleton(beanName);   
    
    	if (sharedInstance != null && args == null) {
    		if (logger.isDebugEnabled()) {
    			if (isSingletonCurrentlyInCreation(beanName)) {
    				logger.debug("Returning eagerly cached instance of singleton bean '" + beanName +
    						"' that is not fully initialized yet - a consequence of a circular reference");
    			}
    			else {
    				logger.debug("Returning cached instance of singleton bean '" + beanName + "'");
    			}
    		}        
            
            // 1. 如果 sharedInstance 是普通的 Bean 实例,则下面的方法会直接返回
            // 2. 如果 sharedInstance 是工厂Bean类型,则需要获取 getObject 方法,可以参考关于 FactoryBean 的实现类 
    		bean = getObjectForBeanInstance(sharedInstance, name, beanName, null);
    	}
    	else {
    		
            // 循环依赖有三种,setter注入、多实例和构造函数,Spring 只能解决 setter 注入,所以这里是 Prototype 则会抛出异常
    		if (isPrototypeCurrentlyInCreation(beanName)) {
    			throw new BeanCurrentlyInCreationException(beanName);
    		}    
    
    		// 1. 父 bean 工厂存在
            // 2. 当前 bean 不存在于当前bean工厂,则到父工厂查找 bean 实例
    		BeanFactory parentBeanFactory = getParentBeanFactory();
    		if (parentBeanFactory != null && !containsBeanDefinition(beanName)) {
    			// 获取 name 对应的 beanName,如果 name 是以 & 开头,则返回 & + beanName
    			String nameToLookup = originalBeanName(name);         
                
                // 根据 args 参数是否为空,调用不同的父容器方法获取 bean 实例
    			if (args != null) {
    				return (T) parentBeanFactory.getBean(nameToLookup, args);
    			}
    			else {
    				return parentBeanFactory.getBean(nameToLookup, requiredType);
    			}
    		}       
    
            // 1. typeCheckOnly,用于判断调用 getBean 方法时,是否仅是做类型检查
            // 2. 如果不是只做类型检查,就会调用 markBeanAsCreated 进行记录
    		if (!typeCheckOnly) {
    			markBeanAsCreated(beanName);
    		}
    		try {    
        
                // 从容器 getMergedLocalBeanDefinition 获取 beanName 对应的 GenericBeanDefinition,转换为 RootBeanDefinition
    			final RootBeanDefinition mbd = getMergedLocalBeanDefinition(beanName); 
                // 检查当前创建的 bean 定义是否为抽象 bean 定义
    			checkMergedBeanDefinition(mbd, beanName, args);
    			
                // 处理使用了 depends-on 注解的依赖创建 bean 实例
    			String[] dependsOn = mbd.getDependsOn();
    			if (dependsOn != null) {
    				for (String dep : dependsOn) {   
                        // 监测是否存在 depends-on 循环依赖,若存在则会抛出异常
    					if (isDependent(beanName, dep)) {
    						throw new BeanCreationException(mbd.getResourceDescription(), beanName,
    								"Circular depends-on relationship between '" + beanName + "' and '" + dep + "'");
    					}       
                        
                        // 注册依赖记录
    					registerDependentBean(dep, beanName);
    					try {    
    					    // 加载 depends-on 依赖(dep 是 depends-on 缩写)
    						getBean(dep);
    					}
    					catch (NoSuchBeanDefinitionException ex) {
    						throw new BeanCreationException(mbd.getResourceDescription(), beanName,
    								"'" + beanName + "' depends on missing bean '" + dep + "'", ex);
    					}
    				}
    			}  
    
    			// 创建单例 bean 实例
    			if (mbd.isSingleton()) {    
    
    			    // 把 beanName 和 new ObjectFactory 匿名内部类传入回调
    				sharedInstance = getSingleton(beanName, new ObjectFactory<Object>() {
    					@Override
    					public Object getObject() throws BeansException {
    						try {    
                                // 创建 bean
    							return createBean(beanName, mbd, args);
    						}
    						catch (BeansException ex) {
    							// 创建失败则销毁
    							destroySingleton(beanName);
    							throw ex;
    						}
    					}
    				});
    				bean = getObjectForBeanInstance(sharedInstance, name, beanName, mbd);
    			}      
                // 创建其他类型的 bean 实例
    			else if (mbd.isPrototype()) {
    				// It's a prototype -> create a new instance.
    				Object prototypeInstance = null;
    				try {
    					beforePrototypeCreation(beanName);
    					prototypeInstance = createBean(beanName, mbd, args);
    				}
    				finally {
    					afterPrototypeCreation(beanName);
    				}
    				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, new ObjectFactory<Object>() {
    						@Override
    						public Object getObject() throws BeansException {
    							beforePrototypeCreation(beanName);
    							try {
    								return createBean(beanName, mbd, args);
    							}
    							finally {
    								afterPrototypeCreation(beanName);
    							}
    						}
    					});
    					bean = getObjectForBeanInstance(scopedInstance, name, beanName, mbd);
    				}
    				catch (
    
    下一篇:没有了