Spring Boot应用Shutdown Hook触发后中途终止，求专家协助

我之前处理过好几个类似的场景，这种钩子执行到一半就停的情况，通常和Spring生命周期协同、执行超时或者线程中断有关，给你几个排查和解决的方向：

一、先定位钩子中断的具体位置 #

首先在你的自定义ShutdownHook代码里，给关键步骤加上日志输出，这样能精准定位到哪一步终止了：

Runtime.getRuntime().addShutdownHook(new Thread(() -> {
    System.out.println("Shutdown hook started");
    try {
        System.out.println("Executing cleanup step 1...");
        // 你的步骤1逻辑
        System.out.println("Cleanup step 1 completed");
        
        System.out.println("Executing cleanup step 2...");
        // 你的步骤2逻辑
        System.out.println("Cleanup step 2 completed");
        
        // 更多步骤...
    } catch (Exception e) {
        System.err.println("Error in shutdown hook: " + e.getMessage());
        e.printStackTrace();
    }
    System.out.println("Shutdown hook finished");
}));

通过日志就能知道是执行到某一步抛出了异常，还是被中断，或者直接没输出后续日志（可能是超时被JVM强制终止）。

二、替换Runtime Hook为Spring生命周期事件（推荐） #

Spring Boot自带的生命周期机制比直接用Runtime.addShutdownHook更可靠，因为它会和上下文关闭流程协同，不会出现中途被打断的情况。你可以用ContextClosedEvent监听器来实现自定义关闭逻辑：

1. 创建一个监听器组件：

@Component
public class CustomShutdownHandler implements ApplicationListener<ContextClosedEvent> {

    @Override
    public void onApplicationEvent(ContextClosedEvent event) {
        // 这里写你的关闭逻辑
        System.out.println("Starting custom shutdown logic...");
        
        // 模拟耗时操作（比如关闭资源、发送通知等）
        try {
            Thread.sleep(15000); // 假设需要15秒完成
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
            System.err.println("Shutdown logic was interrupted, performing emergency cleanup");
        }
        
        System.out.println("Custom shutdown logic completed");
    }
}

2. 恢复Spring自带的ShutdownHook：
   把代码里的registerShutdownHook(false)去掉，让Spring自动注册钩子，这样Spring会在收到SIGTERM时，先触发所有ContextClosedEvent监听器，再优雅关闭上下文。

3. 设置关闭超时时间：
   在application.properties或application.yml里配置Spring关闭阶段的超时时间，确保你的逻辑有足够时间执行：

# 给每个关闭阶段设置30秒超时
spring.lifecycle.timeout-per-shutdown-phase=30s

三、如果坚持用Runtime ShutdownHook，需调整执行逻辑 #

如果你必须用Runtime.addShutdownHook，要确保钩子和Spring上下文的状态协同：

1. 在钩子中先优雅关闭Spring上下文：

ConfigurableApplicationContext applicationContext = new SpringApplicationBuilder(MyApp.class)
        .profiles("default")
        .registerShutdownHook(false) // 关闭Spring自带钩子
        .build()
        .run(args);

Runtime.getRuntime().addShutdownHook(new Thread(() -> {
    try {
        // 先让Spring优雅关闭上下文
        applicationContext.close();
        // 再执行自定义逻辑
        System.out.println("Executing custom shutdown tasks...");
        // 你的自定义逻辑
    } catch (Exception e) {
        e.printStackTrace();
    }
}));

这样能避免Spring上下文在你的钩子执行过程中被意外关闭，导致资源不可用。

2. 处理线程中断：
   钩子线程可能会被JVM中断，所以要在代码中捕获InterruptedException，并执行必要的紧急清理：

new Thread(() -> {
    try {
        // 你的清理逻辑
    } catch (InterruptedException e) {
        Thread.currentThread().interrupt();
        // 执行紧急清理
        System.err.println("Shutdown hook interrupted, running emergency cleanup");
        // 比如关闭数据库连接、释放文件锁等
    }
})

四、检查JVM和系统层面的超时 #

有些环境（比如容器化部署）会在发送SIGTERM后，等待一段时间就发送SIGKILL强制终止进程，比如Kubernetes默认是30秒。如果你的钩子执行时间超过这个阈值，就会被强制打断：

• 如果是容器部署，调整容器的终止等待时间（比如Kubernetes的terminationGracePeriodSeconds）；
• 确保你的关闭逻辑尽可能优化，减少耗时操作。

内容的提问来源于stack exchange，提问作者Raashith