解决.NET Core 8 Web API中Service Bus泛型消费者的IServiceProvider释放问题

核心原因 #

HostedService默认是单例生命周期，若直接在HostedService中创建短暂/作用域级别的IServiceProvider，当HostedService初始化逻辑完成后，该作用域可能被释放，导致后续EventProcessor调用时依赖失效。另外，若EventProcessorFactory未与容器正确绑定生命周期，也会引发注入服务被提前释放的问题。

具体解决方案 #

1. 用IServiceScopeFactory创建独立作用域 #

避免直接注入IServiceProvider，改用IServiceScopeFactory，每次处理事件时创建独立作用域，确保服务实例有效：

public class ServiceBusConsumerBase<T>
{
    private readonly IServiceScopeFactory _scopeFactory;

    public ServiceBusConsumerBase(IServiceScopeFactory scopeFactory)
    {
        _scopeFactory = scopeFactory;
    }

    private IEventProcessorStrategy<T> GetEventProcessorStrategy()
    {
        using var scope = _scopeFactory.CreateScope();
        return scope.ServiceProvider.GetRequiredService<IEventProcessorStrategy<T>>();
    }
}

2. 正确配置EventProcessorFactory的生命周期 #

将自定义EventProcessorFactory注册为单例，内部通过IServiceScopeFactory创建作用域，而非直接持有IServiceProvider：

// 注册工厂
services.AddSingleton<IEventProcessorFactory, CustomEventProcessorFactory>();

public class CustomEventProcessorFactory : IEventProcessorFactory
{
    private readonly IServiceScopeFactory _scopeFactory;

    public CustomEventProcessorFactory(IServiceScopeFactory scopeFactory)
    {
        _scopeFactory = scopeFactory;
    }

    public IEventProcessor CreateEventProcessor(PartitionContext context)
    {
        using var scope = _scopeFactory.CreateScope();
        return scope.ServiceProvider.GetRequiredService<YourEventProcessor>();
    }
}

3. 调整HostedService逻辑，避免提前释放作用域 #

在PostConsumerHostedService中，不要在启动方法中创建一次性作用域并持有其IServiceProvider，直接注入IServiceScopeFactory来获取所需服务：

public class PostConsumerHostedService : IHostedService
{
    private readonly IServiceScopeFactory _scopeFactory;
    private Task _consumerTask;

    public PostConsumerHostedService(IServiceScopeFactory scopeFactory)
    {
        _scopeFactory = scopeFactory;
    }

    public Task StartAsync(CancellationToken cancellationToken)
    {
        using var scope = _scopeFactory.CreateScope();
        var consumerTaskService = scope.ServiceProvider.GetRequiredService<PostConsumerTaskService>();
        _consumerTask = consumerTaskService.StartConsumingAsync(cancellationToken);
        return Task.CompletedTask;
    }

    public async Task StopAsync(CancellationToken cancellationToken)
    {
        if (_consumerTask != null)
        {
            await _consumerTask;
        }
    }
}

4. 验证服务注册的生命周期 #

根据业务需求配置IEventProcessorStrategy<T>的生命周期：若每个事件处理需新实例，注册为瞬态；若可复用且线程安全，注册为单例：

// 瞬态注册示例
services.AddTransient<IEventProcessorStrategy<PostEvent>, PostEventProcessorStrategy>();

错误排查要点 #

• 检查代码中是否直接持有IServiceProvider引用，未通过作用域获取服务
• 确认HostedService中创建的作用域是否在消费任务启动后被提前释放
• 验证EventProcessor的创建逻辑是否每次都使用了有效作用域

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