Spring提供了定時任務的功能,但是在多個實例的集群中,會出現定時任務重復執行多次的情況。
使用Qutaz框架自帶的分布式定時任務可以很好的解決這個問題,但是講道理功能有些過于強大,對于需求不高,乃至可以一定程度上允許失誤的簡單任務中,性價比比較低。
使用task任務時,可以通過在redis等緩存、數據庫中創建鎖來實現避免重復執行任務的功能。
基本思路如下:
- 在redis中設置一個key作為鎖,值為時間戳
- 嘗試用setnx方法直接設置鎖,若成功則直接執行任務。
- 若設置失敗,使用getset方法獲取當前鎖并更新時間戳
- 若獲取的時間戳在有效期內,則不執行任務,否則執行任務
當然這種實現方法是很粗糙的。對于高并發的頻繁定時任務處理很不完美。若執行失敗也會導致任務丟失。
本方案實現的處理場景是間隔比較長的數據處理定時任務。服務器集群也只有三個節點,上線運行效果良好。
簡要實現代碼如下:
private boolean getLock(String key){String syncKey = "sync_lock_"+key;long curr = System.currentTimeMillis();String time = curr+"";long has = redisTemplate.setnx(syncKey,time);if(has == 1){return true;}else{String lock = redisTemplate.getSet(syncKey,time);if(lock == null){return true;}else{long l = NumberUtils.toLong(lock);//三十秒以內都算有效鎖return Math.abs(curr-l)<30000;}}}
復制代碼