spring初始化源码分析
这篇文章主要介绍“spring初始化源码分析”的相关知识，小编通过实际案例向大家展示操作过程，操作方法简单快捷，实用性强，希望这篇“spring初始化源码分析”文章能帮助大家解决问题。
1、refresh()简介
通过ClassPathXmlApplicationContext构造方法进入 refresh方法
public void refresh() throws BeansException, IllegalStateException {
synchronized (this.startupShutdownMonitor) {
//容器刷新前做一些准备工作
prepareRefresh();
// 创建DefaultListableBeanFactory对象，解析出所有BeanDefinition信息，
//注册缓存在DefaultListableBeanFactory的beanDefinitionMap属性中，供后面创建bean对象时使用
ConfigurableListableBeanFactory beanFactory = obtainFreshBeanFactory();
// 为beanFactory提供一些标准配置，如：类加载器、环境变量等
prepareBeanFactory(beanFactory);
try {
// 为beanFactory提供一些个性配置，通过在子上下文中复写该方法来实现
postProcessBeanFactory(beanFactory);
//创建实现BeanFactoryPostProcessor的实现类，并执行接口的方法。
//该方法执行完后会输出实例中的1-7步的日志
invokeBeanFactoryPostProcessors(beanFactory);
//创建BeanPostProcessor的实现类，并注册到BeanFactoryPostProcessor的beanPostProcessors列表中，
//在后面创建普通非lazy对象时会遍历该列表回调前置和后置方法
registerBeanPostProcessors(beanFactory);
//跟国际化消息相关，没去研究过
initMessageSource();
//初始化该上下文的事件广播
initApplicationEventMulticaster();
//模板方法，在不同的容器刷新的时候可以自定义逻辑
onRefresh();
//创建ApplicationListener的实现类，并注册到该上下文中
registerListeners();
//完成所有剩余的非lazy的bean的创建
finishBeanFactoryInitialization(beanFactory);
//上下文的创建完成的一些设置和缓存清理，并发布创建完成事件
finishRefresh();
}catch (BeansException ex) {
……
}finally {
//Reset common introspection caches in Spring's core, since we
//might not ever need metadata for singleton beans anymore...
resetCommonCaches();
}
}2、关键代码跟踪
先看《spring初始化源码浅析之关键类和扩展接口》文中代码执行结果：
2.1、obtainFreshBeanFactory()代码分析
首先找到beanFactory的入口方法，如下
继续debug进入refreshBeanFactory方法，如下
从下图中可以看到，XmlBeanDefinitionReader为加载BeanDefinition的关键类，而将beanFactoy作为构造参数主要是为了将创建好的BeanDefinition对象注册到beanFactory中，后面会贴出相应的代码,如下
继续断点进入XmlBeanDefinitionReader的loadBeanDefinitions方法，可见入参为main方法中的指定配置文件的名称,如下
断点继续走，跳过将applicationContext.xml文件解析成Document的过程，进入registerBeanDefinitions(Document doc, Resource resource)方法，入参为applicationContext.xml对应的Document对象，该方法构造一个BeanDefinitionDocumentReader对象来具体的负责从doc对象创建BeanDefinition对象，并注册到beanFactory中,如下
注意 BeanDefinitionDocumentReader的registerBeanDefinitions方法一个入参为XmlReaderContext对象，该对象的reader即为前面创建XmlBeanDefinitionReader对象。
继续断点进入以下方法：
最后进入DefaultListableBeanFactory的registerBeanDefinition方法，最后将创建好的BeanDefinition对象缓存到DefaultListableBeanFactory的一个ConcurrentHashMap中
最终将配置文件中所有的bean配置转成BeanDefinition对象缓存起来，供后面创建具体的bean对象使用。
2.2、invokeBeanFactoryPostProcessors(beanFactory)代码分析
进入方法发现逻辑都交给PostProcessorRegistrationDelegate类来处理：
断点一直走到下面方法，先尝试从单利的缓存中去找，找不到再通过单例工厂类创建对象:
public Object getSingleton(String beanName, ObjectFactory<?> singletonFactory) {
synchronized (this.singletonObjects) {
Object singletonObject = this.singletonObjects.get(beanName);
if (singletonObject == null) {
………………
singletonObject = singletonFactory.getObject();
newSingleton = true;
…………
if (newSingleton) {
//添加到单例缓存中
addSingleton(beanName, singletonObject);
}
}
return singletonObject;
}
}
//由于缓存单例对象的 hashmap没有hellword对象，进入singletonFactory.getObject()方法 ，
//继续断点到 AbstractAutowireCapableBeanFactory的doCreateBean放法
protected Object doCreateBean(final String beanName, final RootBeanDefinition mbd, final @Nullable Object[] args)
throws BeanCreationException {
// Instantiate the bean.
BeanWrapper instanceWrapper = null;
if (mbd.isSingleton()) {
instanceWrapper = this.factoryBeanInstanceCache.remove(beanName);
}
if (instanceWrapper == null) {
//创建bean对象的包装器，beanName=hellowordService，
//该方法执行完成后输出第一步日志：1->HelloWorldService constructor
instanceWrapper = createBeanInstance(beanName, mbd, args);
}
final Object bean = instanceWrapper.getWrappedInstance();//创建bean对象
…………
try {
//从RootBeanDefinition 获取属性信息并填充到instanceWrapper对象
populateBean(beanName, mbd, instanceWrapper);
//进入初始化bean对象的操作
exposedObject = initializeBean(beanName, exposedObject, mbd);
}
catch (Throwable ex) {
if (ex instanceof BeanCreationException && beanName.equals(((BeanCreationException) ex).getBeanName())) {
throw (BeanCreationException) ex;
}
else {
throw new BeanCreationException(
mbd.getResourceDescription(), beanName, "Initialization of bean failed", ex);
}
}
…………
//将创建好的bean对象注册到缓存起来
registerDisposableBeanIfNecessary(beanName, bean, mbd);
}
…………
protected Object initializeBean(final String beanName, final Object bean, @Nullable RootBeanDefinition mbd) {
if (System.getSecurityManager() != null) {
AccessController.doPrivileged((PrivilegedAction<Object>) () -> {
invokeAwareMethods(beanName, bean);
return null;
}, getAccessControlContext());
}
else {
// 开始调用各种ware接口的方法，会输出2、3、4步的日志
invokeAwareMethods(beanName, bean);
}
Object wrappedBean = bean;
if (mbd == null || !mbd.isSynthetic()) {
//执行BeanPostProcessor的前置方法postProcessBeforeInitialization，由于
//ApplicationContextAwareProcessor实现该接口，该类中会执行很多*Aware的类，而hellwordService
//实现ApplicationContextAware类，所在会输出：4->ApplicationContextAware.setApplicationContext:
wrappedBean = applyBeanPostProcessorsBeforeInitialization(wrappedBean, beanName);
}
try {
//init bean对象
invokeInitMethods(beanName, wrappedBean, mbd);
}
catch (Throwable ex) {
throw new BeanCreationException(
(mbd != null ? mbd.getResourceDescription() : null),
beanName, "Invocation of init method failed", ex);
}
if (mbd == null || !mbd.isSynthetic()) {
//执行BeanPostProcessor的后置方法postProcessAfterInitialization，
wrappedBean = applyBeanPostProcessorsAfterInitialization(wrappedBean, beanName);
}
return wrappedBean;
}
private void invokeAwareMethods(final String beanName, final Object bean) {
if (bean instanceof Aware) {
if (bean instanceof BeanNameAware) {
//日志输出 2->BeanNameAware.setBeanName:helloWorldService
((BeanNameAware) bean).setBeanName(beanName);
}
if (bean instanceof BeanClassLoaderAware) {
ClassLoader bcl = getBeanClassLoader();
if (bcl != null) {
((BeanClassLoaderAware) bean).setBeanClassLoader(bcl);
}
}
if (bean instanceof BeanFactoryAware) {
//日志输出 3->BeanFactoryAware.setBeanFactory:
((BeanFactoryAware) bean).setBeanFactory(AbstractAutowireCapableBeanFactory.this);
}
}
}
…………
protected void invokeInitMethods(String beanName, final Object bean, @Nullable RootBeanDefinition mbd)
throws Throwable {
boolean isInitializingBean = (bean instanceof InitializingBean);
if (isInitializingBean && (mbd == null || !mbd.isExternallyManagedInitMethod("afterPropertiesSet"))) {
if (logger.isTraceEnabled()) {
logger.trace("Invoking afterPropertiesSet() on bean with name '" + beanName + "'");
}
if (System.getSecurityManager() != null) {
try {
AccessController.doPrivileged((PrivilegedExceptionAction<Object>) () -> {
((InitializingBean) bean).afterPropertiesSet();
return null;
}, getAccessControlContext());
}
catch (PrivilegedActionException pae) {
throw pae.getException();
}
}
else {
//日志输出：5->InitializingBean.afterPropertiesSet
((InitializingBean) bean).afterPropertiesSet();
}
}
if (mbd != null && bean.getClass() != NullBean.class) {
String initMethodName = mbd.getInitMethodName();
if (StringUtils.hasLength(initMethodName) &&
!(isInitializingBean && "afterPropertiesSet".equals(initMethodName)) &&
!mbd.isExternallyManagedInitMethod(initMethodName)) {
//执行自定义init method方法，输出日志 ：6->init method
invokeCustomInitMethod(beanName, bean, mbd);
}
}
}
}最后回到getSingleton方法：
public Object getSingleton(String beanName, ObjectFactory<?> singletonFactory) {
……
//添加到单例缓存中
addSingleton(beanName, singletonObject);
}hellwordService对象创建完毕后，便执行 下一步的invokeBeanFactoryPostProcessors方法，输出第7步日志：
7->BeanFactoryPostProcessor.postProcessBeanFactory 将peopleService的content属性修改为i am ok
到此为止，invokeBeanFactoryPostProcessors(beanFactory);执行完毕
2.3、registerBeanPostProcessors(beanFactory)代码分析
可以看到代码和invokeBeanFactoryPostProcessors(beanFactory)的代码模式几乎一样，在本方法中会创建所有实现BeanPostProcessor接口类并注册到beanFactory中供后面对象创建时回调，代码不再做分析
protected void registerBeanPostProcessors(ConfigurableListableBeanFactory beanFactory) {
PostProcessorRegistrationDelegate.registerBeanPostProcessors(beanFactory, this);
}2.4、registerListeners();代码分析
protected void registerListeners() {
// Register statically specified listeners first.
for (ApplicationListener<?> listener : getApplicationListeners()) {
//hellowordService便在此处注册
getApplicationEventMulticaster().addApplicationListener(listener);
}
…………
}2.5、finishBeanFactoryInitialization(beanFactory)代码分析
断点直接进入一下代码：
public void preInstantiateSingletons() throws BeansException {
if (logger.isTraceEnabled()) {
logger.trace("Pre-instantiating singletons in " + this);
}
List<String> beanNames = new ArrayList<>(this.beanDefinitionNames);
// Trigger initialization of all non-lazy singleton beans...
for (String beanName : beanNames) {
RootBeanDefinition bd = getMergedLocalBeanDefinition(beanName);
if (!bd.isAbstract() && bd.isSingleton() && !bd.isLazyInit()) {
if (isFactoryBean(beanName)) {
Object bean = getBean(FACTORY_BEAN_PREFIX + beanName);
if (bean instanceof FactoryBean) {
final FactoryBean<?> factory = (FactoryBean<?>) bean;
boolean isEagerInit;
if (System.getSecurityManager() != null && factory instanceof SmartFactoryBean) {
isEagerInit = AccessController.doPrivileged((PrivilegedAction<Boolean>)
((SmartFactoryBean<?>) factory)::isEagerInit,
getAccessControlContext());
}
else {
isEagerInit = (factory instanceof SmartFactoryBean &&
((SmartFactoryBean<?>) factory).isEagerInit());
}
if (isEagerInit) {
getBean(beanName);
}
}
}
else {
//所有非lazy对象便在此处创建,如实例中的peopleServcie，对象创建过程前面已分析
//peopleServcie的创建过程回掉beanpostProcessors的前置和后置方法，输出日志：
//8->BeanPostProcessor.postProcessBeforeInitialization->peopleService
//9->BeanPostProcessor.postProcessAfterInitialization->peopleService
getBean(beanName);
}
}
}
…………
}2.4、finishRefresh()代码分析
protected void finishRefresh() {
// Clear context-level resource caches (such as ASM metadata from scanning).
clearResourceCaches();
// Initialize lifecycle processor for this context.
initLifecycleProcessor();
// Propagate refresh to lifecycle processor first.
getLifecycleProcessor().onRefresh();
// Publish the final event.
//发布ContextRefreshedEvent事件，输入日志
//10->ApplicationListener.onApplicationEvent:
publishEvent(new ContextRefreshedEvent(this));
// Participate in LiveBeansView MBean, if active.
LiveBeansView.registerApplicationContext(this);
}关于“spring初始化源码分析”的内容就介绍到这里了，感谢大家的阅读。如果想了解更多行业相关的知识，可以关注蜗牛博客行业资讯频道，小编每天都会为大家更新不同的知识点。
免责声明：本站发布的内容（图片、视频和文字）以原创、转载和分享为主，文章观点不代表本网站立场，如果涉及侵权请联系站长邮箱：niceseo99@gmail.com进行举报，并提供相关证据，一经查实，将立刻删除涉嫌侵权内容。
版权声明：如无特殊标注，文章均为本站原创，转载时请以链接形式注明文章出处。
评论