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;}}} 復制代碼

轉載于:https://juejin.im/post/5a31e9f8f265da43333e6a1b

總結

以上是生活随笔為你收集整理的基于Redis实现分布式锁，避免重复执行定时任务的全部內容，希望文章能夠幫你解決所遇到的問題。

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