這篇文章主要為大家展示了如何優(yōu)雅停止Spring Boot應(yīng)用,內(nèi)容簡(jiǎn)而易懂,希望大家可以學(xué)習(xí)一下,學(xué)習(xí)完之后肯定會(huì)有收獲的,下面讓小編帶大家一起來(lái)看看吧。
創(chuàng)新互聯(lián)公司專(zhuān)注于企業(yè)成都營(yíng)銷(xiāo)網(wǎng)站建設(shè)、網(wǎng)站重做改版、中牟網(wǎng)站定制設(shè)計(jì)、自適應(yīng)品牌網(wǎng)站建設(shè)、H5建站、商城網(wǎng)站建設(shè)、集團(tuán)公司官網(wǎng)建設(shè)、成都外貿(mào)網(wǎng)站建設(shè)公司、高端網(wǎng)站制作、響應(yīng)式網(wǎng)頁(yè)設(shè)計(jì)等建站業(yè)務(wù),價(jià)格優(yōu)惠性?xún)r(jià)比高,為中牟等各大城市提供網(wǎng)站開(kāi)發(fā)制作服務(wù)。
首先來(lái)介紹下什么是優(yōu)雅地停止,簡(jiǎn)而言之,就是對(duì)應(yīng)用進(jìn)程發(fā)送停止指令之后,能保證 正在執(zhí)行的業(yè)務(wù)操作不受影響,可以繼續(xù)完成已有請(qǐng)求的處理,但是停止接受新請(qǐng)求 。
在 Spring Boot 2.3 中增加了新特性 優(yōu)雅停止,目前 Spring Boot 內(nèi)置的四個(gè)嵌入式 Web 服務(wù)器( Jetty、Reactor Netty、Tomcat 和 Undertow
)以及反應(yīng)式和基于 Servlet 的 Web 應(yīng)用程序都支持優(yōu)雅停止。
下面,我們先用新版本嘗試下:
Spring Boot 2.3 優(yōu)雅停止
首先創(chuàng)建一個(gè) Spring Boot 的 Web 項(xiàng)目,版本選擇 2.3.0.RELEASE
,Spring Boot 2.3.0.RELEASE
版本內(nèi)置的 Tomcat 為 9.0.35
。
然后需要在 application.yml
中添加一些配置來(lái)啟用優(yōu)雅停止的功能:
# 開(kāi)啟優(yōu)雅停止 Web 容器,默認(rèn)為 IMMEDIATE:立即停止 server: shutdown: graceful # 最大等待時(shí)間 spring: lifecycle: timeout-per-shutdown-phase: 30s
其中,平滑關(guān)閉內(nèi)置的 Web 容器(以 Tomcat 為例)的入口代碼在 org.springframework.boot.web.embedded.tomcat
的 GracefulShutdown
里,大概邏輯就是先停止外部的所有新請(qǐng)求,然后再處理關(guān)閉前收到的請(qǐng)求,有興趣的可以自己去看下。
內(nèi)嵌的 Tomcat 容器平滑關(guān)閉的配置已經(jīng)完成了,那么如何優(yōu)雅關(guān)閉 Spring 容器了,就需要 Actuator 來(lái)實(shí)現(xiàn) Spring 容器的關(guān)閉了。
然后加入 actuator
依賴(lài),依賴(lài)如下所示:
org.springframework.boot spring-boot-starter-actuator
然后接著再添加一些配置來(lái)暴露 actuator 的 shutdown 接口:
# 暴露 shutdown 接口 management: endpoint: shutdown: enabled: true endpoints: web: exposure: include: shutdown
其中通過(guò) Actuator 關(guān)閉 Spring 容器的入口代碼在 org.springframework.boot.actuate.context
包下 ShutdownEndpoint
類(lèi)中,主要的就是執(zhí)行 doClose()
方法關(guān)閉并銷(xiāo)毀 applicationContext
,有興趣的可以自己去看下。
配置搞定后,然后在 controller
包下創(chuàng)建一個(gè) WorkController
類(lèi),并有一個(gè) work
方法,用來(lái)模擬復(fù)雜業(yè)務(wù)耗時(shí)處理流程,具體代碼如下:
@RestController public class WorkController { @GetMapping("/work") public String work() throws InterruptedException { // 模擬復(fù)雜業(yè)務(wù)耗時(shí)處理流程 Thread.sleep(10 * 1000L); return "success"; } }
然后,我們啟動(dòng)項(xiàng)目,先用 Postman 請(qǐng)求 http://localhost:8080/work
處理業(yè)務(wù):
然后在這個(gè)時(shí)候,調(diào)用 http://localhost:8080/actuator/shutdown
就可以執(zhí)行優(yōu)雅地停止,返回結(jié)果如下:
{ "message": "Shutting down, bye..." }
如果在這個(gè)時(shí)候,發(fā)起新的請(qǐng)求 http://localhost:8080/work
,會(huì)沒(méi)有反應(yīng):
再回頭看第一個(gè)請(qǐng)求,返回了結(jié)果: success
。
其中有幾條服務(wù)日志如下:
2020-05-20 23:05:15.163 INFO 102724 --- [ Thread-253] o.s.b.w.e.tomcat.GracefulShutdown : Commencing graceful shutdown. Waiting for active requests to complete
2020-05-20 23:05:15.287 INFO 102724 --- [tomcat-shutdown] o.s.b.w.e.tomcat.GracefulShutdown : Graceful shutdown complete
2020-05-20 23:05:15.295 INFO 102724 --- [ Thread-253] o.s.s.concurrent.ThreadPoolTaskExecutor : Shutting down ExecutorService 'applicationTaskExecutor'
從日志中也可以看出來(lái),當(dāng)調(diào)用 shutdown
接口的時(shí)候,會(huì)先等待請(qǐng)求處理完畢后再優(yōu)雅地停止。
到此為止,Spring Boot 2.3 的優(yōu)雅關(guān)閉就講解完了,是不是很簡(jiǎn)單呢?如果是在之前不支持優(yōu)雅關(guān)閉的版本如何去做呢?
Spring Boot 舊版本優(yōu)雅停止
在這里介紹 GitHub 上 issue 里 Spring Boot 開(kāi)發(fā)者提供的一種方案:
選取的 Spring Boot 版本為 2.2.6.RELEASE
,首先要實(shí)現(xiàn) TomcatConnectorCustomizer
接口,該接口是自定義 Connector
的回調(diào)接口:
@FunctionalInterface public interface TomcatConnectorCustomizer { void customize(Connector connector); }
除了定制 Connector
的行為,還要實(shí)現(xiàn) ApplicationListener
接口,因?yàn)橐O(jiān)聽(tīng) Spring 容器的關(guān)閉事件,即當(dāng)前的 ApplicationContext 執(zhí)行 close()
方法,這樣我們就可以在請(qǐng)求處理完畢后進(jìn)行 Tomcat 線(xiàn)程池的關(guān)閉,具體的實(shí)現(xiàn)代碼如下:
@Bean public GracefulShutdown gracefulShutdown() { return new GracefulShutdown(); } private static class GracefulShutdown implements TomcatConnectorCustomizer, ApplicationListener{ private static final Logger log = LoggerFactory.getLogger(GracefulShutdown.class); private volatile Connector connector; @Override public void customize(Connector connector) { this.connector = connector; } @Override public void onApplicationEvent(ContextClosedEvent event) { this.connector.pause(); Executor executor = this.connector.getProtocolHandler().getExecutor(); if (executor instanceof ThreadPoolExecutor) { try { ThreadPoolExecutor threadPoolExecutor = (ThreadPoolExecutor) executor; threadPoolExecutor.shutdown(); if (!threadPoolExecutor.awaitTermination(30, TimeUnit.SECONDS)) { log.warn("Tomcat thread pool did not shut down gracefully within 30 seconds. Proceeding with forceful shutdown"); } } catch (InterruptedException ex) { Thread.currentThread().interrupt(); } } } }
有了定制的 Connector
回調(diào),還需要在啟動(dòng)過(guò)程中添加到內(nèi)嵌的 Tomcat 容器中,然后等待監(jiān)聽(tīng)到關(guān)閉指令時(shí)執(zhí)行, addConnectorCustomizers
方法可以把定制的 Connector
行為添加到內(nèi)嵌的 Tomcat 中,具體代碼如下:
@Bean public ConfigurableServletWebServerFactory tomcatCustomizer() { TomcatServletWebServerFactory factory = new TomcatServletWebServerFactory(); factory.addConnectorCustomizers(gracefulShutdown()); return factory; }
到此為止,內(nèi)置的 Tomcat 容器平滑關(guān)閉的操作就完成了,Spring 容器優(yōu)雅停止上面已經(jīng)說(shuō)過(guò)了,再次就不再贅述了。
通過(guò)測(cè)試,同樣可以達(dá)到上面那樣優(yōu)雅停止的效果。
總結(jié)
本文主要講解了 Spring Boot 2.3 版本和舊版本的優(yōu)雅停止,避免強(qiáng)制停止導(dǎo)致正在處理的業(yè)務(wù)邏輯會(huì)被中斷,進(jìn)而導(dǎo)致產(chǎn)生業(yè)務(wù)異常的情形。
另外使用 Actuator 的同時(shí)要注意安全問(wèn)題,比如可以通過(guò)引入 security
依賴(lài),打開(kāi)安全限制并進(jìn)行身份驗(yàn)證,設(shè)置單獨(dú)的 Actuator 管理端口并配置只對(duì)內(nèi)網(wǎng)開(kāi)放等。
本文的完整代碼在 https://github.com/wupeixuan/SpringBoot-Learn
的 graceful-shutdown
目錄下。
以上就是關(guān)于如何優(yōu)雅停止Spring Boot應(yīng)用的內(nèi)容,如果你們有學(xué)習(xí)到知識(shí)或者技能,可以把它分享出去讓更多的人看到。