ASP.NET Core SignalR服务端Hub中AggregateException捕获方案咨询

问题根源 #

你遇到的AggregateException是因为客户端取消流后，底层ChannelReader关联的任务异常未被正确观察，最终在终结器线程被重新抛出。外层try-catch未捕获到异常，是因为await foreach处理IAsyncEnumerable时，部分异常会在枚举完成后才暴露，超出了当前捕获逻辑的覆盖范围。

具体修复方案 #

1. 手动控制枚举器生命周期，覆盖全流程异常 #

通过手动获取异步枚举器并管理其生命周期，确保枚举过程中所有阶段的异常都能被捕获：

public async Task MetricsStream(IAsyncEnumerable<ReadPointMetrics> stream)
{
    // 绑定SignalR请求的取消令牌，和客户端取消行为联动
    await using var enumerator = stream.GetAsyncEnumerator(Context.RequestAborted);
    try
    {
        while (await enumerator.MoveNextAsync())
        {
            var metrics = enumerator.Current;
            try
            {
                await readerDeviceHub.StoreMetrics(readerId, metrics);
            }
            catch (Exception e)
            {
                log?.Error(e, "存储指标时出错");
            }
        }
    }
    catch (Exception e)
    {
        // 区分客户端主动取消和其他异常
        if (e is OperationCanceledException && Context.RequestAborted.IsCancellationRequested)
        {
            log?.Information("客户端取消了指标流");
        }
        else
        {
            log?.Warning(e, "指标流处理异常");
        }
    }
}

这种方式替代了await foreach的默认逻辑，能直接捕获MoveNextAsync过程中抛出的客户端取消异常，避免异常成为未观察任务。

2. 全局兜底处理未观察任务异常 #

如果仍存在漏网的未观察任务异常，可以在应用启动时注册全局处理逻辑，防止异常在终结器线程抛出：

// 在Program.cs中添加
TaskScheduler.UnobservedTaskException += (sender, e) =>
{
    log.LogError(e.Exception, "未观察到的任务异常");
    e.SetObserved(); // 标记异常已处理，阻止终结器线程重抛
};

3. 优化SignalR流式配置 #

调整SignalR的流式传输参数，减少因超时、缓冲区溢出导致的隐式取消：

// 在Program.cs配置SignalR时
builder.Services.AddSignalR(options =>
{
    options.StreamBufferCapacity = 100; // 根据业务场景调整缓冲区大小
    options.ClientTimeoutInterval = TimeSpan.FromMinutes(5);
});

关键说明 #

• 客户端主动取消流属于正常业务场景，建议单独捕获OperationCanceledException并记录为信息日志，而非错误级别。
• 手动管理枚举器的IAsyncDisposable生命周期，能覆盖await foreach默认逻辑未处理的异常场景。

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