ASP.NET Core 8中后台服务执行MediatR命令时命令处理程序依赖注入失效问题

我太懂你这个痛点了——明明把MediatR命令丢进后台任务队列了，Mediator本身能正常拿到，但命令处理程序里的依赖全是null，折腾半天找不到原因对吧？核心问题确实是作用域管理没做对，后台服务是单例生命周期，直接用根服务容器拿Scoped/Transient类型的依赖肯定会出问题。

下面给你一步步梳理正确的解决思路和代码实现：

1. 核心问题：后台任务必须创建独立作用域 #

后台任务队列的托管服务是单例的，如果你直接用根ServiceProvider获取服务，那些注册为Scoped（比如DbContext）或Transient的依赖要么无法正确解析，要么生命周期不匹配导致注入失败。所以必须在后台任务委托里创建一个独立的作用域，从作用域内获取所有需要的服务。

2. 修正后台任务的执行逻辑 #

把你原来的后台任务代码改成这样：

await _taskQueue.QueueBackgroundWorkItemAsync(async (serviceProvider, cancellationToken) => {
    // 关键：创建作用域，所有服务从作用域内获取
    using var scope = serviceProvider.CreateScope();
    var scopedProvider = scope.ServiceProvider;
    
    // 从作用域获取IMediator（别直接实例化Mediator，要依赖接口）
    var mediator = scopedProvider.GetRequiredService<IMediator>();
    
    // 执行命令时记得传入取消令牌
    await mediator.Send(new CollectAndZipDataCommand(), cancellationToken);
    await mediator.Send(new SendDownloadLinkPerMailCommand(), cancellationToken);
});

3. 确保后台任务队列与托管服务的实现正确 #

先检查你的任务队列和托管服务代码是否符合规范，这里给你一个标准实现：

任务队列接口与实现

public interface IBackgroundTaskQueue
{
    ValueTask QueueBackgroundWorkItemAsync(Func<IServiceProvider, CancellationToken, Task> workItem);
    ValueTask<Func<IServiceProvider, CancellationToken, Task>> DequeueAsync(CancellationToken cancellationToken);
}

public class BackgroundTaskQueue : IBackgroundTaskQueue
{
    private readonly Channel<Func<IServiceProvider, CancellationToken, Task>> _queue;

    public BackgroundTaskQueue(int capacity)
    {
        var options = new BoundedChannelOptions(capacity)
        {
            FullMode = BoundedChannelFullMode.Wait
        };
        _queue = Channel.CreateBounded<Func<IServiceProvider, CancellationToken, Task>>(options);
    }

    public async ValueTask QueueBackgroundWorkItemAsync(Func<IServiceProvider, CancellationToken, Task> workItem)
    {
        ArgumentNullException.ThrowIfNull(workItem);
        await _queue.Writer.WriteAsync(workItem);
    }

    public async ValueTask<Func<IServiceProvider, CancellationToken, Task>> DequeueAsync(CancellationToken cancellationToken)
    {
        return await _queue.Reader.ReadAsync(cancellationToken);
    }
}

后台托管服务实现

public class QueuedHostedService : BackgroundService
{
    private readonly ILogger<QueuedHostedService> _logger;
    private readonly IBackgroundTaskQueue _taskQueue;
    private readonly IServiceProvider _services;

    public QueuedHostedService(IBackgroundTaskQueue taskQueue, ILogger<QueuedHostedService> logger, IServiceProvider services)
    {
        _taskQueue = taskQueue;
        _logger = logger;
        _services = services;
    }

    protected override async Task ExecuteAsync(CancellationToken stoppingToken)
    {
        _logger.LogInformation("后台任务队列服务已启动");

        while (!stoppingToken.IsCancellationRequested)
        {
            var workItem = await _taskQueue.DequeueAsync(stoppingToken);

            try
            {
                // 把根服务提供者传递给任务委托
                await workItem(_services, stoppingToken);
            }
            catch (Exception ex)
            {
                _logger.LogError(ex, "后台任务执行失败");
            }
        }

        _logger.LogInformation("后台任务队列服务已停止");
    }
}

4. 注册服务到DI容器 #

在Program.cs里正确注册这些组件：

// 注册后台任务队列（指定队列容量，比如100）
builder.Services.AddSingleton<IBackgroundTaskQueue>(_ => new BackgroundTaskQueue(100));
// 注册后台托管服务
builder.Services.AddHostedService<QueuedHostedService>();
// 注册MediatR，确保扫描到你的命令和处理程序所在的程序集
builder.Services.AddMediatR(cfg => {
    cfg.RegisterServicesFromAssemblyContaining<Program>();
});

5. 检查命令处理程序的依赖注册 #

最后确认你的命令处理程序依赖的服务（比如DbContext、邮件服务等）是按正确的生命周期注册的：

// 比如DbContext是Scoped生命周期
builder.Services.AddDbContext<AppDbContext>(options => 
    options.UseSqlServer(builder.Configuration.GetConnectionString("DefaultConnection")));
// 邮件服务如果是无状态的，可以注册为Transient
builder.Services.AddTransient<IMailService, MailService>();

额外提醒 #

• 后台任务执行失败的话不会自动重试，建议加try-catch捕获异常，或者用Polly等库实现重试逻辑
• 如果你的数据库操作需要和前台请求保持一致性，那存储元数据的操作最好同步完成，不要丢到后台；如果允许最终一致性，再考虑异步处理

备注：内容来源于stack exchange，提问作者frodo_ff