ASP.NET Core 6多租户API中为HangFire模拟IHttpContextAccessor

针对HangFire后台作业无HttpContext的问题，核心思路是解除服务对HttpContext的强依赖，通过显式传递关键数据或提供独立上下文来适配后台场景，以下是具体可行方案：

1. 重构JWT服务，支持手动传入令牌 #

修改IJwtAuthenticationManager的设计，新增支持直接传入令牌的方法，避免仅从HttpContext获取：

// 在IJwtAuthenticationManager接口中新增方法
string GetTenantConnectionString(string accessToken);

// 实现类中新增逻辑
public string GetTenantConnectionString(string accessToken)
{
    // 直接解析传入的令牌获取租户域名
    var principal = _jwtTokenHandler.ValidateToken(accessToken, _tokenValidationParameters, out _);
    var customerDomainName = principal.Claims.First(c => c.Type == "CustomerDomain").Value;
    
    var keyName = customerDomainName + ":DataContext";
    return _configuration.GetValue<string>(keyName);
}

// 保留原方法兼容Web请求场景
public string GetTenantConnectionString()
{
    var token = GetAccessToken();
    return string.IsNullOrEmpty(token) ? string.Empty : GetTenantConnectionString(token);
}

2. 调度作业时显式传递关键参数 #

在Web API触发后台作业时，将当前请求的JWT令牌、租户ID等数据作为参数传入作业方法：

// Web API接口中触发作业
var accessToken = _jwtAuthenticationManager.GetAccessToken();
BackgroundJob.Enqueue(() => _reportService.GenerateMonthlyReport(accessToken, currentTenantId));

后台作业服务中直接使用传入的参数获取所需数据：

public class ReportService
{
    private readonly IJwtAuthenticationManager _jwtAuthManager;

    public ReportService(IJwtAuthenticationManager jwtAuthManager)
    {
        _jwtAuthManager = jwtAuthManager;
    }

    public void GenerateMonthlyReport(string accessToken, string tenantId)
    {
        // 使用传入的令牌获取连接字符串
        var connectionString = _jwtAuthManager.GetTenantConnectionString(accessToken);
        // 后续业务逻辑...
    }
}

3. 自定义HangFire过滤器，临时注入HttpContext（兼容旧代码） #

如果无法快速重构现有依赖HttpContext的服务，可以通过HangFire过滤器在作业执行前临时设置IHttpContextAccessor的上下文：

public class HangFireJobContextFilter : JobFilterAttribute, IClientFilter, IServerFilter
{
    private readonly IHttpContextAccessor _httpContextAccessor;

    public HangFireJobContextFilter(IHttpContextAccessor httpContextAccessor)
    {
        _httpContextAccessor = httpContextAccessor;
    }

    // 客户端调度作业时，将令牌存入作业参数
    public void OnCreating(CreatingContext context)
    {
        var accessToken = _httpContextAccessor.HttpContext?.Request.Headers["Authorization"].ToString();
        if (!string.IsNullOrEmpty(accessToken))
        {
            context.SetJobParameter("AccessToken", accessToken);
        }
    }

    // 服务端执行作业前，模拟HttpContext
    public void OnPerforming(PerformingContext context)
    {
        var accessToken = context.GetJobParameter<string>("AccessToken");
        if (!string.IsNullOrEmpty(accessToken))
        {
            var httpContext = new DefaultHttpContext();
            httpContext.Request.Headers["Authorization"] = accessToken;
            _httpContextAccessor.HttpContext = httpContext;
        }
    }

    // 作业执行后清空上下文，避免污染后续作业
    public void OnPerformed(PerformedContext context)
    {
        _httpContextAccessor.HttpContext = null;
    }

    public void OnCreated(CreatedContext context) { }
}

在Startup中注册过滤器：

services.AddHangfire(config =>
{
    // 其他HangFire配置...
    config.UseFilter(new HangFireJobContextFilter(new HttpContextAccessor()));
});

4. 优化DbContext初始化逻辑 #

新增jmasdbContext的构造函数重载，支持直接传入连接字符串，避免依赖IJwtAuthenticationManager：

// 新增构造函数，用于后台作业场景
public jmasdbContext(DbContextOptions<jmasdbContext> options, string connectionString)
    : base(options)
{
    ConnectionString = connectionString;
}

// 保留原构造函数兼容Web请求场景
public jmasdbContext(DbContextOptions<jmasdbContext> options, ITenantProviderService tnt, IJwtAuthenticationManager jwt, IWebHostEnvironment env)
    : base(options)
{
    if (!env.EnvironmentName.Equals("Development"))
    {
        if (tnt != null && tnt.HasTenantSet())
        {
            ConnectionString = tnt.Tenant.ConnectionString;
        }
        else if (jwt != null && !string.IsNullOrEmpty(jwt.GetAccessToken()))
        {
            ConnectionString = jwt.GetTenantConnectionString();
        }
    }
}

后台作业中直接通过新构造函数创建DbContext：

public void GenerateMonthlyReport(string accessToken)
{
    var connectionString = _jwtAuthManager.GetTenantConnectionString(accessToken);
    var dbOptions = new DbContextOptionsBuilder<jmasdbContext>()
        .UseSqlServer(connectionString)
        .Options;
    
    using var dbContext = new jmasdbContext(dbOptions, connectionString);
    // 业务逻辑处理...
}

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