【Spring】容器刷新(refresh)流程解析


一、概述

  源碼如下:

@Override
    public void refresh() throws BeansException, IllegalStateException {
        synchronized (this.startupShutdownMonitor) {
            // Prepare this context for refreshing.
            prepareRefresh();

            // Tell the subclass to refresh the internal bean factory.
            ConfigurableListableBeanFactory beanFactory = obtainFreshBeanFactory();

            // Prepare the bean factory for use in this context.
            prepareBeanFactory(beanFactory);

            try {
                // Allows post-processing of the bean factory in context subclasses.
                postProcessBeanFactory(beanFactory);

                // Invoke factory processors registered as beans in the context.
                invokeBeanFactoryPostProcessors(beanFactory);

                // Register bean processors that intercept bean creation.
                registerBeanPostProcessors(beanFactory);

                // Initialize message source for this context.
                initMessageSource();

                // Initialize event multicaster for this context.
                initApplicationEventMulticaster();

                // Initialize other special beans in specific context subclasses.
                onRefresh();

                // Check for listener beans and register them.
                registerListeners();

                // Instantiate all remaining (non-lazy-init) singletons.
                finishBeanFactoryInitialization(beanFactory);

                // Last step: publish corresponding event.
                finishRefresh();
            }

            catch (BeansException ex) {
                if (logger.isWarnEnabled()) {
                    logger.warn("Exception encountered during context initialization - " +
                            "cancelling refresh attempt: " + ex);
                }

                // Destroy already created singletons to avoid dangling resources.
                destroyBeans();

                // Reset 'active' flag.
                cancelRefresh(ex);

                // Propagate exception to caller.
                throw ex;
            }

            finally {
                // Reset common introspection caches in Spring's core, since we
                // might not ever need metadata for singleton beans anymore...
                resetCommonCaches();
            }
        }
    }

二、prepareRefresh()

  刷新前的預處理:
  

  1. initPropertySources()初始化一些屬性設置;子類自定義個性化的屬性設置方法;
  2. getEnvironment().validateRequiredProperties();檢驗屬性的合法等
  3. earlyApplicationEvents= new LinkedHashSet ();保存容器中的一些早期的事件;

三、obtainFreshBeanFactory()

   獲取BeanFactory:

  1. refreshBeanFactory();刷新【創建】BeanFactory
    • 創建了一個this.beanFactory = new DefaultListableBeanFactory();
    • 設置id;
  2. getBeanFactory();返回剛才GenericApplicationContext創建的BeanFactory對象;
  3. 將創建的BeanFactory【DefaultListableBeanFactory】返回;

四、prepareBeanFactory(beanFactory);

  BeanFactory的預准備工作(BeanFactory進行一些設置):

  1. 設置BeanFactory的類加載器、支持表達式解析器...
  2. 添加部分BeanPostProcessor【ApplicationContextAwareProcessor】
  3. 設置忽略的自動裝配的接口EnvironmentAware、EmbeddedValueResolverAware、xxx;
  4. 注冊可以解析的自動裝配;我們能直接在任何組件中自動注入:BeanFactory、ResourceLoader、ApplicationEventPublisher、ApplicationContext
  5. 添加BeanPostProcessor【ApplicationListenerDetector】
  6. 添加編譯時的AspectJ;
  7. 給BeanFactory中注冊一些能用的組件;
    environment【ConfigurableEnvironment】、
    systemProperties【Map 】、
    systemEnvironment【Map

五、postProcessBeanFactory(beanFactory);

  BeanFactory准備工作完成后進行的后置處理工作: 

  • 子類通過重寫這個方法來在BeanFactory創建並預准備完成以后做進一步的設置

  
以上是BeanFactory的創建及預准備工作
   

六、invokeBeanFactoryPostProcessors(beanFactory)

執行BeanFactoryPostProcessor的方法,BeanFactoryPostProcessor:BeanFactory的后置處理器。在BeanFactory標准初始化之后執行的;
兩個接口:BeanFactoryPostProcessorBeanDefinitionRegistryPostProcessor

執行BeanFactoryPostProcessor的方法;

  1. 先執行BeanDefinitionRegistryPostProcessor的方法

    • 獲取所有的BeanDefinitionRegistryPostProcessor;
    • 看先執行實現了PriorityOrdered優先級接口的BeanDefinitionRegistryPostProcessor、
      postProcessor.postProcessBeanDefinitionRegistry(registry)
    • 在執行實現了Ordered順序接口的BeanDefinitionRegistryPostProcessor;
      postProcessor.postProcessBeanDefinitionRegistry(registry)
    • 最后執行沒有實現任何優先級或者是順序接口的BeanDefinitionRegistryPostProcessors;
      postProcessor.postProcessBeanDefinitionRegistry(registry)

  2. 再執行BeanFactoryPostProcessor的方法

    • 獲取所有的BeanFactoryPostProcessor
    • 看先執行實現了PriorityOrdered優先級接口的BeanFactoryPostProcessor、postProcessor.postProcessBeanFactory()
    • 在執行實現了Ordered順序接口的BeanFactoryPostProcessor;postProcessor.postProcessBeanFactory()
    • 最后執行沒有實現任何優先級或者是順序接口的BeanFactoryPostProcessor;postProcessor.postProcessBeanFactory()

七、registerBeanPostProcessors(beanFactory)

  注冊BeanPostProcessor(Bean的后置處理器)【 intercept bean creation】不同接口類型的BeanPostProcessor;在Bean創建前后的執行時機是不一樣的BeanPostProcessor、DestructionAwareBeanPostProcessor、InstantiationAwareBeanPostProcessor、SmartInstantiationAwareBeanPostProcessor、MergedBeanDefinitionPostProcessor【internalPostProcessors】
  

  1. 獲取所有的 BeanPostProcessor;后置處理器都默認可以通過PriorityOrderedOrdered接口來執行優先級
  2. 先注冊PriorityOrdered優先級接口的BeanPostProcessor;把每一個BeanPostProcessor;添加到BeanFactory中beanFactory.addBeanPostProcessor(postProcessor);
  3. 再注冊Ordered接口的
  4. 最后注冊沒有實現任何優先級接口的
  5. 最終注冊MergedBeanDefinitionPostProcessor;
  6. 注冊一個ApplicationListenerDetector;來在Bean創建完成后檢查是否是ApplicationListener,如果是applicationContext.addApplicationListener((ApplicationListener<?>) bean);

八、initMessageSource()

初始化MessageSource組件(做國際化功能;消息綁定,消息解析:

  1. 獲取BeanFactory
  2. 看容器中是否有id為messageSource的,類型是MessageSource的組件;如果有賦值給messageSource;如果沒有自己創建一個DelegatingMessageSource;MessageSource:取出國際化配置文件中的某個key的值;能按照區域信息獲取;
  3. 把創建好的MessageSource注冊在容器中,以后獲取國際化配置文件的值的時候,可以自動注入MessageSource;beanFactory.registerSingleton(MESSAGE_SOURCE_BEAN_NAME, this.messageSource); MessageSource.getMessage(String code, Object[] args, String defaultMessage, Locale locale);

九、initApplicationEventMulticaster()

  初始化事件派發器:

  1. 獲取BeanFactory
  2. 從BeanFactory中獲取applicationEventMulticaster的ApplicationEventMulticaster;
  3. 如果上一步沒有配置;創建一個SimpleApplicationEventMulticaster
  4. 將創建的ApplicationEventMulticaster添加到BeanFactory中,以后其他組件直接自動注入

十、onRefresh()

  留給子容器(子類):

  1. 子類重寫這個方法,在容器刷新的時候可以自定義邏輯;

十一、registerListeners()

  給容器中將所有項目里面的ApplicationListener注冊進來:

  1. 從容器中拿到所有的ApplicationListener
  2. 將每個監聽器添加到事件派發器中getApplicationEventMulticaster().addApplicationListenerBean(listenerBeanName);
  3. 派發之前步驟產生的事件;

十二、finishBeanFactoryInitialization(beanFactory)

  初始化所有剩下的單實例bean:beanFactory.preInstantiateSingletons();初始化后剩下的單實例bean:

  1. 獲取容器中的所有Bean,依次進行初始化和創建對象
  2. 獲取Bean的定義信息;RootBeanDefinition
  3. Bean不是抽象的,是單實例的,是懶加載;

    • 判斷是否是FactoryBean;是否是實現FactoryBean接口的Bean;
    • 不是工廠Bean。利用getBean(beanName) 創建對象

      • 0、getBean(beanName); ioc.getBean();
      • 1、doGetBean(name, null, null, false);
      • 2、先獲取緩存中保存的單實例Bean。如果能獲取到說明這個Bean之前被創建過(所有創建過的單實例Bean都會被緩存起來)從private final Map<String, Object> singletonObjects = new ConcurrentHashMap<String, Object>(256);獲取的
      • 3、緩存中獲取不到,開始Bean的創建對象流程;
      • 4、標記當前bean已經被創建
      • 5、獲取Bean的定義信息;
      • 6、【獲取當前Bean依賴的其他Bean;如果有按照getBean()把依賴的Bean先創建出來;】
      • 7、啟動單實例Bean的創建流程;
       1)、createBean(beanName, mbd, args);
       2)、Object bean = resolveBeforeInstantiation(beanName, mbdToUse);讓BeanPostProcessor先攔截返回代理對象;【InstantiationAwareBeanPostProcessor】:提前執行;先觸發:postProcessBeforeInstantiation();如果有返回值:觸發postProcessAfterInitialization();
      3)、如果前面的InstantiationAwareBeanPostProcessor沒有返回代理對象;調用4)
      4)、Object beanInstance = doCreateBean(beanName, mbdToUse, args);創建Bean
      1)、【創建Bean實例】;createBeanInstance(beanName, mbd, args);利用工廠方法或者對象的構造器創建出Bean實例;
      2)、applyMergedBeanDefinitionPostProcessors(mbd, beanType, beanName);調用MergedBeanDefinitionPostProcessor的postProcessMergedBeanDefinition(mbd, beanType, beanName);
      3)、【Bean屬性賦值】populateBean(beanName, mbd, instanceWrapper);
      賦值之前:
      1)、拿到InstantiationAwareBeanPostProcessor后置處理器; postProcessAfterInstantiation();
      2)、拿到InstantiationAwareBeanPostProcessor后置處理器;postProcessPropertyValues();
      =====賦值之前:===
      3)、應用Bean屬性的值;為屬性利用setter方法等進行賦值;
      applyPropertyValues(beanName, mbd, bw, pvs);
      4)、【Bean初始化】initializeBean(beanName, exposedObject, mbd);
      1)、【執行Aware接口方法】invokeAwareMethods(beanName, bean);執行xxxAware接口的方法
      BeanNameAware\BeanClassLoaderAware\BeanFactoryAware
      2)、【執行后置處理器初始化之前】applyBeanPostProcessorsBeforeInitialization(wrappedBean, beanName);
      BeanPostProcessor.postProcessBeforeInitialization();
      3)、【執行初始化方法】invokeInitMethods(beanName, wrappedBean, mbd); 1)、是否是InitializingBean接口的實現;執行接口規定的初始化;2)、是否自定義初始化方法;
      4)、【執行后置處理器初始化之后】applyBeanPostProcessorsAfterInitialization、BeanPostProcessor.postProcessAfterInitialization();
      5)、注冊Bean的銷毀方法;
      5)、將創建的Bean添加到緩存中singletonObjects;
      ioc容器就是這些Map;很多的Map里面保存了單實例Bean,環境信息。。。。;
      所有Bean都利用getBean創建完成以后;
      檢查所有的Bean是否是SmartInitializingSingleton接口的;如果是;就執行afterSingletonsInstantiated();

十二、finishRefresh()

完成BeanFactory的初始化創建工作;IOC容器就創建完成:

  1. initLifecycleProcessor();初始化和生命周期有關的后置處理器;LifecycleProcessor默認從容器中找是否有lifecycleProcessor的組件【LifecycleProcessor】;如果沒有new DefaultLifecycleProcessor();
    加入到容器;
    寫一個LifecycleProcessor的實現類,可以在BeanFactory
    void onRefresh();
    void onClose();
  2. getLifecycleProcessor().onRefresh();
    拿到前面定義的生命周期處理器(BeanFactory);回調onRefresh();
  3. publishEvent(new ContextRefreshedEvent(this));發布容器刷新完成事件;
  4. liveBeansView.registerApplicationContext(this);

十三、總結

  1. Spring容器在啟動的時候,先會保存所有注冊進來的Bean的定義信息;
    • xml注冊bean;
    • 注解注冊Bean;@Service、@Component、@Bean、xxx
  2. Spring容器會合適的時機創建這些Bean
    • 用到這個bean的時候;利用getBean創建bean;創建好以后保存在容器中;
    • 統一創建剩下所有的bean的時候;finishBeanFactoryInitialization();
  3. 后置處理器;BeanPostProcessor
    • 每一個bean創建完成,都會使用各種后置處理器進行處理;來增強bean的功能;
      AutowiredAnnotationBeanPostProcessor:處理自動注入
      AnnotationAwareAspectJAutoProxyCreator:來做AOP功能;
      xxx....
      增強的功能注解:
      AsyncAnnotationBeanPostProcessor
      ....
  4. 事件驅動模型;
    ApplicationListener;事件監聽;
    ApplicationEventMulticaster;事件派發:


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM