@RefreshScope注解

spring啟動(dòng)時(shí)會(huì)調(diào)用ClassPathBeanDefinitionScanner.java類中的doScan()對包路徑下的所有class進(jìn)行掃描，獲取bean的定義，同時(shí)對bean的@RefreshScope(@Scope的父類)進(jìn)行處理。

1. 獲取作用在類上的@RefreshScope(@Scope的父類)注解元數(shù)據(jù)，封裝成ScopeMetadata對象，同時(shí)聲明bean的作用域candidate.setScope(scopeMetadata.getScopeName());
2. 根據(jù)scopeMetadata即@Scope對bean進(jìn)行代理，使用ScopedProxyFactoryBean類創(chuàng)建RootBeanDefinition代替原理的bean定義。將被代理的原始bean定義注冊到容器中(scopedTarget.configController -> ConfigController)，再將代理的bean定義注冊到容器中(configController -> ScopedProxyFactoryBean)

處理這個(gè)使用@RefreshScope注解的bean的是RefreshScope組件，可以看到父類GenericScope實(shí)現(xiàn)了BeanDefinitionRegistryPostProcessor和BeanFactoryPostProcessor接口，這是容器的后置處理器，當(dāng)容器啟動(dòng)時(shí)會(huì)先調(diào)用BeanDefinitionRegistryPostProcessor接口中的postProcessBeanDefinitionRegistry()方法，再BeanFactoryPostProcessor接口中的postProcessBeanFactory()方法。

public class RefreshScope extends GenericScope
		implements ApplicationContextAware, Ordered{...}
public class GenericScope implements Scope, BeanFactoryPostProcessor,
		BeanDefinitionRegistryPostProcessor, DisposableBean{...}        

獲取容器中包含的所有的bean定義，再通過bean裝飾的bean定義獲取作用域，判斷是否為RefreshScope能處理的作用域，在構(gòu)造RefreshScope實(shí)例時(shí)設(shè)置了name為"refresh"getName().equals(root.getDecoratedDefinition().getBeanDefinition().getScope())。ps:這是個(gè)細(xì)節(jié)，在被裝飾的bean定義的scope是"refresh"，而裝飾者bean的scope是""；之后處理的時(shí)候先處理裝飾者bean，在處理原始bean，就是通過這個(gè)scope來判斷的。如果是的話將bean的class設(shè)置為LockedScopedProxyFactoryBean，將當(dāng)前RefreshScope實(shí)例對象設(shè)置為構(gòu)造函數(shù)的參數(shù)?？聪翷ockedScopedProxyFactoryBean這個(gè)類：

public static class LockedScopedProxyFactoryBean<S extends GenericScope>
			extends ScopedProxyFactoryBean implements MethodInterceptor{...}
public class ScopedProxyFactoryBean extends ProxyConfig implements FactoryBean<Object>, BeanFactoryAware{...}            

可以看到LockedScopedProxyFactoryBean的父類實(shí)現(xiàn)了BeanFactoryAware接口，因此在bean實(shí)例化的時(shí)候會(huì)調(diào)用實(shí)現(xiàn)的setBeanFactory()方法，這時(shí)會(huì)通過代理工廠創(chuàng)建代理對象，即生成LockedScopedProxyFactoryBean類的代理對象。由于LockedScopedProxyFactoryBean類實(shí)現(xiàn)了Advised接口，因此可以作為代理對象的攔截器，當(dāng)調(diào)用代理對象的方法時(shí)攔截器就會(huì)起作用。

public void setBeanFactory(BeanFactory beanFactory) {
......
    ProxyFactory pf = new ProxyFactory();
    pf.copyFrom(this);
    pf.setTargetSource(this.scopedTargetSource);
.....
    this.proxy = pf.getProxy(cbf.getBeanClassLoader());
}
public void setBeanFactory(BeanFactory beanFactory) {
    super.setBeanFactory(beanFactory);
    Object proxy = getObject();
    if (proxy instanceof Advised) {
        Advised advised = (Advised) proxy;
        advised.addAdvice(0, this);
    }
}

總結(jié)下@RefreshScope注解的bean實(shí)例化的過程：

1. 使用了@RefreshScope注解的bean的定義會(huì)被設(shè)置成LockedScopedProxyFactoryBean.class
2. 創(chuàng)建bean時(shí)先生成LockedScopedProxyFactoryBean的實(shí)例對象
3. 由于LockedScopedProxyFactoryBean實(shí)現(xiàn)了BeanFactoryAware接口，會(huì)調(diào)用setBeanFactory()
4. 在setBeanFactory()方法中會(huì)通過cglib創(chuàng)建LockedScopedProxyFactoryBean對象的代理對象，F(xiàn)actoryBean接口的getObject()會(huì)返回此代理對象，因此最終得到的就是LockedScopedProxyFactoryBean對象的代理對
5. 由于代理對象為LockedScopedProxyFactoryBean的子類，因此實(shí)現(xiàn)了Advised接口，可以將調(diào)用setBeanFactory()方法的LockedScopedProxyFactoryBean對象作為攔截器保存下來

當(dāng)容器啟動(dòng)完成刷新后會(huì)發(fā)布ContextRefreshedEvent事件，RefreshScope類中的start()使用了@EventListener注解，可以作為監(jiān)聽器對ContextRefreshedEvent事進(jìn)行處理。找到scope是"refresh"的bean的定義，再走Scope的代碼塊進(jìn)行實(shí)例化。

protected <T> T doGetBean(final String name, @Nullable final Class<T> requiredType,
			@Nullable final Object[] args, boolean typeCheckOnly) throws BeansException {
......
if (mbd.isSingleton()) {
    ......
}
else if (mbd.isPrototype()) {
    ......
}
else {
    String scopeName = mbd.getScope();
    //根據(jù)name獲取Scope，當(dāng)前一共有四個(gè)
    //refresh -> {RefreshScope@5469}
    //request -> {RequestScope@7462} 
    //session -> {SessionScope@7464} 
    //application -> {ServletContextScope@7466} 
    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);
            }
        });
        bean = getObjectForBeanInstance(scopedInstance, name, beanName, mbd);
    }
}
......
}

獲取到RefreshScope對象后就會(huì)調(diào)用其中的get()方法進(jìn)行初始化。先創(chuàng)建BeanLifecycleWrapper對象，包含了bean的name和創(chuàng)建bean的工廠方法(lamdba表達(dá)式)，再調(diào)用BeanLifecycleWrapper類中的getBean()方法獲取bean的實(shí)例對象，此時(shí)調(diào)用this.bean = this.objectFactory.getObject();工廠方法來創(chuàng)建bean，則回到createBean(beanName, mbd, args);方法完成bean的創(chuàng)建。接下來看看方法是怎么調(diào)用的。

1. 獲取被代理原始bean的實(shí)例對象
2. 創(chuàng)建攔截器鏈，找到之前加入的LockedScopedProxyFactoryBean攔截器，調(diào)用invoke()方法進(jìn)行處理
3. 獲取代理對象，即LockedScopedProxyFactoryBean的代理對象；獲取讀寫鎖的讀鎖，當(dāng)前配置刷新時(shí)，則無法獲取
4. 以反射方式調(diào)用目標(biāo)方法method.invoke(target, args)

再看看配置怎么刷新到bean當(dāng)中的。當(dāng)配置源變更時(shí)方法調(diào)用鏈如下：

• NacosContextRefresher#registerNacosListener()注冊監(jiān)聽器(receiveConfigInfo())
• ApplicationEventPublisher.java#publishEvent()發(fā)布RefreshEvent事件
• SimpleApplicationEventMulticaster#multicastEvent()方法廣播事件
• RefreshEventListener#handle(RefreshEvent event)處理RefreshEvent事件
• ContextRefresher#refresh()進(jìn)行處理，做了三件事
  • 刷新配置源
  • 發(fā)布EnvironmentChangeEvent事件，重新生成配置源Bean(@ConfigurationProperties注解Bean)
  • 將配置寫到@RefreshScope注解標(biāo)注的Bean

開始分析怎么刷新到@RefreshScope注解標(biāo)注的Bean：將保存原始被代理的Bean的BeanLifecycleWrapperCache中清空，獲取寫鎖(此時(shí)其他線程無法獲取讀鎖)，調(diào)用每個(gè)BeanLifecycleWrapper的destroy()方法進(jìn)行銷毀。緩存被清空了，如果重新獲取Bean就得重新創(chuàng)建，此時(shí)就會(huì)進(jìn)行Bean的屬性填充，就可以從屬性源中獲取新的屬性了

到此這篇關(guān)于Spring中@RefreshScope注解的處理方法詳解的文章就介紹到這了,更多相關(guān)Spring的@RefreshScope注解內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

最新評論