题目
Spring Boot应用在分布式环境下如何实现优雅关闭并处理未完成的任务？
信息
- 类型：问答
- 难度：⭐⭐⭐
考点
Spring Boot优雅关闭,分布式事务处理,异步任务管理,服务注册与发现
快速回答
在分布式环境下实现Spring Boot应用的优雅关闭，需要关注以下几个方面：
- 启用优雅关闭：配置
server.shutdown=graceful并设置超时时间 - 处理未完成的任务：对于异步任务，使用
@PreDestroy或实现SmartLifecycle来等待任务完成 - 分布式事务协调：在关闭前确保跨服务的事务一致性，可能需要结合分布式事务框架如Seata
- 注册中心注销：在关闭前主动从服务注册中心（如Eureka）注销，避免流量损失
在分布式系统中，Spring Boot应用的优雅关闭不仅涉及单实例的关闭，还需要考虑对上下游服务的影响，以及未完成任务的妥善处理。下面从多个方面进行详细说明。
1. 优雅关闭的基本配置
Spring Boot 2.3及以上版本内置了优雅关闭功能。在application.properties中配置：
server.shutdown=graceful
spring.lifecycle.timeout-per-shutdown-phase=30s这样，当接收到SIGTERM信号时，Spring Boot会停止接收新请求，并等待当前请求处理完成，最长等待30秒。
2. 异步任务的处理
如果应用中有使用@Async的异步任务，需要确保在关闭前这些任务能够完成。可以通过以下方式实现：
- 使用
ThreadPoolTaskExecutor并重写shutdown方法：
@Bean
public Executor asyncExecutor() {
ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor() {
@Override
public void shutdown() {
super.shutdown();
try {
if (!this.getThreadPoolExecutor().awaitTermination(30, TimeUnit.SECONDS)) {
// 强制关闭
this.getThreadPoolExecutor().shutdownNow();
}
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
}
}
};
// 配置线程池参数
return executor;
}- 在
@PreDestroy方法中等待任务完成：
@PreDestroy
public void destroy() {
// 获取所有运行中的任务并等待
CompletableFuture[] futures = ... // 获取所有未完成的CompletableFuture
CompletableFuture.allOf(futures).join();
}3. 分布式事务处理
在关闭时如果有跨服务的事务未完成，需要确保事务一致性。以Seata为例：
- 在关闭前，检查是否有全局事务未提交，并等待其完成。
- 如果等待超时，根据业务规则决定回滚或记录日志人工介入。
示例代码（在关闭钩子中）：
Runtime.getRuntime().addShutdownHook(new Thread(() -> {
GlobalTransactionContext current = GlobalTransactionContext.getCurrent();
if (current != null) {
try {
current.commit();
} catch (TransactionException e) {
// 处理异常
}
}
}));4. 服务注销与流量切换
在关闭前，需要主动从注册中心注销，并确保负载均衡器不再将流量路由到该实例：
- 对于Eureka，调用
EurekaClient.shutdown()。 - 对于Kubernetes，使用就绪探针（Readiness Probe）在关闭时返回失败。
最佳实践：在接收到关闭信号后，先标记服务不可用，等待一段时间（如30秒）后再开始关闭流程。
5. 常见错误
- 未设置超时时间导致关闭无限期等待
- 忽略异步任务，导致数据不一致
- 未处理分布式事务，造成部分提交
- 未从注册中心注销，导致请求失败
6. 扩展知识
- 使用Spring Cloud Sleuth和Zipkin追踪未完成请求
- 结合消息队列的消费者优雅退出机制，如Kafka的
Consumer.close() - 在Kubernetes环境中，使用
preStop钩子执行自定义关闭脚本
