redis鎖處理並發問題


redis鎖處理並發問題

redis鎖處理高並發問題十分常見,使用的時候常見有幾種錯誤,和對應的解決辦法。

  • set方式
  • setnx方式
  • setnx+getset方式

set方式 
加鎖:redis中set一個值,set(lock,1); 
並發處理:其他線程必須拿到這個值,才可以往下進行,否則等待。

while(jedis.exists(lock)){
        Thread.sleep(500);
    }
    set(lock,1);
    執行業務代碼;
    jedis.del(lock);

釋放鎖:執行完業務代碼之后,釋放redis鎖,jedis.del(lock) 
防止死鎖:set(lock,1) —>3秒后未釋放,則自動釋放setex(lock, 3, 1) 
問題:高並發情況下,進程同時獲取鎖狀態為null,同時設置,鎖之間相互覆蓋,但是倆進程仍在並發執行業務代碼。 


setnx方式 
后來發現有setnx的原子操作命令,鎖存在不能設置值,返回0;鎖不存在,則設置鎖,返回1; 
加鎖:jedis.setnx(lock, 1) 
並發處理:

while(jedis.setnx(lock,1)==0){
    Thread.sleep(300);
}
執行業務代碼;
jedis.del(lock);

釋放鎖:執行完業務代碼之后,釋放redis鎖,jedis.del(lock) 
問題:當進程執行出現問題,鎖未釋放,則其他進程永遠處於阻塞狀態,出現死鎖。 
防止死鎖:加鎖時帶上時間戳,setnx(lock, 時間戳+超時時間)

while(jedis.setnx(lock,now+超時時間)==0){
        if(jedis.get(lock)<now){
            jedis.del(lock);
            jedis.setnx(lock,now+超時時間);
            break;
        }else{
            Thread.sleep(300);
        }
    }
    執行業務代碼;
    jedis.del(lock);

問題:當倆進程同時讀到發現鎖超時,都去釋放鎖,相互覆蓋,則倆進程同時獲得鎖,仍並發執行業務代碼。 

setnx+getset方式 
為解決上面的問題,可以使用getset命令,getset設置鍵值,並返回原來的鍵值。 
加鎖:setnx(lock, 時間戳+超時時間) 
解決並發

while(jedis.setnx(lock, now+超時時間)==0){
    if(now>jedis.get(lock) && now>jedis.getset(lock, now+超時時間)){
        break;
    }else{
        Thread.sleep(300);
    }
}
執行業務代碼;
jedis.del(lock);

釋放鎖:jedis.del(lock);


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM