hangfire在每台服务器上重复工作

我有一种情况,我需要在hangfire中注册的定期作业,以便在群集中的每台服务器上运行。

(工作是在本地复制一些文件,因此需要定期在每台服务器上运行)

到目前为止,我已经尝试使用服务器名称的id注册相同的作业,从而导致n个服务器的n作业:

RecurringJob.AddOrUpdate(Environment.MachineName, () => CopyFiles(Environment.MachineName), Cron.MinuteInterval(_delay)); 

并且作业本身会检查它是否是正确的服务器,并且仅在以下情况下执行以下操作:

  public static void CopyFiles(string taskId) { if (string.IsNullOrWhiteSpace(taskId) || !taskId.Equals(Environment.MachineName)) { return; } // do stuff here if it matches our taskname } 

这样做的问题是所有作业在第一台服务器上执行,标记为完成,因此其他服务器不执行。

有没有办法确保作业在所有服务器上运行?

或者有没有办法确保只有一台服务器可以处理给定的工作? 即在创建它的服务器上定位作业

使用此链接找到答案。

只需将作业分配给特定于您希望其处理的服务器的队列。

所以我把我的队列改为:

 RecurringJob.AddOrUpdate(Environment.MachineName, () => CopyFiles(Environment.MachineName), Cron.MinuteInterval(_delay), queue: Environment.MachineName.ToLower(CultureInfo.CurrentCulture)); 

当我启动我的服务器时,我这样做:

 _backgroundJobServer = new BackgroundJobServer(new BackgroundJobServerOptions { Queues = new[] { Environment.MachineName.ToLower() } });