redis分布式鎖(簡易版)

2021-10-01 04:47:24 字數 2007 閱讀 6309

上一章介紹了redis鍵失效後觸發的事件,本章寫到如何做乙個簡單的redis分布式鎖

當多人同時對一條redis記憶體資料進行操作時上鎖,首先保證只有乙個人能消費,其次保證不會被重複消費

1、當多個消費者同時收到觸發事件後,為了保證消費的原子性,那麼收到訊息後首先的操作就應該是上鎖,同時上鎖時,只有乙個人能上鎖成功,那麼只有上鎖成功的那個人才能進行消費,其餘消費者直接return。

2、對鎖進行時間設定,所謂時間設定就是上鎖後多長時間內這個鎖固定別人都無法上

3、上鎖原理就是相當於同時對乙個redis 插入乙個相同的key,不同的value

/**

* 上鎖

* @param key

* @param requestid

* @param expire

* @return

*/public

boolean

setlock

(string key,string requestid,

long expire)

; string result = redistemplate.

execute

(callback)

;return

!stringutils.

isempty

(result);}

catch

(exception e)

return

false

;}

jediscommands.set方法有4個引數:

key:鍵 (需要上鎖的鍵)注意:這個鍵最好自己寫在配置檔案或者列舉中單獨維護,不要用這個失效觸發的鍵,我之前用過,但是不好用,不知道為什麼

requestid:每個客戶端的唯一id (uuid)

nx:保證key不存在才會set

px:key具有過期時間

expiretime:key的具體過期時間 (毫秒)

上鎖成功後會有乙個boolean的值返回,得知是否上鎖成功

/**

* 得到鎖的值

* @param key

* @return

*/public string get

(string key)

; string result = redistemplate.

execute

(callback)

;return result;

}catch

(exception e)

return"";

}

通過key得到鎖的值,上鎖時的uuid

/**

* 釋放鎖

* @param key

* @param requestid

* @return

*/public

boolean

releaselock

(string key,string requestid)

// 單機模式

else

if(nativeconnection instanceof

jedis

)return

0l;}

; long result = redistemplate.

execute

(callback)

;return result != null && result >0;

}catch

(exception e)

return

false

;}

解鎖,根據key和uuid進行解鎖,通過lua指令碼,能保證原子性

//解鎖指令碼

public

static

final string unlock_lua;

static

基於AOP和Redis實現的簡易版分布式鎖

所以我準備通過分布式鎖去解決這個問題。分布式鎖一般解決如下兩類問題 1 效率性問題,比如重 簡訊,重複生成同樣的訂單等。2 正確性問題,比如在某乙個請求扣款的同時不允許其他請求同時去扣款。當然,題目中寫了簡易版是因為,這次的分布式鎖只準備解決效率性的問題,而不解決正確性的問題。之所以基於redis,...

redis分布式鎖

redis分布式鎖 直接上 我寫了四個redis分布式鎖的方法,大家可以提個意見 第一種方法 redis分布式鎖 param timeout public void lock long timeout thread.sleep 100 catch exception e override publi...

Redis分布式鎖

分布式鎖一般有三種實現方式 1.資料庫樂觀鎖 2.基於redis的分布式鎖 3.基於zookeeper的分布式鎖.首先,為了確保分布式鎖可用,我們至少要確保鎖的實現同時滿足以下四個條件 互斥性。在任意時刻,只有乙個客戶端能持有鎖。不會發生死鎖。即使有乙個客戶端在持有鎖的期間崩潰而沒有主動解鎖,也能保...