在Kubernetes中实现ASP.NET Core 6优雅关闭遇问题求助

问题描述 #

在Alpine Linux上运行ASP.NET Core 6容器，已实现LifetimeEventsHostedService监听应用生命周期事件，启动时日志正常输出：

LifetimeEventsHostedService has been called.
StartAsync has been called.
OnStarted has been called.

但执行kubectl delete pod my-pod-xyz -n mynamespace或重启容器时，Pod被终止并启动新实例，容器日志中未出现OnStopping方法里的日志（如"OnStopping has been called"），优雅关闭逻辑未触发。

相关代码 #

Program.cs #

public class Program
{
    public static void Main(string[] args)
    {
        CreateHostBuilder(args).Build().Run();
    }

    public static IHostBuilder CreateHostBuilder(string[] args) =>
        Host.CreateDefaultBuilder(args)
            .ConfigureWebHostDefaults(webBuilder =>
            {
                webBuilder.UseStartup<Startup>();
                webBuilder.ConfigureKestrel(options =>
                {
                    options.Limits.KeepAliveTimeout = TimeSpan.FromMinutes(60);
                });
            }).ConfigureServices(services =>
            {
                services.AddHostedService<LifetimeEventsHostedService>();
                services.Configure<HostOptions>(option =>
                {
                    option.ShutdownTimeout = TimeSpan.FromSeconds(15);
                });
            });
}

LifetimeEventsHostedService.cs #

internal class LifetimeEventsHostedService : IHostedService
{
    private readonly ILogger<LifetimeEventsHostedService> _logger;
    private readonly IHostApplicationLifetime _appLifetime;

    public LifetimeEventsHostedService(
        ILogger<LifetimeEventsHostedService> logger,
        IHostApplicationLifetime appLifetime)
    {
        _logger = logger;
        _appLifetime = appLifetime;
        _logger.LogInformation("LifetimeEventsHostedService has been called.");
    }

    public Task StartAsync(CancellationToken cancellationToken)
    {
        _logger.LogInformation("StartAsync has been called.");
        _appLifetime.ApplicationStarted.Register(OnStarted);
        _appLifetime.ApplicationStopping.Register(OnStopping);
        _appLifetime.ApplicationStopped.Register(OnStopped);

        return Task.CompletedTask;
    }

    public Task StopAsync(CancellationToken cancellationToken)
    {
        _logger.LogInformation("StopAsync has been called.");
        return Task.CompletedTask;
    }

    private void OnStarted()
    {
        _logger.LogInformation("OnStarted has been called.");
    }

    private void OnStopping()
    {
        _logger.LogInformation("OnStopping has been called.");

        _logger.LogInformation("SIGTERM received, waiting for 30 seconds");
        Thread.Sleep(30000);
        _logger.LogInformation("Termination delay complete, continuing stopping process");
    }

    private void OnStopped()
    {
        _logger.LogInformation("OnStopped has been called.");
    }
}

可能的原因及解决方法 #

1. .NET进程未接收SIGTERM信号（PID 1问题） #

Alpine Linux默认使用ash shell，如果Dockerfile的ENTRYPOINT用了shell形式（比如ENTRYPOINT dotnet YourApp.dll），shell会成为PID 1，它不会转发SIGTERM信号给子进程（.NET应用），导致应用无法感知终止信号。

解决：
修改Dockerfile的ENTRYPOINT为exec形式，确保.NET进程成为PID 1：

ENTRYPOINT ["dotnet", "YourApp.dll"]

或者用exec命令强制转发信号：

ENTRYPOINT exec dotnet YourApp.dll

2. 关闭超时配置冲突 #

你设置的HostOptions.ShutdownTimeout是15秒，但OnStopping里用Thread.Sleep(30000)等待30秒，当.NET主机的关闭超时到期后，会强制终止进程，导致OnStopping的日志还没输出或执行完成就被杀死。

解决：
调整HostOptions.ShutdownTimeout为大于等于你的处理时间，比如35秒：

services.Configure<HostOptions>(option =>
{
    option.ShutdownTimeout = TimeSpan.FromSeconds(35);
});

3. Kubernetes终止宽限期不足 #

Kubernetes的Pod默认terminationGracePeriodSeconds是30秒，如果你的处理时间超过这个值，K8s会在宽限期结束后直接发送SIGKILL杀死进程，导致优雅关闭逻辑无法完成。

解决：
在Pod的Deployment配置中增加终止宽限期，比如设为40秒（大于你的处理时间+主机关闭超时）：

spec:
  terminationGracePeriodSeconds: 40
  containers:
  - name: your-app-container
    # 其他配置

4. 同步阻塞导致日志未输出 #

Thread.Sleep是同步阻塞操作，可能会影响日志的实时输出（尤其是在控制台日志未刷新的情况下），同时IHostApplicationLifetime的ApplicationStopping注册的同步委托可能在执行过程中被强制终止。

优化：
将OnStopping改为异步方法，使用非阻塞的延迟等待：

private async Task OnStoppingAsync()
{
    _logger.LogInformation("OnStopping has been called.");
    _logger.LogInformation("SIGTERM received, waiting for 30 seconds");
    await Task.Delay(30000);
    _logger.LogInformation("Termination delay complete, continuing stopping process");
}

// 在StartAsync中注册异步委托
public Task StartAsync(CancellationToken cancellationToken)
{
    _logger.LogInformation("StartAsync has been called.");
    _appLifetime.ApplicationStarted.Register(OnStarted);
    _appLifetime.ApplicationStopping.Register(async () => await OnStoppingAsync());
    _appLifetime.ApplicationStopped.Register(OnStopped);

    return Task.CompletedTask;
}

5. 测试验证 #

先在本地Docker环境测试，避免K8s的干扰：

1. 启动容器：docker run -d --name test-app your-image
2. 发送SIGTERM信号：docker exec test-app kill -SIGTERM 1
3. 查看日志：docker logs test-app，检查是否输出OnStopping的日志。

如果本地测试正常，再去K8s环境验证配置是否正确。

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