// 支付回調(diào)處理
@PostMapping("/callback")
public void handleCallback(Payment payment) {
    // 1. 更新訂單狀態(tài)
    orderService.updateStatus(payment.getOrderId(), PAID);
    
    // 2. 發(fā)放權(quán)益（kill發(fā)生時(shí)此處未執(zhí)行）
    benefitService.grantVip(payment.getUserId()); 
}

server:
  shutdown: graceful # 開啟優(yōu)雅停機(jī)
  
spring:
  lifecycle:
    timeout-per-shutdown-phase: 30s # 最長(zhǎng)等待時(shí)間

@Bean
public ExecutorService threadPool() {
    ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
    executor.setWaitForTasksToCompleteOnShutdown(true); // 等待任務(wù)完成
    executor.setAwaitTerminationSeconds(60); // 最大等待時(shí)間
    return executor.getThreadPoolExecutor();
}

@Around("@annotation(org.springframework.web.bind.annotation.RequestMapping)")
public Object handleRequest(ProceedingJoinPoint pjp) {
    Lock lock = redisson.getLock("order_lock");
    try {
        lock.lock();
        return pjp.proceed();
    } finally {
        if (!isShuttingDown()) {
            lock.unlock(); // 非停機(jī)時(shí)正常釋放
        }
        // 停機(jī)時(shí)由鎖管理器統(tǒng)一釋放
    }
}

STOPSIGNAL SIGTERM # 使用SIGTERM替代SIGKILL

# Deployment配置
spec:
terminationGracePeriodSeconds:60# 寬限期
containers:
    -lifecycle:
        preStop:
          exec:
            command:["/bin/sh","-c","sleep 20;"]# 預(yù)留緩沖時(shí)間

@PreDestroy
public void close() {
    HikariPool pool = dataSource.getHikariPoolMXBean();
    pool.suspendPool(); // 停止借出連接
    pool.softEvictConnections(); // 驅(qū)逐空閑連接
    while (pool.getActiveConnections() > 0) {
        Thread.sleep(500); // 等待活動(dòng)連接完成
    }
    pool.shutdown(); // 徹底關(guān)閉
}

@PreDestroy
public void stop() {
    channel.basicCancel(consumerTag); // 取消訂閱
    while (unackedMessages.get() > 0) {
        Thread.sleep(100); // 等待ACK完成
    }
    connection.close();
}

public class LockManager implements DisposableBean {
    @Override
    public void destroy() {
        lockMap.forEach((key, lock) -> {
            if (lock.isHeldByCurrentThread()) {
                lock.unlock(); // 強(qiáng)制釋放未解鎖的鎖
            }
        });
    }
}

public enum ShutdownState {
    RUNNING,    // 正常運(yùn)行
    PRE_SHUTDOWN, // 拒絕新請(qǐng)求
    DRAINING,    // 排空存量請(qǐng)求
    TERMINATED   // 完全終止
}

# 停機(jī)前執(zhí)行
curl -X POST http://localhost:8080/actuator/shutdown-prepare

# 驗(yàn)證項(xiàng)：
1. 新請(qǐng)求返回503
2. 活動(dòng)線程數(shù)持續(xù)下降
3. 數(shù)據(jù)庫(kù)連接數(shù)歸零
4. MQ無(wú)未ACK消息