基于Zookeeper開源客戶端Curator實(shí)現(xiàn)分布式鎖

在實(shí)際生產(chǎn)中,尤其是分布式環(huán)境下蚯姆,因?yàn)槲覀冞壿嬚嬲幚淼臉I(yè)務(wù)數(shù)據(jù)是只有一份的硫麻,接口并發(fā)時(shí)勢(shì)必會(huì)出現(xiàn)并發(fā)問題蝇完,使得業(yè)務(wù)數(shù)據(jù)不正確官硝,這個(gè)時(shí)候就需要一種類似于鎖的東西來保證數(shù)據(jù)的冪等性,比如秒殺業(yè)務(wù)四敞。實(shí)現(xiàn)分布式鎖的方式非常多泛源,zookeeper、redis忿危、數(shù)據(jù)庫(kù)等均可,如果使用zookeeper原生方式來實(shí)現(xiàn)的話還是比較復(fù)雜的没龙,基于這種場(chǎng)景铺厨,我們利用Apache的開源客戶端Curator來實(shí)現(xiàn)分布式鎖。首先來回顧一下zookeeper的相關(guān)知識(shí):

zookeeper的四種節(jié)點(diǎn)類型

1硬纤、持久化節(jié)點(diǎn) :所謂持久節(jié)點(diǎn)解滓,是指在節(jié)點(diǎn)創(chuàng)建后,就一直存在筝家,直到有刪除操作來主動(dòng)清除這個(gè)節(jié)點(diǎn)——不會(huì)因?yàn)閯?chuàng)建該節(jié)點(diǎn)的客戶端會(huì)話失效而消失洼裤。

2、持久化順序節(jié)點(diǎn):這類節(jié)點(diǎn)的基本特性和上面的節(jié)點(diǎn)類型是一致的溪王。額外的特性是腮鞍,在ZK中值骇,每個(gè)父節(jié)點(diǎn)會(huì)為他的第一級(jí)子節(jié)點(diǎn)維護(hù)一份時(shí)序,會(huì)記錄每個(gè)子節(jié)點(diǎn)創(chuàng)建的先后順序移国≈ù瘢基于這個(gè)特性,在創(chuàng)建子節(jié)點(diǎn)的時(shí)候迹缀,可以設(shè)置這個(gè)屬性使碾,那么在創(chuàng)建節(jié)點(diǎn)過程中,ZK會(huì)自動(dòng)為給定節(jié)點(diǎn)名加上一個(gè)數(shù)字后綴祝懂,作為新的節(jié)點(diǎn)名票摇。這個(gè)數(shù)字后綴的范圍是整型的最大值。基于持久順序節(jié)點(diǎn)原理的經(jīng)典應(yīng)用-分布式唯一ID生成器砚蓬。

3兄朋、臨時(shí)節(jié)點(diǎn):和持久節(jié)點(diǎn)不同的是,臨時(shí)節(jié)點(diǎn)的生命周期和客戶端會(huì)話綁定怜械。也就是說颅和,如果客戶端會(huì)話失效,那么這個(gè)節(jié)點(diǎn)就會(huì)自動(dòng)被清除掉缕允。注意峡扩,這里提到的是會(huì)話失效,而非連接斷開障本。另外教届,在臨時(shí)節(jié)點(diǎn)下面不能創(chuàng)建子節(jié)點(diǎn),集群zk環(huán)境下驾霜,同一個(gè)路徑的臨時(shí)節(jié)點(diǎn)只能成功創(chuàng)建一個(gè)案训,利用這個(gè)特性可以用來實(shí)現(xiàn)master-slave選舉

4粪糙、臨時(shí)順序節(jié)點(diǎn):相對(duì)于臨時(shí)節(jié)點(diǎn)而言强霎,臨時(shí)順序節(jié)點(diǎn)比臨時(shí)節(jié)點(diǎn)多了個(gè)有序,也就是說每創(chuàng)建一個(gè)節(jié)點(diǎn)都會(huì)加上節(jié)點(diǎn)對(duì)應(yīng)的序號(hào)蓉冈,先創(chuàng)建成功城舞,序號(hào)越小。其經(jīng)典應(yīng)用場(chǎng)景為實(shí)現(xiàn)分布式鎖寞酿。

監(jiān)視器(watcher)

當(dāng)zookeeper創(chuàng)建一個(gè)節(jié)點(diǎn)時(shí)家夺,會(huì)注冊(cè)一個(gè)該節(jié)點(diǎn)的監(jiān)視器,當(dāng)節(jié)點(diǎn)狀態(tài)發(fā)生改變時(shí)伐弹,watch會(huì)被觸發(fā)拉馋,zooKeeper將會(huì)向客戶端發(fā)送一條通知(就一條,因?yàn)閣atch只能被觸發(fā)一次)。

原理

Curator內(nèi)部是通過InterProcessMutex(可重入鎖)來在zookeeper中創(chuàng)建臨時(shí)有序節(jié)點(diǎn)實(shí)現(xiàn)的煌茴,之前說過随闺,如果通過臨時(shí)節(jié)點(diǎn)及watch機(jī)制實(shí)現(xiàn)鎖的話,這種方式存在一個(gè)比較大的問題:所有取鎖失敗的進(jìn)程都在等待景馁、監(jiān)聽創(chuàng)建的節(jié)點(diǎn)釋放板壮,很容易發(fā)生"羊群效應(yīng)",zookeeper的壓力是比較大的合住,而臨時(shí)有序節(jié)點(diǎn)就很好的避免了這個(gè)問題绰精,Curator內(nèi)部就是創(chuàng)建的臨時(shí)有序節(jié)點(diǎn)。

基本原理:

創(chuàng)建臨時(shí)有序節(jié)點(diǎn)透葛,每個(gè)線程均能創(chuàng)建節(jié)點(diǎn)成功笨使,但是其序號(hào)不同,只有序號(hào)最小的可以擁有鎖僚害,其它線程只需要監(jiān)聽比自己序號(hào)小的節(jié)點(diǎn)狀態(tài)即可

基本思路如下:

1硫椰、在你指定的節(jié)點(diǎn)下創(chuàng)建一個(gè)鎖目錄lock;

2萨蚕、線程X進(jìn)來獲取鎖在lock目錄下靶草,并創(chuàng)建臨時(shí)有序節(jié)點(diǎn);

3岳遥、線程X獲取lock目錄下所有子節(jié)點(diǎn)奕翔,并獲取比自己小的兄弟節(jié)點(diǎn),如果不存在比自己小的節(jié)點(diǎn)浩蓉,說明當(dāng)前線程序號(hào)最小派继,順利獲取鎖;

4捻艳、此時(shí)線程Y進(jìn)來創(chuàng)建臨時(shí)節(jié)點(diǎn)并獲取兄弟節(jié)點(diǎn) 驾窟,判斷自己是否為最小序號(hào)節(jié)點(diǎn),發(fā)現(xiàn)不是认轨,于是設(shè)置監(jiān)聽(watch)比自己小的節(jié)點(diǎn)(這里是為了發(fā)生上面說的羊群效應(yīng))绅络;

5、線程X執(zhí)行完邏輯好渠,刪除自己的節(jié)點(diǎn)昨稼,線程Y監(jiān)聽到節(jié)點(diǎn)有變化,進(jìn)一步判斷自己是已經(jīng)是最小節(jié)點(diǎn)拳锚,順利獲取鎖。

?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請(qǐng)聯(lián)系作者
  • 序言:七十年代末寻行,一起剝皮案震驚了整個(gè)濱河市霍掺,隨后出現(xiàn)的幾起案子,更是在濱河造成了極大的恐慌,老刑警劉巖杆烁,帶你破解...
    沈念sama閱讀 221,273評(píng)論 6 515
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件牙丽,死亡現(xiàn)場(chǎng)離奇詭異,居然都是意外死亡兔魂,警方通過查閱死者的電腦和手機(jī)烤芦,發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 94,349評(píng)論 3 398
  • 文/潘曉璐 我一進(jìn)店門,熙熙樓的掌柜王于貴愁眉苦臉地迎上來析校,“玉大人构罗,你說我怎么就攤上這事≈遣#” “怎么了遂唧?”我有些...
    開封第一講書人閱讀 167,709評(píng)論 0 360
  • 文/不壞的土叔 我叫張陵,是天一觀的道長(zhǎng)吊奢。 經(jīng)常有香客問我盖彭,道長(zhǎng),這世上最難降的妖魔是什么页滚? 我笑而不...
    開封第一講書人閱讀 59,520評(píng)論 1 296
  • 正文 為了忘掉前任召边,我火速辦了婚禮,結(jié)果婚禮上裹驰,老公的妹妹穿的比我還像新娘隧熙。我一直安慰自己,他們只是感情好邦马,可當(dāng)我...
    茶點(diǎn)故事閱讀 68,515評(píng)論 6 397
  • 文/花漫 我一把揭開白布贱鼻。 她就那樣靜靜地躺著,像睡著了一般滋将。 火紅的嫁衣襯著肌膚如雪邻悬。 梳的紋絲不亂的頭發(fā)上,一...
    開封第一講書人閱讀 52,158評(píng)論 1 308
  • 那天随闽,我揣著相機(jī)與錄音父丰,去河邊找鬼。 笑死掘宪,一個(gè)胖子當(dāng)著我的面吹牛蛾扇,可吹牛的內(nèi)容都是我干的。 我是一名探鬼主播魏滚,決...
    沈念sama閱讀 40,755評(píng)論 3 421
  • 文/蒼蘭香墨 我猛地睜開眼镀首,長(zhǎng)吁一口氣:“原來是場(chǎng)噩夢(mèng)啊……” “哼!你這毒婦竟也來了鼠次?” 一聲冷哼從身側(cè)響起更哄,我...
    開封第一講書人閱讀 39,660評(píng)論 0 276
  • 序言:老撾萬(wàn)榮一對(duì)情侶失蹤芋齿,失蹤者是張志新(化名)和其女友劉穎,沒想到半個(gè)月后成翩,有當(dāng)?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體觅捆,經(jīng)...
    沈念sama閱讀 46,203評(píng)論 1 319
  • 正文 獨(dú)居荒郊野嶺守林人離奇死亡,尸身上長(zhǎng)有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點(diǎn)故事閱讀 38,287評(píng)論 3 340
  • 正文 我和宋清朗相戀三年麻敌,在試婚紗的時(shí)候發(fā)現(xiàn)自己被綠了栅炒。 大學(xué)時(shí)的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片。...
    茶點(diǎn)故事閱讀 40,427評(píng)論 1 352
  • 序言:一個(gè)原本活蹦亂跳的男人離奇死亡术羔,死狀恐怖赢赊,靈堂內(nèi)的尸體忽然破棺而出,到底是詐尸還是另有隱情聂示,我是刑警寧澤域携,帶...
    沈念sama閱讀 36,122評(píng)論 5 349
  • 正文 年R本政府宣布,位于F島的核電站鱼喉,受9級(jí)特大地震影響秀鞭,放射性物質(zhì)發(fā)生泄漏。R本人自食惡果不足惜扛禽,卻給世界環(huán)境...
    茶點(diǎn)故事閱讀 41,801評(píng)論 3 333
  • 文/蒙蒙 一锋边、第九天 我趴在偏房一處隱蔽的房頂上張望。 院中可真熱鬧编曼,春花似錦豆巨、人聲如沸。這莊子的主人今日做“春日...
    開封第一講書人閱讀 32,272評(píng)論 0 23
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽(yáng)。三九已至熊户,卻和暖如春萍膛,著一層夾襖步出監(jiān)牢的瞬間,已是汗流浹背嚷堡。 一陣腳步聲響...
    開封第一講書人閱讀 33,393評(píng)論 1 272
  • 我被黑心中介騙來泰國(guó)打工蝗罗, 沒想到剛下飛機(jī)就差點(diǎn)兒被人妖公主榨干…… 1. 我叫王不留,地道東北人蝌戒。 一個(gè)月前我還...
    沈念sama閱讀 48,808評(píng)論 3 376
  • 正文 我出身青樓串塑,卻偏偏與公主長(zhǎng)得像,于是被迫代替她去往敵國(guó)和親北苟。 傳聞我的和親對(duì)象是個(gè)殘疾皇子桩匪,可洞房花燭夜當(dāng)晚...
    茶點(diǎn)故事閱讀 45,440評(píng)論 2 359