點(diǎn)擊上方藍(lán)色字體，選擇“標(biāo)星公眾號(hào)”

優(yōu)質(zhì)文章，第一時(shí)間送達(dá)

? 作者?|? BarryW

來(lái)源 |? urlify.cn/JrAZBb

76套java從入門到精通實(shí)戰(zhàn)課程分享

分布式鎖三種實(shí)現(xiàn)方式：

1. 基于數(shù)據(jù)庫(kù)實(shí)現(xiàn)分布式鎖；

2. 基于緩存（Redis等）實(shí)現(xiàn)分布式鎖；

3. 基于Zookeeper實(shí)現(xiàn)分布式鎖；

一，基于數(shù)據(jù)庫(kù)實(shí)現(xiàn)分布式鎖

1. 悲觀鎖

利用select … where … for update 排他鎖

注意: 其他附加功能與實(shí)現(xiàn)一基本一致，這里需要注意的是“where name=lock ”，name字段必須要走索引，否則會(huì)鎖表。有些情況下，比如表不大，mysql優(yōu)化器會(huì)不走這個(gè)索引，導(dǎo)致鎖表問(wèn)題。

2. 樂(lè)觀鎖

所謂樂(lè)觀鎖與前邊最大區(qū)別在于基于CAS思想，是不具有互斥性，不會(huì)產(chǎn)生鎖等待而消耗資源，操作過(guò)程中認(rèn)為不存在并發(fā)沖突，只有update version失敗后才能覺(jué)察到。我們的搶購(gòu)、秒殺就是用了這種實(shí)現(xiàn)以防止超賣。
通過(guò)增加遞增的版本號(hào)字段實(shí)現(xiàn)樂(lè)觀鎖

二，基于緩存（Redis等）實(shí)現(xiàn)分布式鎖

1. 使用命令介紹：
（1）SETNX
SETNX key val：當(dāng)且僅當(dāng)key不存在時(shí)，set一個(gè)key為val的字符串，返回1；若key存在，則什么都不做，返回0。
（2）expire
expire key timeout：為key設(shè)置一個(gè)超時(shí)時(shí)間，單位為second，超過(guò)這個(gè)時(shí)間鎖會(huì)自動(dòng)釋放，避免死鎖。
（3）delete
delete key：刪除key

在使用Redis實(shí)現(xiàn)分布式鎖的時(shí)候，主要就會(huì)使用到這三個(gè)命令。

2. 實(shí)現(xiàn)思想：
（1）獲取鎖的時(shí)候，使用setnx加鎖，并使用expire命令為鎖添加一個(gè)超時(shí)時(shí)間，超過(guò)該時(shí)間則自動(dòng)釋放鎖，鎖的value值為一個(gè)隨機(jī)生成的UUID，通過(guò)此在釋放鎖的時(shí)候進(jìn)行判斷。
（2）獲取鎖的時(shí)候還設(shè)置一個(gè)獲取的超時(shí)時(shí)間，若超過(guò)這個(gè)時(shí)間則放棄獲取鎖。
（3）釋放鎖的時(shí)候，通過(guò)UUID判斷是不是該鎖，若是該鎖，則執(zhí)行delete進(jìn)行鎖釋放。

3. 分布式鎖的簡(jiǎn)單實(shí)現(xiàn)代碼：

1?/**
??2??*?分布式鎖的簡(jiǎn)單實(shí)現(xiàn)代碼??4??*/
??5?public?class?DistributedLock?{
??6?
??7?????private?final?JedisPool?jedisPool;
??8?
??9?????public?DistributedLock(JedisPool?jedisPool)?{
?10?????????this.jedisPool?=?jedisPool;
?11?????}
?12?
?13?????/**
?14??????*?加鎖
?15??????*?@param?lockName???????鎖的key
?16??????*?@param?acquireTimeout?獲取超時(shí)時(shí)間
?17??????*?@param?timeout????????鎖的超時(shí)時(shí)間
?18??????*?@return?鎖標(biāo)識(shí)
?19??????*/
?20?????public?String?lockWithTimeout(String?lockName,?long?acquireTimeout,?long?timeout)?{
?21?????????Jedis?conn?=?null;
?22?????????String?retIdentifier?=?null;
?23?????????try?{
?24?????????????//?獲取連接
?25?????????????conn?=?jedisPool.getResource();
?26?????????????//?隨機(jī)生成一個(gè)value
?27?????????????String?identifier?=?UUID.randomUUID().toString();
?28?????????????//?鎖名，即key值
?29?????????????String?lockKey?=?"lock:"?+?lockName;
?30?????????????//?超時(shí)時(shí)間，上鎖后超過(guò)此時(shí)間則自動(dòng)釋放鎖
?31?????????????int?lockExpire?=?(int)?(timeout?/?1000);
?32?
?33?????????????//?獲取鎖的超時(shí)時(shí)間，超過(guò)這個(gè)時(shí)間則放棄獲取鎖
?34?????????????long?end?=?System.currentTimeMillis()?+?acquireTimeout;
?35?????????????while?(System.currentTimeMillis()??36?????????????????if?(conn.setnx(lockKey,?identifier)?==?1)?{
?37?????????????????????conn.expire(lockKey,?lockExpire);
?38?????????????????????//?返回value值，用于釋放鎖時(shí)間確認(rèn)
?39?????????????????????retIdentifier?=?identifier;
?40?????????????????????return?retIdentifier;
?41?????????????????}
?42?????????????????//?返回-1代表key沒(méi)有設(shè)置超時(shí)時(shí)間，為key設(shè)置一個(gè)超時(shí)時(shí)間
?43?????????????????if?(conn.ttl(lockKey)?==?-1)?{
?44?????????????????????conn.expire(lockKey,?lockExpire);
?45?????????????????}
?46?
?47?????????????????try?{
?48?????????????????????Thread.sleep(10);
?49?????????????????}?catch?(InterruptedException?e)?{
?50?????????????????????Thread.currentThread().interrupt();
?51?????????????????}
?52?????????????}
?53?????????}?catch?(JedisException?e)?{
?54?????????????e.printStackTrace();
?55?????????}?finally?{
?56?????????????if?(conn?!=?null)?{
?57?????????????????conn.close();
?58?????????????}
?59?????????}
?60?????????return?retIdentifier;
?61?????}
?62?
?63?????/**
?64??????*?釋放鎖
?65??????*?@param?lockName???鎖的key
?66??????*?@param?identifier?釋放鎖的標(biāo)識(shí)
?67??????*?@return
?68??????*/
?69?????public?boolean?releaseLock(String?lockName,?String?identifier)?{
?70?????????Jedis?conn?=?null;
?71?????????String?lockKey?=?"lock:"?+?lockName;
?72?????????boolean?retFlag?=?false;
?73?????????try?{
?74?????????????conn?=?jedisPool.getResource();
?75?????????????while?(true)?{
?76?????????????????//?監(jiān)視lock，準(zhǔn)備開(kāi)始事務(wù)
?77?????????????????conn.watch(lockKey);
?78?????????????????//?通過(guò)前面返回的value值判斷是不是該鎖，若是該鎖，則刪除，釋放鎖
?79?????????????????if?(identifier.equals(conn.get(lockKey)))?{
?80?????????????????????Transaction?transaction?=?conn.multi();
?81?????????????????????transaction.del(lockKey);
?82?????????????????????List