利用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{
//此時說明該資源鎖被其他執行緒重置或釋放,已不再擁有鎖的釋放權
//結束
}