.NET Core WebAPI中间件如何处理浏览器发起的请求取消？

首先明确：中间件无法直接终止关联任务，核心原因是业务代码未正确监听请求取消令牌（RequestAborted），导致请求取消时不会抛出OperationCanceledException，自然无法被中间件捕获。以下是具体解决步骤：

1. 让业务代码响应取消令牌 #

所有异步业务/仓储方法必须接收并使用CancellationToken（从HttpContext.RequestAborted获取），确保请求取消时能触发异常。

示例：仓储层方法 #

public async Task<Entity> GetEntityAsync(int id, CancellationToken cancellationToken)
{
    // 耗时操作绑定取消令牌，取消时直接抛出OperationCanceledException
    await Task.Delay(3000, cancellationToken);
    
    // 主动检查取消状态（适用于同步逻辑或无法绑定令牌的操作）
    cancellationToken.ThrowIfCancellationRequested();
    
    // 业务逻辑
    return await _dbContext.Entities.FindAsync(id, cancellationToken);
}

示例：控制器传递令牌 #

[HttpGet("{id}")]
public async Task<IActionResult> Get(int id)
{
    // 将HttpContext的取消令牌传入业务方法
    var entity = await _repository.GetEntityAsync(id, HttpContext.RequestAborted);
    return Ok(entity);
}

2. 优化中间件捕获异常 #

框架有时会将OperationCanceledException包装在AggregateException中，需同时处理两种情况：

public async Task Invoke(HttpContext context)
{
    try
    {    
        await _next(context);
    }
    catch (OperationCanceledException)
    {
        // 处理请求取消：记录日志、返回自定义状态码（如499 Client Closed Request）
        context.Response.StatusCode = StatusCodes.Status499ClientClosedRequest;
    }
    catch (AggregateException ex) when (ex.InnerException is OperationCanceledException)
    {
        // 处理包装在聚合异常中的取消请求
        context.Response.StatusCode = StatusCodes.Status499ClientClosedRequest;
    }
}

3. 简化令牌传递（可选） #

若不想在每个方法手动传令牌，可通过IHttpContextAccessor封装全局检查逻辑：

步骤1：注册IHttpContextAccessor #

在Program.cs中添加：

builder.Services.AddHttpContextAccessor();

步骤2：封装基类 #

public abstract class BaseService
{
    private readonly IHttpContextAccessor _httpContextAccessor;
    protected CancellationToken CancelToken => _httpContextAccessor.HttpContext?.RequestAborted ?? CancellationToken.None;

    public BaseService(IHttpContextAccessor httpContextAccessor)
    {
        _httpContextAccessor = httpContextAccessor;
    }

    protected void CheckCancellation() => CancelToken.ThrowIfCancellationRequested();
}

步骤3：业务类继承使用 #

public class OrderService : BaseService
{
    public OrderService(IHttpContextAccessor httpContextAccessor) : base(httpContextAccessor) { }

    public async Task ProcessOrderAsync()
    {
        await Task.Delay(2000);
        CheckCancellation(); // 自动检查请求是否取消
        // 后续业务逻辑
    }
}

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