0

0

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

月夜之吻

月夜之吻

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

|

675人浏览过

|

来源于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<MyBackgroundWorker>();
<p>var app = builder.Build();
app.MapGet("/health", () => "ok");</p><p>// 注册停机钩子
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);
});
});</p><p>await app.RunAsync();

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

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

银河易创
银河易创

一站式AIGC创作平台,集成GPT-3.5、GPT-4、文心一言等对话模型、Midjourney、DallE等绘画工具、AI音乐、AI视频和AI PPT等功能!

下载
  • 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<MyBackgroundWorker> _logger;
<pre class='brush:php;toolbar:false;'>public MyBackgroundWorker(ILogger<MyBackgroundWorker> 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);
}

}

容易被忽略的三个破坏点

哪怕代码写了 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); }) 还在跑 —— 它完全脱离取消体系,只能靠超时强杀。

热门AI工具

更多
DeepSeek
DeepSeek

幻方量化公司旗下的开源大模型平台

豆包大模型
豆包大模型

字节跳动自主研发的一系列大型语言模型

通义千问
通义千问

阿里巴巴推出的全能AI助手

腾讯元宝
腾讯元宝

腾讯混元平台推出的AI助手

文心一言
文心一言

文心一言是百度开发的AI聊天机器人,通过对话可以生成各种形式的内容。

讯飞写作
讯飞写作

基于讯飞星火大模型的AI写作工具,可以快速生成新闻稿件、品宣文案、工作总结、心得体会等各种文文稿

即梦AI
即梦AI

一站式AI创作平台,免费AI图片和视频生成。

ChatGPT
ChatGPT

最最强大的AI聊天机器人程序,ChatGPT不单是聊天机器人,还能进行撰写邮件、视频脚本、文案、翻译、代码等任务。

相关专题

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

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

207

2024.02.23

Java 消息队列与异步架构实战
Java 消息队列与异步架构实战

本专题系统讲解 Java 在消息队列与异步系统架构中的核心应用,涵盖消息队列基本原理、Kafka 与 RabbitMQ 的使用场景对比、生产者与消费者模型、消息可靠性与顺序性保障、重复消费与幂等处理,以及在高并发系统中的异步解耦设计。通过实战案例,帮助学习者掌握 使用 Java 构建高吞吐、高可靠异步消息系统的完整思路。

48

2026.01.28

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

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

182

2024.05.11

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

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

226

2025.12.18

登录token无效
登录token无效

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

6606

2023.09.14

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

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

842

2023.09.14

token怎么获取
token怎么获取

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

1092

2023.12.21

token什么意思
token什么意思

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

2106

2024.03.01

C# ASP.NET Core微服务架构与API网关实践
C# ASP.NET Core微服务架构与API网关实践

本专题围绕 C# 在现代后端架构中的微服务实践展开,系统讲解基于 ASP.NET Core 构建可扩展服务体系的核心方法。内容涵盖服务拆分策略、RESTful API 设计、服务间通信、API 网关统一入口管理以及服务治理机制。通过真实项目案例,帮助开发者掌握构建高可用微服务系统的关键技术,提高系统的可扩展性与维护效率。

3

2026.03.11

热门下载

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

精品课程

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

共6课时 | 0.4万人学习

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

共72课时 | 7.1万人学习

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

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