电脑知识|欧美黑人一区二区三区|软件|欧美黑人一级爽快片淫片高清|系统|欧美黑人狂野猛交老妇|数据库|服务器|编程开发|网络运营|知识问答|技术教程文章 - 好吧啦网

您的位置:首頁技術文章
文章詳情頁

Spring IOC原理補充說明(循環依賴、Bean作用域等)

瀏覽:43日期:2023-08-18 18:31:05

前言

通過之前的幾篇文章將Spring基于XML配置的IOC原理分析完成,但其中還有一些比較重要的細節沒有分析總結,比如循環依賴的解決、作用域的實現原理、BeanPostProcessor的執行時機以及SpringBoot零配置實現原理(@ComponentScan、@Import、@ImportSource、@Bean注解的使用和解析)等等。下面就先來看看循環依賴是怎么解決的,在此之前一定要熟悉整個Bean的實例化過程,本篇只會貼出關鍵性代碼。

正文

循環依賴

首先來看幾個問題:

什么是循環依賴?

在熟悉了Bean實例化原理后,你會怎么解決循環依賴的問題?

Spring怎么解決循環依賴?有哪些循環依賴可以被解決?哪些又不能?

什么是循環依賴?

這個概念很容易理解,簡單說就是兩個類相互依賴,類似線程死鎖的問題,也就是當創建A對象時需要注入B的依賴對象,但B同時也依賴A,那到底該先創建A還是先創建B呢?

Spring是如何解決循環依賴的?

探究Spring的解決方法之前,我們首先得搞清楚Spring Bean有幾種依賴注入的方式:

通過構造函數

通過屬性

通過方法(不一定是setter方法,只要在方法上加上了@Autowired,都會進行依賴注入)

其次,Spring作用域有singleton、prototype、request、session等等,但在非單例模式下發生循環依賴是會直接拋出異常的,下面這個代碼不知道你還有沒有印象,在AbstractBeanFactory.doGetBean中有這個判斷:

if (isPrototypeCurrentlyInCreation(beanName)) { throw new BeanCurrentlyInCreationException(beanName);}

為什么這么設計呢?反過來想,如果不這么設計,你怎么知道循環依賴到底是依賴的哪個對象呢?搞清楚了這個再來看哪些依賴注入的方式發生循環依賴是可以解決,而那些又不能。結論是構造函數方式沒辦法解決循環依賴,其它兩種都可以。

我們先來看看為什么通過屬性注入和方法注入可以解決。回憶一下Bean的實例化過程:

protected Object doCreateBean(final String beanName, final RootBeanDefinition mbd, final @Nullable Object[] args) throws BeanCreationException { // Instantiate the bean. BeanWrapper instanceWrapper = null; if (mbd.isSingleton()) { instanceWrapper = this.factoryBeanInstanceCache.remove(beanName); } if (instanceWrapper == null) { //創建實例 instanceWrapper = createBeanInstance(beanName, mbd, args); } final Object bean = instanceWrapper.getWrappedInstance(); Class<?> beanType = instanceWrapper.getWrappedClass(); if (beanType != NullBean.class) { mbd.resolvedTargetType = beanType; } // Allow post-processors to modify the merged bean definition. synchronized (mbd.postProcessingLock) { if (!mbd.postProcessed) { try { // Bean實例化完成后收集類中的注解(@PostConstruct,@PreDestroy,@Resource, @Autowired,@Value) applyMergedBeanDefinitionPostProcessors(mbd, beanType, beanName); } catch (Throwable ex) { throw new BeanCreationException(mbd.getResourceDescription(), beanName, 'Post-processing of merged bean definition failed', ex); } mbd.postProcessed = true; } } // Eagerly cache singletons to be able to resolve circular references // even when triggered by lifecycle interfaces like BeanFactoryAware. // 單例bean提前暴露 boolean earlySingletonExposure = (mbd.isSingleton() && this.allowCircularReferences && isSingletonCurrentlyInCreation(beanName)); if (earlySingletonExposure) { if (logger.isTraceEnabled()) { logger.trace('Eagerly caching bean ’' + beanName + '’ to allow for resolving potential circular references'); } //這里著重理解,對理解循環依賴幫助非常大,重要程度 5 添加三級緩存 addSingletonFactory(beanName, () -> getEarlyBeanReference(beanName, mbd, bean)); } // Initialize the bean instance. Object exposedObject = bean; try { //ioc di,依賴注入的核心方法,該方法必須看 populateBean(beanName, mbd, instanceWrapper); //bean 實例化+ioc依賴注入完以后的調用,非常重要 exposedObject = initializeBean(beanName, exposedObject, mbd); } catch (Throwable ex) { if (ex instanceof BeanCreationException && beanName.equals(((BeanCreationException) ex).getBeanName())) { throw (BeanCreationException) ex; } else { throw new BeanCreationException( mbd.getResourceDescription(), beanName, 'Initialization of bean failed', ex); } } if (earlySingletonExposure) { Object earlySingletonReference = getSingleton(beanName, false); if (earlySingletonReference != null) { if (exposedObject == bean) { exposedObject = earlySingletonReference; } else if (!this.allowRawInjectionDespiteWrapping && hasDependentBean(beanName)) { String[] dependentBeans = getDependentBeans(beanName); Set<String> actualDependentBeans = new LinkedHashSet<>(dependentBeans.length); for (String dependentBean : dependentBeans) { if (!removeSingletonIfCreatedForTypeCheckOnly(dependentBean)) { actualDependentBeans.add(dependentBean); } } if (!actualDependentBeans.isEmpty()) { throw new BeanCurrentlyInCreationException(beanName, 'Bean with name ’' + beanName + '’ has been injected into other beans [' + StringUtils.collectionToCommaDelimitedString(actualDependentBeans) + '] in its raw version as part of a circular reference, but has eventually been ' + 'wrapped. This means that said other beans do not use the final version of the ' + 'bean. This is often the result of over-eager type matching - consider using ' + '’getBeanNamesOfType’ with the ’allowEagerInit’ flag turned off, for example.'); } } } } // Register bean as disposable. try { //注冊bean銷毀時的類DisposableBeanAdapter registerDisposableBeanIfNecessary(beanName, bean, mbd); } catch (BeanDefinitionValidationException ex) { throw new BeanCreationException( mbd.getResourceDescription(), beanName, 'Invalid destruction signature', ex); } return exposedObject; }

仔細看這個過程其實不難理解,首先Spring會通過無參構造實例化一個空的A對象,實例化完成后會調用addSingletonFactory存入到三級緩存中(注意這里存入的是singletonFactory對象):

protected void addSingletonFactory(String beanName, ObjectFactory<?> singletonFactory) { Assert.notNull(singletonFactory, 'Singleton factory must not be null'); synchronized (this.singletonObjects) { // 一級緩存 if (!this.singletonObjects.containsKey(beanName)) { System.out.println('========set value to 3 level cache->beanName->' + beanName + '->value->' + singletonFactory); // 三級緩存 this.singletonFactories.put(beanName, singletonFactory); // 二級緩存 this.earlySingletonObjects.remove(beanName); this.registeredSingletons.add(beanName); } } }

然后才會去依賴注入觸發類B的實例化,所以這時緩存中已經存在了一個空的A對象;同樣B也是通過無參構造實例化,B依賴注入又調用getBean獲取A的實例,而在創建對象之前,先是從緩存中獲取對象:

//從緩存中拿實例 Object sharedInstance = getSingleton(beanName); protected Object getSingleton(String beanName, boolean allowEarlyReference) { //根據beanName從緩存中拿實例 //先從一級緩存拿 Object singletonObject = this.singletonObjects.get(beanName); //如果bean還正在創建,還沒創建完成,其實就是堆內存有了,屬性還沒有DI依賴注入 if (singletonObject == null && isSingletonCurrentlyInCreation(beanName)) { synchronized (this.singletonObjects) { //從二級緩存中拿 singletonObject = this.earlySingletonObjects.get(beanName); //如果還拿不到,并且允許bean提前暴露 if (singletonObject == null && allowEarlyReference) { //從三級緩存中拿到對象工廠 ObjectFactory<?> singletonFactory = this.singletonFactories.get(beanName); if (singletonFactory != null) { //從工廠中拿到對象 singletonObject = singletonFactory.getObject(); //升級到二級緩存 System.out.println('======get instance from 3 level cache->beanName->' + beanName + '->value->' + singletonObject ); this.earlySingletonObjects.put(beanName, singletonObject); //刪除三級緩存 this.singletonFactories.remove(beanName); } } } } return singletonObject; }

很明顯,會從三級緩存中拿到singletonFactory對象并調用getObject方法,這是一個Lambda表達式,在表達式中又調用了getEarlyBeanReference方法:

protected Object getEarlyBeanReference(String beanName, RootBeanDefinition mbd, Object bean) { Object exposedObject = bean; if (!mbd.isSynthetic() && hasInstantiationAwareBeanPostProcessors()) { for (BeanPostProcessor bp : getBeanPostProcessors()) { if (bp instanceof SmartInstantiationAwareBeanPostProcessor) { SmartInstantiationAwareBeanPostProcessor ibp = (SmartInstantiationAwareBeanPostProcessor) bp; exposedObject = ibp.getEarlyBeanReference(exposedObject, beanName); } } } return exposedObject; }

這里你點進去看會發現都是返回之前我們創建的空的A對象,因此B對象能夠依賴注入完成并存入到一級緩存中,接著A對象繼續未完成的依賴注入自然是可以成功的,也存入到一級緩存中。Spring就是這樣通過緩存解決了循環依賴,但是不知道你注意到沒有在上面的getSingleton方法中,從三級緩存中拿到對象后,會添加到二級緩存并刪除三級緩存,這是為什么呢?這個二級緩存有什么用呢?

其實也很簡單,就是為了提高效率的,因為在getEarlyBeanReference方法中是循環調用BeanPostProcessor類的方法的,當只有一對一的依賴時沒有什么問題,但是當A和B相互依賴,A又和C相互依賴,A在注入完B觸發C的依賴注入時,這個循環還有必要么?讀者們可以自行推演一下整個過程。

至此,Spring是如何解決循環依賴的相信你也很清楚了,現在再來看通過構造函數依賴注入為什么不能解決循環依賴是不是也很清晰了?因為通過構造函數實例化并依賴注入是沒辦法緩存一個實例對象供依賴對象注入的。

作用域實現原理以及如何自定義作用域

作用域實現原理

在Spring中主要有reqest、session、singleton、prototype等等幾種作用域,前面我們分析了singleton創建bean的原理,是通過緩存來實現的,那么其它的呢?還是回到AbstractBeanFactory.doGetBean方法中來:

if (mbd.isSingleton()) { sharedInstance = getSingleton(beanName, () -> { try { 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; } }); // 該方法是FactoryBean接口的調用入口 bean = getObjectForBeanInstance(sharedInstance, name, beanName, mbd);}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); } // 該方法是FactoryBean接口的調用入口 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); } }); // 該方法是FactoryBean接口的調用入口 bean = getObjectForBeanInstance(scopedInstance, name, beanName, mbd); }}

在singleton作用域下,會調用getSingleton方法,然后回調createBean創建對象,最終在getSingleton中完成緩存;而當scope為prototype時,可以看到是直接調用了createBean方法并返回,沒有任何的緩存操作,因此每次調用getBean都會創建新的對象,即使是同一個線程;除此之外都會進入到else片段中。

這個代碼也很簡單,首先通過我們配置的scopeName從scopes中拿到對應的Scope對象,如SessionScope和RequestScope(但這兩個只會在Web環境中被加載,在WebApplicationContextUtils.registerWebApplicationScopes可以看到注冊操作),然后調用對應的get方法存到對應的request或session對象中去。代碼很簡單,這里就不分析了。

自定義Scope

通過以上分析,不難發現我們是很容易實現一個自己的Scope的,首先實現Scope接口,然后將我們類的實例添加到scopes緩存中來,關鍵是怎么添加呢?在AbstractBeanFactory類中有一個registerScope方法就是干這個事的,因此我們只要拿到一個BeanFactory對象就行了,那要怎么拿?還記得在refresh中調用的invokeBeanFactoryPostProcessors方法么?因此我們只需要實現BeanFactoryPostProcessor接口就可以了,是不是So Easy!

BeanPostProcessor的執行時機

BeanPostProcessor執行點很多,根據其接口類型在不同的位置進行調用,只有熟記其執行時機,才能更好的進行擴展,這里以一張時序圖來總結:

Spring IOC原理補充說明(循環依賴、Bean作用域等)

SpringBoot零配置實現原理淺析

在SpringBoot項目中,省去了大量繁雜的xml配置,只需要使用@ComponentScan、@Configuration以及@Bean注解就可以達到和使用xml配置的相同效果,大大簡化了我們的開發,那這個實現原理是怎樣的呢?熟悉了xml解析原理,相信對于這種注解的方式基本上也能猜個大概。

首先我們進入到AnnotationConfigApplicationContext類,這個就是注解方式的IOC容器:

public AnnotationConfigApplicationContext(String... basePackages) { this(); scan(basePackages); refresh(); } public AnnotationConfigApplicationContext() { this.reader = new AnnotatedBeanDefinitionReader(this); this.scanner = new ClassPathBeanDefinitionScanner(this); }

這里ClassPathBeanDefinitionScanner在解析xml時出現過,就是用來掃描包找到合格的資源的;同時還創建了一個AnnotatedBeanDefinitionReader對象對應XmlBeanDefinitionReader,用來解析注解:

public AnnotatedBeanDefinitionReader(BeanDefinitionRegistry registry, Environment environment) { Assert.notNull(registry, 'BeanDefinitionRegistry must not be null'); Assert.notNull(environment, 'Environment must not be null'); this.registry = registry; this.conditionEvaluator = new ConditionEvaluator(registry, environment, null); AnnotationConfigUtils.registerAnnotationConfigProcessors(this.registry); } public static Set<BeanDefinitionHolder> registerAnnotationConfigProcessors( BeanDefinitionRegistry registry, @Nullable Object source) { DefaultListableBeanFactory beanFactory = unwrapDefaultListableBeanFactory(registry); if (beanFactory != null) { if (!(beanFactory.getDependencyComparator() instanceof AnnotationAwareOrderComparator)) { beanFactory.setDependencyComparator(AnnotationAwareOrderComparator.INSTANCE); } if (!(beanFactory.getAutowireCandidateResolver() instanceof ContextAnnotationAutowireCandidateResolver)) { beanFactory.setAutowireCandidateResolver(new ContextAnnotationAutowireCandidateResolver()); } } Set<BeanDefinitionHolder> beanDefs = new LinkedHashSet<>(8); if (!registry.containsBeanDefinition(CONFIGURATION_ANNOTATION_PROCESSOR_BEAN_NAME)) { RootBeanDefinition def = new RootBeanDefinition(ConfigurationClassPostProcessor.class); def.setSource(source); beanDefs.add(registerPostProcessor(registry, def, CONFIGURATION_ANNOTATION_PROCESSOR_BEAN_NAME)); } if (!registry.containsBeanDefinition(AUTOWIRED_ANNOTATION_PROCESSOR_BEAN_NAME)) { RootBeanDefinition def = new RootBeanDefinition(AutowiredAnnotationBeanPostProcessor.class); def.setSource(source); beanDefs.add(registerPostProcessor(registry, def, AUTOWIRED_ANNOTATION_PROCESSOR_BEAN_NAME)); } // Check for JSR-250 support, and if present add the CommonAnnotationBeanPostProcessor. if (jsr250Present && !registry.containsBeanDefinition(COMMON_ANNOTATION_PROCESSOR_BEAN_NAME)) { RootBeanDefinition def = new RootBeanDefinition(CommonAnnotationBeanPostProcessor.class); def.setSource(source); beanDefs.add(registerPostProcessor(registry, def, COMMON_ANNOTATION_PROCESSOR_BEAN_NAME)); } // Check for JPA support, and if present add the PersistenceAnnotationBeanPostProcessor. if (jpaPresent && !registry.containsBeanDefinition(PERSISTENCE_ANNOTATION_PROCESSOR_BEAN_NAME)) { RootBeanDefinition def = new RootBeanDefinition(); try { def.setBeanClass(ClassUtils.forName(PERSISTENCE_ANNOTATION_PROCESSOR_CLASS_NAME, AnnotationConfigUtils.class.getClassLoader())); } catch (ClassNotFoundException ex) { throw new IllegalStateException( 'Cannot load optional framework class: ' + PERSISTENCE_ANNOTATION_PROCESSOR_CLASS_NAME, ex); } def.setSource(source); beanDefs.add(registerPostProcessor(registry, def, PERSISTENCE_ANNOTATION_PROCESSOR_BEAN_NAME)); } if (!registry.containsBeanDefinition(EVENT_LISTENER_PROCESSOR_BEAN_NAME)) { RootBeanDefinition def = new RootBeanDefinition(EventListenerMethodProcessor.class); def.setSource(source); beanDefs.add(registerPostProcessor(registry, def, EVENT_LISTENER_PROCESSOR_BEAN_NAME)); } if (!registry.containsBeanDefinition(EVENT_LISTENER_FACTORY_BEAN_NAME)) { RootBeanDefinition def = new RootBeanDefinition(DefaultEventListenerFactory.class); def.setSource(source); beanDefs.add(registerPostProcessor(registry, def, EVENT_LISTENER_FACTORY_BEAN_NAME)); } return beanDefs; }

在AnnotatedBeanDefinitionReader構造方法中可以看到調用了registerAnnotationConfigProcessors注冊一些列注解解析的Processor類,重點關注ConfigurationClassPostProcessor類,該類是BeanDefinitionRegistryPostProcessor的子類,所以會在refresh中調用,該類又會委托ConfigurationClassParser去解析@Configuration、@Bean、@ComponentScan等注解,所以這兩個類就是SpringBoot實現零配置的關鍵類,實現和之前分析的注解解析流程差不多,所以具體的實現邏輯讀者請自行分析。

回頭看當解析器和掃描器創建好后,同樣是調用scan方法掃描包,然后refresh啟動容器,所以實現邏輯都是一樣的,殊途同歸,只不過通過父子容器的構造方式使得我們可以很方便的擴展Spring。

總結

本篇是關于IOC實現的一些補充,最重要的是要理解循環依賴的解決辦法,其次SpringBoot零配置實現原理雖然這里只是簡單起了個頭,但需要好好閱讀源碼分析。另外還有很多細節,不可能全都講到,需要我們自己反復琢磨,尤其是Bean實例化那一塊,這將是后面我們理解AOP的基礎。希望大家多多支持好吧啦網。

標簽: Spring
相關文章:
主站蜘蛛池模板: 不锈钢螺丝 - 六角螺丝厂家 - 不锈钢紧固件 - 万千紧固件--紧固件一站式采购 | 10吨无线拉力计-2吨拉力计价格-上海佳宜电子科技有限公司 | 南京办公用品网-办公文具用品批发-打印机耗材采购 | 制丸机,小型中药制丸机,全自动制丸机价格-甘肃恒跃制药设备有限公司 | 交联度测试仪-湿漏电流测试仪-双85恒温恒湿试验箱-常州市科迈实验仪器有限公司 | 哲力实业_专注汽车涂料汽车漆研发生产_汽车漆|修补油漆品牌厂家 长沙一级消防工程公司_智能化弱电_机电安装_亮化工程专业施工承包_湖南公共安全工程有限公司 | 干式磁选机_湿式磁选机_粉体除铁器-潍坊国铭矿山设备有限公司 | 安全,主动,被动,柔性,山体滑坡,sns,钢丝绳,边坡,防护网,护栏网,围栏,栏杆,栅栏,厂家 - 护栏网防护网生产厂家 | led太阳能路灯厂家价格_风光互补庭院灯_农村市政工程路灯-中山华可路灯品牌 | 便携式高压氧舱-微压氧舱-核生化洗消系统-公众洗消站-洗消帐篷-北京利盟救援 | 承插管件_不锈钢承插管件_锻钢高压管件-温州科正阀门管件有限公司 | 雨水收集系统厂家-雨水收集利用-模块雨水收集池-徐州博智环保科技有限公司 | 超声波反应釜【百科】-以马内利仪器 | 金联宇电缆|广东金联宇电缆厂家_广东金联宇电缆实业有限公司 | 苏州柯瑞德货架-仓库自动化改造解决方案 | 派财经_聚焦数字经济内容服务平台 | 吸音板,隔音板,吸音材料,吸音板价格,声学材料 - 佛山诺声吸音板厂家 | 首页_欧瑞传动官方网站--主营变频器、伺服系统、新能源、软起动器、PLC、HMI | 国产液相色谱仪-超高效液相色谱仪厂家-上海伍丰科学仪器有限公司 | 红外光谱仪维修_二手红外光谱仪_红外压片机_红外附件-天津博精仪器 | 热缩管切管机-超声波切带机-织带切带机-无纺布切布机-深圳市宸兴业科技有限公司 | 合肥活动房_安徽活动板房_集成打包箱房厂家-安徽玉强钢结构集成房屋有限公司 | 智能交通网_智能交通系统_ITS_交通监控_卫星导航_智能交通行业 | 环氧乙烷灭菌器_压力蒸汽灭菌器_低温等离子过氧化氢灭菌器 _低温蒸汽甲醛灭菌器_清洗工作站_医用干燥柜_灭菌耗材-环氧乙烷灭菌器_脉动真空压力蒸汽灭菌器_低温等离子灭菌设备_河南省三强医疗器械有限责任公司 | 中高频感应加热设备|高频淬火设备|超音频感应加热电源|不锈钢管光亮退火机|真空管烤消设备 - 郑州蓝硕工业炉设备有限公司 | 澳洁干洗店加盟-洗衣店干洗连锁「澳洁干洗免费一对一贴心服务」 干洗加盟网-洗衣店品牌排行-干洗设备价格-干洗连锁加盟指南 | 培训中心-翰香原香酥板栗饼加盟店总部-正宗板栗酥饼技术 | 净化车间装修_合肥厂房无尘室设计_合肥工厂洁净工程装修公司-安徽盛世和居装饰 | 工业胀紧套_万向节联轴器_链条-规格齐全-型号选购-非标订做-厂家批发价格-上海乙谛精密机械有限公司 | 杭州可当科技有限公司—流量卡_随身WiFi_AI摄像头一站式解决方案 | 万烁建筑设计院-建筑设计公司加盟,设计院加盟分公司,市政设计加盟 | 寮步纸箱厂_东莞纸箱厂 _东莞纸箱加工厂-东莞市寮步恒辉纸制品厂 | 新中天检测有限公司青岛分公司-山东|菏泽|济南|潍坊|泰安防雷检测验收 | 南京技嘉环保科技有限公司-杀菌除臭剂|污水|垃圾|厕所|橡胶厂|化工厂|铸造厂除臭剂 | PCB接线端子_栅板式端子_线路板连接器_端子排生产厂家-置恒电气 喷码机,激光喷码打码机,鸡蛋打码机,手持打码机,自动喷码机,一物一码防伪溯源-恒欣瑞达有限公司 假肢-假肢价格-假肢厂家-河南假肢-郑州市力康假肢矫形器有限公司 | 医疗仪器模块 健康一体机 多参数监护仪 智慧医疗仪器方案定制 血氧监护 心电监护 -朗锐慧康 | 金属清洗剂,防锈油,切削液,磨削液-青岛朗力防锈材料有限公司 | 同学聚会纪念册制作_毕业相册制作-成都顺时针宣传画册设计公司 | 水性漆|墙面漆|木器家具漆|水漆涂料_晨阳水漆官网 | 酒糟烘干机-豆渣烘干机-薯渣烘干机-糟渣烘干设备厂家-焦作市真节能环保设备科技有限公司 | 昆明挖掘机修理厂_挖掘机翻新再制造-昆明聚力工程机械维修有限公司 |