ASP.NET Core单例后台服务安全访问DbContext的最佳实践

问题背景 #

我有一个ASP.NET Core 8应用，包含一个长时运行的后台服务，通过定时器刷新内存缓存。该服务以单例模式注册（托管后台工作者），需要定期查询数据库。直接在服务构造函数中注入AppDbContext时，会抛出以下错误：

InvalidOperationException: Cannot consume scoped service 'AppDbContext' from singleton 'MyCacheService'.

错误示例代码 #

Program.cs

builder.Services.AddDbContext<AppDbContext>(options =>
    options.UseSqlServer(builder.Configuration.GetConnectionString("Default")));

builder.Services.AddHostedService<MyCacheService>(); // MyCacheService是长时单例服务

MyCacheService.cs

public class MyCacheService : BackgroundService
{
    private readonly AppDbContext _db; // 将作用域DbContext注入单例服务

    public MyCacheService(AppDbContext db)
    {
        _db = db; // 启动时触发InvalidOperationException
    }

    protected override async Task ExecuteAsync(CancellationToken stoppingToken)
    {
        while (!stoppingToken.IsCancellationRequested)
        {
            var items = await _db.Items.ToListAsync(stoppingToken);
            // 刷新缓存...
            await Task.Delay(TimeSpan.FromMinutes(1), stoppingToken);
        }
    }
}

已知异常由生命周期不匹配导致，且无法将后台服务改为作用域模式，需找到符合生产环境要求的正确实现方式。

推荐方案：使用IDbContextFactory<T> #

这是EF Core官方推荐的用于后台任务、单例服务等场景获取DbContext的方案，能彻底避免生命周期冲突，同时保证DbContext的正确创建与释放。

实现步骤 #

1. 注册DbContext工厂
   在Program.cs中使用AddDbContextFactory注册工厂：

// Program.cs
builder.Services.AddDbContextFactory<AppDbContext>(options =>
    options.UseSqlServer(builder.Configuration.GetConnectionString("Default")));

builder.Services.AddHostedService<MyCacheService>();

2. 在后台服务中注入并使用工厂

public class MyCacheService : BackgroundService
{
    private readonly IDbContextFactory<AppDbContext> _dbContextFactory;

    public MyCacheService(IDbContextFactory<AppDbContext> dbContextFactory)
    {
        _dbContextFactory = dbContextFactory;
    }

    protected override async Task ExecuteAsync(CancellationToken stoppingToken)
    {
        while (!stoppingToken.IsCancellationRequested)
        {
            // 每次查询创建独立的DbContext实例，using自动释放资源
            using var db = _dbContextFactory.CreateDbContext();
            var items = await db.Items.ToListAsync(stoppingToken);
            
            // 刷新缓存逻辑...
            
            await Task.Delay(TimeSpan.FromMinutes(1), stoppingToken);
        }
    }
}

备选方案：使用IServiceScopeFactory手动创建作用域 #

如果需要同时使用多个作用域服务（不止DbContext），可以通过创建作用域来获取所需服务：

实现示例 #

public class MyCacheService : BackgroundService
{
    private readonly IServiceScopeFactory _scopeFactory;

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

    protected override async Task ExecuteAsync(CancellationToken stoppingToken)
    {
        while (!stoppingToken.IsCancellationRequested)
        {
            // 创建作用域，using自动释放作用域内所有服务
            using var scope = _scopeFactory.CreateScope();
            var db = scope.ServiceProvider.GetRequiredService<AppDbContext>();
            
            var items = await db.Items.ToListAsync(stoppingToken);
            // 刷新缓存...
            
            await Task.Delay(TimeSpan.FromMinutes(1), stoppingToken);
        }
    }
}

关键注意事项 #

• 资源释放：必须用using语句包裹DbContext或作用域，确保每次操作后及时释放资源，避免数据库连接池耗尽。
• 线程安全：DbContext本身不是线程安全的，每个操作必须使用独立实例，禁止在多线程或循环迭代中复用同一个DbContext。
• 并发控制：如果后台任务的执行时间可能超过定时器间隔，需添加锁或其他并发控制机制，避免同时创建过多DbContext实例导致数据库压力过大。
• 取消令牌传递：所有异步数据库操作都要传入stoppingToken，确保应用关闭时能及时终止正在执行的操作，避免资源泄漏。

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