拒絕 kill -9 暴力停止，優(yōu)雅停止 SpringCloud 服務(wù)
點擊關(guān)注公眾號，Java干貨及時送達(dá)
對于微服務(wù)來說，服務(wù)的優(yōu)雅上下線是必要的。就上線來說，如果組件或者容器沒有啟動成功，就不應(yīng)該對外暴露服務(wù)，對于下線來說，如果機(jī)器已經(jīng)停機(jī)了，就應(yīng)該保證服務(wù)已下線，如此可避免上游流量進(jìn)入不健康的機(jī)器。
優(yōu)雅下線
基礎(chǔ)下線（Spring/SpringBoot/內(nèi)置容器）
首先JVM本身是支持通過shutdownHook的方式優(yōu)雅停機(jī)的。
Runtime.getRuntime().addShutdownHook(new Thread() {
@Override
public void run() {
close();
}
});
此方式支持在以下幾種場景優(yōu)雅停機(jī):
1、 程序正常退出
2、 使用System.exit()
3、 終端使用Ctrl+C
4、 使用Kill pid干掉進(jìn)程
那么如果你偏偏要kill -9 程序肯定是不知所措的。
而在Springboot中，其實已經(jīng)幫你實現(xiàn)好了一個shutdownHook，支持響應(yīng)Ctrl+c或者kill -15 TERM信號。
隨便啟動一個應(yīng)用，然后Ctrl+c一下，觀察日志就可知， 它在AnnotationConfigEmbeddedWebApplicationContext這個類中打印出了疑似Closing...的日志，真正的實現(xiàn)邏輯在其父類
AbstractApplicationContext中(這個其實是spring中的類，意味著什么呢，在spring中就支持了對優(yōu)雅停機(jī)的擴(kuò)展)。
public void registerShutdownHook() {
if (this.shutdownHook == null) {
this.shutdownHook = new Thread() {
public void run() {
synchronized(AbstractApplicationContext.this.startupShutdownMonitor) {
AbstractApplicationContext.this.doClose();
}
}
};
Runtime.getRuntime().addShutdownHook(this.shutdownHook);
}
}
public void destroy() {
this.close();
}
public void close() {
Object var1 = this.startupShutdownMonitor;
synchronized(this.startupShutdownMonitor) {
this.doClose();
if (this.shutdownHook != null) {
try {
Runtime.getRuntime().removeShutdownHook(this.shutdownHook);
} catch (IllegalStateException var4) {
;
}
}
}
}
protected void doClose() {
if (this.active.get() && this.closed.compareAndSet(false, true)) {
if (this.logger.isInfoEnabled()) {
this.logger.info("Closing " + this);
}
LiveBeansView.unregisterApplicationContext(this);
try {
this.publishEvent((ApplicationEvent)(new ContextClosedEvent(this)));
} catch (Throwable var3) {
this.logger.warn("Exception thrown from ApplicationListener handling ContextClosedEvent", var3);
}
if (this.lifecycleProcessor != null) {
try {
this.lifecycleProcessor.onClose();
} catch (Throwable var2) {
this.logger.warn("Exception thrown from LifecycleProcessor on context close", var2);
}
}
this.destroyBeans();
this.closeBeanFactory();
this.onClose();
this.active.set(false);
}
}
我們能對它做些什么呢，其實很明顯，在doClose方法中它發(fā)布了一個ContextClosedEvent的方法，不就是給我們擴(kuò)展用的么。于是我們可以寫個監(jiān)聽器監(jiān)聽ContextClosedEvent，在發(fā)生事件的時候做下線邏輯，對微服務(wù)來說即是從注冊中心中注銷掉服務(wù)。
@Component
public class GracefulShutdownListener implements ApplicationListener<ContextClosedEvent> {
@Override
public void onApplicationEvent(ContextClosedEvent contextClosedEvent){
//注銷邏輯
zookeeperRegistry.unregister(mCurrentServiceURL);
...
}
}
可能會有疑問的是，微服務(wù)中一般來說，注銷服務(wù)往往是優(yōu)雅下線的第一步，接著才會執(zhí)行停機(jī)操作，那么這個時候流量進(jìn)來怎么辦呢？
個人會建議是，在注銷服務(wù)之后就可開啟請求擋板拒絕流量了，通過微服務(wù)框架本身的故障轉(zhuǎn)移功能去處理被拒絕的流量即可。
Docker中的下線
好有人說了，我用docker部署服務(wù)，支不支持優(yōu)雅下線。
那來看看docker的一些停止命令都會干些啥：
一般來說，正常人可能會用docker stop或者docker kill 命令去關(guān)閉容器（當(dāng)然如果上一步注冊了USR2自定義信息，可能會通過docker exec kill -12去關(guān)閉）。
對于docker stop來說，它會發(fā)一個SIGTERM(kill -15 term信息)給容器的PID1進(jìn)程，并且默認(rèn)會等待10s，再發(fā)送一個SIGKILL(kill -9 信息)給PID1。
那么很明顯，docker stop允許程序有個默認(rèn)10s的反應(yīng)時間去做一下優(yōu)雅停機(jī)的操作，程序只要能對kill -15 信號做些反應(yīng)就好了，如上一步描述。那么這是比較良好的方式。
當(dāng)然如果shutdownHook方法執(zhí)行了個50s，那肯定不優(yōu)雅了?？梢酝ㄟ^docker stop -t 加上等待時間。
外置容器的shutdown腳本（Jetty）
如果非要用外置容器方式部署（個人認(rèn)為浪費資源并提升復(fù)雜度）。那么能不能優(yōu)雅停機(jī)呢。
可以當(dāng)然也是可以的，這里有兩種方式：
首先RPC框架本身提供優(yōu)雅上下線接口，以供調(diào)用來結(jié)束整個應(yīng)用的生命周期，并且提供擴(kuò)展點供開發(fā)者自定義服務(wù)下線自身的停機(jī)邏輯。同時調(diào)用該接口的操作會封裝成一個preStop操作固化在jetty或者其他容器的shutdown腳本中，保證在容器停止之前先調(diào)用下線接口結(jié)束掉整個應(yīng)用的生命周期。shutdown腳本中執(zhí)行類發(fā)起下線服務(wù) -> 關(guān)閉端口 -> 檢查下線服務(wù)直至完成 -> 關(guān)閉容器的流程。
而更簡單的另一種方法是直接在腳本中加入kill -15命令。
優(yōu)雅上線
優(yōu)雅上線相對來說可能會更加困難一些，因為沒有什么默認(rèn)的實現(xiàn)方式，但是總之呢，一個原則就是確保端口存在之后才上線服務(wù)。
springboot內(nèi)置容器優(yōu)雅上線
這個就很簡單了，并且業(yè)界在應(yīng)用層面的優(yōu)雅上線均是在內(nèi)置容器的前提下實現(xiàn)的，并且還可以配合一些列健康檢查做文章。
參看sofa-boot的健康檢查的源碼，它會在程序啟動的時候先對springboot的組件做一些健康檢查，然后再對它自己搞得sofa的一些中間件做健康檢查，整個健康檢查的流程完畢之后（sofaboot 目前是沒法對自身應(yīng)用層面做健康檢查的，它有寫相關(guān)接口，但是寫死了port is ready...）才會暴露服務(wù)或者說優(yōu)雅上線，那么它健康檢查的時機(jī)是什么時候呢：
@Override
public void onApplicationEvent(ContextRefreshedEvent event) {
healthCheckerProcessor.init();
healthIndicatorProcessor.init();
afterHealthCheckCallbackProcessor.init();
publishBeforeHealthCheckEvent();
readinessHealthCheck();
}
可以看到它是監(jiān)聽了ContextRefreshedEvent這個事件。在內(nèi)置容器模式中，內(nèi)置容器模式的start方法是在refreshContext方法中，方法執(zhí)行完成之后發(fā)布一個ContextRefreshedEvent事件，也就是說在監(jiān)聽到這個事件的時候，內(nèi)置容器必然是啟動成功了的。
但ContextRefreshedEvent這個事件，在一些特定場景中由于種種原因，ContextRefreshedEvent會被監(jiān)聽到多次，沒有辦法保證當(dāng)前是最后一次event，從而正確執(zhí)行優(yōu)雅上線邏輯。
在springboot中還有一個更加靠后的事件，叫做ApplicationReadyEvent，它的發(fā)布藏在了afterRefresh還要后面的那一句listeners.finished(context, null)中，完完全全可以保證內(nèi)置容器 端口已經(jīng)存在了，所以我們可以監(jiān)聽這個事件去做優(yōu)雅上線的邏輯，甚至可以把中間件相關(guān)的健康檢查集成在這里。
@Component
public class GracefulStartupListener implements ApplicationListener<ApplicationReadyEvent> {
@Override
public void onApplicationEvent(ApplicationReadyEvent applicationReadyEvent){
//注冊邏輯 優(yōu)雅上線
apiRegister.register(urls);
...
}
}
外置容器(Jetty)優(yōu)雅上線
目前大多數(shù)應(yīng)用的部署模式不管是jetty部署模式還是docker部署模式(同樣使用jetty鏡像)，本質(zhì)上用的都是外置容器。那么這個情況就比較困難了，至少在應(yīng)用層面無法觀察到外部容器的運(yùn)行狀態(tài)，并且容器本身沒有提供什么hook給你實現(xiàn)。
那么和優(yōu)雅上線一樣，需要RPC框架提供優(yōu)雅上線接口來初始化整個應(yīng)用的生命周期，并且提供擴(kuò)展點給開發(fā)者供執(zhí)行自定義的上線邏輯(上報版本探測信息等)。同樣將調(diào)用這個接口封裝成一個postStart操作，固化在jetty等外置容器的startup腳本中，保證應(yīng)用在容器啟動之后在上線。容器執(zhí)行類似啟動容器 -> 健康檢查 -> 上線服務(wù)邏輯 -> 健康上線服務(wù)直至完成 的流程。
轉(zhuǎn)自：fredalxin
鏈接：https://fredal.xin/graceful-soa-updown