我有一个在Hangfire中设置的定期作业列表,所有作业间隔为20分钟.
职位ID test_1 => MyTestMethod(1)
职位ID test_50 => MyTestMethod(50)
职位ID test_37 => MyTestMethod(37)
有时,作业可能需要比其间隔更长的时间,即超过20分钟,并且我希望确保作业不再运行,而另一个实例已经在运行.
DisableConcurrentExecutionAttribute在这里不合适,因为该方法可以同时运行,而不是使用相同的参数.
我试图有一个静态字典< string,DateTime>跟踪作业是否已经运行以便它可以阻止并发方法调用,但问题是如果应用程序因任何原因重新启动,那么它“忘记”当前正在运行的作业(当然Hangfire将继续运行背景)
UPDATE
我还尝试将JobState表添加到我的数据库以跟踪正在运行的作业,然后在MyTestMethod启动时检查该表,但这依赖于MyTestMethod设置running = 1,当它启动时运行= 0,当它结束并且线程崩溃中途通过那可能不会发生的工作(无论出于何种原因),从而阻止工作再次运行.
解决方法
我有类似的要求,基本上我想使用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);
}
}
