使用BackgroundService订阅Azure Event Hub时，如何正确检测CancellationToken触发？

你的核心问题是：BackgroundService的ExecuteAsync方法在启动EventProcessorClient后会直接返回，导致服务被判定为执行完成而停止。你看到的while (!stoppingToken.IsCancellationRequested)循环，本质是用来让ExecuteAsync保持运行状态，但空循环会浪费CPU资源，并非最优解。

正确实现方式 #

EventProcessorClient.StartProcessingAsync是非阻塞方法，它会在后台启动事件处理逻辑。我们需要让ExecuteAsync持续处于等待状态直到收到取消信号，同时在取消时正确停止处理器并释放资源，而非使用空循环。

修改后的完整代码如下：

public class EventConsumerService : BackgroundService
{
    private const string connectionString = "<event_hub_connection_string>";
    private const string eventHubName = "<event_hub_name>";
    private const string blobStorageConnectionString = "<blob_connection_string>";
    private const string blobContainerName = "<container_name>";

    private EventProcessorClient _processor;

    protected override async Task ExecuteAsync(CancellationToken stoppingToken)
    {
        string consumerGroup = EventHubConsumerClient.DefaultConsumerGroupName;

        // 创建Blob容器客户端，用于处理器的 checkpoint 存储
        BlobContainerClient storageClient = new BlobContainerClient(blobStorageConnectionString, blobContainerName);

        // 初始化事件处理器客户端
        _processor = new EventProcessorClient(storageClient, consumerGroup, connectionString, eventHubName);

        // 注册事件处理和错误处理回调
        _processor.ProcessEventAsync += ProcessEventHandler;
        _processor.ProcessErrorAsync += ProcessErrorHandler;

        try
        {
            // 启动事件处理
            await _processor.StartProcessingAsync(stoppingToken);

            // 等待取消信号，避免ExecuteAsync返回导致服务停止
            // 使用Task.Delay无限等待，直到取消令牌触发
            await Task.Delay(Timeout.Infinite, stoppingToken);
        }
        catch (TaskCanceledException)
        {
            // 取消信号触发，属于正常退出流程
        }
        finally
        {
            // 确保处理器正确停止，释放资源
            if (_processor != null)
            {
                await _processor.StopProcessingAsync(stoppingToken);
                // 注销回调，避免内存泄漏
                _processor.ProcessEventAsync -= ProcessEventHandler;
                _processor.ProcessErrorAsync -= ProcessErrorHandler;
            }
        }
    }

    static async Task ProcessEventHandler(ProcessEventArgs eventArgs)
    {
        // 处理收到的事件
        Console.WriteLine("	Received event: {0}", Encoding.UTF8.GetString(eventArgs.Data.Body.ToArray()));

        // 更新checkpoint，记录已处理的位置
        await eventArgs.UpdateCheckpointAsync(eventArgs.CancellationToken);
    }

    static Task ProcessErrorHandler(ProcessErrorEventArgs eventArgs)
    {
        // 处理错误
        Console.WriteLine("Error occurred: {0}", eventArgs.Exception.Message);
        return Task.CompletedTask;
    }
}

关键说明 #

1. 替代空循环：用await Task.Delay(Timeout.Infinite, stoppingToken)代替空循环，它会在等待时释放线程资源，直到取消令牌触发，不会占用额外CPU。
2. 资源清理：在finally块中调用StopProcessingAsync，确保处理器正常停止，并注销事件回调，防止内存泄漏。
3. 取消异常处理：捕获TaskCanceledException是因为Task.Delay在取消时会抛出该异常，属于正常流程，无需额外处理。

如果一定要用while循环（不推荐），需添加延迟避免CPU空转：

while (!stoppingToken.IsCancellationRequested)
{
    // 添加1秒延迟，减少CPU占用
    await Task.Delay(1000, stoppingToken);
}

但这种方式不如直接等待取消信号优雅，优先推荐Task.Delay无限等待的方案。

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