針對RedisTemplate分布式鎖實現(xiàn)WatchDog
來源:騰訊云 2023-04-21 16:27:32
(相關資料圖)
在此之前,去看了下Redission的實現(xiàn)原理,不過在開發(fā)中,原本的代碼使用RedistTemplate實現(xiàn)的,也不太想換,所以我想了下,不如自己實現(xiàn)要給WatchDog。
我的想法是,在用戶加上鎖的時候開啟個定時任務線程,并且在定時任務中,判斷原線程isAlive狀態(tài)進行“續(xù)命”。
下面是代碼(在這里面為了方便,未使用的是HuTool.CornUtil來實現(xiàn)動態(tài)定時任務):
/** * Title * * @ClassName: LockUtil * @Description:鎖工具類,通過內(nèi)部枚舉類實現(xiàn)單例,防止反射攻擊 * @author: Karos * @date: 2023/1/4 0:17 * @Blog: https://www.wzl1.top/ */package cn.katool.lock;import cn.hutool.core.util.BooleanUtil;import cn.hutool.core.util.ObjectUtil;import cn.hutool.cron.CronUtil;import cn.hutool.cron.task.Task;import cn.katool.Config.LockConfig;import cn.katool.Exception.ErrorCode;import cn.katool.Exception.KaToolException;import cn.katool.other.MethodIntefaceUtil;import com.qiniu.util.StringUtils;import lombok.SneakyThrows;import lombok.extern.slf4j.Slf4j;import org.springframework.context.annotation.Bean;import org.springframework.context.annotation.Scope;import org.springframework.data.redis.core.RedisTemplate;import org.springframework.stereotype.Component;import org.springframework.util.ObjectUtils;import javax.annotation.Resource;import java.util.concurrent.ConcurrentHashMap;import java.util.concurrent.TimeUnit;@Component@Scope("prototype")@Slf4jpublic class LockUtil { @Resource RedisTemplate redisTemplate; private LockUtil(){ } private static boolean isOpenCorn=false; /** * 帶看門狗機制上鎖 * @param lockObj * @return */ public boolean DistributedLock(Object lockObj){ try { return DistributedLock(lockObj,null,null); } catch (KaToolException e) { throw new RuntimeException(e); } } @Resource LockConfig lockConfig; //加鎖 /** * 無看門狗機制上鎖 * @param obj * @param exptime * @param timeUnit * @return * @throws KaToolException */ public boolean DistributedLock(Object obj,Long exptime,TimeUnit timeUnit) throws KaToolException { if (ObjectUtil.isEmpty(obj)){ throw new KaToolException(ErrorCode.PARAMS_ERROR," Lock=> 傳入obj為空"); } Boolean isDelay=false; if (ObjectUtil.isAllEmpty(exptime,timeUnit)){ isDelay=true; } if(ObjectUtil.isEmpty(exptime)){ exptime= lockConfig.getInternalLockLeaseTime();; } if (ObjectUtils.isEmpty(timeUnit)){ timeUnit=lockConfig.getTimeUnit(); } //線程被鎖住了,就一直等待 DistributedAssert(obj); Boolean aBoolean = redisTemplate.opsForValue().setIfAbsent("Lock:"+obj.toString(), "1", exptime, timeUnit); log.info("katool=> LockUntil => DistributedLock:{} value:{} extime:{} timeUnit:{}",obj.toString(), "1", exptime, timeUnit); //實現(xiàn)看門狗 if (isDelay){ if (LockUtil.isOpenCorn==false){ //如果同一個項目之前打開過,那么先關閉,避免重復啟動 CronUtil.stop(); //支持秒級別定時任務 CronUtil.setMatchSecond(true); //定時服務啟動 CronUtil.start(); LockUtil.isOpenCorn=true; } Thread thread = Thread.currentThread(); TimeUnit finalTimeUnit = timeUnit; Long finalExptime = exptime; class TempClass{ public String scheduleId; } final TempClass tempClass = new TempClass(); tempClass.scheduleId=CronUtil.schedule("0/30 * * * * ?", new Task() { @SneakyThrows @Override public void execute() { boolean alive = thread.isAlive(); if (alive) { delayDistributedLock(obj, finalExptime>=3?(finalExptime / 3):finalExptime, finalTimeUnit); return; } else { if (tempClass.scheduleId==null||"".equals(tempClass.scheduleId)){ return; } CronUtil.remove(tempClass.scheduleId); DistributedUnLock(obj); return; } } }); } return BooleanUtil.isTrue(aBoolean); } //檢鎖 public void DistributedAssert(Object obj) throws KaToolException { if (ObjectUtils.isEmpty(obj)){ throw new KaToolException(ErrorCode.PARAMS_ERROR," Lock=> 傳入obj為空"); } while(true){ Object o = redisTemplate.opsForValue().get("Lock:" + obj.toString()); if (ObjectUtils.isEmpty(o))return; } } //延期 public boolean delayDistributedLock(Object obj,Long exptime,TimeUnit timeUnit) throws KaToolException { if (ObjectUtils.isEmpty(obj)){ throw new KaToolException(ErrorCode.PARAMS_ERROR," Lock=> 傳入obj為空"); } Boolean aBoolean = redisTemplate.opsForValue().setIfPresent("Lock:"+obj.toString(), "1", exptime, timeUnit); log.info("katool=> LockUntil => delayDistributedLock:{} value:{} extime:{} timeUnit:{}",obj.toString(), "1", exptime, timeUnit); return BooleanUtil.isTrue(aBoolean); } //釋放鎖 public boolean DistributedUnLock(Object obj) throws KaToolException { if (ObjectUtils.isEmpty(obj)){ throw new KaToolException(ErrorCode.PARAMS_ERROR," Lock=> 傳入obj為空"); } Boolean aBoolean = redisTemplate.delete("Lock:" + obj.toString()); log.info("katool=> LockUntil => unDistributedLock:{} isdelete:{} ",obj.toString(),true); return BooleanUtil.isTrue(aBoolean); } //利用枚舉類實現(xiàn)單例模式,枚舉類屬性為靜態(tài)的 private enum SingletonFactory{ Singleton; LockUtil lockUtil; private SingletonFactory(){ lockUtil=new LockUtil(); } public LockUtil getInstance(){ return lockUtil; } } @Bean("LockUtil") public static LockUtil getInstance(){ return SingletonFactory.Singleton.lockUtil; }}
關鍵詞:
圖片版權歸原作者所有,如有侵權請聯(lián)系我們,我們立刻刪除。
新化月報網(wǎng)報料熱線:886 2395@qq.com
新化月報網(wǎng)報料熱線:886 2395@qq.com
最近更新
- 針對RedisTemplate分布式鎖實現(xiàn)WatchDog2023-04-21
- Python面向?qū)ο缶幊?三大特性-繼承-單繼承2023-04-21
- Consul 簡單示例2023-04-21
- 熱點評!Python面向?qū)ο缶幊?魔術方法-__call__和__getattr__方法2023-04-21
- 使用車載空調(diào)該注意什么?車載空調(diào)的工作原理是是什么?2023-04-21
- 池西區(qū)應急局開展2023年汛前災害信息員培訓班|每日報道2023-04-21
- 如何去除地板異味?擦地板要用什么清潔劑?2023-04-21
- 環(huán)球快訊:錢報健康小站丨錯把精華液當眼藥水,大伯差點失明,這事千萬注意2023-04-21
- 世界速訊:“啃讀挑戰(zhàn)”打造區(qū)域教師教育“金字招牌”2023-04-21
- 臺州市路橋區(qū)氣象臺發(fā)布大風黃色預警【Ⅲ級/較重】 當前要聞2023-04-21
- 北京市臍血庫第五次通過血液與生物治療促進協(xié)會AABB復審2023-04-21
- 惠潤攜手中國綠化基金會,以植愈之力守護綠色2023-04-21
- 天天速看:預防癌癥三步走2023-04-21
- 省級科研實驗室落戶 名優(yōu)茶采摘機初亮相?“科技+機械” 引領余杭農(nóng)業(yè)高質(zhì)量發(fā)展 天天看點2023-04-21
- 珈瑪高端數(shù)控加工中心,給您提供專業(yè)的永續(xù)服務2023-04-21
- 擁抱F5.5G,華為將打造全光萬兆之城五大場景 簡訊2023-04-21
- 【環(huán)球熱聞】答復|餐飲經(jīng)營者是否可以以農(nóng)村群體聚餐的形式從事餐飲經(jīng)營活動2023-04-21
- 平定縣氣象局發(fā)布大風藍色預警【Ⅳ級/一般】|天天觀察2023-04-21
- 世界速看:誰是鄂州最佳“剪刀手”?這場比賽有看頭2023-04-21
- 世界觀察:首屆中歐綠色創(chuàng)新發(fā)展大會在江門舉辦2023-04-21
- 商湯絕影許亮:和汽車"商量" 創(chuàng)建艙內(nèi)場景新生態(tài) 世界報資訊2023-04-21
- 河口街道:人間最美四月天 解鎖社區(qū)美好答案2023-04-21
- 春風行動|“零距離”服務企業(yè) “心連心”綠色幫扶2023-04-21
- 河北:電網(wǎng)春季忙“體檢” 迎峰度夏早準備2023-04-21
- 雄安新區(qū):第二季度43個重點項目集中開工 總投資268億元_快資訊2023-04-21
- 請?zhí)崆靶钏〗裉煳錆h這個區(qū)域?qū)⑼K甠環(huán)球看熱訊2023-04-21
- 江河集團(601886)4月21日主力資金凈賣出214.65萬元 全球微速訊2023-04-21
- 《酒釀美好》新書發(fā)布:郎酒新篇章背后的三品路徑2023-04-21
- Whale帷幄發(fā)布“人機協(xié)作”Alivia,AGI重塑營銷科技新范式-世界實時2023-04-21
- MIFU(米夫),真正的美國進口品牌!2023-04-21