Hangfire多租户场景传租户哈希配置EF DbContext咨询

核心逻辑是解耦「租户哈希获取」和「DbContext连接串生成」两个环节，用异步上下文隔离的租户存储做中转，不需要修改现有EF配置的核心逻辑，同时兼容原有Web请求的租户解析流程。

第一步：实现线程安全的租户上下文存储 #

用AsyncLocal做存储载体，保证异步执行流内的数据独立，跨线程、跨请求/作业不会串值，同时兼容Web请求和后台作业两类场景：

public interface ITenantContext
{
    string CurrentDatabaseHash { get; set; }
}

public class TenantContext : ITenantContext
{
    private static readonly AsyncLocal<string> _currentHash = new();
    public string CurrentDatabaseHash
    {
        get => _currentHash.Value;
        set => _currentHash.Value = value;
    }
}

服务注册时配置为Scoped生命周期：

builder.Services.AddScoped<ITenantContext, TenantContext>();

第二步：改造租户解析过滤器 #

把原有从HttpContext、Hangfire作业参数拿到的哈希值统一写入租户上下文，作业执行完成后清空残留值：

public class TenantResolverFilter : IClientFilter, IServerFilter
{
    private readonly IHttpContextAccessor _httpContextAccessor;
    private readonly ITenantContext _tenantContext;

    public TenantResolverFilter(IHttpContextAccessor httpContextAccessor, ITenantContext tenantContext)
    {
        _httpContextAccessor = httpContextAccessor;
        _tenantContext = tenantContext;
    }
    public void OnCreating(CreatingContext filterContext)
    {
        if (filterContext == null) throw new ArgumentNullException(nameof(filterContext));
        var hash = _httpContextAccessor.HttpContext.GetCurrentTenantDatabaseHash();
        filterContext.SetJobParameter("hash", hash);
        // 兼容普通Web请求的租户赋值逻辑
        _tenantContext.CurrentDatabaseHash = hash;
    }

    public void OnCreated(CreatedContext filterContext)
    {
    }

    public void OnPerforming(PerformingContext filterContext)
    {
        var hash = filterContext.GetJobParameter<string>("hash");
        _tenantContext.CurrentDatabaseHash = hash;
    }

    public void OnPerformed(PerformedContext filterContext)
    {
        // 执行完清空值，避免上下文复用导致串租户
        _tenantContext.CurrentDatabaseHash = null;
    }
}

将过滤器注册为Hangfire全局过滤器，无需在每个作业方法上打特性：

builder.Services.AddHangfire((provider, config) =>
{
    // 原有Hangfire配置...
    config.UseFilter(provider.GetRequiredService<TenantResolverFilter>());
});

第三步：改造EF Core动态连接逻辑 #

不再在DbContext注册时写死连接串，每次解析DbContext实例时从当前服务Scope的租户上下文取哈希，动态生成对应连接串：

builder.Services.AddDbContext<AppDbContext>((sp, options) =>
{
    var tenantContext = sp.GetRequiredService<ITenantContext>();
    var config = sp.GetRequiredService<IOptions<DbConfig>>().Value;
    // 这里替换为你自己的哈希-连接串映射逻辑，比如读配置缓存、租户库映射表
    string connectionString = ResolveConnectionStringByHash(tenantContext.CurrentDatabaseHash, config);
    
    options.UseSqlServer(connectionString, sqlOption =>
    {
        sqlOption.CommandTimeout(config.SqlCommandTimeout);
        sqlOption.EnableRetryOnFailure(3);
    });
});

落地注意事项 #

• 禁止用静态变量存储当前租户哈希，高并发场景下必然出现租户数据串读问题，AsyncLocal基于异步执行上下文做隔离，完全适配Hangfire的作业执行模型
• Hangfire执行每个作业时都会创建独立的服务解析Scope，Scoped生命周期的ITenantContext在单个作业执行周期内唯一，不会和其他并发作业、Web请求冲突
• 如果业务用到Hangfire批处理、延续子作业，需要扩展过滤器逻辑，自动从父作业继承哈希参数，避免子作业因缺少参数无法解析连接
• 注册Hangfire过滤器时必须从DI容器获取实例，不要手动new过滤器对象，否则构造函数注入的依赖无法正常加载

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