一. 什麼是分布式鎖
分布式鎖其實可以理解為:控制分布式系統有序的去對共享資源進行操作,通過互斥來保持一致性。
舉個不太恰當的例子:假設共享的資源就是乙個房子,裡面有各種書,分布式系統就是要進屋看書的人,分布式鎖就是保證這個房子只有乙個門並且一次只有乙個人可以進,而且門只有一把鑰匙。然後許多人要去看書,可以,排隊,第乙個人拿著鑰匙把門開啟進屋看書並且把門鎖上,然後第二個人沒有鑰匙,那就等著,等第乙個出來,然後你在拿著鑰匙進去,然後就是以此類推
二. 保證分布式鎖滿足的四個條件
1.互斥性
2.安全性
3.避免死鎖
4.容錯
三. 使用redis實現分布式鎖
加鎖:123
4567
891011
1213
1415
1617
1819
2021
2223
2425
2627
2829
3031
jedis jedis =
new
jedis(
"127.0.0.1"
,
6379
);
private
static
final
string success =
"ok"
;
/**
* 加鎖操作
* @param key 鎖標識
* @param value 客戶端標識
* @param timeout 過期時間
*/
public
boolean lock(string key,string value,long timeout)
return
false
;
}
解讀:解鎖12
3456
78910
1112
1314
1516
1718
1920
2122
2324
2526
2728
2930
3132
33jedis jedis =
new
jedis(
"127.0.0.1"
,
6379
);
private
static
final
long unlock_success = 1l;
/**
* 解鎖操作
* @param key 鎖標識
* @param value 客戶端標識
* @return
*/
public
static
boolean unlock(string key,string value)
return
false
;
}
解讀:上述就實現了怎麼使用redis去正確的實現分布式鎖,但是有個小缺陷就是鎖過期時間要設定為多少合適,這個其實還是需要去根據業務場景考量一下的
上面那只是講了加鎖與解鎖的操作,試想一下如果在業務中去拿鎖如果沒有拿到是應該阻塞著一直等待還是直接返回,這個問題其實可以寫乙個重試機制,根據重試次數和重試時間做乙個迴圈去拿鎖,當然這個重試的次數和時間設多少合適,是需要根據自身業務去衡量的12
3456
78910
1112
1314
1516
1718
1920
2122
2324
2526
2728
2930
3132
3334
3536
3738
3940
4142
4344
4546
47/**
* 重試機制
* @param key 鎖標識
* @param value 客戶端標識
* @param timeout 過期時間
* @param retry 重試次數
* @param sleeptime 重試間隔時間
* @return
*/
public
boolean lockretry(string key,string value,long timeout,integer retry,long sleeptime)
thread.sleep(sleeptime);
}
}
catch
(exception e)
return
flag;
}
到這,用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的分布式鎖.首先,為了確保分布式鎖可用,我們至少要確保鎖的實現同時滿足以下四個條件 互斥性。在任意時刻,只有乙個客戶端能持有鎖。不會發生死鎖。即使有乙個客戶端在持有鎖的期間崩潰而沒有主動解鎖,也能保...
redis分布式鎖
使用redis的setnx命令實現分布式鎖 redis為單程序單執行緒模式,採用佇列模式將併發訪問變成序列訪問,且多個客戶端對redis的連線並不存在競爭關係。redis的setnx命令可以方便的實現分布式鎖。setnx key value 將key的值設為value,當且僅當key不存在。如給定的...