文章目錄

• Spring源碼系列：
• 前言
• 正文
• • 方法1：finishRefresh
  • 方法2：initLifecycleProcessor
  • 方法3：onRefresh
  • 方法4：publishEvent
  • 方法5：multicastEvent
  • 方法6：invokeListener
  • 方法7：doInvokeListener
• 總結(jié)

目前成都創(chuàng)新互聯(lián)公司已為數(shù)千家的企業(yè)提供了網(wǎng)站建設(shè)、域名、網(wǎng)站空間、網(wǎng)站改版維護(hù)、企業(yè)網(wǎng)站設(shè)計(jì)、八宿網(wǎng)站維護(hù)等服務(wù)，公司將堅(jiān)持客戶導(dǎo)向、應(yīng)用為本的策略，正道將秉承"和諧、參與、激情"的文化，與客戶和合作伙伴齊心協(xié)力一起成長(zhǎng)，共同發(fā)展。Spring源碼系列：

Spring IOC源碼：簡(jiǎn)單易懂的Spring IOC 思路介紹
Spring IOC源碼：核心流程介紹
Spring IOC源碼：ApplicationContext刷新前準(zhǔn)備工作
Spring IOC源碼：obtainFreshBeanFactory 詳解（上）
Spring IOC源碼：obtainFreshBeanFactory 詳解（中）
Spring IOC源碼：obtainFreshBeanFactory 詳解（下）
Spring IOC源碼：＜context:component-scan＞源碼詳解
Spring IOC源碼：invokeBeanFactoryPostProcessors 后置處理器詳解
Spring IOC源碼：registerBeanPostProcessors 詳解
Spring IOC源碼：實(shí)例化前的準(zhǔn)備工作
Spring IOC源碼：finishBeanFactoryInitialization詳解
Spring IoC源碼：getBean 詳解
Spring IoC源碼：createBean（ 上）
Spring IoC源碼：createBean（ 中）
Spring IoC源碼：createBean（ 下）
Spring IoC源碼：finishRefresh 完成刷新詳解

前言

當(dāng)完成Bean定義信息解析、Bean的創(chuàng)建、初始化流程之后，到最后一個(gè)方法finishRefresh完成上下文刷新。

正文

來(lái)到refresh()方法中的最后一個(gè)方法finishRefresh();

public void refresh() throws BeansException, IllegalStateException {synchronized (this.startupShutdownMonitor) {	// 容器刷新前準(zhǔn)備工作
			prepareRefresh();

			// Tell the subclass to refresh the internal bean factory.
			//創(chuàng)建Bean工廠，解析配置
			ConfigurableListableBeanFactory beanFactory = obtainFreshBeanFactory();

			// bean工廠準(zhǔn)備工作
			prepareBeanFactory(beanFactory);

			try {		//拓展接口，留給子類進(jìn)行實(shí)現(xiàn)拓展
				postProcessBeanFactory(beanFactory);

				// 注冊(cè)執(zhí)行，BeanFactoryPostProcessor
				invokeBeanFactoryPostProcessors(beanFactory);

				// 注冊(cè)創(chuàng)建BeanPostProcessor
				registerBeanPostProcessors(beanFactory);

				// 這個(gè)方法主要作用就是使用國(guó)際化，定制不同的消息文本，比如定義了一個(gè)Person的Bean，它有name屬性，我們需要在不同的國(guó)家展示對(duì)應(yīng)國(guó)家所在語(yǔ)言名稱，這時(shí)候就可以使用國(guó)際化了。
				initMessageSource();

				// Initialize event multicaster for this context.
				//初始化應(yīng)用事件廣播器
				initApplicationEventMulticaster();

				// Initialize other special beans in specific context subclasses.
				//拓展接口，留給子類進(jìn)行實(shí)現(xiàn)拓展，springboot就對(duì)該方法進(jìn)行了處理
				onRefresh();

				// Check for listener beans and register them.
				//將內(nèi)部的、以及我們自定義的監(jiān)聽(tīng)器添加到緩存中，為后續(xù)邏輯處理做準(zhǔn)備。還有添加事件源到緩存中。
				registerListeners();

				// Instantiate all remaining (non-lazy-init) singletons.
				//實(shí)例化剩下非懶加載的Bean
				finishBeanFactoryInitialization(beanFactory);

				// Last step: publish corresponding event.
				//使用應(yīng)用事件廣播器推送上下文刷新完畢事件（ContextRefreshedEvent ）到相應(yīng)的監(jiān)聽(tīng)器。
				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.
				//執(zhí)行相關(guān)銷(xiāo)毀方法
				destroyBeans();

				// Reset 'active' flag.
				//重置上下文刷新?tīng)顟B(tài)
				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();
			}
		}
	}

finishRefresh()，見(jiàn)方法1詳解

方法1：finishRefresh

protected void finishRefresh() {// Clear context-level resource caches (such as ASM metadata from scanning).
		//清除該資源加載器中的所有資源緩存
		clearResourceCaches();

		// Initialize lifecycle processor for this context.
		//初始化LifecycleProcessor。
		initLifecycleProcessor();

		// Propagate refresh to lifecycle processor first.
		//調(diào)用LifecycleProcessor的onRefresh方法進(jìn)行刷新
		getLifecycleProcessor().onRefresh();

		// 發(fā)布事件
		publishEvent(new ContextRefreshedEvent(this));

		// Participate in LiveBeansView MBean, if active.
		LiveBeansView.registerApplicationContext(this);
	}

initLifecycleProcessor()，見(jiàn)方法2詳解

getLifecycleProcessor().onRefresh()，見(jiàn)方法3詳解

publishEvent(new ContextRefreshedEvent(this))，見(jiàn)方法4詳解

方法2：initLifecycleProcessor

protected void initLifecycleProcessor() {//獲取BeanFactory工廠
		ConfigurableListableBeanFactory beanFactory = getBeanFactory();
		//判斷是否存在名稱為lifecycleProcessor的Bean或定義信息
		if (beanFactory.containsLocalBean(LIFECYCLE_PROCESSOR_BEAN_NAME)) {	//獲取或創(chuàng)建LifecycleProcessor
			this.lifecycleProcessor =
					beanFactory.getBean(LIFECYCLE_PROCESSOR_BEAN_NAME, LifecycleProcessor.class);
			if (logger.isTraceEnabled()) {		logger.trace("Using LifecycleProcessor [" + this.lifecycleProcessor + "]");
			}
		}
		else {	//bean工廠中不存在該bean的信息，則創(chuàng)建一個(gè)默認(rèn)的
			DefaultLifecycleProcessor defaultProcessor = new DefaultLifecycleProcessor();
			defaultProcessor.setBeanFactory(beanFactory);
			this.lifecycleProcessor = defaultProcessor;
			//注冊(cè)添加到一級(jí)緩存中
			beanFactory.registerSingleton(LIFECYCLE_PROCESSOR_BEAN_NAME, this.lifecycleProcessor);
			if (logger.isTraceEnabled()) {		logger.trace("No '" + LIFECYCLE_PROCESSOR_BEAN_NAME + "' bean, using " +
						"[" + this.lifecycleProcessor.getClass().getSimpleName() + "]");
			}
		}
	}

方法3：onRefresh

public void onRefresh() {startBeans(true);
		this.running = true;
	}

private void startBeans(boolean autoStartupOnly) {//獲取Lifecycle類型的bean集合
		MaplifecycleBeans = getLifecycleBeans();
		Mapphases = new HashMap<>();
		lifecycleBeans.forEach((beanName, bean) ->{	//autoStartupOnly 為true時(shí)，代表是容器自動(dòng)啟動(dòng)調(diào)用，這時(shí)只有SmartLifecycle 類型且isAutoStartup為T(mén)RUE才會(huì)調(diào)用
			//如果autoStartupOnly 為false，代表是手動(dòng)調(diào)用，會(huì)調(diào)用所有的Lifecycle
			if (!autoStartupOnly || (bean instanceof SmartLifecycle && ((SmartLifecycle) bean).isAutoStartup())) {		//獲取階段值，即優(yōu)先級(jí)值。如果有實(shí)現(xiàn)Phased接口，則通過(guò)getPhase方法返回?cái)?shù)值，值越小則排序越前
				int phase = getPhase(bean);
				//判斷容器中是否已存在，不存在則創(chuàng)建LifecycleGroup 類型對(duì)象
				LifecycleGroup group = phases.get(phase);
				if (group == null) {group = new LifecycleGroup(phase, this.timeoutPerShutdownPhase, lifecycleBeans, autoStartupOnly);
					phases.put(phase, group);
				}
				group.add(beanName, bean);
			}
		});
		if (!phases.isEmpty()) {	Listkeys = new ArrayList<>(phases.keySet());
			//排序
			Collections.sort(keys);
			//遍歷調(diào)用
			for (Integer key : keys) {		phases.get(key).start();
			}
		}
	}

方法4：publishEvent

protected void publishEvent(Object event, @Nullable ResolvableType eventType) {Assert.notNull(event, "Event must not be null");

		// Decorate event as an ApplicationEvent if necessary
		//判斷事件是否繼承了ApplicationEvent接口
		ApplicationEvent applicationEvent;
		if (event instanceof ApplicationEvent) {	applicationEvent = (ApplicationEvent) event;
		}
		else {	//將事件封裝成PayloadApplicationEvent類型的事件
			applicationEvent = new PayloadApplicationEvent<>(this, event);
			//設(shè)置事件類型
			if (eventType == null) {		eventType = ((PayloadApplicationEvent) applicationEvent).getResolvableType();
			}
		}

		// Multicast right now if possible - or lazily once the multicaster is initialized
		if (this.earlyApplicationEvents != null) {	this.earlyApplicationEvents.add(applicationEvent);
		}
		else {	//使用多播器發(fā)布事件
			getApplicationEventMulticaster().multicastEvent(applicationEvent, eventType);
		}

		// Publish event via parent context as well...
		//使用父上下文進(jìn)行發(fā)布事件
		if (this.parent != null) {	if (this.parent instanceof AbstractApplicationContext) {		((AbstractApplicationContext) this.parent).publishEvent(event, eventType);
			}
			else {		this.parent.publishEvent(event);
			}
		}
	}

getApplicationEventMulticaster().multicastEvent(applicationEvent, eventType)，見(jiàn)方法5詳解

方法5：multicastEvent

public void multicastEvent(final ApplicationEvent event, @Nullable ResolvableType eventType) {//獲取事件源類型
		ResolvableType type = (eventType != null ? eventType : resolveDefaultEventType(event));
		Executor executor = getTaskExecutor();
		//根據(jù)事件類型獲取對(duì)應(yīng)類型的監(jiān)聽(tīng)器
		for (ApplicationListenerlistener : getApplicationListeners(event, type)) {	//調(diào)用監(jiān)聽(tīng)器的onApplicationEvent方法
			if (executor != null) {		executor.execute(() ->invokeListener(listener, event));
			}
			else {		invokeListener(listener, event);
			}
		}
	}

invokeListener(listener, event))，見(jiàn)方法6詳解

方法6：invokeListener

protected void invokeListener(ApplicationListenerlistener, ApplicationEvent event) {//獲取錯(cuò)誤處理器
		ErrorHandler errorHandler = getErrorHandler();
		if (errorHandler != null) {	try {	//調(diào)用監(jiān)聽(tīng)器處理方法
				doInvokeListener(listener, event);
			}
			catch (Throwable err) {		errorHandler.handleError(err);
			}
		}
		else {	doInvokeListener(listener, event);
		}
	}

doInvokeListener(listener, event)，見(jiàn)方法7詳解

方法7：doInvokeListener

private void doInvokeListener(ApplicationListener listener, ApplicationEvent event) {try {	//調(diào)用監(jiān)聽(tīng)器的onApplicationEvent方法，并傳入事件
			listener.onApplicationEvent(event);
		}
		catch (ClassCastException ex) {	String msg = ex.getMessage();
			if (msg == null || matchesClassCastMessage(msg, event.getClass())) {		// Possibly a lambda-defined listener which we could not resolve the generic event type for
				// ->let's suppress the exception and just log a debug message.
				Log logger = LogFactory.getLog(getClass());
				if (logger.isTraceEnabled()) {logger.trace("Non-matching event type for listener: " + listener, ex);
				}
			}
			else {		throw ex;
			}
		}
	}

總結(jié)

Spring IOC中refresh()所有方法都講解完了，這里面的內(nèi)容非車(chē)多，花了不少時(shí)間在看，但是感覺(jué)還是比較粗糙，文章中有很多點(diǎn)理解得不是很到位，如果大家有更好的見(jiàn)解，歡迎指點(diǎn)評(píng)論。學(xué)習(xí)IOC過(guò)程是非常枯燥的，但是耐心去看真的能發(fā)現(xiàn)這個(gè)框架設(shè)計(jì)真的很厲害，拓展性做得很好，有很多地方值得我們?cè)诠ぷ髦羞M(jìn)行參考開(kāi)發(fā)。后續(xù)會(huì)發(fā)布Spring 系列的其它文章，如AOP，只有不斷的學(xué)習(xí)，才能加深對(duì)Spring框架的理解。

你是否還在尋找穩(wěn)定的海外服務(wù)器提供商？創(chuàng)新互聯(lián)www.cdcxhl.cn海外機(jī)房具備T級(jí)流量清洗系統(tǒng)配攻擊溯源，準(zhǔn)確流量調(diào)度確保服務(wù)器高可用性，企業(yè)級(jí)服務(wù)器適合批量采購(gòu)，新人活動(dòng)首月15元起，快前往官網(wǎng)查看詳情吧

當(dāng)前標(biāo)題：SpringIoC源碼：finishRefresh完成刷新詳解-創(chuàng)新互聯(lián)
URL分享：http://www.rwnh.cn/article34/csoise.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供網(wǎng)站內(nèi)鏈、動(dòng)態(tài)網(wǎng)站、網(wǎng)站改版、ChatGPT、小程序開(kāi)發(fā)、做網(wǎng)站

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請(qǐng)盡快告知，我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng)，如需處理請(qǐng)聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時(shí)需注明來(lái)源： 創(chuàng)新互聯(lián)