redis鎖處理並發問題
Redis鎖處理高並發問題十分常見,使用的時候常見有幾種錯誤,和對應的解決辦法,在此進行自己的總結和整理。
- set方式
- setnx方式
- setnx+getset方式
set方式
作為redis小白,一開始能想到的使用redis加鎖的方式就是set。
加鎖:redis中set一個值,set(lock,1);
並發處理:其他線程必須拿到這個值,才可以往下進行,否則等待。
while(jedis.exists(lock)){ Thread.sleep(500); } set(lock,1); 執行業務代碼; jedis.del(lock);
- 1
- 2
- 3
- 4
- 5
- 6
- 1
- 2
- 3
- 4
- 5
- 6
釋放鎖:執行完業務代碼之后,釋放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);
- 1
- 2
- 3
- 4
- 5
- 1
- 2
- 3
- 4
- 5
釋放鎖:執行完業務代碼之后,釋放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);
- 1
- 2
- 3
- 4
- 5
- 6
- 7
- 9
- 10
問題:當倆進程同時讀到發現鎖超時,都去釋放鎖,相互覆蓋,則倆進程同時獲得鎖,仍並發執行業務代碼。
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);
- 1
- 25
- 7
釋放鎖:jedis.del(lock);
http://blog.csdn.net/d1562901685/article/details/54881862