如何在BackgroundService（IHostedService）中实例化DbContext

为什么不能直接在构造函数中注入DbContext #

BackgroundService是Singleton生命周期（与应用进程同寿命），而默认的DbContext是Scoped生命周期（每个请求/作用域创建一次）。如果直接在构造函数注入DbContext，会导致这个DbContext被Singleton服务长期持有，相当于永久处于打开状态，带来以下问题：

• 数据库连接长期占用，耗尽连接池
• DbContext的缓存和跟踪状态持续累积，引发数据不一致、内存泄漏
• 违背EF Core的设计最佳实践

推荐的两种实现方式 #

方式一：使用IServiceScopeFactory创建临时作用域 #

通过注入IServiceScopeFactory，每次需要操作数据库时创建独立作用域，在作用域内获取DbContext，用完自动释放。这种方式完全复用已有的DbContext配置（包括连接字符串），无需重复编写配置逻辑。

示例代码：

public class BackgroundTaskService : BackgroundService
{
    private readonly IServiceScopeFactory _scopeFactory;

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

    protected override async Task ExecuteAsync(CancellationToken stoppingToken)
    {
        while (!stoppingToken.IsCancellationRequested)
        {
            // 创建临时作用域
            using (var scope = _scopeFactory.CreateScope())
            {
                var dbContext = scope.ServiceProvider.GetRequiredService<YourDbContext>();
                
                // 执行队列检查逻辑
                var pendingItems = await dbContext.PendingQueueItems.ToListAsync(stoppingToken);
                foreach (var item in pendingItems)
                {
                    // 处理业务逻辑
                }

                await dbContext.SaveChangesAsync(stoppingToken);
            }

            // 间隔一段时间再检查，比如1分钟
            await Task.Delay(TimeSpan.FromMinutes(1), stoppingToken);
        }
    }
}

方式二：使用IDbContextFactory（EF Core 3.0+支持） #

EF Core提供IDbContextFactory<T>专门用于在非Scoped场景（如Singleton、控制台程序）创建DbContext实例。先在Program.cs中配置工厂：

builder.Services.AddDbContextFactory<YourDbContext>(options =>
    options.UseSqlServer(builder.Configuration.GetConnectionString("DefaultConnection")));

再在BackgroundService中注入工厂，按需创建DbContext：

public class BackgroundTaskService : BackgroundService
{
    private readonly IDbContextFactory<YourDbContext> _dbContextFactory;

    public BackgroundTaskService(IDbContextFactory<YourDbContext> dbContextFactory)
    {
        _dbContextFactory = dbContextFactory;
    }

    protected override async Task ExecuteAsync(CancellationToken stoppingToken)
    {
        while (!stoppingToken.IsCancellationRequested)
        {
            // 创建DbContext实例，用using自动释放
            using (var dbContext = _dbContextFactory.CreateDbContext())
            {
                var pendingItems = await dbContext.PendingQueueItems.ToListAsync(stoppingToken);
                // 处理队列逻辑...
                await dbContext.SaveChangesAsync(stoppingToken);
            }

            await Task.Delay(TimeSpan.FromMinutes(1), stoppingToken);
        }
    }
}

两种方式的对比 #

• IServiceScopeFactory：适合需要获取多个Scoped服务的场景，不局限于DbContext
• IDbContextFactory<T>：更专注于DbContext的创建，代码更简洁，是EF官方推荐的非Scoped场景方案

两种方式都无需重复编写连接字符串读取逻辑，配置已在Program.cs中完成，服务会自动复用这些配置。

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