ASP.NET Core Web API与Worker Service联动及DbContext访问问题咨询

核心问题分析 #

Worker Service默认是Singleton生命周期，而DbContext默认采用Scoped生命周期，直接注入会导致生命周期不匹配；另外你用AddScoped注册的服务，在Singleton的Worker中无法直接获取——因为Scoped服务依赖请求上下文，而Worker不存在请求管道。

具体实现步骤 #

1. 抽离共享服务配置 #

把DbContext和需要共享的业务服务，抽离到公共的服务扩展类（或单独类库），避免重复注册逻辑：

// 公共扩展类：ServiceCollectionExtensions.cs
public static class ServiceCollectionExtensions
{
    public static IServiceCollection AddSharedServices(this IServiceCollection services, IConfiguration config)
    {
        // 注册DbContext，保持Scoped生命周期
        services.AddDbContext<AppDbContext>(options =>
            options.UseSqlServer(config.GetConnectionString("DefaultConnection")));
        
        // 注册共享业务服务，可根据需求选Scoped/Transient
        services.AddScoped<IYourBusinessService, YourBusinessService>();
        
        return services;
    }
}

2. 在Web API和Worker中分别注册共享服务 #

• Web API的Program.cs：

var builder = WebApplication.CreateBuilder(args);
// 注册共享服务
builder.Services.AddSharedServices(builder.Configuration);
// 注册Identity Server及Web API相关服务
builder.Services.AddIdentityServer()
    .AddAspNetIdentity<ApplicationUser>()
    .AddConfigurationStore(options =>
    {
        options.ConfigureDbContext = b => b.UseSqlServer(builder.Configuration.GetConnectionString("DefaultConnection"));
    })
    .AddOperationalStore(options =>
    {
        options.ConfigureDbContext = b => b.UseSqlServer(builder.Configuration.GetConnectionString("DefaultConnection"));
    });
// 其他Web API配置...

• Worker Service的Program.cs：

var host = Host.CreateDefaultBuilder(args)
    .ConfigureServices((context, services) =>
    {
        // 注册共享服务
        services.AddSharedServices(context.Configuration);
        // 注册Worker（默认Singleton）
        services.AddHostedService<YourWorker>();
    })
    .Build();

host.Run();

3. 在Worker中正确获取Scoped服务 #

通过IServiceScopeFactory创建临时作用域，在作用域内获取Scoped的DbContext或服务，用完自动释放：

public class YourWorker : BackgroundService
{
    private readonly IServiceScopeFactory _scopeFactory;
    private readonly ILogger<YourWorker> _logger;

    public YourWorker(IServiceScopeFactory scopeFactory, ILogger<YourWorker> logger)
    {
        _scopeFactory = scopeFactory;
        _logger = logger;
    }

    protected override async Task ExecuteAsync(CancellationToken stoppingToken)
    {
        while (!stoppingToken.IsCancellationRequested)
        {
            // 创建临时作用域
            using var scope = _scopeFactory.CreateScope();
            var dbContext = scope.ServiceProvider.GetRequiredService<AppDbContext>();
            var businessService = scope.ServiceProvider.GetRequiredService<IYourBusinessService>();

            // 执行业务逻辑示例
            var dataCount = await dbContext.YourEntities.CountAsync(stoppingToken);
            _logger.LogInformation("Worker processed data at: {Time}, Count: {Count}", DateTimeOffset.Now, dataCount);

            await Task.Delay(5000, stoppingToken);
        }
    }
}

4. 统一数据库连接配置 #

确保Web API和Worker的appsettings.json中使用相同的ConnectionString，或通过环境变量统一配置，避免连接不一致问题。

额外注意事项 #

• 禁止在Worker中持有Scoped服务的长期引用，必须每次操作都创建新作用域。
• 如果Worker需要访问Identity Server的配置数据，需将ConfigurationDbContext也加入共享服务注册，同样通过作用域获取。

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