在分布式系統(tǒng)中，服務(wù)的優(yōu)雅停機(jī)（Graceful Shutdown）是確保業(yè)務(wù)連續(xù)性的重要機(jī)制。Spring Boot 通過(guò) 內(nèi)嵌服務(wù)器支持 和 生命周期管理 實(shí)現(xiàn)了這一功能，以下是具體實(shí)現(xiàn)方式和配置細(xì)節(jié)：

1. 優(yōu)雅停機(jī)的核心目標(biāo)

• 停止接收新請(qǐng)求：關(guān)閉監(jiān)聽(tīng)端口，不再接受新連接。
• 等待處理中的請(qǐng)求完成：允許正在執(zhí)行的請(qǐng)求繼續(xù)處理直至超時(shí)。
• 釋放資源：關(guān)閉數(shù)據(jù)庫(kù)連接池、線程池等資源。
• 避免數(shù)據(jù)不一致：確保事務(wù)完整性，防止中途中斷。

2. 基于內(nèi)嵌服務(wù)器的優(yōu)雅停機(jī)配置

Spring Boot 從 2.3 版本 開(kāi)始，為 Tomcat、Jetty、Undertow 等內(nèi)嵌服務(wù)器內(nèi)置了優(yōu)雅停機(jī)支持。

2.1 啟用優(yōu)雅停機(jī)

在 application.properties 或 application.yml 中配置：

server:
  shutdown: graceful  # 啟用優(yōu)雅停機(jī)模式
spring:
  lifecycle:
    timeout-per-shutdown-phase: 30s  # 等待請(qǐng)求完成的超時(shí)時(shí)間（默認(rèn)30秒）

2.2 不同服務(wù)器的行為

2.3 驗(yàn)證停機(jī)流程

1.發(fā)送停機(jī)信號(hào)：

通過(guò) SIGTERM 信號(hào)（Kill 命令）或 Actuator 端點(diǎn)關(guān)閉應(yīng)用。

使用 Actuator 端點(diǎn)需要添加依賴和配置：

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-actuator</artifactId>
</dependency>

management:
  endpoint:
    shutdown:
      enabled: true
  endpoints:
    web:
      exposure:
        include: shutdown

發(fā)送 POST 請(qǐng)求關(guān)閉應(yīng)用：

curl -X POST http://localhost:8080/actuator/shutdown

2.觀察日志：

2023-10-05 14:20:00 INFO  o.s.b.w.e.tomcat.GracefulShutdown : Commencing graceful shutdown. Waiting for active requests to complete
2023-10-05 14:20:30 INFO  o.s.b.w.e.tomcat.GracefulShutdown : Graceful shutdown complete

3. 自定義停機(jī)邏輯擴(kuò)展

3.1 監(jiān)聽(tīng)停機(jī)事件

通過(guò)實(shí)現(xiàn) ApplicationListener<ContextClosedEvent> 監(jiān)聽(tīng)上下文關(guān)閉事件：

@Component
public class GracefulShutdownListener implements ApplicationListener<ContextClosedEvent> {
    @Override
    public void onApplicationEvent(ContextClosedEvent event) {
        //dubbo關(guān)閉
        DubboBootstrap.getInstance().stop();
        // 執(zhí)行自定義清理邏輯（如關(guān)閉線程池、釋放資源）
        ExecutorService executor = event.getApplicationContext().getBean(ExecutorService.class);
        executor.shutdown();
        try {
            if (!executor.awaitTermination(30, TimeUnit.SECONDS)) {
                executor.shutdownNow();
            }
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
        }
    }
}

3.2 使用 @PreDestroy 注解

在 Bean 銷毀前執(zhí)行清理邏輯：

@Service
public class DatabaseService {
    @PreDestroy
    public void cleanup() {
        // 關(guān)閉數(shù)據(jù)庫(kù)連接
        DataSource dataSource = ...;
        dataSource.close();
    }
}

4. 集成 Kubernetes 的優(yōu)雅停機(jī)

在 Kubernetes 中，結(jié)合 Pod 生命周期鉤子 實(shí)現(xiàn)優(yōu)雅停機(jī)：

4.1 配置 PreStop Hook

在 Deployment 配置中添加 preStop 鉤子，延遲終止進(jìn)程：

spec:
  template:
    spec:
      containers:
        - name: app
          lifecycle:
            preStop:
              exec:
                command: ["sh", "-c", "sleep 30"]  # 等待30秒后發(fā)送SIGTERM
          terminationGracePeriodSeconds: 60  # 總寬限期（包括preStop）

4.2 配合就緒探針

在停機(jī)前標(biāo)記服務(wù)不可用：

readinessProbe:
  httpGet:
    path: /actuator/health/readiness
    port: 8080

5. 常見(jiàn)問(wèn)題與解決方案

6. 驗(yàn)證優(yōu)雅停機(jī)效果

1.發(fā)送長(zhǎng)耗時(shí)請(qǐng)求：

curl http://localhost:8080/long-task

2.觸發(fā)停機(jī)：

curl -X POST http://localhost:8080/actuator/shutdown

3.觀察結(jié)果：

• 新請(qǐng)求返回 503 Service Unavailable。
• 正在處理的請(qǐng)求繼續(xù)執(zhí)行直至完成或超時(shí)。

總結(jié)

通過(guò) 內(nèi)嵌服務(wù)器配置、生命周期鉤子 和 Kubernetes 集成，Spring Boot 實(shí)現(xiàn)了開(kāi)箱即用的優(yōu)雅停機(jī)功能。關(guān)鍵配置包括：

• 啟用 server.shutdown=graceful。
• 設(shè)置合理的超時(shí)時(shí)間。
• 結(jié)合 Actuator 端點(diǎn)或 Kubernetes 生命周期管理。

到此這篇關(guān)于一文帶你掌握springBoot如何做到優(yōu)雅停機(jī)的的文章就介紹到這了,更多相關(guān)springBoot停機(jī)內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

最新評(píng)論