Spring Cloud应用部署时如何等待Eureka客户端移除自身后再完全关闭？

这个问题我太熟了——之前帮团队排查过好多次类似的生产问题：K8s滚动更新时，Spring Cloud实例收到SIGTERM就直接下线，但调用方的Eureka客户端还缓存着旧的注册表信息，导致请求不断打到已停机的实例，产生一堆无意义的错误。下面是几个经过生产验证的解决方案，从配置调整到代码实现再到K8s生命周期配置，给你一步步理清楚：

首先要优化Eureka的心跳和过期配置，让Eureka服务器更快感知到实例下线，同时让调用方更快拉取到最新的注册表：

在你的application.yml里添加这些配置：

eureka:
  client:
    healthcheck:
      enabled: true # 开启健康检查，让Eureka基于应用健康状态判断实例可用性
    fetch-registry-interval-seconds: 10 # 缩短调用方拉取注册表的间隔，默认30秒
  instance:
    lease-renewal-interval-in-seconds: 5 # 实例向Eureka发送心跳的间隔，默认30秒
    lease-expiration-duration-in-seconds: 10 # Eureka多久没收到心跳就标记实例过期，默认90秒
    prefer-ip-address: true

Spring Boot 2.3+自带了优雅停机功能，我们可以结合它，在应用真正关闭前主动向Eureka注销自己，并且等待足够时间让注册表同步到所有客户端：

第一步：开启Spring Boot优雅停机 #

在application.yml里添加：

server:
  shutdown: graceful # 开启优雅停机，会等待正在处理的请求完成后再关闭
spring:
  lifecycle:
    timeout-per-shutdown-phase: 30s # 给停机流程留足够时间，比如30秒

第二步：自定义注销逻辑，等待Eureka同步 #

写一个配置类，用@PreDestroy注解在应用关闭前执行注销和等待：

import org.springframework.cloud.netflix.eureka.serviceregistry.EurekaRegistration;
import org.springframework.cloud.netflix.eureka.serviceregistry.EurekaServiceRegistry;
import org.springframework.context.annotation.Configuration;
import javax.annotation.PreDestroy;
import java.util.concurrent.TimeUnit;

@Configuration
public class EurekaGracefulShutdownConfig {

    private final EurekaServiceRegistry serviceRegistry;
    private final EurekaRegistration registration;

    // 构造注入Eureka注册相关的Bean
    public EurekaGracefulShutdownConfig(EurekaServiceRegistry serviceRegistry, EurekaRegistration registration) {
        this.serviceRegistry = serviceRegistry;
        this.registration = registration;
    }

    @PreDestroy
    public void gracefulShutdown() {
        // 主动向Eureka服务器注销当前实例
        serviceRegistry.deregister(registration);
        
        try {
            // 等待足够时间，让Eureka把实例移除的信息同步给所有客户端
            // 这个时间可以根据你的Eureka集群规模和调用方缓存配置调整，比如20秒
            TimeUnit.SECONDS.sleep(20);
        } catch (InterruptedException e) {
            // 恢复中断状态，不影响后续停机流程
            Thread.currentThread().interrupt();
        }
    }
}

K8s在发送SIGTERM信号前，可以通过PreStop钩子先执行一些操作，确保应用有足够时间完成Eureka注销：

在你的Deployment配置里添加PreStop钩子：

spec:
  containers:
  - name: your-application-name
    image: your-app-image:latest
    lifecycle:
      preStop:
        exec:
          # 这里可以直接让容器等待一段时间，和上面的代码等待配合，双重保险
          command: ["sleep", "20"]

如果你开启了Spring Boot Actuator的shutdown端点，也可以用钩子主动触发优雅停机：

# 先在application.yml里开启shutdown端点
management:
  endpoints:
    web:
      exposure:
        include: shutdown
  endpoint:
    shutdown:
      enabled: true

# 然后在K8s Deployment里配置PreStop
spec:
  containers:
  - name: your-application-name
    image: your-app-image:latest
    lifecycle:
      preStop:
        exec:
          command: ["/bin/sh", "-c", "curl -X POST http://localhost:8080/actuator/shutdown || true"]

• 调用方配置优化：如果调用方也是Spring Cloud应用，记得调整它们的eureka.client.fetch-registry-interval-seconds，缩短拉取注册表的间隔，让它们更快拿到最新的实例列表。
• 避免流量残留：如果你的应用前面有K8s Service或者Ingress，可以配置健康检查（比如用Actuator的/health端点），让负载均衡器在实例注销后不再转发流量过来，和Eureka的处理形成互补。

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