SpringBoot停服實(shí)踐

IT那活兒發(fā)布于2023-01-11 13:20 / 2416人閱讀

SpringBoot停服實(shí)踐

[

一、介紹

]

當(dāng)外部流量請求到服務(wù)端接口執(zhí)行業(yè)務(wù)邏輯的時(shí)候，若服務(wù)端此時(shí)執(zhí)行關(guān)機(jī)（kill），springboot 默認(rèn)情況會(huì)直接關(guān)閉容器（tomcat等），導(dǎo)致此業(yè)務(wù)邏輯執(zhí)行失敗。在一些業(yè)務(wù)場景下會(huì)出現(xiàn)數(shù)據(jù)不一致的情況，事務(wù)邏輯不會(huì)回滾。

在最新的springboot 2.3版本已內(nèi)置此功能，不需要再自行擴(kuò)展容器線程池來處理，目前springboot嵌入式支持的web服務(wù)器（Jetty、ReactorNetty、Tomcat和Undertow）以及反應(yīng)式和基于Servlet的web應(yīng)用程序都支持優(yōu)雅停機(jī)功能。

此處支持的shutdown行為，我們看下源碼枚舉如下：

publicenumShutdown{

/**

*優(yōu)雅停機(jī)（限期停機(jī)）

GRACEFUL,

/**

*立即停機(jī)

IMMEDIATE;

}

[

二、使用方式

]

在application.properties中添加以下配置

當(dāng)server.shutdown=graceful啟用后，在web容器關(guān)閉時(shí)，web服務(wù)器將不再接收新請求，并將在緩沖期內(nèi)等待活動(dòng)請求完成。緩沖期timeout-per-shutdown-phase配置：默認(rèn)時(shí)間為30S,意味著最大等待30S，超時(shí)后無論線程任務(wù)是否執(zhí)行完畢都會(huì)停機(jī)處理，需要根據(jù)項(xiàng)目實(shí)際需要合理設(shè)置。

以上配置完畢，重新發(fā)布以后，服務(wù)端就支持優(yōu)雅停服了。

[

三、觸發(fā)優(yōu)雅停服

]

1、對進(jìn)程PID執(zhí)行kill-2 而不是kill-9

kill-9，暴力美學(xué)強(qiáng)制殺死進(jìn)程，不會(huì)執(zhí)行ShutdownHook；但是kill-2相當(dāng)于快捷鍵Ctrl+ C會(huì)觸發(fā)Java的ShutdownHook事件處理，進(jìn)行優(yōu)雅停機(jī)或者一些后置處理?？蓞⒖家韵略创a：

@Override

publicvoidregisterShutdownHook(){

if(this.shutdownHook== null){

//No shutdown hook registered yet.

this.shutdownHook= newThread(SHUTDOWN_HOOK_THREAD_NAME) {

@Override

publicvoidrun(){

synchronized(startupShutdownMonitor) {

doClose();

}

};

Runtime.getRuntime().addShutdownHook(this.shutdownHook);

}

2、通過actuator端點(diǎn)實(shí)現(xiàn)優(yōu)雅停機(jī)

前提為項(xiàng)目已加入actuator依賴，以及application.properties加入相關(guān)配置如圖

此時(shí)，POST請求/actuator/shutdown即可執(zhí)行優(yōu)雅關(guān)機(jī)。

源碼解析如下：

@Endpoint(id= "shutdown",enableByDefault = false)

publicclassShutdownEndpointimplementsApplicationContextAware{

@WriteOperation

publicMap shutdown(){

Threadthread = newThread(this::performShutdown);

thread.setContextClassLoader(getClass().getClassLoader());

thread.start();

}

privatevoidperformShutdown(){

try{

Thread.sleep(500L);

}

catch(InterruptedException ex) {

Thread.currentThread().interrupt();

}

//此處close邏輯和上邊shutdownhook的處理一樣

this.context.close();

}

[

四、例子

]

我們通過一個(gè)demo來驗(yàn)證下是否實(shí)現(xiàn)了優(yōu)雅停服，下面是一個(gè)http測試接口，請求后返回一個(gè)json串。

@GetMapping("/test")
publicObject test(){
List test = new ArrayList<>();
for(inti = 0; i < 5; i++) {
String s = "test" +i;
System.out.println(s);
test.add(s);
try{
Thread.sleep(1000);
} catch(InterruptedException e) {
e.printStackTrace();
}
}
return test;
}