码迷,mamicode.com
首页 > 编程语言 > 详细

【spring源码分析】IOC容器初始化(一)

时间:2018-11-24 23:59:56      阅读:319      评论:0      收藏:0      [点我收藏+]

标签:temp   类的方法   获取   blank   核心   ini   阶段   esc   enabled   

前言:spring主要就是对bean进行管理,因此IOC容器的初始化过程非常重要,搞清楚其原理不管在实际生产或面试过程中都十分的有用。在【spring源码分析】准备工作中已经搭建好spring的环境,并利用xml配置形式对类进行了实例化。在test代码中有一个非常关键的类ClassPathXmlApplicationContext,在这个类中实现了IOC容器的初始化,因此我们从ClassPathXmlApplicationContext入手开始研究IOC的初始化过程。


1.ClassPathXmlApplicationContext类继承关系

技术分享图片

ClassPathXmlApplicationContext类的继承关系非常的庞大,在IOC容器初始化的过程中,经常调用父类的方法进行实现,因此需特别注意类之间的继承关系。通过阅读源码,可粗略的将IOC容器初始化过程分为两步:(1)解析xml文件,导入bean;(2)通过反射生成bean。因此下面将从这两大步对IOC初始化进行分析。

2.解析xml文件,导入bean

首先给出导入bean的调用链:

技术分享图片

通过程序调用链可知:

(1)导入bean大致分为三个阶段:①导入bean(loadBeanDefinitions);②解析bean(parseBeanDefinition);③注册bean(registerBeanDefinition)。

(2)最终bean是存储在beanDefinitionMap中:键为类名(beanName),值为GenericBeanDefinition(BeanDefinition)。

下面对导入bean的三个阶段进行分析。

 2.1 导入bean阶段

通过上述调用链,先整理出在导入bean过程中所涉及的类和相关方法。

技术分享图片

技术分享图片

技术分享图片

技术分享图片

技术分享图片

通过上表可以知道,在导入bean阶段主要涉及如下几个类(根据调用顺序):

①ClassPathXmlApplicationContext;②AbstractApplicationContext;

③AbstractRefreshableApplicationContext;④AbstractXmlApplicationContext;

⑤AbstractBeanDefinitionReader;⑥XmlBeanDefinitionReader。

根据类名就可以猜测出①②③④为继承关系,事实的确如此。其继承关系通过ClassPathXmlApplicationContext继承关系图可知:

技术分享图片

⑤⑥也为继承关系,其继承关系如下:

技术分享图片

2.2 bean导入阶段源码分析

通过上面对bean导入阶段大致流程的梳理,应该对bean导入阶段有了大体的认识,下面对该阶段源码进行分析(按上面程序调用链顺序)。

ClassPathXmlApplicationContext构造函数,具体代码如下:

 1     public ClassPathXmlApplicationContext(
 2             String[] configLocations, boolean refresh, @Nullable ApplicationContext parent)
 3             throws BeansException {
 4 
 5         super(parent);
 6         System.out.println("配置文件:"+configLocations[0]);
 7         setConfigLocations(configLocations);  //配置xml文件资源
 8         if (refresh) {
 9             System.out.println("进入核心函数:AbstractApplicationContext#refresh");
10             refresh();
11         }
12     }

这段代码比较好理解主要就是设置xml文件资源,将xml文件的路径保存下来,供后面使用。

第7行代码调用的是AbstractRefreshableConfigApplicationContext的setConfigLocations函数,该函数功能简单:设置xml文件资源,具体代码如下:

 1     /**
 2      * Set the config locations for this application context.
 3      * <p>If not set, the implementation may use a default as appropriate.
 4      */
 5     public void setConfigLocations(@Nullable String... locations) {
 6         if (locations != null) {
 7             Assert.noNullElements(locations, "Config locations must not be null");
 8             this.configLocations = new String[locations.length];
 9             for (int i = 0; i < locations.length; i++) {
10                 this.configLocations[i] = resolvePath(locations[i]).trim();  //解析xml路径,并存入configLocations中
11             }
12         }
13         else {
14             this.configLocations = null;
15         }
16     }

第10行代码refresh()为整个IOC流程的入口,这里调用的是AbstractApplicationContext的refresh方法,具体代码如下:

 1 public void refresh() throws BeansException, IllegalStateException {
 2         synchronized (this.startupShutdownMonitor) {
 3             // Prepare this context for refreshing.
 4             System.out.println("设置上下文活动标志active(会先将上下文标志设置为true),还有进行一些环境配置。");
 5             prepareRefresh();
 6 
 7             // Tell the subclass to refresh the internal bean factory.
 8             System.out.println("核心函数AbstractApplicationContext#obtainFreshBeanFactory,功能解析xml,创建BeanFactory");
 9             ConfigurableListableBeanFactory beanFactory = obtainFreshBeanFactory();
10 
11             // Prepare the bean factory for use in this context.
12             prepareBeanFactory(beanFactory);
13 
14             try {
15                 // Allows post-processing of the bean factory in context subclasses.
16                 postProcessBeanFactory(beanFactory);
17 
18                 // Invoke factory processors registered as beans in the context.
19                 invokeBeanFactoryPostProcessors(beanFactory);
20 
21                 // Register bean processors that intercept bean creation.
22                 registerBeanPostProcessors(beanFactory);
23 
24                 // Initialize message source for this context.
25                 initMessageSource();
26 
27                 // Initialize event multicaster for this context.
28                 initApplicationEventMulticaster();
29 
30                 // Initialize other special beans in specific context subclasses.
31                 onRefresh();
32 
33                 // Check for listener beans and register them.
34                 registerListeners();
35 
36                 // Instantiate all remaining (non-lazy-init) singletons.
37                 //该函数中会对bean进行初始化,利用反射技术。
38                 finishBeanFactoryInitialization(beanFactory);
39 
40                 // Last step: publish corresponding event.
41                 finishRefresh();
42             }
43 
44             catch (BeansException ex) {
45                 if (logger.isWarnEnabled()) {
46                     logger.warn("Exception encountered during context initialization - " +
47                             "cancelling refresh attempt: " + ex);
48                 }
49 
50                 // Destroy already created singletons to avoid dangling resources.
51                 destroyBeans();
52 
53                 // Reset ‘active‘ flag.
54                 cancelRefresh(ex);
55 
56                 // Propagate exception to caller.
57                 throw ex;
58             }
59 
60             finally {
61                 // Reset common introspection caches in Spring‘s core, since we
62                 // might not ever need metadata for singleton beans anymore...
63                 resetCommonCaches();
64             }
65         }
66     }

注:该方法为同步方法;主要关注:①obtainFreshBeanFactory;②finishBeanFactoryInitialization。①方法会进行bean的注入;②方法会利用反射实例化bean。

第5行prepareRefresh函数功能比较简单:设置相关标志(将active设置为true),初始化一些数据。

重点第9行obtainFreshBeanFactory函数生成beanFactory工厂,具体代码如下:

1 protected ConfigurableListableBeanFactory obtainFreshBeanFactory() {
2         refreshBeanFactory();
3         ConfigurableListableBeanFactory beanFactory = getBeanFactory();
4         if (logger.isDebugEnabled()) {
5             logger.debug("Bean factory for " + getDisplayName() + ": " + beanFactory);
6         }
7         return beanFactory;
8     }

注意这里执行完refreshBeanFactory后就会返回beanFactory,关键函数refreshBeanFactory刷新beanFactory,这里会调用AbstractRefreshableApplicationContext中的refreshBeanFactory方法,具体代码如下:

 1 protected final void refreshBeanFactory() throws BeansException {
 2         if (hasBeanFactory()) {
 3             destroyBeans();
 4             closeBeanFactory();
 5         }
 6         try {
 7             System.out.println("在AbstractRefreshableApplicationContext#refreshBeanFactory方法中创建beanFactory");
 8             DefaultListableBeanFactory beanFactory = createBeanFactory();
 9             beanFactory.setSerializationId(getId());
10             customizeBeanFactory(beanFactory);
11             System.out.println("AbstractRefreshableApplicationContext#loadBeanDefinitions(beanFactory)关键函数,载入bean定义");
12             loadBeanDefinitions(beanFactory);
13             synchronized (this.beanFactoryMonitor) {
14                 this.beanFactory = beanFactory;
15             }
16         } catch (IOException ex) {
17             throw new ApplicationContextException("I/O error parsing bean definition source for " + getDisplayName(), ex);
18         }
19     }

分析:

①第2行:首先判断是否存在beanFactory,如果存在则销毁bean,并关闭beanfactory。

②第8行:创建beanFactory。

③第12行:导入bean。

关注第8行创建beanFactory,该函数会调用AbstractRefreshableApplicationContext中的createBeanFactory方法,具体代码如下:

1 protected DefaultListableBeanFactory createBeanFactory() {
2         System.out.println("new一个DefaultListableBeanFactory,需先判断是否存在内部的BeanFactory实例");
3         return new DefaultListableBeanFactory(getInternalParentBeanFactory());
4     }

这里直接new一个DefaultListableBeanFactory实例,这里会先判断是否有父工厂,在DefaultListableBeanFactory的构造函数中会调用其父类AbstractAutowireCapableBeanFactory的构造函数,在其构造函数中需要进行关注下:

1 public AbstractAutowireCapableBeanFactory() {
2         super();
3         ignoreDependencyInterface(BeanNameAware.class);
4         ignoreDependencyInterface(BeanFactoryAware.class);
5         ignoreDependencyInterface(BeanClassLoaderAware.class);
6         System.out.println("AbstractAutowireCapableBeanFactory构造函数中,忽略实现接口BeanNameAware.class/BeanFactoryAware.class/BeanClassLoaderAware.class类的自动装配功能");
7     }

这里会忽略实现BeanNameAware/BeanFactoryAware/BeanClassLoaderAware接口类的自动装配功能。

在实例化DefaultListableBeanFactory后,会对beanFactory进行一些设置,在customizeBeanFactory函数中:

1 protected void customizeBeanFactory(DefaultListableBeanFactory beanFactory) {
2         if (this.allowBeanDefinitionOverriding != null) {
3             beanFactory.setAllowBeanDefinitionOverriding(this.allowBeanDefinitionOverriding);
4         }
5         if (this.allowCircularReferences != null) {
6             beanFactory.setAllowCircularReferences(this.allowCircularReferences);
7         }
8     }

注:这里设置是否可以对BeanDefinition进行覆盖,是否允许循环依赖属性。

接下来重点函数loadBeanDefinitions,这里转向AbstractXmlApplicationContext中的loadBeanDefinitions函数,具体代码如下:

 1 protected void loadBeanDefinitions(DefaultListableBeanFactory beanFactory) throws BeansException, IOException {
 2         // Create a new XmlBeanDefinitionReader for the given BeanFactory.
 3         System.out.println("通过AbstractBeanDefinitionReader父类创建XmlBeanDefinitionReader,用于解析xml文件的bean");
 4         XmlBeanDefinitionReader beanDefinitionReader = new XmlBeanDefinitionReader(beanFactory);
 5 
 6         // Configure the bean definition reader with this context‘s
 7         // resource loading environment.
 8         System.out.println("设置环境与ResourceLoader");
 9         beanDefinitionReader.setEnvironment(this.getEnvironment());
10         beanDefinitionReader.setResourceLoader(this);
11         beanDefinitionReader.setEntityResolver(new ResourceEntityResolver(this));
12 
13         // Allow a subclass to provide custom initialization of the reader,
14         // then proceed with actually loading the bean definitions.
15         initBeanDefinitionReader(beanDefinitionReader);
16         loadBeanDefinitions(beanDefinitionReader);
17     }

分析:

①第4行创建XmlBeanDefinitionReader,是在AbstractBeanDefinitionReader中创建的,传入beanFactory对象。

②9-11行对beanDefinitionReader设置环境、资源导入器、实体解析器。

③第15行注释已经写得很清楚了,允许子类自定义实现beanDefinitionReader方法。

④继续调用loadBeanDefinitions,传入beanDefinitionReader。

此时loadBeanDefinitions函数仍然调用的是AbstractXmlApplicationContext中的方法:

 1 protected void loadBeanDefinitions(XmlBeanDefinitionReader reader) throws BeansException, IOException {
 2         Resource[] configResources = getConfigResources();
 3         if (configResources != null) {
 4             reader.loadBeanDefinitions(configResources);
 5         }
 6         String[] configLocations = getConfigLocations();
 7         if (configLocations != null) {
 8             System.out.println("AbstractXmlApplicationContext的loadBeanDefinitions(XmlBeanDefinitionReader reader),导入xml资源");
 9             reader.loadBeanDefinitions(configLocations);
10         }
11     }

分析:

这里根据资源类型走不同分支,由于我们前面已经设置了configLocation,所以这里走到第9行处。

由于创建beanDefinitionReader是在AbstractBeanDefinitionReader中实现,因此转向AbstractBeanDefinitionReader的loadBeanDefinitions:

1     @Override
2     public int loadBeanDefinitions(String... locations) throws BeanDefinitionStoreException {
3         Assert.notNull(locations, "Location array must not be null");
4         int counter = 0;
5         for (String location : locations) {
6             counter += loadBeanDefinitions(location);
7         }
8         return counter;
9     }

循环资源文件进行导入(这里会多次调用loadBeanDefinitions方法,注意方法入参),继续其loadBeanDefinitions方法,注意方法入参不同,最终转向的loadBeanDefinitions方法代码如下:

 1 public int loadBeanDefinitions(String location, @Nullable Set<Resource> actualResources) throws BeanDefinitionStoreException {
 2         ResourceLoader resourceLoader = getResourceLoader();
 3         if (resourceLoader == null) {
 4             throw new BeanDefinitionStoreException(
 5                     "Cannot import bean definitions from location [" + location + "]: no ResourceLoader available");
 6         }
 7 
 8         if (resourceLoader instanceof ResourcePatternResolver) {
 9             // Resource pattern matching available.
10             try {
11                 System.out.println("在AbstractBeanDefinitionReader中将xml资源转换成Resource");
12                 Resource[] resources = ((ResourcePatternResolver) resourceLoader).getResources(location);
13                 int loadCount = loadBeanDefinitions(resources);
14                 if (actualResources != null) {
15                     for (Resource resource : resources) {
16                         actualResources.add(resource);
17                     }
18                 }
19                 if (logger.isDebugEnabled()) {
20                     logger.debug("Loaded " + loadCount + " bean definitions from location pattern [" + location + "]");
21                 }
22                 return loadCount;
23             }
24             catch (IOException ex) {
25                 throw new BeanDefinitionStoreException(
26                         "Could not resolve bean definition resource pattern [" + location + "]", ex);
27             }
28         }
29         else {
30             // Can only load single resources by absolute URL.
31             Resource resource = resourceLoader.getResource(location);
32             int loadCount = loadBeanDefinitions(resource);
33             if (actualResources != null) {
34                 actualResources.add(resource);
35             }
36             if (logger.isDebugEnabled()) {
37                 logger.debug("Loaded " + loadCount + " bean definitions from location [" + location + "]");
38             }
39             return loadCount;
40         }
41     }

分析:

①第2行:取出资源导入器,为下面将xml配置文件转换成Resource数组做准备。

②第13行:由于将xml配置文件转换成了Resource数组,这里继续调用AbstractBeanDefinitionReader的loadBeanDefinitions方法(注意入参):

 1 public int loadBeanDefinitions(Resource... resources) throws BeanDefinitionStoreException {
 2         System.out.println("在AbstractBeanDefinitionReader#loadBeanDefinitions方法中(参数为Resource)得到" +
 3                 "加载资源文件的个数,也就是beanxml文件的个数");
 4         Assert.notNull(resources, "Resource array must not be null");
 5         int counter = 0;
 6         for (Resource resource : resources) {
 7             counter += loadBeanDefinitions(resource);
 8         }
 9         return counter;
10     }

注意在第7行处,这里要调用子类的方法了,具体调用XmlBeanDefinitionReader的loadBeanDefinitions方法:

 1     /**
 2      * Load bean definitions from the specified XML file.
 3      * @param resource the resource descriptor for the XML file
 4      * @return the number of bean definitions found
 5      * @throws BeanDefinitionStoreException in case of loading or parsing errors
 6      */
 7     @Override
 8     public int loadBeanDefinitions(Resource resource) throws BeanDefinitionStoreException {
 9         return loadBeanDefinitions(new EncodedResource(resource));
10     }
11 
12     /**
13      * Load bean definitions from the specified XML file.
14      * @param encodedResource the resource descriptor for the XML file,
15      * allowing to specify an encoding to use for parsing the file
16      * @return the number of bean definitions found
17      * @throws BeanDefinitionStoreException in case of loading or parsing errors
18      */
19     public int loadBeanDefinitions(EncodedResource encodedResource) throws BeanDefinitionStoreException {
20         Assert.notNull(encodedResource, "EncodedResource must not be null");
21         if (logger.isInfoEnabled()) {
22             logger.info("Loading XML bean definitions from " + encodedResource.getResource());
23         }
24 
25         Set<EncodedResource> currentResources = this.resourcesCurrentlyBeingLoaded.get();
26         if (currentResources == null) {
27             currentResources = new HashSet<>(4);
28             this.resourcesCurrentlyBeingLoaded.set(currentResources);
29         }
30         if (!currentResources.add(encodedResource)) {
31             throw new BeanDefinitionStoreException(
32                     "Detected cyclic loading of " + encodedResource + " - check your import definitions!");
33         }
34         try {
35             System.out.println("XmlBeanDefinitionReader的loadBeanDefinitions(EncodedResource encodedResource)中间Resource转化成InputStream流,进行读取操作");
36             InputStream inputStream = encodedResource.getResource().getInputStream();
37             try {
38                 InputSource inputSource = new InputSource(inputStream);
39                 if (encodedResource.getEncoding() != null) {
40                     inputSource.setEncoding(encodedResource.getEncoding());
41                 }
42                 return doLoadBeanDefinitions(inputSource, encodedResource.getResource());
43             }
44             finally {
45                 inputStream.close();
46             }
47         }
48         catch (IOException ex) {
49             throw new BeanDefinitionStoreException(
50                     "IOException parsing XML document from " + encodedResource.getResource(), ex);
51         }
52         finally {
53             currentResources.remove(encodedResource);
54             if (currentResources.isEmpty()) {
55                 this.resourcesCurrentlyBeingLoaded.remove();
56             }
57         }
58     }

分析:

①这里将Resource对象包装成了EncodedResource对象,注意第25行使用了ThreadLocal来避免线程安全问题。

②第36行:获取了一个输入流,对xml文件进行操作,接下来开始导入bean,转向XmlBeanDefinitionReader的doLoadBeanDefinitions方法:

1 protected int doLoadBeanDefinitions(InputSource inputSource, Resource resource)
2             throws BeanDefinitionStoreException {
3         try {
4             Document doc = doLoadDocument(inputSource, resource);
5             return registerBeanDefinitions(doc, resource);
6         }
7         catch (...)
8     }

至此,导入bean阶段完成,通过这么长的调用链其实主要就是将xml配置文件转换成流,为下一步解析和注册bean做准备。

下面给出bean导入阶段的大致时序图:

技术分享图片

技术分享图片

至此导入bean阶段大致分析完成,该阶段总的来说还是比较简单,下面将对解析bean阶段进行分析。


by Shawn Chen,2018.11.24日,晚。

【spring源码分析】IOC容器初始化(一)

标签:temp   类的方法   获取   blank   核心   ini   阶段   esc   enabled   

原文地址:https://www.cnblogs.com/morewindows0/p/10004293.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!