如何将Hangfire作业参数传入其执行的方法？ASP.NET Core多租户场景

• 你在配置HangfireServer时手动实例化了HfTenantProvider，这个实例是全局单例的，和DI容器中注册的Scoped级IHfTenantProvider不是同一个对象，所以你在过滤器里赋值的租户ID，作业执行时从DI注入的Scoped实例里拿不到
• Hangfire每次执行作业都会创建独立的DI作用域，服务端过滤器如果不是从这个作业Scope里解析服务，就拿不到和作业方法同Scope的租户Provider实例
• 客户端过滤器OnCreating方法用了async void，会导致租户ID还没获取完成就已经创建作业，存在参数丢失风险

1. 调整过滤器注册逻辑，移除手动实例化的FilterProvider #

不需要自定义HfServerFilterProvider和HfClientFilterProvider，直接将过滤器注册到DI，让Hangfire自动从作业作用域解析即可：

// Startup中注册过滤器到DI
services.AddTransient<HfClientTenantFilter>();
services.AddTransient<HfServerTenantFilter>();

// 配置Hangfire全局过滤器
services.AddHangfire(config =>
{
    // 你的原有Hangfire配置（如存储配置等）保留
    config.UseFilter(new CaptureCultureAttribute());
    config.UseFilter(typeof(HfClientTenantFilter));
    config.UseFilter(typeof(HfServerTenantFilter));
});

// 删除手动赋值FilterProvider的逻辑，用默认DI集成
services.AddHangfireServer();

2. 优化HfTenantProvider实现，适配异步执行场景 #

用AsyncLocal存储租户ID，保证异步执行流中取值正确：

public class HfTenantProvider: IHfTenantProvider
{
    private readonly AsyncLocal<string> _currentTenant = new AsyncLocal<string>();

    public void HfSetTenant(string TenantCode)
    {
        _currentTenant.Value = TenantCode;
    }

    public string HfGetTenant()
    {
        return _currentTenant.Value;
    }
}

3. 修复客户端过滤器的异步问题 #

将async void的OnCreating改为同步实现，避免参数丢失：

public void OnCreating(CreatingContext filterContext)
{
    if (filterContext == null) throw new ArgumentNullException(nameof(filterContext));
    // 同步等待获取租户配置，避免async void的不可控问题
    MdxTenantConfig tenantConfig = _multiTenant.GetTenantConfig().GetAwaiter().GetResult();
    filterContext.SetJobParameter("TenantId", tenantConfig.Id);
}

4. 确认作业执行类的依赖注入逻辑 #

确保你的作业类（如示例中的MdxMetaCRUD）的IHfTenantProvider是从构造函数注入的，不要手动实例化：

public class MdxMetaCRUD
{
    private readonly IHfTenantProvider _hfTenantProvider;
    private readonly IContextHelper _contextHelper;

    // 构造函数注入依赖，Hangfire执行作业时会自动从当前作业的Scope解析服务
    public MdxMetaCRUD(IHfTenantProvider hfTenantProvider, IContextHelper contextHelper)
    {
        _hfTenantProvider = hfTenantProvider;
        _contextHelper = contextHelper;
    }

    // 原有HfTest方法逻辑不用修改
    public async Task HfTest()
    {
        string tenant =_hfTenantProvider.HfGetTenant();
        using (var _dbContext = _contextHelper.CreateContext(true, tenant))
        {
            Entity entity = new()
            {
                Name = "HFtest",
                Description = tenant,
                DefaultAuditTrackRetention = 1
            };
            await _dbContext.Entities.AddAsync(entity);
        }
    }
}

修改完成后，服务端过滤器和作业方法会使用同一个作业Scope内的IHfTenantProvider实例，过滤器中存入的租户ID即可正常在作业方法中获取。

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