1. 程式人生 > >利用Redis鎖解決併發問題

利用Redis鎖解決併發問題

轉發 https://blog.csdn.net/fuyifang/article/details/83008884

用redis處理高併發是個很常見的方式,因為redis的訪問效率很高(直接訪問記憶體),一般我們會用來處理網站一瞬間的併發量。

那如果要使用redis來進行高併發問題的解決的話,應注意以下幾點:

1、首先我們要先知道,我們在儲存時,應使用redis的setnx方法,不應該使用set方法,因為setnx擁有原子操作命令(正確點說法應該是使用setnx,根據其屬性可以保證共享資源的原子性操作),當資源鎖存在不能設定值,則返回0,而當鎖不存在,則設定鎖,返回1; 但如果使用set方法,則會出現在高併發情況下,程序同時獲取鎖狀態為null,同時設定,鎖之間相互覆蓋,但是倆程序仍在併發執行業務程式碼的情況。

2、為了防止死鎖,我們不應直接使用jedis.setnx(lock, 1) 來進行簡單的加鎖,這樣會導致當程序執行出現問題,鎖未釋放,則其他程序永遠處於阻塞狀態,出現死鎖。 為了避免死鎖,我們在加鎖時帶上時間戳,setnx(lock, 時間戳+超時時間),當發現鎖超時了,便可以對鎖進行重置,避免死鎖。

接下來,實際操作!

設定鎖:

//其中currentTimeMullis為當前時間、valideTime為超時時間,key為資源

//對該資源進行鎖獲取,如果存在鎖則會返回false,不存在則設定值並返回true

boolean lock = redisService.setnx(key, currentTimeMullis+valideTime);

//如果不存在並設定了值,則可以直接返回,因為已經獲取資源鎖成功

//否則,則代表存在這個鎖,則進行鎖是否超時的判斷。獲取該資源的鎖時間,用於判斷是否超時了

String keyTime = redisService.get(key);

if((Long.valueOf(currentTimeMullis)-Long.valueOf(keyTime))>valideTime){

//該判斷代表該資源鎖已經超時,那麼便進行資源鎖的重置,也就是進行資源鎖的重新設定(刪除並重新設定)

//重新設定成功後也返回,因為獲取鎖成功,可以進行操作啦。

}

//如果以上操作都沒有成功,則返回失敗,代表獲取鎖失敗,不可以進行操作。

釋放鎖:

當對資源處理結束後,則呼叫釋放方法釋放鎖資源

(經提醒,我發現我這裡少了個判斷邏輯…)

//在刪除前,應該先對該資源鎖進行獲取,判斷值與此時釋放鎖的執行緒所攜帶的值是否相等,也就是我們上面建立時用的currentTimeMullis+valideTime。

String keyLockTime = redisService.get(key);

if(keyLockTime!=null&&keyLockTime.equals(currentTimeMullis+valideTime)){

//此時鎖還由當前執行緒保持則釋放鎖

redisService.del(key);

}else{

//此時說明該資源鎖被其他執行緒重置或釋放,已不再擁有鎖的釋放權

//結束

}