如何在Hangfire中实现SaaS应用单租户串行、跨租户并发的任务调度？

核心思路 #

无需为每个租户创建独立服务器，通过自定义任务过滤器+按任务类型划分服务器，即可实现单租户任务串行、跨租户任务并发且全局总并发可控的效果，完全匹配你的需求。

具体实现步骤 #

1. 按任务类型启动独立服务器 #

分别启动OrderImportServer和OrderReleaseServer两个Hangfire服务器，各自设置WorkerCount=20，直接控制对应任务类型的全局最大并发数：

• 订单导入服务器处理所有租户的订单导入任务
• 订单释放服务器处理所有租户的订单释放任务

代码示例（Asp.Net配置）：

// 订单导入服务器配置
app.UseHangfireServer(new BackgroundJobServerOptions
{
    ServerName = "OrderImportServer",
    WorkerCount = 20,
    // 可选：若需明确限定队列，可动态加载所有租户的OI队列，或依赖过滤器自动匹配
});

// 订单释放服务器配置
app.UseHangfireServer(new BackgroundJobServerOptions
{
    ServerName = "OrderReleaseServer",
    WorkerCount = 20,
});

2. 自定义过滤器实现单租户串行 #

通过IServerFilter结合分布式锁（利用SQL Server的锁机制），限制同一租户同一任务类型的任务只能串行执行：

public class TenantSerialExecutionFilter : IServerFilter
{
    private readonly string _connectionString;

    public TenantSerialExecutionFilter(string connectionString)
    {
        _connectionString = connectionString;
    }

    public void OnPerforming(PerformingContext filterContext)
    {
        // 从任务参数或元数据中提取租户ID和任务类型
        var tenantId = filterContext.Job.Args.OfType<string>().FirstOrDefault(id => id.StartsWith("Tenant_"));
        var taskType = filterContext.Job.Method.Name.Contains("Import") ? "OI" : "OR";
        var lockKey = $"Hangfire_TenantLock_{tenantId}_{taskType}";

        // 获取SQL分布式锁，超时时间根据任务耗时调整
        var lockCommand = new SqlCommand($"EXEC sp_getapplock @Resource = '{lockKey}', @LockMode = 'Exclusive', @LockTimeout = 1800000", 
            new SqlConnection(_connectionString));
        lockCommand.Connection.Open();
        lockCommand.ExecuteNonQuery();
        filterContext.Items["LockConnection"] = lockCommand.Connection;
    }

    public void OnPerformed(PerformedContext filterContext)
    {
        if (filterContext.Items.TryGetValue("LockConnection", out var conn) && conn is SqlConnection connection)
        {
            var tenantId = filterContext.Job.Args.OfType<string>().FirstOrDefault(id => id.StartsWith("Tenant_"));
            var taskType = filterContext.Job.Method.Name.Contains("Import") ? "OI" : "OR";
            var lockKey = $"Hangfire_TenantLock_{tenantId}_{taskType}";
            
            new SqlCommand($"EXEC sp_releaseapplock @Resource = '{lockKey}'", connection).ExecuteNonQuery();
            connection.Close();
            connection.Dispose();
        }
    }
}

注册过滤器：

GlobalJobFilters.Filters.Add(new TenantSerialExecutionFilter(Configuration.GetConnectionString("HangfireConnection")));

3. 任务入队时指定租户标识 #

添加任务时，将租户ID传入任务参数，并指定对应类型的租户队列（可选，用于更精准的任务路由）：

// 订单导入任务入队
BackgroundJob.Enqueue<OrderImportService>(s => s.ProcessTenantOrders("Tenant_001"), 
    new EnqueuedState("Tenant_001_OI"));

// 订单释放任务入队
BackgroundJob.Enqueue<OrderReleaseService>(s => s.ReleaseTenantOrders("Tenant_001"), 
    new EnqueuedState("Tenant_001_OR"));

关于你提到的单租户服务器方案的问题 #

技术上该方案可行，但存在明显弊端：

• 大量单Worker服务器会增加系统资源开销和运维复杂度
• SQL Server存储中会生成过多服务器记录，可能影响Hangfire调度性能
• 租户动态增减时需同步创建/销毁服务器，实现成本高

因此更推荐按任务类型划分服务器+自定义过滤器的方案。

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