Spring中SmartLifecycle和Lifecycle的作用和區(qū)別
本文基于SpringBoot 2.5.0-M2
講解Spring中Lifecycle
和SmartLifecycle
的作用和區(qū)別,以及如何控制SmartLifecycle的優(yōu)先級。
并講解SpringBoot中如何通過SmartLifecycle
來啟動/停止web容器.
SmartLifecycle和Lifecycle作用
都是讓開發(fā)者可以在所有的bean都創(chuàng)建完成(getBean) 之后執(zhí)行自己的初始化工作,或者在退出時執(zhí)行資源銷毀工作。
SmartLifecycle和Lifecycle區(qū)別
1.SmartLifecycle
接口繼承Lifecycle
接口,同時繼承了org.springframework.context.Phased
接口用于控制多個SmartLifecycle
實(shí)現(xiàn)之間的優(yōu)先級。
2.在SpringBoot應(yīng)用中,或在Spring應(yīng)用中沒有調(diào)用AbstractApplicationContext#start
方法,如果一個Bean只是實(shí)現(xiàn)了Lifecycle
接口的情況下:
不會執(zhí)行Lifecycle
接口中的啟動方法,包括Lifecycle#isRunning
方法也不會被執(zhí)行。
但是在應(yīng)用 退出時 會執(zhí)行Lifecycle#isRunning
方法判斷該Lifecycle
是否已經(jīng)啟動,如果返回true則調(diào)用Lifecycle#stop()
停止方法。
3. 如果一個Bean實(shí)現(xiàn)了SmartLifecycle
接口,則會執(zhí)行啟動方法。先會被根據(jù)Phased
接口優(yōu)先級分組,封裝在LifecycleGroup
,然后循環(huán)調(diào)用LifecycleGroup#start()
方法,SmartLifecycle#isRunning
判斷是否已經(jīng)執(zhí)行,返回false表示還未執(zhí)行,則調(diào)用SmartLifecycle#start()
執(zhí)行。Phased
返回值越小,優(yōu)先級越高。
4.SmartLifecycle
中還有個isAutoStartup
方法,如果返回false
,在啟動時也不會執(zhí)行start方法,默認(rèn)返回true
源碼分析
SmartLifecycle
和Lifecycle
都是在org.springframework.context.support.DefaultLifecycleProcessor
中被調(diào)用,
DefaultLifecycleProcessor#onRefresh
方法在執(zhí)行AbstractApplicationContext#finishRefresh
時會被調(diào)用,調(diào)用棧如下:
startBeans:142, DefaultLifecycleProcessor (org.springframework.context.support) onRefresh:123, DefaultLifecycleProcessor (org.springframework.context.support) finishRefresh:934, AbstractApplicationContext (org.springframework.context.support) refresh:585, AbstractApplicationContext (org.springframework.context.support) refresh:144, ServletWebServerApplicationContext (org.springframework.boot.web.servlet.context) refresh:755, SpringApplication (org.springframework.boot) refreshContext:426, SpringApplication (org.springframework.boot) run:326, SpringApplication (org.springframework.boot) run:1299, SpringApplication (org.springframework.boot) run:1288, SpringApplication (org.springframework.boot) main:31, DemoApplication (com.example.demo)
DefaultLifecycleProcessor#onRefresh
源碼:
@Override public void onRefresh() { startBeans(true); //autoStartupOnly = true this.running = true; }
DefaultLifecycleProcessor#startBeans
源碼如下:
autoStartupOnly
在onRefresh時傳入的是true,表示只執(zhí)行可以自動啟動的bean,即為:SmartLifecycle
的實(shí)現(xiàn)類,并且SmartLifecycle#isAutoStartup
返回值必須為true。
private void startBeans(boolean autoStartupOnly) { Map<String, Lifecycle> lifecycleBeans = getLifecycleBeans(); Map<Integer, LifecycleGroup> phases = new TreeMap<>(); lifecycleBeans.forEach((beanName, bean) -> { if (!autoStartupOnly || (bean instanceof SmartLifecycle && ((SmartLifecycle) bean).isAutoStartup())) { int phase = getPhase(bean); phases.computeIfAbsent(phase, p -> new LifecycleGroup(phase, this.timeoutPerShutdownPhase, lifecycleBeans, autoStartupOnly) ).add(beanName, bean); } }); if (!phases.isEmpty()) { phases.values().forEach(LifecycleGroup::start); } }
而Spring AbstractApplicationContext#doClose
退出時,無論是SmartLifecycle
或Lifecycle
都會執(zhí)行isRunning
方法,判斷是否已經(jīng)啟動,返回true表示已經(jīng)啟動,則執(zhí)行SmartLifecycle
或Lifecycle
的stop
方法。
源碼見:org.springframework.context.support.DefaultLifecycleProcessor#doStop
方法。
而執(zhí)行AbstractApplicationContext#doClose
一般是應(yīng)用進(jìn)程退出,通過jvm注冊的鉤子方法,或者應(yīng)用程序編碼調(diào)用。
AbstractApplicationContext#registerShutdownHook
源碼
@Override public void registerShutdownHook() { if (this.shutdownHook == null) { // No shutdown hook registered yet. this.shutdownHook = new Thread(SHUTDOWN_HOOK_THREAD_NAME) { @Override public void run() { synchronized (startupShutdownMonitor) { doClose(); } } }; Runtime.getRuntime().addShutdownHook(this.shutdownHook); } }
自定義LifecycleProcessor處理Lifecycle
在源碼分析中提到了DefaultLifecycleProcessor
,其實(shí)現(xiàn)了LifecycleProcessor
接口。然而我們自己也可以實(shí)現(xiàn)該接口,替換默認(rèn)的DefaultLifecycleProcessor
。SpringBoot中則是自己配置了DefaultLifecycleProcessor
,我們可以按照同樣的方式,覆蓋默認(rèn)的實(shí)現(xiàn)。例如可以讓Lifecycle
中的start()
方法在onRefresh()時也能被執(zhí)行。
org.springframework.boot.autoconfigure.context.LifecycleAutoConfiguration
源碼:
/** * {@link EnableAutoConfiguration Auto-configuration} relating to the application * context's lifecycle. * * @author Andy Wilkinson * @since 2.3.0 */ @Configuration(proxyBeanMethods = false) @EnableConfigurationProperties(LifecycleProperties.class) public class LifecycleAutoConfiguration { @Bean(name = AbstractApplicationContext.LIFECYCLE_PROCESSOR_BEAN_NAME) @ConditionalOnMissingBean(name = AbstractApplicationContext.LIFECYCLE_PROCESSOR_BEAN_NAME, search = SearchStrategy.CURRENT) public DefaultLifecycleProcessor defaultLifecycleProcessor(LifecycleProperties properties) { DefaultLifecycleProcessor lifecycleProcessor = new DefaultLifecycleProcessor(); lifecycleProcessor.setTimeoutPerShutdownPhase(properties.getTimeoutPerShutdownPhase().toMillis()); return lifecycleProcessor; } }
SpringBoot中內(nèi)嵌web容器啟動時機(jī)
SpringBoo中就是通過實(shí)現(xiàn)SmartLifecycle
來啟動內(nèi)嵌的web容器,實(shí)現(xiàn)類為WebServerStartStopLifecycle
。
ServletWebServerApplicationContext
在onRefresh
方法中調(diào)用createWebServer
,createWebServer
方法中創(chuàng)建org.springframework.boot.web.server.WebServer
實(shí)例,該對象則包含了控制web容器(tomcat
、jetty
)的啟動與停止方法。
@Override protected void onRefresh() { super.onRefresh(); try { createWebServer(); }catch (Throwable ex) { throw new ApplicationContextException("Unable to start web server", ex); } }
ServletWebServerApplicationContext#createWebServer
源碼:
private void createWebServer() { WebServer webServer = this.webServer; ServletContext servletContext = getServletContext(); if (webServer == null && servletContext == null) { StartupStep createWebServer = this.getApplicationStartup().start("spring.boot.webserver.create"); ServletWebServerFactory factory = getWebServerFactory(); createWebServer.tag("factory", factory.getClass().toString()); this.webServer = factory.getWebServer(getSelfInitializer()); createWebServer.end(); getBeanFactory().registerSingleton("webServerGracefulShutdown", new WebServerGracefulShutdownLifecycle(this.webServer)); getBeanFactory().registerSingleton("webServerStartStop", new WebServerStartStopLifecycle(this, this.webServer)); } else if (servletContext != null) { try { getSelfInitializer().onStartup(servletContext); } catch (ServletException ex) { throw new ApplicationContextException("Cannot initialize servlet context", ex); } } initPropertySources(); }
createWebServer
方法會將創(chuàng)建的webServer
封裝在WebServerStartStopLifecycle
對象中,并注冊到Spring容器中。
org.springframework.boot.web.servlet.context.WebServerStartStopLifecycle
源碼如下:
class WebServerStartStopLifecycle implements SmartLifecycle { private final ServletWebServerApplicationContext applicationContext; private final WebServer webServer; private volatile boolean running; WebServerStartStopLifecycle(ServletWebServerApplicationContext applicationContext, WebServer webServer) { this.applicationContext = applicationContext; this.webServer = webServer; } @Override public void start() { this.webServer.start(); this.running = true; this.applicationContext .publishEvent(new ServletWebServerInitializedEvent(this.webServer, this.applicationContext)); } @Override public void stop() { this.webServer.stop(); } @Override public boolean isRunning() { return this.running; } @Override public int getPhase() { return Integer.MAX_VALUE - 1; } }
WebServerStartStopLifecycle
則實(shí)現(xiàn)了SmartLifecycle
接口,當(dāng)Spring回調(diào)到SmartLifecycle
接口方法時則調(diào)用this.webServer.start();
啟動web容器,web容器啟動完成之后會通過applicationContext
發(fā)布ServletWebServerInitializedEvent
事件,表示web容器啟動成功,可以接收http請求。
和SmartInitializingSingleton區(qū)別
相同點(diǎn):SmartInitializingSingleton
和Lifecycle
、SmartLifecycle
都是在所有的單實(shí)例bean創(chuàng)建(getBean方法)之后執(zhí)行。
不同點(diǎn):
SmartInitializingSingleton
優(yōu)先于Lifecycle
、SmartLifecycle
執(zhí)行。SmartInitializingSingleton
只有一個afterSingletonsInstantiated
方法。而Lifecycle
有start
,stop
,isRunning
等方法。- 多個
SmartInitializingSingleton
實(shí)現(xiàn)之間無法排序控制執(zhí)行的順序,而SmartLifecycle
實(shí)現(xiàn)了Phased
接口,可以通過int getPhase()
控制執(zhí)行循序。 SmartInitializingSingleton
之間可以通過@DependsOn
來控制執(zhí)行順序,但這是由Spring中@DependsOn注解的作用及原理來實(shí)現(xiàn)的. 并不是對SmartInitializingSingleton
做了排序。
到此這篇關(guān)于Spring中SmartLifecycle和Lifecycle的作用和區(qū)別的文章就介紹到這了,更多相關(guān)Spring中SmartLifecycle和Lifecycle內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!
相關(guān)文章
解決MyEclipse中的Building workspace問題的三個方法
這篇文章主要介紹了解決MyEclipse中的Building workspace問題的三個方法,需要的朋友可以參考下2015-11-11Java并發(fā)編程中使用Executors類創(chuàng)建和管理線程的用法
這篇文章主要介紹了Java并發(fā)編程中使用Executors類創(chuàng)建和管理線程的用法,文中舉了用其啟動線程和設(shè)置線程優(yōu)先級的例子,需要的朋友可以參考下2016-03-03Java實(shí)現(xiàn)HttpGet請求傳body參數(shù)
這篇文章主要為大家詳細(xì)介紹了Java實(shí)現(xiàn)HttpGet請求傳body參數(shù)的相關(guān)知識,文中的示例代碼講解詳細(xì),感興趣的小伙伴可以跟隨小編一起學(xué)習(xí)一下2024-02-02