您好,登錄后才能下訂單哦!
這篇文章主要講解了“redis加鎖的方式有哪些”,文中的講解內(nèi)容簡單清晰,易于學(xué)習(xí)與理解,下面請大家跟著小編的思路慢慢深入,一起來研究和學(xué)習(xí)“redis加鎖的方式有哪些”吧!
redis常見的加鎖命令分別是INCR、SETNX、SET
這種鎖的加鎖思路是:
key不存在,那么key的值會先被初始化為0,然后再執(zhí)行INCR操作進(jìn)行加一。
然后其它用戶在執(zhí)行INCR操作進(jìn)行加一時,如果返回的數(shù)值大于1,說明這個key正在被鎖定使用。
1、 客戶端A請求服務(wù)器獲取key的值為1表示獲取了鎖
2、 客戶端B也去請求服務(wù)器獲取key的值為2表示獲取鎖失敗
3、 客戶端A執(zhí)行代碼完成,刪除鎖
4、 客戶端B在等待一段時間后在去請求的時候獲取key的值為1表示獲取鎖成功
5、 客戶端B執(zhí)行代碼完成,刪除鎖
$redis->incr($key); $redis->expire($key, $ttl); //設(shè)置生成時間為1秒
具體使用命令:
127.0.0.1:6379>INCR keyName
這種加鎖的思路是,如果key不存在,將key設(shè)置為value,如果key存在,則SETNX不做任何動作。
SETNX是SET if Not eXists的縮寫。
1、 客戶端A請求服務(wù)器設(shè)置key的值,如果設(shè)置成功就表示加鎖成功
2、 客戶端B也去請求服務(wù)器設(shè)置key的值,如果返回失敗,那么就代表加鎖失敗
3、 客戶端A執(zhí)行代碼完成,刪除鎖
4、 客戶端B在等待一段時間后在去請求設(shè)置key的值,設(shè)置成功
5、 客戶端B執(zhí)行代碼完成,刪除鎖
$redis->setNX($key, $value); $redis->expire($key, $ttl);
具體使用命令:
redis> SETNX keyName value (integer) 1
設(shè)置成功,返回1;設(shè)置失敗,返回0
上面兩種方法都有一個問題,會發(fā)現(xiàn),都需要設(shè)置 key 過期。
那么為什么要設(shè)置key過期呢?
如果請求執(zhí)行因為某些原因意外退出了,導(dǎo)致創(chuàng)建了鎖但是沒有刪除鎖,那么這個鎖將一直存在,以至于以后緩存再也得不到更新。
于是乎我們需要給鎖加一個過期時間以防不測。
但是借助 Expire 來設(shè)置就不是原子性操作了。
所以還可以通過事務(wù)來確保原子性,但是還是有些問題,所以官方就引用了另外一個,使用 SET 命令本身已經(jīng)從版本 2.6.12 開始包含了設(shè)置過期時間的功能。
1、 客戶端A請求服務(wù)器設(shè)置key的值,如果設(shè)置成功就表示加鎖成功
2、 客戶端B也去請求服務(wù)器設(shè)置key的值,如果返回失敗,那么就代表加鎖失敗
3、 客戶端A執(zhí)行代碼完成,刪除鎖
4、 客戶端B在等待一段時間后在去請求設(shè)置key的值,設(shè)置成功
5、 客戶端B執(zhí)行代碼完成,刪除鎖
$redis->set($key, $value, array('nx', 'ex' => $ttl)); //ex表示秒
具體使用:
redis>set key value NX EX max-lock-time 實現(xiàn)加鎖
命令解釋:
key
:key就是redis的key值作為鎖的標(biāo)識,value在這里作為客戶端的標(biāo)識,只有key-value都比配才有刪除鎖的權(quán)利【保證安全性】
max-lock-time
:通過max-lock-time設(shè)置過期時間保證不會出現(xiàn)死鎖【避免死鎖】
NX
:只有這個key不存才的時候才會進(jìn)行操作,if not exists;
EX
:設(shè)置key的過期時間為秒,具體時間由第5個參數(shù)決定
加鎖代碼:
Jedis jedis = new Jedis("127.0.0.1", 6379); private static final String SUCCESS = "OK"; /** * 加鎖操作 * @param key 鎖標(biāo)識 * @param value 客戶端標(biāo)識 * @param timeOut 過期時間 */ public Boolean lock(String key,String value,Long timeOut){ String var1 = jedis.set(key,value,"NX","EX",timeOut); if(LOCK_SUCCESS.equals(var1)){ return true; } return false; }
解鎖代碼:
Jedis jedis = new Jedis("127.0.0.1", 6379); private static final Long UNLOCK_SUCCESS = 1L; /** * 解鎖操作 * @param key 鎖標(biāo)識 * @param value 客戶端標(biāo)識 * @return */ public static Boolean unLock(String key,String value){ String luaScript = "if redis.call(\"get\",KEYS[1]) == ARGV[1] then return redis.call(\"del\",KEYS[1]) else return 0 end"; Object var2 = jedis.eval(luaScript,Collections.singletonList(key), Collections.singletonList(value)); if (UNLOCK_SUCCESS == var2) { return true; } return false; }
luaScript 這個字符串是個lua腳本,代表的意思是如果根據(jù)key拿到的value跟傳入的value相同就執(zhí)行del,否則就返回0【保證安全性】
jedis.eval(String,list,list);這個命令就是去執(zhí)行l(wèi)ua腳本,KEYS的集合就是第二個參數(shù),ARGV的集合就是第三參數(shù)【保證解鎖的原子操作】
上述就實現(xiàn)了怎么使用redis去正確的實現(xiàn)分布式鎖,但是有個小缺陷就是鎖過期時間要設(shè)置為多少合適,這個其實還是需要去根據(jù)業(yè)務(wù)場景考量一下的。
感謝各位的閱讀,以上就是“redis加鎖的方式有哪些”的內(nèi)容了,經(jīng)過本文的學(xué)習(xí)后,相信大家對redis加鎖的方式有哪些這一問題有了更深刻的體會,具體使用情況還需要大家實踐驗證。這里是億速云,小編將為大家推送更多相關(guān)知識點(diǎn)的文章,歡迎關(guān)注!
免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點(diǎn)不代表本網(wǎng)站立場,如果涉及侵權(quán)請聯(lián)系站長郵箱:is@yisu.com進(jìn)行舉報,并提供相關(guān)證據(jù),一經(jīng)查實,將立刻刪除涉嫌侵權(quán)內(nèi)容。