如何禁用Hangfire长时间运行作业的并发执行及相关问题咨询

一、手动触发作业执行两次的常见原因 #

• 前端重复提交：仪表盘触发按钮被快速双击，或网络延迟导致前端重复发送请求，Hangfire收到两次触发指令后生成两个独立的作业实例
• 默认重试机制触发：作业启动初期（如初始化依赖资源阶段）出现短暂异常（如数据库连接瞬断、临时资源不足），触发Hangfire默认的重试逻辑，导致作业二次执行
• 多Worker节点锁同步延迟：若部署了多个Hangfire Worker节点，手动触发时节点间的分布式锁同步存在延迟，可能导致多个节点同时领取并执行同一作业
• 存储状态更新滞后：Hangfire使用的存储（如SQL Server）状态更新不及时，导致Worker节点误以为作业未被领取，进而重复执行

二、避免作业重复执行的解决方案 #

关于DisableConcurrentExecution的适用性 #

别误会，DisableConcurrentExecution的超时参数不是限制作业的执行时长，而是限制当前作业等待获取分布式锁的超时时间。比如设置[DisableConcurrentExecution(86400)]（24小时），意思是如果发现已有同类型作业在运行，当前作业会等待24小时尝试获取锁，超过时间则直接失败。对于长时间运行的作业，只要把超时时间设置得比你的作业最长执行时长更长，完全可以放心使用。

更灵活的防重复方案 #

• 手动触发时指定唯一作业ID：触发作业时自定义唯一ID，避免重复生成作业实例。示例：

  // 用时间戳+作业标识生成唯一ID，防止重复触发
  var uniqueJobId = $"MonthlyThirdSatJob_{DateTime.UtcNow:yyyyMMddHHmmssfff}";
  BackgroundJob.Enqueue<MonthlyJob>(uniqueJobId, job => job.RunLongTask());
  

• 自定义分布式锁校验：在作业执行前，通过Hangfire自带的分布式锁检查是否已有同类型作业在运行，避免重复执行。示例：

  public class MonthlyJob
  {
      // 锁键，确保同一类型作业共用一个锁
      private const string RunningLockKey = "MonthlyThirdSatJob_RunningFlag";
  
      public void RunLongTask()
      {
          using var connection = JobStorage.Current.GetConnection();
          // 设置锁有效期为作业最长执行时长+1小时缓冲
          var lockAcquired = connection.AcquireDistributedLock(RunningLockKey, TimeSpan.FromHours(7));
          
          if (!lockAcquired)
          {
              // 已有作业在运行，直接退出
              return;
          }
  
          try
          {
              // 执行你的长时间作业逻辑
          }
          finally
          {
              // 释放锁，避免死锁
              connection.ReleaseDistributedLock(RunningLockKey);
          }
      }
  }
  

• 使用SkipWhenAlreadyExecuting过滤器：这是Hangfire提供的简化版防并发过滤器，当发现同类型作业正在运行时，直接跳过当前触发的作业，不会等待锁。用法：

  [SkipWhenAlreadyExecuting]
  public class MonthlyJob
  {
      public void RunLongTask()
      {
          // 作业逻辑
      }
  }
  

• 触发前检查作业状态：手动触发前，通过Hangfire的Monitoring API查询是否有同类型作业处于Processing状态，有则不触发。示例：

  var monitoringApi = JobStorage.Current.GetMonitoringApi();
  // 查询正在执行的作业，过滤出当前作业类型
  var runningJobs = monitoringApi.ProcessingJobs(0, 100)
      .Where(j => j.Value.Job.Type == typeof(MonthlyJob));
  
  if (!runningJobs.Any())
  {
      BackgroundJob.Enqueue<MonthlyJob>(job => job.RunLongTask());
  }
  

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