背景

HangFire有個很奇怪的現象，就是即使你設置的循環作業是一天一次，但是每次作業執行很長時間，我們假設是1小時，那么差不多在開始執行之后的30分鐘之后，如果還在執行job,系統就會自動幫你重新開啟了新的job執行。也就是撇開循環周期的影響，我一個長時間的作業，超過三十分鐘的，那么系統又會在你還在執行的時候，三十分鐘之后又起一個來幫你執行。

問題窺探

我之前做項目的時候，就遇到這個問題，莫名其妙。開始的時候，我還以為可以像Quartz加個[DisallowConcurrentExecution]了事。

后面找到這個

但是測試了下，不起作用啊。而且一旦啟用分布式部署，這個就算有用，到時候不也沒用了，后面想想直接來個干脆的，分布式鎖。

解決辦法

1、進入job的時候，定義一個key,判斷是否正在執行。

string uniqueKey = string.Empty;string key = "xxxxx";if (!CacheExtension.getInstance().AddUnique($"{key}_unique", 1, DateTimeOffset.Now.AddDays(365))){LogExtention.getInstance().WriteCustomLogAsync("",?"",?true,?"上批次還未執行結束--xxxxxxjob");return;}uniqueKey = $"{key}_unique";

2、redis-StringSet保證key是唯一的。

/// <summary>/// 新增,若緩存中已存在相同KEY，則返回false，判斷高并發時使用/// </summary>public bool AddUnique(string key, object o, DateTimeOffset expiration, string dependsOnKey = null){key = AddSysCustomKey(key);var ts = expiration - DateTimeOffset.Now;return _client.StringSet(key, ConvertJson(o), ts, When.NotExists);}

3、執行完成的時候，去掉鎖。

try{//todo????????????}finally{? ??????????????????CacheExtension.getInstance().Remove(uniqueKey);}

總結

1、這樣的話，就能在舊的還未完成之前，新的進來，直接return,保證唯一性，也支持了分布式處理。

2、分布式鎖在很多場景，還是很實用的。

總結

以上是生活随笔為你收集整理的HangFire循环作业中作业因执行时间太长未完成新作业开启导致重复数据的问题...的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。