Autofac与Azure WebJobs集成问题：无法解析Per-Request依赖

这问题我之前做WebJobs项目时也踩过坑，核心原因特别明确：Azure WebJobs没有ASP.NET那种HTTP请求管道，Per-Request依赖（绑定AutofacWebRequest作用域）在这个环境里根本不存在。Per-Request是为HTTP请求设计的，而WebJobs是基于触发器（队列、定时器等）的执行模型，每个触发的任务才是独立的执行单元，所以得换个思路处理作用域。

下面是我亲测有效的解决方案：

1. 替换Per-Request注册为Job级别的作用域注册 #

首先，把所有用InstancePerRequest()注册的依赖，改成InstancePerLifetimeScope()或者更精准的InstancePerMatchingLifetimeScope("JobScope")。后者可以确保只有我们指定的Job作用域才会创建实例，避免和其他作用域混淆。

示例代码：

// 原来的Per-Request注册（WebJobs环境下无效）
// builder.RegisterType<MyDbContext>().InstancePerRequest();

// 改成Job作用域注册
builder.RegisterType<MyDbContext>().InstancePerMatchingLifetimeScope("JobScope");

2. 自定义AutofacJobActivator管理Job作用域 #

默认的AutofacActivator没有为每个Job创建独立的作用域，我们需要自己实现IJobActivator，在创建Job实例时启动新作用域，并确保Job执行完成后释放作用域。

完整实现代码：

public class AutofacJobActivator : IJobActivator
{
    private readonly ILifetimeScope _rootContainer;

    public AutofacJobActivator(ILifetimeScope rootContainer)
    {
        _rootContainer = rootContainer ?? throw new ArgumentNullException(nameof(rootContainer));
    }

    public T CreateInstance<T>()
    {
        // 为当前Job创建命名的独立作用域
        var jobScope = _rootContainer.BeginLifetimeScope("JobScope");
        
        // 优化：把作用域和Job实例绑定，确保实例释放时作用域也释放
        if (typeof(IDisposable).IsAssignableFrom(typeof(T)))
        {
            var disposableInstance = (IDisposable)jobScope.Resolve<T>();
            return (T)new DisposableWrapper(disposableInstance, jobScope);
        }
        
        return jobScope.Resolve<T>();
    }

    // 包装类：同时释放Job实例和作用域
    private class DisposableWrapper : IDisposable
    {
        private readonly IDisposable _instance;
        private readonly ILifetimeScope _scope;

        public DisposableWrapper(IDisposable instance, ILifetimeScope scope)
        {
            _instance = instance;
            _scope = scope;
        }

        public void Dispose()
        {
            _instance.Dispose();
            _scope.Dispose();
        }
    }
}

然后在WebJobs Host配置中注册这个自定义Activator：

var containerBuilder = new ContainerBuilder();
// 注册你的所有业务依赖
containerBuilder.RegisterType<MyQueueJob>();
var rootContainer = containerBuilder.Build();

var host = new HostBuilder()
    .UseServiceProviderFactory(new AutofacServiceProviderFactory())
    .ConfigureServices(services =>
    {
        services.AddAutofac();
        // 注册自定义Job Activator
        services.AddSingleton<IJobActivator>(new AutofacJobActivator(rootContainer));
        // 配置触发器（比如队列）
        services.AddAzureStorageQueues(options =>
        {
            options.BatchSize = 1;
        });
    })
    .Build();

await host.RunAsync();

3. 用Job过滤器更优雅地管理作用域生命周期 #

如果你希望把作用域的创建/释放逻辑和Activator解耦，可以使用WebJobs的IJobInvocationFilter过滤器，在Job执行前创建作用域，执行完成后自动释放。

示例过滤器代码：

public class JobScopeManagementFilter : IJobInvocationFilter
{
    private readonly ILifetimeScope _rootScope;
    private readonly AsyncLocal<ILifetimeScope> _currentJobScope = new AsyncLocal<ILifetimeScope>();

    public JobScopeManagementFilter(ILifetimeScope rootScope)
    {
        _rootScope = rootScope;
    }

    public Task OnJobExecutingAsync(JobExecutingContext context, CancellationToken cancellationToken)
    {
        // 创建Job作用域，存入AsyncLocal确保异步流程可访问
        var jobScope = _rootScope.BeginLifetimeScope("JobScope");
        _currentJobScope.Value = jobScope;
        // 也可存入Job上下文，方便Job内部直接获取
        context.Items["CurrentJobScope"] = jobScope;
        return Task.CompletedTask;
    }

    public Task OnJobExecutedAsync(JobExecutedContext context, CancellationToken cancellationToken)
    {
        // 释放当前Job的作用域
        _currentJobScope.Value?.Dispose();
        return Task.CompletedTask;
    }
}

注册过滤器：

services.AddSingleton<IJobFilter>(new JobScopeManagementFilter(rootContainer));

关键注意点 #

• 不要在WebJobs里试图模拟ASP.NET的AutofacWebRequest作用域，这完全不符合WebJobs的执行模型，只会徒增麻烦。
• 所有需要“每个任务实例一次”的依赖（比如数据库上下文、事务对象），都要绑定到Job级别的作用域上，避免多个任务共享实例导致的并发问题。

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