真实的国产乱ⅩXXX66竹夫人,五月香六月婷婷激情综合,亚洲日本VA一区二区三区,亚洲精品一区二区三区麻豆

成都創(chuàng)新互聯(lián)網(wǎng)站制作重慶分公司

如何進(jìn)行Zookeeper分布式鎖的代碼實(shí)現(xiàn)-創(chuàng)新互聯(lián)

這期內(nèi)容當(dāng)中小編將會給大家?guī)碛嘘P(guān)如何進(jìn)行Zookeeper分布式鎖的代碼實(shí)現(xiàn),文章內(nèi)容豐富且以專業(yè)的角度為大家分析和敘述,閱讀完這篇文章希望大家可以有所收獲。

讓客戶滿意是我們工作的目標(biāo),不斷超越客戶的期望值來自于我們對這個行業(yè)的熱愛。我們立志把好的技術(shù)通過有效、簡單的方式提供給客戶,將通過不懈努力成為客戶在信息化領(lǐng)域值得信任、有價值的長期合作伙伴,公司提供的服務(wù)項(xiàng)目有:申請域名、虛擬空間、營銷軟件、網(wǎng)站建設(shè)、西鄉(xiāng)網(wǎng)站維護(hù)、網(wǎng)站推廣。

前言

Zookeeper分布式鎖的代碼實(shí)現(xiàn)

在上一篇博客中,從思路上已經(jīng)分析了Zookeeper如何幫助我們實(shí)現(xiàn)分布式鎖,我們直接來看代碼:

[分布式客戶端]

如何進(jìn)行Zookeeper分布式鎖的代碼實(shí)現(xiàn)

[獲取分布式鎖的方法lock:初始化ZK]

如何進(jìn)行Zookeeper分布式鎖的代碼實(shí)現(xiàn)

[獲取分布式鎖的方法lock:創(chuàng)建臨時節(jié)點(diǎn)與判斷最小路徑]

如何進(jìn)行Zookeeper分布式鎖的代碼實(shí)現(xiàn)

[main測試]

如何進(jìn)行Zookeeper分布式鎖的代碼實(shí)現(xiàn)

[運(yùn)行結(jié)果]

如何進(jìn)行Zookeeper分布式鎖的代碼實(shí)現(xiàn)

需要注意的是,即便監(jiān)控到了比自己序號小的節(jié)點(diǎn)的刪除Watcher,也需要再次確認(rèn)下!

從結(jié)果上,看的很清楚,各個線程有序獲得鎖。

zkclient

zkclient是在zookeeper原生API基礎(chǔ)上做了一點(diǎn)封裝,簡化了ZK的復(fù)雜性。

來看代碼:

如何進(jìn)行Zookeeper分布式鎖的代碼實(shí)現(xiàn)

我們觀察下zkclient的使用,和以前基于zookeeper的原生API有哪些區(qū)別呢?

第一,原生API需要我們利用CountDownLatch來確保ZK的初始化,現(xiàn)在zkclient幫助我們屏蔽掉了這個細(xì)節(jié)

第二,原生API是不可以遞歸創(chuàng)建節(jié)點(diǎn)的,而zkclient可以幫助我們遞歸創(chuàng)建不存在的父節(jié)點(diǎn),還可以遞歸刪除

第三,支持序列化操作,上面的代碼你大概可以看出一些端倪,就是我們從操作byte[]到操作String了。(事實(shí)上,在zkclient中你只需要實(shí)現(xiàn)ZkSerializer接口,就可以完成Object到byte[]的轉(zhuǎn)換,雖然如此,但是實(shí)際開發(fā)中,利用JSON也挺好的?。?/p>

第四,還有最重要的一點(diǎn)就是,zkclient將對節(jié)點(diǎn)的操作和對節(jié)點(diǎn)的監(jiān)控分離開了,在原生API中2者是耦合在一起的!從思想上來看,便于理解;從代碼上來看,也簡潔些(如果寫在一起,頭都大了);更加方便的是,zkclient替我們完成了重復(fù)watch的功能!

[watch訂閱機(jī)制]

如何進(jìn)行Zookeeper分布式鎖的代碼實(shí)現(xiàn)

看到?jīng)]有,是不是有點(diǎn)像MQ的訂閱機(jī)制,非常好用!【但是也有點(diǎn)不太完美,子節(jié)點(diǎn)的數(shù)據(jù)變更為什么沒有監(jiān)控呢,這有點(diǎn)不符合人性??!還好有Curator...】

但是呢,我們知道ZK是有很多應(yīng)用場景的,比如實(shí)現(xiàn)分布式鎖,zkclient并沒有替我們進(jìn)行封裝,但是Curator框架可以幫助我們做到!

Curator

為了更好實(shí)現(xiàn)Java操作Zookeeper服務(wù)器,后來出現(xiàn)Curator框架,功能非常強(qiáng)大,目前已經(jīng)是Apache的頂級項(xiàng)目,有很多豐富的特性,比如session超時重連,主從選舉,分布式計數(shù)器,分布式鎖等,非常有利于Zookeeper復(fù)雜場景下的開發(fā)。

POM文件:

如何進(jìn)行Zookeeper分布式鎖的代碼實(shí)現(xiàn)

增刪改查:

如何進(jìn)行Zookeeper分布式鎖的代碼實(shí)現(xiàn)Curator框架使用鏈?zhǔn)骄幊田L(fēng)格,易讀性很強(qiáng)!

注意,不論是原生的API,還是基于zkclient的API,都是提供的connectTimeout,而Curator提供了sessionTimeout,功能很強(qiáng)大。

如何進(jìn)行Zookeeper分布式鎖的代碼實(shí)現(xiàn)

無論是原生的API,還是zkclient,都是支持異步回調(diào)的,但是Curator框架在支持異步回調(diào)的同時,增加了線程池供我們優(yōu)化!

[NodeCacheListener]

如何進(jìn)行Zookeeper分布式鎖的代碼實(shí)現(xiàn)

[PathChildrenCacheListener]

如何進(jìn)行Zookeeper分布式鎖的代碼實(shí)現(xiàn)

對于Curator而言,為了解決重復(fù)Watch的問題,它引入了一種全新的思想:Cache與ZK SERVER比對的機(jī)制。不論是原生的API,還是基于ZKCLIENT的,其實(shí)它們解決思路都是重復(fù)注冊!

思路決定出路!Curator通過事件驅(qū)動將客戶端的Cache與ZK SERVER的數(shù)據(jù)比對,就自然而然的解決了重復(fù)WATCH的功能!為什么Curator能成為Apache的頂級項(xiàng)目呢,我想大概就是因?yàn)樗呐c眾不同的設(shè)計思想!

在Curator中,有2種Listener,一個是監(jiān)控節(jié)點(diǎn)的NodeCacheListener,一個是監(jiān)控子節(jié)點(diǎn)的PathChildrenCacheListener。PathChildernCacheListener可以監(jiān)控子節(jié)點(diǎn)的新增、修改、刪除,非常好用!

上述就是小編為大家分享的如何進(jìn)行Zookeeper分布式鎖的代碼實(shí)現(xiàn)了,如果剛好有類似的疑惑,不妨參照上述分析進(jìn)行理解。如果想知道更多相關(guān)知識,歡迎關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道。

另外有需要云服務(wù)器可以了解下創(chuàng)新互聯(lián)cdcxhl.cn,海內(nèi)外云服務(wù)器15元起步,三天無理由+7*72小時售后在線,公司持有idc許可證,提供“云服務(wù)器、裸金屬服務(wù)器、高防服務(wù)器、香港服務(wù)器、美國服務(wù)器、虛擬主機(jī)、免備案服務(wù)器”等云主機(jī)租用服務(wù)以及企業(yè)上云的綜合解決方案,具有“安全穩(wěn)定、簡單易用、服務(wù)可用性高、性價比高”等特點(diǎn)與優(yōu)勢,專為企業(yè)上云打造定制,能夠滿足用戶豐富、多元化的應(yīng)用場景需求。


標(biāo)題名稱:如何進(jìn)行Zookeeper分布式鎖的代碼實(shí)現(xiàn)-創(chuàng)新互聯(lián)
分享網(wǎng)址:http://weahome.cn/article/csshgj.html

其他資訊

在線咨詢

微信咨詢

電話咨詢

028-86922220(工作日)

18980820575(7×24)

提交需求

返回頂部