0

0

c# 在高并发服务中,如何做优雅停机(Graceful Shutdown)

月夜之吻

月夜之吻

发布时间:2026-01-18 13:08:02

|

655人浏览过

|

来源于php中文网

原创

GracefulShutdown 是指等待处理中请求完成、拒绝新请求、释放资源后再退出;ASP.NET Core 通过 IHostApplicationLifetime.ApplicationStopping 令牌协调,BackgroundService 需正确传递并响应 CancellationToken,清理操作必须异步且可控。

c# 在高并发服务中,如何做优雅停机(graceful shutdown)

什么是 GracefulShutdown 在 C# 服务中的真实含义

它不是简单调用 Environment.Exit() 或杀进程,而是:等正在处理的请求完成、拒绝新请求、释放资源(如数据库连接、HttpClient 实例、后台任务)、再退出。在 ASP.NET Core 中,这由 IHostApplicationLifetimeIHostedService 协同控制;在裸 BackgroundService 或自托管场景中,需手动监听取消信号。

ASP.NET Core Web API 如何注册优雅停机逻辑

核心是利用 IHostApplicationLifetimeApplicationStopping 取消令牌,在其触发时做清理,同时确保中间件/控制器不接收新请求。关键点在于:HTTP 服务器(Kestrel)默认已支持 graceful shutdown,但你的业务逻辑必须响应取消信号。

  • Program.cs 中注入 IHostApplicationLifetime,并在 ApplicationStopping 回调里执行耗时清理(如等待队列清空、关闭长连接)
  • 所有异步操作(如 await dbContext.SaveChangesAsync()await httpClient.PostAsync())必须传入 ApplicationStopping.Token
  • 避免在 ApplicationStopping 中阻塞主线程(如用 .Wait()),应 await 异步清理
  • Kestrel 默认有 5 秒超时(可通过 WebHostOptions.ShutdownTimeout 调整),超时后强制终止 —— 所以清理逻辑务必可控
var builder = WebApplication.CreateBuilder(args);
builder.Services.AddHostedService();

var app = builder.Build(); app.MapGet("/health", () => "ok");

// 注册停机钩子 app.Lifetime.ApplicationStopping.Register(() => { Console.WriteLine("Shutting down gracefully..."); // 这里可 await,但注意:ApplicationStopping.Token 已触发,不可再用于新操作 // 推荐把清理逻辑封装进 async 方法,并用 Task.Run + await 配合 Token _ = Task.Run(async () => { await MyCleanupAsync(app.Lifetime.ApplicationStopping.Token); }); });

await app.RunAsync();

BackgroundService 中如何正确响应停机信号

BackgroundService 本身已内置对 CancellationToken 的支持,但常见错误是忽略 StopAsync 的超时约束或未取消内部循环。

  • ExecuteAsync 必须接收并传递 cancellationToken 给所有 await 操作
  • StopAsync 中不能只调用 cts.Cancel() 就结束,要 await 等待工作真正退出(比如等待队列消费完毕)
  • 若内部使用 Task.Delay(1000, token) 做轮询,必须确保 token 来自 stoppingToken,而非新创建的 CancellationTokenSource
  • 不要在 StopAsync 中执行同步 I/O(如写文件、发 HTTP),除非加超时保护,否则可能拖垮整个停机流程
public class MyBackgroundWorker : BackgroundService
{
    private readonly ILogger _logger;
public MyBackgroundWorker(ILoggerzuojiankuohaophpcnMyBackgroundWorkeryoujiankuohaophpcn logger)
{
    _logger = logger;
}

protected override async Task ExecuteAsync(CancellationToken stoppingToken)
{
    while (!stoppingToken.IsCancellationRequested)
    {
        try
        {
            await DoWorkAsync(stoppingToken);
            await Task.Delay(5000, stoppingToken); // 注意:token 来自 ExecuteAsync 参数
        }
        catch (OperationCanceledException)
        {
            break;
        }
        catch (Exception ex)
        {
            _logger.LogError(ex, "Error in background worker");
        }
    }
}

private async Task DoWorkAsync(CancellationToken ct)
{
    // 所有 await 必须传入 ct
    await _httpClient.GetAsync("https://api.example.com/health", ct);
}

public override async Task StopAsync(CancellationToken stoppingToken)
{
    _logger.LogInformation("Stopping background worker...");
    // 等待当前轮次完成,但不超过 stoppingToken 超时
    await base.StopAsync(stoppingToken);
}

}

Replit Agent
Replit Agent

Replit最新推出的AI编程工具,可以帮助用户从零开始自动构建应用程序。

下载

容易被忽略的三个破坏点

哪怕代码写了 await ... CancellationToken,仍可能因以下原因导致“假优雅”:

  • HttpClient 实例未复用且未设置 Timeout:单次请求卡死会阻塞整个停机流程;建议统一用 IHttpClientFactory 并配置 DefaultRequestTimeout
  • 数据库连接池未释放:EF Core 的 SaveChangesAsync 若没传 token,可能永远挂住;DbContext 应注册为 Scoped,并在 StopAsync 后显式调用 DisposeAsync()
  • 第三方 SDK(如 Redis client、RabbitMQ consumer)未提供 cancellation 支持:必须查阅文档确认其 StopAsync 是否真正等待消息 ACK 完成,否则可能丢消息

最危险的是:你以为停机成功了,其实某个 Task.Run(() => { Thread.Sleep(30000); }) 还在跑 —— 它完全脱离取消体系,只能靠超时强杀。

相关专题

更多
rabbitmq和kafka有什么区别
rabbitmq和kafka有什么区别

rabbitmq和kafka的区别:1、语言与平台;2、消息传递模型;3、可靠性;4、性能与吞吐量;5、集群与负载均衡;6、消费模型;7、用途与场景;8、社区与生态系统;9、监控与管理;10、其他特性。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

201

2024.02.23

什么是中间件
什么是中间件

中间件是一种软件组件,充当不兼容组件之间的桥梁,提供额外服务,例如集成异构系统、提供常用服务、提高应用程序性能,以及简化应用程序开发。想了解更多中间件的相关内容,可以阅读本专题下面的文章。

178

2024.05.11

Golang 中间件开发与微服务架构
Golang 中间件开发与微服务架构

本专题系统讲解 Golang 在微服务架构中的中间件开发,包括日志处理、限流与熔断、认证与授权、服务监控、API 网关设计等常见中间件功能的实现。通过实战项目,帮助开发者理解如何使用 Go 编写高效、可扩展的中间件组件,并在微服务环境中进行灵活部署与管理。

212

2025.12.18

登录token无效
登录token无效

登录token无效解决方法:1、检查token的有效期限,如果token已经过期,需要重新获取一个新的token;2、检查token的签名,如果签名不正确,需要重新获取一个新的token;3、检查密钥的正确性,如果密钥不正确,需要重新获取一个新的token;4、使用HTTPS协议传输token,建议使用HTTPS协议进行传输 ;5、使用双因素认证,双因素认证可以提高账户的安全性。

6095

2023.09.14

登录token无效怎么办
登录token无效怎么办

登录token无效的解决办法有检查Token是否过期、检查Token是否正确、检查Token是否被篡改、检查Token是否与用户匹配、清除缓存或Cookie、检查网络连接和服务器状态、重新登录或请求新的Token、联系技术支持或开发人员等。本专题为大家提供token相关的文章、下载、课程内容,供大家免费下载体验。

806

2023.09.14

token怎么获取
token怎么获取

获取token值的方法:1、小程序调用“wx.login()”获取 临时登录凭证code,并回传到开发者服务器;2、开发者服务器以code换取,用户唯一标识openid和会话密钥“session_key”。想了解更详细的内容,可以阅读本专题下面的文章。

1062

2023.12.21

token什么意思
token什么意思

token是一种用于表示用户权限、记录交易信息、支付虚拟货币的数字货币。可以用来在特定的网络上进行交易,用来购买或出售特定的虚拟货币,也可以用来支付特定的服务费用。想了解更多token什么意思的相关内容可以访问本专题下面的文章。

1245

2024.03.01

线程和进程的区别
线程和进程的区别

线程和进程的区别:线程是进程的一部分,用于实现并发和并行操作,而线程共享进程的资源,通信更方便快捷,切换开销较小。本专题为大家提供线程和进程区别相关的各种文章、以及下载和课程。

481

2023.08.10

高德地图升级方法汇总
高德地图升级方法汇总

本专题整合了高德地图升级相关教程,阅读专题下面的文章了解更多详细内容。

43

2026.01.16

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
进程与SOCKET
进程与SOCKET

共6课时 | 0.3万人学习

Redis+MySQL数据库面试教程
Redis+MySQL数据库面试教程

共72课时 | 6.4万人学习

关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号 技术交流群
PHP中文网订阅号
每天精选资源文章推送

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号