5.2Spring源码解析——refresh方法

 refresh方法在ConfigurableApplicationContext类中定义的具体实现是在AbstractApplicationContext中实现。这个方法的原文描述信息是:由于这是一个启动方法,如果它调用失败,它应该销毁已创建的单例,以避免悬空资源。换句话说,在调用该方法之后,应该实例化所有单例或者不是单例的对象。
 在类ConfigurableApplicationContext中还定义了一个registerShutdownHook方法,这个方法是在JVM关闭的时候调用的用来销毁所有的bean。
 接下来分析refresh方法

public void refresh() throws BeansException, IllegalStateException {
        synchronized (this.startupShutdownMonitor) {
//----------------------------------------1--------------------------------------//
            // 准备刷新和加载之前的上下文
            prepareRefresh();
//----------------------------------------1--------------------------------------//

//----------------------------------------2--------------------------------------//
            //告诉子类刷新内部bean工厂
            ConfigurableListableBeanFactory beanFactory = obtainFreshBeanFactory();
//----------------------------------------2--------------------------------------//

//----------------------------------------3--------------------------------------//
            // 准备在此上下文中使用的bean工厂
            prepareBeanFactory(beanFactory);
//----------------------------------------3--------------------------------------//

            try {
        //----------------------------------------4--------------------------------------//
                //注册对应的BeanPostProcessor接口,就是ServletContextAwareProcessor
                postProcessBeanFactory(beanFactory);
      //----------------------------------------4--------------------------------------//

  //----------------------------------------5--------------------------------------//
                //调用注册的BeanFactoryPostProcessor的postProcessBeanDefinitionRegistry方法
                invokeBeanFactoryPostProcessors(beanFactory);
  //----------------------------------------5--------------------------------------//

//----------------------------------------6--------------------------------------//
                // 注册拦截bean创建的bean处理器
                registerBeanPostProcessors(beanFactory);
//----------------------------------------6--------------------------------------//

                //初始化上下文的消息源。
                initMessageSource();
                //初始化上下文的事件传播器。
                initApplicationEventMulticaster();
                //在特定上下文子类中初始化其他特殊bean。
                onRefresh();
                // 检查监听器bean并注册它们
                registerListeners();
//----------------------------------------7--------------------------------------//
                //实例化所有剩余(非延迟初始化)单例。
                finishBeanFactoryInitialization(beanFactory);
//----------------------------------------7--------------------------------------//

//----------------------------------------8--------------------------------------//
                //最后一步:发布相应的事件。
                finishRefresh();
//----------------------------------------8-------------------------------------//
            }

            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();
            }
        }
    }

方法1:prepareRefresh

protected void prepareRefresh() {
        this.startupDate = System.currentTimeMillis();
        this.closed.set(false);
        this.active.set(true);
        if (logger.isDebugEnabled()) {
            if (logger.isTraceEnabled()) {
                logger.trace("Refreshing " + this);
            }
            else {
                logger.debug("Refreshing " + getDisplayName());
            }
        }
        //在上下文环境中初始化任何占位符属性源
        initPropertySources();
        // 验证指定的每个属性是不是可以解析的
        getEnvironment().validateRequiredProperties();
        // 初始化传播器
        this.earlyApplicationEvents = new LinkedHashSet<>();
    }

方法2:obtainFreshBeanFactory

    protected ConfigurableListableBeanFactory obtainFreshBeanFactory() {
        //初始化BeanFactory
        refreshBeanFactory();
        //返回实例化的BeanFactory
        return getBeanFactory();
    }

 其中的refreshBeanFactory方法的作用用来实例化BeanFactory并加载解析对应的Bean配置,其加载Bean的过程和前面讲到的BeanFactory加载的过程相同

protected final void refreshBeanFactory() throws BeansException {
        //通过beanFactoryMonitor这个Bean工厂的监视器来判断是否已经实例化了BeanFactory
        if (hasBeanFactory()) {
            //如果实例化了BeanFactory,则先销毁所有的单例Bean
            destroyBeans();
            //关闭BeanFactory,也就是将beanFactory的值置为null
            closeBeanFactory();
        }
        try {
            //创建BeanFactory实例,如果实现了ConfigurableApplicationContext则返回父上下文的内部bean工厂;否则,返回父上下文本身
            DefaultListableBeanFactory beanFactory = createBeanFactory();
            beanFactory.setSerializationId(getId());
            //如果用户自定义了允许Bean定义覆盖和允许循环引用则设置为定义的,默认为不允许
            customizeBeanFactory(beanFactory);
            //加载bean,前面已经讲过bean的加载
            loadBeanDefinitions(beanFactory);
            synchronized (this.beanFactoryMonitor) {
                this.beanFactory = beanFactory;
            }
        }
        catch (IOException ex) {
            throw new ApplicationContextException("I/O error parsing bean definition source for " + getDisplayName(), ex);
        }
    }

方法3:prepareBeanFactory

 这个方法主要是配置BeanFactory的各种类加载器,需要的依赖和需要忽略的依赖,后处理器,解析器等

    protected void prepareBeanFactory(ConfigurableListableBeanFactory beanFactory) {
        //设置加载Bean用的类加载器
        beanFactory.setBeanClassLoader(getClassLoader());
        //设置Bean中表达式解析用的解析器,默认的SpEL解析器
        beanFactory.setBeanExpressionResolver(new StandardBeanExpressionResolver(beanFactory.getBeanClassLoader()));
        //添加属性注册时候的注册器,可以自定义注册器,只需要实现PropertyEditorRegistrar接口
        beanFactory.addPropertyEditorRegistrar(new ResourceEditorRegistrar(this, getEnvironment()));
        //添加ApplicationContextAwareProcessor(其中包含了ApplicationContext,起到了传递的作用)
        beanFactory.addBeanPostProcessor(new ApplicationContextAwareProcessor(this));
        //忽略给定的自动装配依赖关系接口,放到ignoredDependencyInterfaces中保存
        beanFactory.ignoreDependencyInterface(EnvironmentAware.class);
        beanFactory.ignoreDependencyInterface(EmbeddedValueResolverAware.class);
        beanFactory.ignoreDependencyInterface(ResourceLoaderAware.class);
        beanFactory.ignoreDependencyInterface(ApplicationEventPublisherAware.class);
        beanFactory.ignoreDependencyInterface(MessageSourceAware.class);
        beanFactory.ignoreDependencyInterface(ApplicationContextAware.class);
        // BeanFactory interface not registered as resolvable type in a plain factory.
        // MessageSource registered (and found for autowiring) as a bean.
        //自动装配值注册特殊依赖关系类型,放到resolvableDependencies集合中保存
        beanFactory.registerResolvableDependency(BeanFactory.class, beanFactory);
        beanFactory.registerResolvableDependency(ResourceLoader.class, this);
        beanFactory.registerResolvableDependency(ApplicationEventPublisher.class, this);
        beanFactory.registerResolvableDependency(ApplicationContext.class, this);
        //注册ApplicationListenerDetector作为早期后处理器以检测内部bean实现了ApplicationListener的情况
        // Register early post-processor for detecting inner beans as ApplicationListeners.
        beanFactory.addBeanPostProcessor(new ApplicationListenerDetector(this));
        // Detect a LoadTimeWeaver and prepare for weaving, if found.
        //如果beanFactory中包含loadTimeWeaver名称的bean,则需要使用对应的临时的类加载器处理
        if (beanFactory.containsBean(LOAD_TIME_WEAVER_BEAN_NAME)) {
            beanFactory.addBeanPostProcessor(new LoadTimeWeaverAwareProcessor(beanFactory));
            // Set a temporary ClassLoader for type matching.
            beanFactory.setTempClassLoader(new ContextTypeMatchClassLoader(beanFactory.getBeanClassLoader()));
        }
        // Register default environment beans.
        //注册默认的需要的上下文环境bean,包含environment,systemProperties和systemEnvironment
        if (!beanFactory.containsLocalBean(ENVIRONMENT_BEAN_NAME)) {
            beanFactory.registerSingleton(ENVIRONMENT_BEAN_NAME, getEnvironment());
        }
        if (!beanFactory.containsLocalBean(SYSTEM_PROPERTIES_BEAN_NAME)) {
            beanFactory.registerSingleton(SYSTEM_PROPERTIES_BEAN_NAME, getEnvironment().getSystemProperties());
        }
        if (!beanFactory.containsLocalBean(SYSTEM_ENVIRONMENT_BEAN_NAME)) {
            beanFactory.registerSingleton(SYSTEM_ENVIRONMENT_BEAN_NAME, getEnvironment().getSystemEnvironment());
        }
    }

方法4:postProcessBeanFactory

 这个方法主要注册web请求相关的处理器和bean以及配置

protected void postProcessBeanFactory(ConfigurableListableBeanFactory beanFactory) {
        //将ServletContextAwareProcessor注册到bean注册前处理器中
        beanFactory.addBeanPostProcessor(new ServletContextAwareProcessor(this.servletContext, this.servletConfig));
        //将ServletContextAware和ServletConfigAware设置为忽略依赖
        beanFactory.ignoreDependencyInterface(ServletContextAware.class);
        beanFactory.ignoreDependencyInterface(ServletConfigAware.class);
        //注册特定于Web的范围(如request,session和application),添加对应的web请求依赖(ServletRequest,ServletResponse,HttpSession,WebRequest使用各自对应的BeanFactory)
        WebApplicationContextUtils.registerWebApplicationScopes(beanFactory, this.servletContext);
        //注册环境变量,在servletContext和servletConfig中设置的和自带的
        WebApplicationContextUtils.registerEnvironmentBeans(beanFactory, this.servletContext, this.servletConfig);
    }

方法5:invokeBeanFactoryPostProcessors

 这个方法主要是调用实现了的bean后处理器

protected void invokeBeanFactoryPostProcessors(ConfigurableListableBeanFactory beanFactory) {
        /**
         * 这里的调用所有的实现了BeanFactoryPostProcessor接口的类的方法,调用postProcessBeanDefinitionRegistry方法的时候按照会按照一定顺序来调用
         * 1.调用实现PriorityOrdered的BeanDefinitionRegistryPostProcessors
         * 2.调用实现Ordered的BeanDefinitionRegistryPostProcessors
         * 3.调用所有其他BeanDefinitionRegistryPostProcessors,直到不再出现其他BeanDefinitionRegistryPostProcessors
         * 调用postProcessBeanFactory没有顺序
         */
        PostProcessorRegistrationDelegate.invokeBeanFactoryPostProcessors(beanFactory, getBeanFactoryPostProcessors());
        //这里特殊处理前面说到的bean名称为loadTimeWeaver的Bean
        if (beanFactory.getTempClassLoader() == null && beanFactory.containsBean(LOAD_TIME_WEAVER_BEAN_NAME)) {
            beanFactory.addBeanPostProcessor(new LoadTimeWeaverAwareProcessor(beanFactory));
            beanFactory.setTempClassLoader(new ContextTypeMatchClassLoader(beanFactory.getBeanClassLoader()));
        }
    }

方法6:registerBeanPostProcessors

 这个方法主要是注册实现了的bean后处理器

protected void registerBeanPostProcessors(ConfigurableListableBeanFactory beanFactory) {
        /**
         * 这里的注册所有的实现了BeanPostProcessor接口的类的方法一定顺序来注册
         * 1.注册实现PriorityOrdered的BeanPostProcessor
         * 2.注册实现Ordered的BeanPostProcessor
         * 3.注册所有其他BeanPostProcessor,直到不再出现其他BeanPostProcessor
         * 最后,重新注册ApplicationListenerDetector为后处理器以检测内部bean实现ApplicationListener接口的,并将其移动到处理器链的末尾
         */
        PostProcessorRegistrationDelegate.registerBeanPostProcessors(beanFactory, this);
    }

方法7:finishBeanFactoryInitialization

 在这里加载并实例化所有的懒加载的bean

protected void  finishBeanFactoryInitialization(ConfigurableListableBeanFactory beanFactory) {
        //设置对应的用于类型转换的服务接口,ConversionService可以自己实现
        if (beanFactory.containsBean(CONVERSION_SERVICE_BEAN_NAME) &&
                beanFactory.isTypeMatch(CONVERSION_SERVICE_BEAN_NAME, ConversionService.class)) {
            beanFactory.setConversionService(
                    beanFactory.getBean(CONVERSION_SERVICE_BEAN_NAME, ConversionService.class));
        }

        /* Register a default embedded value resolver if no bean post-processor
         (such as a PropertyPlaceholderConfigurer bean) registered any before:
         at this point, primarily for resolution in annotation attribute values.*/
        if (!beanFactory.hasEmbeddedValueResolver()) {
            beanFactory.addEmbeddedValueResolver(strVal -> getEnvironment().resolvePlaceholders(strVal));
        }

        // Initialize LoadTimeWeaverAware beans early to allow for registering their transformers early.
        String[] weaverAwareNames = beanFactory.getBeanNamesForType(LoadTimeWeaverAware.class, false, false);
        for (String weaverAwareName : weaverAwareNames) {
            getBean(weaverAwareName);
        }

        //停止使用临时ClassLoader进行类型匹配,因为已经加载完了bean
        beanFactory.setTempClassLoader(null);

        //冻结所以的bean定义,说明注册的bean定义将不被修改或任何进一步的处理
        beanFactory.freezeConfiguration();

        //初始化剩下的单实例(非惰性),在这个方法中最终会调用getBean方法,就会实例化bean
        beanFactory.preInstantiateSingletons();
    }

方法8:finishRefresh

    protected void finishRefresh() {
                //清除上下文级资源缓存
        clearResourceCaches();

        // 为此上下文初始化生命周期处理器,可以自定义LifecycleProcessor,如果没有则使用默认的DefaultLifecycleProcessor
        initLifecycleProcessor();

        // 刷新bean的生命周期  
        getLifecycleProcessor().onRefresh();

        // Publish the final event.
        publishEvent(new ContextRefreshedEvent(this));

        // Participate in LiveBeansView MBean, if active.
        LiveBeansView.registerApplicationContext(this);
    }
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 212,294评论 6 493
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 90,493评论 3 385
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 157,790评论 0 348
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 56,595评论 1 284
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 65,718评论 6 386
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 49,906评论 1 290
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 39,053评论 3 410
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 37,797评论 0 268
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 44,250评论 1 303
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 36,570评论 2 327
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 38,711评论 1 341
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 34,388评论 4 332
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 40,018评论 3 316
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 30,796评论 0 21
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 32,023评论 1 266
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 46,461评论 2 360
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 43,595评论 2 350

推荐阅读更多精彩内容