Redis的setNX分布式鎖超時(shí)時(shí)間失效 -1問題及解決

更新時(shí)間：2023年01月09日 15:08:46 作者：終遇你..

這篇文章主要介紹了Redis的setNX分布式鎖超時(shí)時(shí)間失效 -1問題及解決方案，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教

Redis setNX分布式鎖超時(shí)時(shí)間失效 -1

使用SETNX加鎖

加鎖的思路：

如果 key 不存在，將 key 設(shè)置為 value，如果 key 已存在，則 SETNX 不做任何動(dòng)作。

使用 RedisTemplate 操作Redis

? ? @Autowired
? ? private RedisTemplate redisTemplate;
?
? ? @RequestMapping("/setNx")
? ? public String setNx() {
? ? ? ? String key = "redis_nx_test";
? ? ? ? String value = "1";
?
? ? ? ? boolean res = redisTemplate.getConnectionFactory().getConnection().setNX(key.getBytes(), value.getBytes());
? ? ? ? log.info("setNX:{}", res);
? ? ? ? if (res) {
? ? ? ? ? ? redisTemplate.getConnectionFactory().getConnection().expire(key.getBytes(), 50);
? ? ? ? ? ? log.info("設(shè)置過期時(shí)間");
? ? ? ? }
?
? ? ? ? return "success";
? ? }

解決死鎖

考慮一種情況，如果進(jìn)程獲得鎖后，斷開了與 Redis 的連接（可能是進(jìn)程掛掉，或者網(wǎng)絡(luò)中斷），如果沒有有效的釋放鎖的機(jī)制，那么其他進(jìn)程都會(huì)處于一直等待的狀態(tài)，即出現(xiàn)“死鎖”。

目前考慮是使用定時(shí)任務(wù)進(jìn)行掃描處理超時(shí)時(shí)間為 -1的key

@Scheduled(initialDelay = 1000,fixedDelay = 1000*60*30)
? ? public void deleteExceptionKey(){
? ? ? ? String key = "redis_nx_test";
? ? ? ??
? ? ? ? //返回 -2 ? 表示這個(gè)key已過期，已不存在
? ? ? ? //返回 -1 ? 表示這個(gè)key沒有設(shè)置有效期
? ? ? ? //返回0以上的值 ? 表示是這個(gè)key的剩余有效時(shí)間
? ? ? ? Long l = redisTemplate.opsForValue().getOperations().getExpire(key);
? ? ? ? log.info("Expire:{}", l);
? ? ? ? if(l == -1){
? ? ? ? ? ?Boolean b = ?redisTemplate.delete(key);
? ? ? ? ? ? log.info("刪除key:{},{}", key,b);
? ? ? ? }
? ? }

Redis分布式鎖，超時(shí)問題的處理

分布式鎖超時(shí)問題解決方案，主要是基于redission。Redisson是架設(shè)在Redis基礎(chǔ)上的一個(gè)Java駐內(nèi)存數(shù)據(jù)網(wǎng)格（In-Memory Data Grid）。充分的利用了Redis鍵值數(shù)據(jù)庫提供的一系列優(yōu)勢(shì)，基于Java實(shí)用工具包中常用接口，為使用者提供了一系列具有分布式特性的常用工具類。

redis實(shí)現(xiàn)分布式鎖，主要是通過SETNX命令，設(shè)置一組 key,value。在同一時(shí)刻只能有一個(gè)線程設(shè)置成功，該線程獲得了分布式鎖。