.NET Core多租户Azure应用如何对接独立HangFire进程？

核心原理 #

HangFire的任务调度、队列、状态都依赖于共享存储后端（数据库/Redis），Web应用只负责提交任务到存储，独立服务器从存储拉取任务执行，两者通过共享存储完成对接，不需要直接的进程间通信。

步骤1：配置共享存储 #

Web应用和独立HangFire服务器必须使用完全相同的存储配置，确保能访问同一个数据源。以Azure SQL Server为例：

Web应用配置（Program.cs）

var builder = WebApplication.CreateBuilder(args);

// 配置HangFire存储（仅配置，不启动工作线程）
builder.Services.AddHangfire(config =>
{
    config.UseSqlServerStorage(builder.Configuration.GetConnectionString("HangFireStorage"));
});

// 注入任务提交所需服务，禁用Web应用的任务处理能力
builder.Services.AddHangfireServer(options =>
{
    options.ServerName = "WebApp-Submitter";
    options.WorkerCount = 0; // 不启动工作线程，仅作为任务提交端
});

var app = builder.Build();

// 可选：挂载HangFire仪表盘，用于查看任务状态
app.UseHangfireDashboard("/hangfire");

app.Run();

独立控制台应用配置（Program.cs）

var host = Host.CreateDefaultBuilder(args)
    .ConfigureServices(services =>
    {
        // 配置与Web应用完全一致的HangFire存储
        services.AddHangfire(config =>
        {
            config.UseSqlServerStorage(Configuration.GetConnectionString("HangFireStorage"));
        });

        // 启动HangFire服务器，负责处理任务
        services.AddHangfireServer(options =>
        {
            options.ServerName = "Standalone-JobServer";
            options.WorkerCount = Environment.ProcessorCount * 2; // 根据服务器配置调整工作线程数
        });
    })
    .Build();

await host.RunAsync();

步骤2：Web应用提交多租户任务 #

在Web应用的业务逻辑中，通过IRecurringJobManager提交定时报表任务，任务参数需包含租户ID以实现多租户隔离：

public class ReportScheduler
{
    private readonly IRecurringJobManager _recurringJobManager;

    public ReportScheduler(IRecurringJobManager recurringJobManager)
    {
        _recurringJobManager = recurringJobManager;
    }

    // 为指定租户创建每日报表任务
    public void CreateDailyReportTask(string tenantId)
    {
        _recurringJobManager.AddOrUpdate(
            jobId: $"DailyReport-Tenant-{tenantId}",
            methodCall: () => GenerateTenantReport(tenantId),
            cronExpression: Cron.Daily(2, 0), // 每天凌晨2点执行
            timeZone: TimeZoneInfo.Utc
        );
    }

    // 实际执行报表生成的方法（必须为public，HangFire才能调用）
    public void GenerateTenantReport(string tenantId)
    {
        // 根据tenantId生成对应租户的报表逻辑
        // 示例：查询租户数据、生成PDF、存储到Azure Blob或发送邮件
    }
}

步骤3：多租户任务隔离要点 #

• 任务ID必须包含租户标识（如示例中的DailyReport-Tenant-{tenantId}），避免不同租户的任务冲突。
• 可自定义HangFire过滤器，确保任务提交时必须携带租户ID：

public class TenantValidationFilter : JobFilterAttribute, IClientFilter
{
    public void OnCreating(CreatingContext filterContext)
    {
        if (!filterContext.Job.Args.Any(arg => arg is string tenantId && !string.IsNullOrEmpty(tenantId)))
        {
            throw new InvalidOperationException("任务必须包含租户ID参数");
        }
    }
}

在配置HangFire时注册过滤器：

config.UseFilter(new TenantValidationFilter());

部署注意事项 #

• 独立服务器可部署为Azure Web Job（托管式，推荐）、Azure Container Instance或Azure VM上的Windows服务。
• 确保独立服务器能访问共享存储：Azure SQL需配置防火墙规则允许服务器IP；Redis需配置正确的访问密钥和网络规则。
• 监控：通过Web应用的HangFire仪表盘查看任务状态、执行记录，排查失败任务。

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