asp.net-mvc – 如果Hangfire已经运行,请停止启动定期作业
我有一个在Hangfire中设置的定期作业列表,所有作业间隔为20分钟.
它们都调用相同的方法,但参数不同. 职位ID test_1 => MyTestMethod(1) 有时,作业可能需要比其间隔更长的时间,即超过20分钟,并且我希望确保作业不再运行,而另一个实例已经在运行. DisableConcurrentExecutionAttribute在这里不合适,因为该方法可以同时运行,而不是使用相同的参数. 我试图有一个静态字典< string,DateTime>跟踪作业是否已经运行以便它可以阻止并发方法调用,但问题是如果应用程序因任何原因重新启动,那么它“忘记”当前正在运行的作业(当然Hangfire将继续运行背景) UPDATE 我确信我可以通过简单的工作ID查询Hangfire工作状态来解决这个问题 – 我只是无法找到如何做到这一点? 解决方法
我有类似的要求,基本上我想使用DisableConcurrentExecutionAttribute,但要考虑参数.这样,如果一个作业使用相同的参数排队,它仍然会不会并行运行.我拿了示例DisableMultipleQueuedItemsFilter,它实际上删除了作业并修改了DisableConcurrentExecutionAttribute以使用参数.不同之处在于,如果作业具有相同的参数列表,则它们将排队,它们不会并行运行.
这里可以看到完整的示例,包含两个属性:https://gist.github.com/sbosell/3831f5bb893b20e82c72467baf8aefea 属性的相关代码: public class DisableConcurrentExecutionWithParametersAttribute : JobFilterAttribute,IServerFilter { private readonly int _timeoutInSeconds; public DisableConcurrentExecutionWithParametersAttribute (int timeoutInSeconds) { if (timeoutInSeconds < 0) throw new ArgumentException("Timeout argument value should be greater that zero."); _timeoutInSeconds = timeoutInSeconds; } public void OnPerforming(PerformingContext filterContext) { var resource = GetResource(filterContext.BackgroundJob.Job); var timeout = TimeSpan.FromSeconds(_timeoutInSeconds); var distributedLock = filterContext.Connection.AcquireDistributedLock(resource,timeout); filterContext.Items["DistributedLock"] = distributedLock; } public void OnPerformed(PerformedContext filterContext) { if (!filterContext.Items.ContainsKey("DistributedLock")) { throw new InvalidOperationException("Can not release a distributed lock: it was not acquired."); } var distributedLock = (IDisposable)filterContext.Items["DistributedLock"]; distributedLock.Dispose(); } private static string GetFingerprint(Job job) { var parameters = string.Empty; if (job?.Arguments != null) { parameters = string.Join(".",job.Arguments); } if (job?.Type == null || job.Method == null) { return string.Empty; } var payload = $"{job.Type.FullName}.{job.Method.Name}.{parameters}"; var hash = SHA256.Create().ComputeHash(System.Text.Encoding.UTF8.GetBytes(payload)); var fingerprint = Convert.ToBase64String(hash); return fingerprint; } private static string GetResource(Job job) { return GetFingerprint(job); } } (编辑:李大同) 【声明】本站内容均来自网络,其相关言论仅代表作者个人观点,不代表本站立场。若无意侵犯到您的权利,请及时与联系站长删除相关内容! |
- asp.net-mvc-3 – ASP.NET MVC 3从控制器返回.csv文件
- ASP.net WebForms – 构造函数与Page_Load
- ASP.NET DateTime Picker
- asp.net-mvc – SquishIt MVC – 调试模式,不刷新
- ASP.NET Web Forms jQuery
- asp.net – “localhost”上运行网站是非常慢
- asp.net-mvc-3 – MVC3:超出最大请求长度
- asp.net-mvc-3 – 具有MVC3的多用户应用程序,ASP.NET成员资
- asp.net-mvc – ASP.NET MVC在HTTP DELETE请求上有405错误?
- asp.net – 此操作需要连接到“主”数据库