hangfire recurring job on every server
我有一种情况,我需要使用 hangfire 注册的重复作业才能在集群中的每台服务器上运行。
(工作是在本地复制一些文件,因此需要定期在每台服务器上运行)
到目前为止,我已经尝试使用服务器名称的 id 注册相同的作业,从而导致 n 个服务器的 n 个作业:
1
|
RecurringJob.AddOrUpdate(Environment.MachineName, () => CopyFiles(Environment.MachineName), Cron.MinuteInterval(_delay));
|
并且作业本身会检查它是否是正确的服务器,并且只有在正确的情况下才会执行:
1
2 3 4 5 6 7 8 9 |
public static void CopyFiles(string taskId) { if (string.IsNullOrWhiteSpace(taskId) || !taskId.Equals(Environment.MachineName)) { return; } // do stuff here if it matches our taskname |
这样做的问题是所有作业都在第一台服务器上执行,被标记为完成,因此其他服务器不执行。
有什么方法可以确保作业在所有服务器上运行吗?
或者有没有办法确保只有一台服务器可以处理给定的作业?即在创建它的服务器上定位作业
使用此链接找到答案。
只需将作业分配给特定于您希望它处理的服务器的队列。
所以我将队列更改为:
1
2 3 4 |
RecurringJob.AddOrUpdate(Environment.MachineName,
() => CopyFiles(Environment.MachineName), Cron.MinuteInterval(_delay), queue: Environment.MachineName.ToLower(CultureInfo.CurrentCulture)); |
当我启动我的服务器时,我会这样做:
1
2 3 4 |
原创文章,作者:ItWorker,如若转载,请注明出处:https://blog.ytso.com/269592.html