作者 | 驕龍

導讀：本篇是《SpringCloud 應用在 Kubernetes 上的最佳實踐》系列文章的第八篇，主要介紹了如何做到流量的無損上/下線。更多相關文章閱讀可查看文末。

前言

上篇我們講的是發布回滾過程，尤其是在 Kubernetes 的回滾過程中，原生有提供 Rollout 到上一個版本的能力，能保證我們在發布過程中遇到問題時快速回退的能力。然而在每一次上線的過程中，我們最難處理的就是正在運行中的流量，如何做到流量的無損上/下線，是一個系統能保證 SLA 的關鍵。

介紹

什么是優雅上線？就如下面這個房子一樣，未建好的房子，人住進去會有危險，房子應該建好，裝修好，人才能住進去。

那么如何做到優雅上線呢？我們先來看一個 WEB 應用的加載過程，就像上面造房子一樣，是個漫長的過程：

應用的加載是漫長的，在加載過程，服務是不可預期的；如過早地打開 Socket 監聽，則客戶端可能感受到漫長的等待；如果數據庫、消息隊列、REDIS 客戶端未完成初始化，則服務可能因缺少關鍵的底層服務而異常。

所以在應用準備完成后，才接入服務，即做到優雅上線。當然應用上線后，也可能因如數據庫斷連等情況引起服務不可用；或是準備完成了，但在上線前又發生數據庫斷連，導致服務異常。為了簡化問題，后面兩種情況作為一個應用自愈的問題來看待。

什么是優雅下線？與建房子相反就像下面的危房一樣，人住在里面很危險，人應該先從房子出來，然后推掉房子。

那么如何做到優雅下線呢？我們先來看一個 WEB 應用的停止過程：

所以關閉服務接入（轉移服務接入），完成正在處理的服務，清理自身占用的資源后退出即做到優雅下線。

如何實現優雅下線

從上面介紹看，似乎不難，但事實上，很少有系統真正實現了優雅上下線。因為軟件本身由無數各種各樣相互依賴的結構組成，每個結構都使用一些資源，污染一些資源；通常在設計之初優雅上下線也不被作為優先考慮的需求，所以對于下線的過程，通常都沒被充分考慮，在設計上通常要求：

• 結構（組件）應形成層次關系；
• 用戶線程需能收到停止信號并響應退出；否則使用 daemon 線程；
• 結構應按依賴關系自下向上構建：就像建房子一樣，自內向外構建而成；
• 結構應按依賴關系自上向下銷毀：就像拆房子一樣，自外向內拆解。

優雅下線實現路徑

大致分為一個完整的過程，需要經歷一下四個關鍵的節點，如下圖：

• 接收信號：停止信號可能從進程內部觸發（比如 Crash 場景），如果自退出的話基本上無法保證優雅下線；所以能保證優雅下線的前提就是需要正確處理來自進程外部的信號；

• 停止流量接收：由于在停止之前，我們會有一些正在處理的請求，貿然退出會對這些請求產生損耗。但是在這段時間之內我們絕不能再接收新的業務請求，如果這是一個后臺任務型（消息消費型或任務調度型）的程序，也要停止接收新的消息和任務。對于一個普通的 WEB 場景，這一塊不同的場景實現的方式也會不一樣，下面的 Srping Cloud 應用的下線流程會詳細講解；

• 銷毀資源：常見的是一些系統資源，也包括一些緩存、鎖的清理、同時也包括線程池、關閉阻塞中的的 IO 操作，等到我們這些服務器資源銷毀之后，就可以通知主線程退出。

Spring Cloud 應用

一個 Spring boot 應用通常由應用本身和一系列的 Starter 組成，對于 Spring boot 體系，需要了解如下核心概念：

• Starter：提供一系列的模塊，由 Spring boot 核心通過 auto-configuration 機制加載；

• Bean：一切皆 Bean，starter 模塊的加載產生各種 Bean；

• Context：Bean 的容器，容器擁有生命周期，Bean 需要感知生命周期事件；

• LifeCycle：生命周期管理接口；

• ApplicationEvent：模塊之間，模塊與容器之間，通過發送或監聽事件來達到互相通訊的目的。

所以對于應用上下線這個主題，我們應盡可能利用其豐富的原生事件機制，Spring Cloud 中內置的 Starter 機制針對整個生命周期管理的過程有了很好的封裝。

Spring Cloud 應用的優雅上線

Spring Cloud 啟動過程觸發回調及事件如下，詳細介紹見 application-events-and-listeners，簡單羅列如下：

Spring 自身及其組件大量基于這些事件構建，如響應 WebServerInitializedEvent 事件向服務注冊中心注冊服務，對于應用一般可利用：

• InitializingBean or @PostConstruct：在 Bean 裝配完后，被回調，如完成數據源初始化連接；

• ApplicationReadyEvent、ApplicationRunner、CommandLineRunner：如開始監聽消息隊列，處理消息；注冊到SLB等；先通過配置禁用服務的自動注冊，在這里做手動服務注冊。

Spring Cloud 應用的優雅下線

Spring Cloud 本身可以作為一個應用單獨存在，也可以是依附在一個微服務集群中，同時還能作為反向代理架構中的一個網關。不同的場景，需要用到的方法也不一樣，我們就常用的三種場景針對性的加以說明。

場景一：直接訪問 WEB 服務

客戶端直接訪問 WEB 應用，在這個用例下，優雅下線需要做的事情有：

• 正在處理的請求完成處理
• 應用自身完成安全下線并正常退出
• 客戶端感知到連接異常

Spring-boot 從 2.3 開始內置了 WEB 應用優雅下線的能力，需配置如下，具體介紹參見 graceful-shutdown。

server.shutdown=graceful spring.lifecycle.timeout-per-shutdown-phase=20s

其實現方式：

• 首先關閉 socket 監聽，等待正在處理的所有請求完成：具體可見 WebServerGracefulShutdownLifecycle，通過 getPhase 返回最大值，達到早于 WEB 容器關閉執行的目的；

• 然后觸發 WEB 容器關閉：具體可見 WebServerStartStopLifecycle。

但其實，對于未被 WEB 容器完全接收的請求，客戶端仍會收到連接被重置的異常，只是這個時間窗口極小。該需求從提出到實現的時間跨度較長，感興趣的可參見 github 上的討論。

場景二：經由反向代理的服務優雅下線

因為實例前面還有反向代理，相比上個場景，需要新增“反向代理下線”這個處理流程。即若應用已經下線，但反向代理未摘除該應用實例時客戶端將感知到失敗。一般采取的策略有：

• 反向代理支持失敗轉移到其它應用實例；
• 在關閉應用前，如將健康探測接口返回不健康以及等待足夠的超時，讓反向代理感知并摘除實例的路由信息。

對于仍在使用 2.3 以前版本的 Spring Cloud 應用，可參見一個方案，實現方式：

• 使用自身的 shutdownHook 替換 Spring 的 shutdownHook；
• 先改變 health 狀態，等待一段時間，讓反向代理感知并摘除實例的路由信息。

場景三：在微服務集群中下線單個服務

在優雅關閉 Spring Cloud 應用自身之前，我們除了完成場景一之中的目標之外，還需要將自身節點從注冊中心中下線。目前在 Spring Cloud 中針對注冊中心下線的場景暫未提供開箱即用的方法，下面介紹兩種可能的實現方案：

方案 1：先通過腳本、或通過監聽 ContextClosedEvent 反注冊服務摘除流量；等待足夠時間，如使用 ribbon 負載均衡器，需要長于配置的刷新時間；對于基于 HTTP 的服務，若 Spring Cloud 版本小于 2.3，則時間需加上預期的請求處理時間；

方案 2：客戶端支持連接感知重試，如重試，實現方案可參考Spring-retry，針對連接異常 RemoteConnectFailureException 做重試。

針對 Eureka 中的場景，有一個很好的參考的例子，請參見：https://home1-oss.github.io/home1-oss-gitbook/release/docs/oss-eureka/GRACEFUL_SHUTDOWN.html

Kubernetes 下的機制

Kubernetes 中針對應用的的管控提供了豐富的手段，正常的情況它提供了應用生命周期中的靈活擴展點，同時也支持自己擴展它的 Operator 自定義上下線的流程。

拋開實現成本，以下線的情況來說，一個 Kubernetes 應用實例下線之前，管控程序會向 POD 發送一個 SIGTERM 的信號，應用響應時除了額外響應這一個信號之外，還能觸發一段自定義的 PreStop 的掛在腳本，代碼樣例如下：

yaml lifecycle: preStop: exec: command: - sh- -c- "sleep 5"

上面的例子一點特殊說明：因服務控制面刷新與 POD 收到 SIGTERM 同時發生，所以這里通過 sleep 5 讓服務控制面先完成刷新，應用進程再響應 SIGTERM 信號。

Spring Cloud 與 Kubernetes 的結合

Kubernetes 會根據健康檢查的情況來更新服務(Service)列表，其中如果 Liveness 失敗，則會觸發容器重建，這是一個相對很重的操作；若 Readiness 失敗，則 Kubenetes 則默認不會將路由服務流量到相應的容器；基于這一機理，Spring Cloud 2.3 開始，也做了原生的的支持，具體參見 liveness-and-readiness-probes-with-Spring-boot，這些健康檢查端點可對接 Kubnetes 相應的 probe：

• /actuator/health/liveness
• /actuator/health/readiness

同時，Spring Boot 內置了相應的 API、事件、Health Check 監控，部分代碼/配置片段如下：

java // Available as a component in the application context ApplicationAvailability availability; LivenessState livenessState = availabilityProvider.getLivenessState(); ReadinessState readinessState = availabilityProvider.getReadinessState(); .... // 對于應用，也可以通過API，發布相應的事件，來改變應用的狀態 AvailabilityChangeEvent.publish(this.eventPublisher, ex, LivenessState.BROKEN); // 同時，應用監控也可影響這健康狀態，將監控與健康關聯，在K8S體系下，可以實現如離群摘除，應用自愈的能力 // application.properties management.endpoint.health.group.liveness.include=livenessProbe,cacheCheck

回到 Spring Cloud 應用?在微服務集群中下線單個服務?的章節中，我們的應用如果跑在 Kuberntes 中，如果我們使用了原生的 Kubernetes 機制去管理應用生命周期的話，只需要發布一個應用事件 (LivenessState.BROKEN) 即可實現優雅下線的能力。

EDAS提供內置的優雅上下線能力

通過上面兩部分了解了 Spring Cloud 和 K8s 中的機制，EDAS 基于原生的機制，衍生出來了自己的方法，除了最大化利用這些能力：主動更新 Liveness、Readiness、Ribbon 服務列表之外，我們還提供了無代碼侵入的開箱即用的能力，列舉如下：

• 無損下線 Spring Cloud 應用
• 無損下線 dubbo 應用
• 使用離群實例摘除保障 Spring Cloud 應用的可用性
• 使用離群實例摘除保障 Dubbo 應用的可用性

后續

這一章節之后，和發布相關的內容都已經更新完畢，下一章節我們要開始高可用部分的能力，高可用也是系統保障 SLA 的關鍵部分，簡單的理解是流量洪峰到來如何保證系統不會受到影響？當然我們還有一部分要達成的是洪峰退去之后資源是否存在浪費？敬請期待 …

相關文章推薦：

• 《SpringCloud 應用在 Kubernetes 上的最佳實踐 —— 開發篇》

• 《SpringCloud 應用在 Kubernetes 上的最佳實踐 — 部署篇(開發部署）》

• 《SpringCloud 應用在 Kubernetes 上的最佳實踐 — 部署篇(工具部署)》

• 《SpringCloud 應用在 Kubernetes 上的最佳實踐 — 線上發布（可灰度）》

• 《SpringCloud 應用在 Kubernetes 上的最佳實踐 — 診斷（線上聯調）》

• 《SpringCloud 應用在 Kubernetes 上的最佳實踐 — 線上發布（可監控）》

• 《SpringCloud 應用在 Kubernetes 上的最佳實踐 — 線上發布（可回滾）》

“阿里巴巴云原生關注微服務、Serverless、容器、Service Mesh 等技術領域、聚焦云原生流行技術趨勢、云原生大規模的落地實踐，做最懂云原生開發者的公眾號。”

總結

以上是生活随笔為你收集整理的SpringCloud 应用在 Kubernetes 上的最佳实践 — 线上发布（优雅上下线）的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。