如何创建可长期复用的DBContext以支持后台线程数据库访问

首先明确：不要创建“永久”DbContext。DbContext的设计定位是短生命周期对象，长时间持有会导致内存泄漏、实体跟踪缓存堆积、数据一致性问题等。正确的做法是在后台任务每次需要访问数据库时，创建独立的短生命周期DbContext实例，或通过依赖注入的范围服务获取。

推荐方案：依赖注入+范围服务（符合.NET最佳实践） #

默认情况下，AddDbContext会将DataContext注册为Scoped生命周期（请求级），在后台任务中可以通过IServiceProvider创建临时服务范围，从中获取DbContext，使用完毕后自动释放。

1. 注册服务（Program.cs） #

var builder = WebApplication.CreateBuilder(args);

// 注册DbContext（默认Scoped）
builder.Services.AddDbContext<DataContext>();
// 注册后台定时任务
builder.Services.AddHostedService<ScheduleReminderService>();

var app = builder.Build();
// ... 其他中间件配置
app.Run();

2. 实现后台定时任务 #

using Microsoft.Extensions.Hosting;
using Microsoft.Extensions.Logging;
using Microsoft.Extensions.DependencyInjection;

public class ScheduleReminderService : BackgroundService
{
    private readonly IServiceProvider _serviceProvider;
    private readonly ILogger<ScheduleReminderService> _logger;

    public ScheduleReminderService(IServiceProvider serviceProvider, ILogger<ScheduleReminderService> logger)
    {
        _serviceProvider = serviceProvider;
        _logger = logger;
    }

    protected override async Task ExecuteAsync(CancellationToken stoppingToken)
    {
        // 每小时执行一次任务
        using var timer = new PeriodicTimer(TimeSpan.FromHours(1));
        
        while (await timer.WaitForNextTickAsync(stoppingToken) && !stoppingToken.IsCancellationRequested)
        {
            try
            {
                // 创建临时服务范围，获取DbContext
                using var scope = _serviceProvider.CreateScope();
                var dbContext = scope.ServiceProvider.GetRequiredService<DataContext>();

                // 查询剩余时间不足3小时的未提醒日程
                var now = DateTime.UtcNow;
                var targetSchedules = await dbContext.Schedules
                    .Include(s => s.Account) // 关联用户信息用于发邮件
                    .Where(s => s.StartTime - now <= TimeSpan.FromHours(3) 
                                && s.StartTime > now
                                && !s.ReminderSent) // 假设字段标记是否已发送提醒
                    .ToListAsync(stoppingToken);

                // 批量处理提醒
                foreach (var schedule in targetSchedules)
                {
                    // 替换为实际发邮件逻辑
                    _logger.LogInformation("向用户 {Email} 发送日程提醒：{ScheduleTitle}", schedule.Account.Email, schedule.Title);
                    // 标记已发送，避免重复提醒
                    schedule.ReminderSent = true;
                }

                await dbContext.SaveChangesAsync(stoppingToken);
            }
            catch (Exception ex)
            {
                _logger.LogError(ex, "日程提醒任务执行失败");
            }
        }
    }
}

备选方案：直接实例化DbContext（不推荐，但可应急） #

如果无法使用依赖注入的范围服务，可以在需要时直接创建DataContext实例，使用后手动释放：

public class ScheduleReminderService : BackgroundService
{
    private readonly IConfiguration _configuration;
    private readonly ILogger<ScheduleReminderService> _logger;

    public ScheduleReminderService(IConfiguration configuration, ILogger<ScheduleReminderService> logger)
    {
        _configuration = configuration;
        _logger = logger;
    }

    protected override async Task ExecuteAsync(CancellationToken stoppingToken)
    {
        using var timer = new PeriodicTimer(TimeSpan.FromHours(1));
        while (await timer.WaitForNextTickAsync(stoppingToken))
        {
            try
            {
                // 每次任务执行时创建新的DbContext
                using var dbContext = new DataContext(_configuration);
                // ... 执行查询、发邮件、保存更改逻辑
            }
            catch (Exception ex)
            {
                _logger.LogError(ex, "任务执行出错");
            }
        }
    }
}

关键注意事项 #

1. SQLite并发问题：SQLite是文件型数据库，需在连接字符串中添加Cache=Shared避免多线程访问锁冲突：

   "ConnectionStrings": {
       "WebApiDatabase": "Data Source=webapi.db;Cache=Shared"
   }
   

2. 异常处理：后台任务必须捕获异常，避免单次执行失败导致整个任务终止。
3. 避免长期持有：无论哪种方式，都要确保DbContext使用后被及时释放（通过using语句）。

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