您好,登錄后才能下訂單哦!
本篇內容介紹了“Spring源碼分析之如何解決循環依賴”的有關知識,在實際案例的操作過程中,不少人都會遇到這樣的困境,接下來就讓小編帶領大家學習一下如何處理這些情況吧!希望大家仔細閱讀,能夠學有所成!
首先,我們需要明白什么是循環依賴?簡單來說就是A對象創建過程中需要依賴B對象,而B對象創建過程中同樣也需要A對象,所以A創建時需要先去把B創建出來,但B創建時又要先把A創建出來...死循環有木有...
那么在Spring中,有多少種循環依賴的情況呢?大部分人只知道兩個普通的Bean之間的循環依賴,而Spring中其實存在三種對象(普通Bean,工廠Bean,代理對象),他們之間都會存在循環依賴,這里我給列舉出來,大致分別以下幾種:
那么,在Spring中是如何解決這個問題的呢?
首先,我們先設想一下,如果讓我們自己來編碼,我們會如何解決這個問題?
現在我們有兩個互相依賴的對象A和B
public class NormalBeanA {
private NormalBeanB normalBeanB;
public void setNormalBeanB(NormalBeanB normalBeanB) {
this.normalBeanB = normalBeanB;
}
}
public class NormalBeanB {
private NormalBeanA normalBeanA;
public void setNormalBeanA(NormalBeanA normalBeanA) {
this.normalBeanA = normalBeanA;
}
}
然后我們想要讓他們彼此都含有對象
public class Main {
public static void main(String[] args) {
// 先創建A對象
NormalBeanA normalBeanA = new NormalBeanA();
// 創建B對象
NormalBeanB normalBeanB = new NormalBeanB();
// 將A對象的引用賦給B
normalBeanB.setNormalBeanA(normalBeanA);
// 再將B賦給A
normalBeanA.setNormalBeanB(normalBeanB);
}
}
發現了嗎?我們并沒有先創建一個完整的A對象,而是先創建了一個空殼對象(Spring中稱為早期對象),將這個早期對象A先賦給了B,使得得到了一個完整的B對象,再將這個完整的B對象賦給A,從而解決了這個循環依賴問題,so easy!
那么Spring中是不是也這樣做的呢?我們就來看看吧~
AbstractAutowireCapableBeanFactory#doCreateBean
假設此時在創建A
protected Object doCreateBean(String beanName, RootBeanDefinition mbd, @Nullable Object[] args){
// beanName -> A
// 實例化A
BeanWrapper instanceWrapper = createBeanInstance(beanName, mbd, args);
// 是否允許暴露早期對象
boolean earlySingletonExposure = (mbd.isSingleton() && this.allowCircularReferences &&
isSingletonCurrentlyInCreation(beanName));
if (earlySingletonExposure) {
// 將獲取早期對象的回調方法放到三級緩存中
addSingletonFactory(beanName, () -> getEarlyBeanReference(beanName, mbd, bean));
}
}
addSingletonFactory
protected void addSingletonFactory(String beanName, ObjectFactory<?> singletonFactory) {
synchronized (this.singletonObjects) {
// 單例緩存池中沒有該Bean
if (!this.singletonObjects.containsKey(beanName)) {
// 將回調函數放入三級緩存
this.singletonFactories.put(beanName, singletonFactory);
this.earlySingletonObjects.remove(beanName);
this.registeredSingletons.add(beanName);
}
}
}
ObjectFactory是一個函數式接口
在這里,我們發現在創建Bean時,Spring不管三七二十一,直接將一個獲取早期對象的回調方法放進了一個三級緩存中,我們再來看一下回調方法的邏輯
getEarlyBeanReference
protected Object getEarlyBeanReference(String beanName, RootBeanDefinition mbd, Object bean) {
Object exposedObject = bean;
// 調用BeanPostProcessor對早期對象進行處理,在Spring的內置處理器中,并無相關的處理邏輯
// 如果開啟了AOP,將引入一個AnnotationAwareAspectJAutoProxyCreator,此時將可能對Bean進行動態代理
if (!mbd.isSynthetic() && hasInstantiationAwareBeanPostProcessors()) {
for (BeanPostProcessor bp : getBeanPostProcessors()) {
if (bp instanceof SmartInstantiationAwareBeanPostProcessor) {
SmartInstantiationAwareBeanPostProcessor ibp = (SmartInstantiationAwareBeanPostProcessor) bp;
exposedObject = ibp.getEarlyBeanReference(exposedObject, beanName);
}
}
}
return exposedObject;
}
在這里,如果沒有開啟AOP,或者該對象不需要動態代理,會直接返回原對象
此時,已經將A的早期對象緩存起來了,接下來在填充屬性時會發生什么呢?
相信大家也應該想到了,A對象填充屬性時必然發現依賴了B對象,此時就將轉頭創建B,在創建B時同樣會經歷以上步驟,此時就該B對象填充屬性了,這時,又將要轉頭創建A,那么,現在會有什么不一樣的地方呢?我們看看getBean的邏輯吧
doGetBean
protected <T> T doGetBean(
String name, @Nullable Class<T> requiredType, @Nullable Object[] args, boolean typeCheckOnly){
// 此時beanName為A
String beanName = transformedBeanName(name);
// 嘗試從三級緩存中獲取bean,這里很關鍵
Object sharedInstance = getSingleton(beanName);
}
protected Object getSingleton(String beanName, boolean allowEarlyReference) {
// 從單例緩存池中獲取,此時仍然是取不到的
Object singletonObject = this.singletonObjects.get(beanName);
// 獲取不到,判斷bean是否正在創建,沒錯,此時A確實正在創建
if (singletonObject == null && isSingletonCurrentlyInCreation(beanName)) {
// 由于現在仍然是在同一個線程,基于同步鎖的可重入性,此時不會阻塞
synchronized (this.singletonObjects) {
// 從早期對象緩存池中獲取,這里是沒有的
singletonObject = this.earlySingletonObjects.get(beanName);
if (singletonObject == null && allowEarlyReference) {
// 從三級緩存中獲取回調函數,此時就獲取到了我們在創建A時放入的回調函數
ObjectFactory<?> singletonFactory = this.singletonFactories.get(beanName);
if (singletonFactory != null) {
// 調用回調方法獲取早期bean,由于我們現在討論的是普通對象,所以返回原對象
singletonObject = singletonFactory.getObject();
// 將早期對象放到二級緩存,移除三級緩存
this.earlySingletonObjects.put(beanName, singletonObject);
this.singletonFactories.remove(beanName);
}
}
}
}
// 返回早期對象A
return singletonObject;
}
震驚!此時我們就拿到了A的早期對象進行返回,所以B得以被填充屬性,B創建完畢后,又將返回到A填充屬性的過程,A也得以被填充屬性,A也創建完畢,這時,A和B都創建好了,循環依賴問題得以收場~
普通Bean和普通Bean之間的問題就到這里了,不知道小伙伴們有沒有暈呢~
普通Bean和代理對象之間的循環依賴與兩個普通Bean的循環依賴其實大致相同,只不過是多了一次動態代理的過程,我們假設A對象是需要代理的對象,B對象仍然是一個普通對象,然后,我們開始創建A對象。
剛開始創建A的過程與上面的例子是一模一樣的,緊接著自然是需要創建B,然后B依賴了A,于是又倒回去創建A,此時,再次走到去緩存池獲取的過程。
// 從三級緩存中獲取回調函數
ObjectFactory<?> singletonFactory = this.singletonFactories.get(beanName);
if (singletonFactory != null) {
// 調用回調方法獲取早期bean,此時返回的是一個A的代理對象
singletonObject = singletonFactory.getObject();
// 將早期對象放到二級緩存,移除三級緩存
this.earlySingletonObjects.put(beanName, singletonObject);
this.singletonFactories.remove(beanName);
}
這時就不太一樣了,在singletonFactory.getObject()
時,由于此時A是需要代理的對象,在調用回調函數時,就會觸發動態代理的過程
AbstractAutoProxyCreator#getEarlyBeanReference
public Object getEarlyBeanReference(Object bean, String beanName) {
// 生成一個緩存Key
Object cacheKey = getCacheKey(bean.getClass(), beanName);
// 放入緩存中,用于在初始化后調用該后置處理器時判斷是否進行動態代理過
this.earlyProxyReferences.put(cacheKey, bean);
// 將對象進行動態代理
return wrapIfNecessary(bean, beanName, cacheKey);
}
此時,B在創建時填充的屬性就是A的代理對象了,B創建完畢,返回到A的創建過程,但此時的A仍然是一個普通對象,可B引用的A已經是個代理對象了,不知道小伙伴看到這里有沒有迷惑呢?
不急,讓我們繼續往下走,填充完屬性自然是需要初始化的,在初始化后,會調用一次后置處理器,我們看看會不會有答案吧
protected Object initializeBean(String beanName, Object bean, @Nullable RootBeanDefinition mbd) {
//...省略前面的步驟...
// 調用初始化方法
invokeInitMethods(beanName, wrappedBean, mbd);
// 處理初始化后的bean
wrappedBean = applyBeanPostProcessorsAfterInitialization(wrappedBean, beanName);
}
在處理初始化后的bean,又會調用動態代理的后置處理器了
public Object postProcessAfterInitialization(@Nullable Object bean, String beanName) {
if (bean != null) {
Object cacheKey = getCacheKey(bean.getClass(), beanName);
// 判斷緩存中是否有該對象,有則說明該對象已被動態代理,跳過
if (this.earlyProxyReferences.remove(cacheKey) != bean) {
return wrapIfNecessary(bean, beanName, cacheKey);
}
}
return bean;
}
不知道小伙伴發現沒有,earlyProxyReferences
這個緩存可不就是我們在填充B的屬性,進而從緩存中獲取A時放進去的嗎?不信您往上翻到getEarlyBeanReference
的步驟看看~
所以,此時并未進行任何處理,依舊返回了我們的原對象A,看來這里并沒有我們要的答案,那就繼續吧~
// 是否允許暴露早期對象
if (earlySingletonExposure) {
// 從緩存池中獲取早期對象
Object earlySingletonReference = getSingleton(beanName, false);
if (earlySingletonReference != null) {
// bean為初始化前的對象,exposedObject為初始化后的對象
// 判斷兩對象是否相等,基于上面的分析,這兩者是相等的
if (exposedObject == bean) {
// 將早期對象賦給exposedObject
exposedObject = earlySingletonReference;
}
}
}
我們來分析一下上面的邏輯,getSingleton
從緩存池中獲取早期對象返回的是什么呢?
synchronized (this.singletonObjects) {
// 從早期對象緩存池中獲取,此時就拿到了我們填充B屬性時放入的A的代理對象
singletonObject = this.earlySingletonObjects.get(beanName);
if (singletonObject == null && allowEarlyReference) {
// 從三級緩存中獲取回調函數
ObjectFactory<?> singletonFactory = this.singletonFactories.get(beanName);
if (singletonFactory != null) {
// 調用回調方法獲取早期bean
singletonObject = singletonFactory.getObject();
// 將早期對象放到二級緩存,移除三級緩存
this.earlySingletonObjects.put(beanName, singletonObject);
this.singletonFactories.remove(beanName);
}
}
}
發現了嗎?此時我們就獲取到了A的代理對象,然后我們又把這個對象賦給了exposedObject,此時創建對象的流程走完,我們得到的A不就是個代理對象了嗎~
此次栗子是先創建需要代理的對象A,假設我們先創建普通對象B會發生什么呢?
代理對象與代理對象的循環依賴是怎么樣的呢?解決過程又是如何呢?這里就留給小伙伴自己思考了,其實和普通Bean與代理對象是一模一樣的,小伙伴想想是不是呢,這里我就不做分析了。
這里所說的普通Bean與工廠Bean并非指bean與FactoryBean,這將毫無意義,而是指普通Bean與FactoryBean的getObject
方法產生了循環依賴,因為FactoryBean
最終產生的對象是由getObject
方法所產出。我們先來看看栗子吧~
假設工廠對象A依賴普通對象B,普通對象B依賴普通對象A。
小伙伴看到這里就可能問了,誒~你這不對呀,怎么成了「普通對象B依賴普通對象A」呢?不應該是工廠對象A嗎?是這樣的,在Spring中,由于普通對象A是由工廠對象A產生,所有在普通對象B想要獲取普通對象A時,其實最終尋找調用的是工廠對象A的getObject
方法,所以只要普通對象B依賴普通對象A就可以了,Spring會自動幫我們把普通對象B和工廠對象A聯系在一起。
小伙伴,哦~
普通對象A
public class NormalBeanA {
private NormalBeanB normalBeanB;
public void setNormalBeanB(NormalBeanB normalBeanB) {
this.normalBeanB = normalBeanB;
}
}
工廠對象A
@Component
public class FactoryBeanA implements FactoryBean<NormalBeanA> {
@Autowired
private ApplicationContext context;
@Override
public NormalBeanA getObject() throws Exception {
NormalBeanA normalBeanA = new NormalBeanA();
NormalBeanB normalBeanB = context.getBean("normalBeanB", NormalBeanB.class);
normalBeanA.setNormalBeanB(normalBeanB);
return normalBeanA;
}
@Override
public Class<?> getObjectType() {
return NormalBeanA.class;
}
}
普通對象B
@Component
public class NormalBeanB {
@Autowired
private NormalBeanA normalBeanA;
}
假設我們先創建對象A
由于FactoryBean和Bean的創建過程是一樣的,只是多了步getObject
,所以我們直接定位到調用getObject
入口
if (mbd.isSingleton()) {
// 開始創建bean
sharedInstance = getSingleton(beanName, () -> {
// 創建bean
return createBean(beanName, mbd, args);
});
// 處理FactoryBean
bean = getObjectForBeanInstance(sharedInstance, name, beanName, mbd);
}
protected Object getObjectForBeanInstance(
Object beanInstance, String name, String beanName, @Nullable RootBeanDefinition mbd) {
// 先嘗試從緩存中獲取,保證多次從工廠bean獲取的bean是同一個bean
object = getCachedObjectForFactoryBean(beanName);
if (object == null) {
// 從FactoryBean獲取對象
object = getObjectFromFactoryBean(factory, beanName, !synthetic);
}
}
protected Object getObjectFromFactoryBean(FactoryBean<?> factory, String beanName, boolean shouldPostProcess) {
// 加鎖,防止多線程時重復創建bean
synchronized (getSingletonMutex()) {
// 這里是Double Check
Object object = this.factoryBeanObjectCache.get(beanName);
if (object == null) {
// 獲取bean,調用factoryBean的getObject()
object = doGetObjectFromFactoryBean(factory, beanName);
}
// 又從緩存中取了一次,why? 我們慢慢分析
Object alreadyThere = this.factoryBeanObjectCache.get(beanName);
if (alreadyThere != null) {
object = alreadyThere;
}else{
// ...省略初始化bean的邏輯...
// 將獲取到的bean放入緩存
this.factoryBeanObjectCache.put(beanName, object);
}
}
}
private Object doGetObjectFromFactoryBean(FactoryBean<?> factory, String beanName){
return factory.getObject();
}
現在,就走到了我們自定義的getObject
方法,由于我們調用了context.getBean("normalBeanB", NormalBeanB.class)
,此時,將會去創建B對象,在創建過程中,先將B的早期對象放入三級緩存,緊接著填充屬性,發現依賴了A對象,又要倒回來創建A對象,從而又回到上面的邏輯,再次調用我們自定義的getObject
方法,這個時候會發生什么呢?
又要去創建B對象...(Spring:心好累)
但是!此時我們在創建B時,是直接通過getBean
在緩存中獲取到了B的早期對象,得以返回了!于是我們自定義的getObject
調用成功,返回了一個完整的A對象!
但是此時FactoryBean
的緩沖中還是什么都沒有的。
// 又從緩存中取了一次
Object alreadyThere = this.factoryBeanObjectCache.get(beanName);
if (alreadyThere != null) {
object = alreadyThere;
}
這一次取alreadyThere
必然是null,流程繼續執行,將此時將獲取到的bean放入緩存
this.factoryBeanObjectCache.put(beanName, object);
從FactoryBean獲取對象的流程結束,返回到創建B的過程中,B對象此時的屬性也得以填充,再返回到第一次創建A的過程,也就是我們第一次調用自定義的getObject
方法,調用完畢,返回到這里
// 獲取bean,調用factoryBean的getObject()
object = doGetObjectFromFactoryBean(factory, beanName);
Object alreadyThere = this.factoryBeanObjectCache.get(beanName);
if (alreadyThere != null) {
object = alreadyThere;
那么,此時this.factoryBeanObjectCache.get(beanName)
能從緩沖中拿到對象了嗎?有沒有發現,拿到了剛剛B對象填充屬性時再次創建A對象放進去的!
所以,明白這里為什么要再次從緩存中獲取了吧?就是為了解決由于循環依賴時調用了兩次自定義的getObject
方法,從而創建了兩個不相同的A對象,保證我們返回出去的A對象唯一!
怕小伙伴暈了,畫個圖給大家
我們已經舉例4種循環依賴的栗子,Spring都有所解決,那么有沒有Spring也無法解決的循環依賴問題呢?
有的!就是這個FactoryBean
與FactoryBean
的循環依賴!
假設工廠對象A依賴工廠對象B,工廠對象B依賴工廠對象A,那么,這次的栗子會是什么樣呢?
普通對象
public class NormalBeanA {
private NormalBeanB normalBeanB;
public void setNormalBeanB(NormalBeanB normalBeanB) {
this.normalBeanB = normalBeanB;
}
}
public class NormalBeanB {
private NormalBeanA normalBeanA;
public void setNormalBeanA(NormalBeanA normalBeanA) {
this.normalBeanA = normalBeanA;
}
}
工廠對象
@Component
public class FactoryBeanA implements FactoryBean<NormalBeanA> {
@Autowired
private ApplicationContext context;
@Override
public NormalBeanA getObject() throws Exception {
NormalBeanA normalBeanA = new NormalBeanA();
NormalBeanB normalBeanB = context.getBean("factoryBeanB", NormalBeanB.class);
normalBeanA.setNormalBeanB(normalBeanB);
return normalBeanA;
}
@Override
public Class<?> getObjectType() {
return NormalBeanA.class;
}
}
@Component
public class FactoryBeanB implements FactoryBean<NormalBeanB> {
@Autowired
private ApplicationContext context;
@Override
public NormalBeanB getObject() throws Exception {
NormalBeanB normalBeanB = new NormalBeanB();
NormalBeanA normalBeanA = context.getBean("factoryBeanA", NormalBeanA.class);
normalBeanB.setNormalBeanA(normalBeanA);
return normalBeanB;
}
@Override
public Class<?> getObjectType() {
return NormalBeanB.class;
}
}
首先,我們開始創建對象A,此時為調用工廠對象A的getObject
方法,轉而去獲取對象B,便會走到工廠對象B的getObject
方法,然后又去獲取對象A,又將調用工廠對象A的getObject
,再次去獲取對象B,于是再次走到工廠對象B的getObject
方法......此時,已經歷了一輪循環,卻沒有跳出循環的跡象,妥妥的死循環了。
我們畫個圖吧~
沒錯!這個圖就是這么簡單,由于始終無法創建出一個對象,不管是早期對象或者完整對象,使得兩個工廠對象反復的去獲取對方,導致陷入了死循環。
那么,我們是否有辦法解決這個問題呢?
我的答案是無法解決,如果有想法的小伙伴也可以自己想一想哦~
我們發現,在發生循環依賴時,只要循環鏈中的某一個點可以先創建出一個早期對象,那么在下一次循環時,就會使得我們能夠獲取到早期對象從而跳出循環!
而由于工廠對象與工廠對象間是無法創建出這個早期對象的,無法滿足跳出循環的條件,導致變成了死循環。
那么此時Spring中會拋出一個什么樣的異常呢?
當然是棧溢出異常啦!兩個工廠對象一直相互調用,不斷開辟棧幀,可不就是棧溢出有木有~
上面的情況是無法解決循環依賴的,那么這個情況可以解決嗎?
答案是可以的!
我們分析了,一個循環鏈是否能夠得到終止,關鍵在于是否能夠在某個點創建出一個早期對象(臨時對象),而代理對象在doCreateBean
時,是會生成一個早期對象放入三級緩存的,于是該循環鏈得以終結。
“Spring源碼分析之如何解決循環依賴”的內容就介紹到這里了,感謝大家的閱讀。如果想了解更多行業相關的知識可以關注億速云網站,小編將為大家輸出更多高質量的實用文章!
免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。