建站
咨詢
售后
建站咨詢
新聞中心
一、寫在前面
這篇文章再給大家聊一下ZooKeeper實現(xiàn)分布式鎖的原理。
成都創(chuàng)新互聯(lián)是專業(yè)的洪雅網站建設公司，洪雅接單;提供成都網站設計、做網站、成都外貿網站建設公司,網頁設計,網站設計,建網站,PHP網站建設等專業(yè)做網站服務;采用PHP框架,可快速的進行洪雅網站開發(fā)網頁制作和功能擴展;專業(yè)做搜索引擎喜愛的網站,專業(yè)的做網站團隊,希望更多企業(yè)前來合作!
同理，我是直接基于比較常用的Curator這個開源框架，聊一下這個框架對ZooKeeper（以下簡稱zk）分布式鎖的實現(xiàn)。
一般除了大公司是自行封裝分布式鎖框架之外，建議大家用這些開源框架封裝好的分布式鎖實現(xiàn)，這是一個比較快捷省事兒的方式。
二、ZooKeeper分布式鎖機制
接下來我們一起來看看，多客戶端獲取及釋放zk分布式鎖的整個流程及背后的原理。
首先大家看看下面的圖，如果現(xiàn)在有兩個客戶端一起要爭搶zk上的一把分布式鎖，會是個什么場景？
如果大家對zk還不太了解，建議先百度一下，快速了解一些基本概念，比如zk有哪些節(jié)點類型等等。
參見上圖。zk里有一把鎖，這個鎖就是zk上的一個節(jié)點。然后呢，兩個客戶端都要來獲取這個鎖，具體是怎么來獲取呢？
咱們就假設客戶端A搶先一步，對zk發(fā)起了加分布式鎖的請求，這個加鎖請求是用到了zk中的一個特殊的概念，叫做“臨時順序節(jié)點”。
簡單來說，就是直接在"my_lock"這個鎖節(jié)點下，創(chuàng)建一個順序節(jié)點，這個順序節(jié)點有zk內部自行維護的一個節(jié)點序號。
比如說，第一個客戶端來搞一個順序節(jié)點，zk內部會給起個名字叫做：xxx-000001。然后第二個客戶端來搞一個順序節(jié)點，zk可能會起個名字叫做：xxx-000002。大家注意一下，最后一個數(shù)字都是依次遞增的，從1開始逐次遞增。zk會維護這個順序。
所以這個時候，假如說客戶端A先發(fā)起請求，就會搞出來一個順序節(jié)點，大家看下面的圖，Curator框架大概會弄成如下的樣子：
大家看，客戶端A發(fā)起一個加鎖請求，先會在你要加鎖的node下搞一個臨時順序節(jié)點，這一大坨長長的名字都是Curator框架自己生成出來的。
然后，那個最后一個數(shù)字是"1"。大家注意一下，因為客戶端A是第一個發(fā)起請求的，所以給他搞出來的順序節(jié)點的序號是"1"。
接著客戶端A創(chuàng)建完一個順序節(jié)點。還沒完，他會查一下"my_lock"這個鎖節(jié)點下的所有子節(jié)點，并且這些子節(jié)點是按照序號排序的，這個時候他大概會拿到這么一個集合：
接著客戶端A會走一個關鍵性的判斷，就是說：唉！兄弟，這個集合里，我創(chuàng)建的那個順序節(jié)點，是不是排在第一個啊？
如果是的話，那我就可以加鎖了??！因為明明我就是第一個來創(chuàng)建順序節(jié)點的人，所以我就是第一個嘗試加分布式鎖的人??！
bingo！加鎖成功！大家看下面的圖，再來直觀的感受一下整個過程。
接著假如說，客戶端A都加完鎖了，客戶端B過來想要加鎖了，這個時候他會干一樣的事兒：先是在"my_lock"這個鎖節(jié)點下創(chuàng)建一個臨時順序節(jié)點，此時名字會變成類似于：
大家看看下面的圖：
客戶端B因為是第二個來創(chuàng)建順序節(jié)點的，所以zk內部會維護序號為"2"。
接著客戶端B會走加鎖判斷邏輯，查詢"my_lock"鎖節(jié)點下的所有子節(jié)點，按序號順序排列，此時他看到的類似于：
同時檢查自己創(chuàng)建的順序節(jié)點，是不是集合中的第一個？
明顯不是啊，此時第一個是客戶端A創(chuàng)建的那個順序節(jié)點，序號為"01"的那個。所以加鎖失敗！
加鎖失敗以后，客戶端B就會通過ZK的API，對他的上一個順序節(jié)點加一個監(jiān)聽器。zk天然就可以實現(xiàn)對某個節(jié)點的監(jiān)聽。
我們舉例說明，客戶端B的順序節(jié)點是：
他的上一個順序節(jié)點，不就是下面這個嗎？
也就是客戶端A創(chuàng)建的那個順序節(jié)點！
所以，客戶端B會對：
這個節(jié)點加一個監(jiān)聽器，監(jiān)聽這個節(jié)點是否被刪除等變化！
說了那么多，老規(guī)矩，給大家來一張圖，直觀的感受一下：
接著，客戶端A加鎖之后，可能處理了一些代碼邏輯，然后就會釋放鎖。那么，釋放鎖是個什么過程呢？
其實很簡單，就是把自己在zk里創(chuàng)建的那個順序節(jié)點，也就是：
這個節(jié)點給刪除。
刪除了那個節(jié)點之后，zk會負責通知監(jiān)聽這個節(jié)點的監(jiān)聽器，也就是客戶端B之前加的那個監(jiān)聽器，說：兄弟，你監(jiān)聽的那個節(jié)點被刪除了，有人釋放了鎖。
我們一起來看看下面的圖，體會一下這個過程：
此時客戶端B的監(jiān)聽器感知到了上一個順序節(jié)點被刪除，也就是排在他之前的某個客戶端釋放了鎖。
此時，就會通知客戶端B重新嘗試去獲取鎖，也就是獲取"my_lock"節(jié)點下的子節(jié)點集合，此時為：
集合里此時只有客戶端B創(chuàng)建的唯一的一個順序節(jié)點了！
然后呢，客戶端B一判斷，發(fā)現(xiàn)自己居然是集合中的第一個順序節(jié)點，bingo！可以加鎖了！直接完成加鎖，運行后續(xù)的業(yè)務代碼即可，運行完了之后再次釋放鎖。
最后，再給大家來一張圖，大伙兒順著圖仔細的捋一捋這整個過程：
三、總結
其實如果有客戶端C、客戶端D等N個客戶端爭搶一個zk分布式鎖，原理都是類似的。
大家都是上來直接創(chuàng)建一個鎖節(jié)點下的一個接一個的臨時順序節(jié)點
如果自己不是第一個節(jié)點，就對自己上一個節(jié)點加監(jiān)聽器
只要上一個節(jié)點釋放鎖，自己就排到前面去了，相當于是一個排隊機制。
而且用臨時順序節(jié)點的另外一個用意就是，如果某個客戶端創(chuàng)建臨時順序節(jié)點之后，不小心自己宕機了也沒關系，zk感知到那個客戶端宕機，會自動刪除對應的臨時順序節(jié)點，相當于自動釋放鎖，或者是自動取消自己的排隊。
最后，咱們來看下用Curator框架進行加鎖和釋放鎖的一個過程：
其實用開源框架就是這點好，方便。這個Curator框架的zk分布式鎖的加鎖和釋放鎖的實現(xiàn)原理，其實就是上面我們說的那樣子。
但是如果你要手動實現(xiàn)一套那個代碼的話。還是有點麻煩的，要考慮到各種細節(jié)，異常處理等等。所以大家如果考慮用zk分布式鎖，可以參考下本文的思路。?
當前題目：年底裸辭準備面試，我用七張圖畫了ZK分布式鎖
URL分享：http://www.5511xx.com/article/dpppiio.html
