Spring提供了定時任務(wù)的功能，但是在多個實例的集群中，會出現(xiàn)定時任務(wù)重復(fù)執(zhí)行多次的情況。

使用Qutaz框架自帶的分布式定時任務(wù)可以很好的解決這個問題，但是講道理功能有些過于強大，對于需求不高，乃至可以一定程度上允許失誤的簡單任務(wù)中，性價比比較低。

使用task任務(wù)時，可以通過在redis等緩存、數(shù)據(jù)庫中創(chuàng)建鎖來實現(xiàn)避免重復(fù)執(zhí)行任務(wù)的功能。

基本思路如下：

• 在redis中設(shè)置一個key作為鎖，值為時間戳
• 嘗試用setnx方法直接設(shè)置鎖，若成功則直接執(zhí)行任務(wù)。
• 若設(shè)置失敗，使用getset方法獲取當(dāng)前鎖并更新時間戳
• 若獲取的時間戳在有效期內(nèi)，則不執(zhí)行任務(wù)，否則執(zhí)行任務(wù)

當(dāng)然這種實現(xiàn)方法是很粗糙的。對于高并發(fā)的頻繁定時任務(wù)處理很不完美。若執(zhí)行失敗也會導(dǎo)致任務(wù)丟失。

本方案實現(xiàn)的處理場景是間隔比較長的數(shù)據(jù)處理定時任務(wù)。服務(wù)器集群也只有三個節(jié)點，上線運行效果良好。

簡要實現(xiàn)代碼如下：

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);//三十秒以內(nèi)都算有效鎖return Math.abs(curr-l)<30000;}}} 復(fù)制代碼

轉(zhuǎn)載于:https://juejin.im/post/5a31e9f8f265da43333e6a1b

總結(jié)

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

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。