版權(quán)說明:本文檔由用戶提供并上傳,收益歸屬內(nèi)容提供方,若內(nèi)容存在侵權(quán),請(qǐng)進(jìn)行舉報(bào)或認(rèn)領(lǐng)
文檔簡介
ZooKeeper
分布式應(yīng)用的協(xié)調(diào)器ZooKeeper
分布式應(yīng)用的協(xié)調(diào)器主要內(nèi)容ZooKeeper的數(shù)據(jù)模型ZooKeeper的數(shù)據(jù)讀寫機(jī)制ZooKeeper的使用方法主要內(nèi)容ZooKeeper的數(shù)據(jù)模型為什么需要ZooKeeper?大部分分布式應(yīng)用需要一個(gè)主控、協(xié)調(diào)器或控制器來管理物理分布的子進(jìn)程(如資源、任務(wù)分配等)目前,大部分應(yīng)用需要開發(fā)私有的協(xié)調(diào)程序,缺乏一個(gè)通用的機(jī)制協(xié)調(diào)程序的反復(fù)編寫浪費(fèi),且難以形成通用、伸縮性好的協(xié)調(diào)器ZooKeeper:提供通用的分布式鎖服務(wù),用以協(xié)調(diào)分布式應(yīng)用(如,為HBase提供服務(wù))為什么需要ZooKeeper?大部分分布式應(yīng)用需要一個(gè)主控、ZooKeeper的數(shù)據(jù)模型層次化目錄結(jié)構(gòu)命名符合常規(guī)文件系統(tǒng)規(guī)范,
不能包含/節(jié)點(diǎn)Znode可以包含數(shù)據(jù)與子
節(jié)點(diǎn)客戶端應(yīng)用可在節(jié)點(diǎn)上設(shè)置
監(jiān)視器節(jié)點(diǎn)數(shù)據(jù)不支持部分讀寫,
而是一次性完整讀寫臨時(shí)性節(jié)點(diǎn)ZooKeeper的數(shù)據(jù)模型層次化目錄結(jié)構(gòu)節(jié)點(diǎn)創(chuàng)建屬性臨時(shí)性節(jié)點(diǎn)創(chuàng)建的節(jié)點(diǎn)不是持久節(jié)點(diǎn)一旦與客戶端的會(huì)話結(jié)束,節(jié)點(diǎn)自動(dòng)刪除Sequence創(chuàng)建節(jié)點(diǎn)時(shí),編號(hào)自動(dòng)加1例如x-1,x-2,s-3,x-4等節(jié)點(diǎn)創(chuàng)建屬性臨時(shí)性節(jié)點(diǎn)ZooKeeper的讀寫機(jī)制ZooKeeper是一個(gè)由多個(gè)Server組成的集群一個(gè)Leader,多個(gè)Follower每個(gè)Server都保存了一份數(shù)據(jù)副本全局?jǐn)?shù)據(jù)一致分布式讀寫更新請(qǐng)求轉(zhuǎn)發(fā),由Leader實(shí)施ZooKeeper的讀寫機(jī)制ZooKeeper是一個(gè)由多個(gè)S使用ZooKeeper的約定更新請(qǐng)求順序執(zhí)行來自同一個(gè)Client的更新請(qǐng)求按其發(fā)送順序依次執(zhí)行數(shù)據(jù)更新原子性一次數(shù)據(jù)更新要么成功,要么失敗。不存在部分?jǐn)?shù)據(jù)寫入成功或失敗的情況全局唯一數(shù)據(jù)視圖Client無論連接哪個(gè)Server,數(shù)據(jù)視圖都是一致的實(shí)時(shí)性在一定時(shí)間范圍內(nèi),Client能讀到最新數(shù)據(jù)使用ZooKeeper的約定更新請(qǐng)求順序執(zhí)行ZooKeeper的APIStringcreate(path,data,acl,flags)voiddelete(path,expectedVersion)StatsetData(path,data,expectedVersion)(data,Stat)getData(path,watch)Statexists(path,watch)String[]getChildren(path,watch)voidsync(path)StatsetACL(path,acl,expectedVersion)(acl,Stat)getACL(path)包含監(jiān)視器調(diào)用參數(shù)均包含節(jié)點(diǎn)路徑ZooKeeper的APIStringcreate(pat對(duì)比:Chubby的APIhandleOpen(path,…)?Close(handle,…)?GetContentsAndStat(handle,…),GetStat(handle),ReadDir(handle,…)?SetContents(handle),SetACL(handle,…)?Delete(path)?Acquire(),TryAcquire(),Release()?GetSequencer(),SetSequencer(),CheckSequencer()?僅Open包含節(jié)點(diǎn)路徑,生成handle供其他API使用對(duì)比:Chubby的APIhandleOpen(path,如何使用ZooKeeper?關(guān)于ZooKeeper的鎖服務(wù)這里的“鎖”并非對(duì)ZooKeeper的資源加鎖,用于對(duì)第三方資源加鎖用例多個(gè)第三方分布式Server需要使用某第三方資源,誰獲取了ZooKeeper中的獨(dú)占鎖,誰就可以使用第三方資源,否則等待如何使用ZooKeeper?關(guān)于ZooKeeper的鎖服務(wù)如何使用ZooKeeper?Leader選舉用于在多個(gè)節(jié)點(diǎn)中選取主控,如GFS中對(duì)外服務(wù)Master節(jié)點(diǎn)的選取1)getData(“/servers/leader”,true)2)如果讀取成功則從數(shù)據(jù)中獲取leader信息,退出3)讀取失敗,執(zhí)行create(“.../servers/leader”,hostname,EPHEMERAL)(注意節(jié)點(diǎn)類型)如果創(chuàng)建成功則自己成為leader,寫入信息,退出5)如果寫入失敗,則返回步驟1getData設(shè)置了監(jiān)視器,如果數(shù)據(jù)發(fā)生變化,會(huì)重啟上述流程如何使用ZooKeeper?Leader選舉1)getDat如何使用ZooKeeper?獨(dú)占鎖如果分布式應(yīng)用需要對(duì)某資源獨(dú)占使用,可以申請(qǐng)獨(dú)占鎖1)id=create(“.../locks/x-”,SEQUENCE|EPHEMERAL)2)getChildren(“.../locks/”,false)3)如果id是第一個(gè)節(jié)點(diǎn),則獲取獨(dú)占鎖,退出4)exists(nameoflastchildbeforeid,true)(注意,設(shè)置了監(jiān)視器)5)如果id之前不存在節(jié)點(diǎn),返回步驟26)等待通知7)返回步驟2有且僅有一個(gè)Client可以獲取到獨(dú)占鎖如何使用ZooKeeper?獨(dú)占鎖1)id=create如何使用ZooKeeper?共享鎖1)id=create(“.../locks/s-”,SEQUENCE|EPHEMERAL)2)getChildren(“.../locks/”,false)3)如果id之前沒有x-類型的節(jié)點(diǎn),獲取共享鎖,退出4)exists(nameofthelastx-beforeid,true)5)如果id之前不存在x-類型節(jié)點(diǎn),返回步驟26)等待事件通知7)返回步驟2如果之前沒有獨(dú)占鎖,就可以獲取共享鎖如何使用ZooKeeper?共享鎖1)id=create如何使用ZooKeeper?其他應(yīng)用(小數(shù)據(jù)存儲(chǔ))例如,GFS中master如何獲知ChunkServer信息?基于ZooKeeper的實(shí)現(xiàn)方法ChunkServer執(zhí)行如下操作:1)id=create(“.../chunkservers/cs-”,SEQUENCE|EPHEMERAL)2)向節(jié)點(diǎn)id中寫入ChunkServer元信息Master執(zhí)行如下操作:1)getChildren(“.../chunkservers/”,true)2)讀取子節(jié)點(diǎn)數(shù)據(jù),獲知ChunkServer元信息如何使用ZooKeeper?其他應(yīng)用(小數(shù)據(jù)存儲(chǔ))基于Zoo其他ZooKeeper的會(huì)話Client通過發(fā)送PING請(qǐng)求與Server保持會(huì)話通過PING,可以同時(shí)獲知Client與Server是否活躍ZooKeeper的監(jiān)視器監(jiān)視器是一次性的,一次事件通知后就作廢其他ZooKeeper的會(huì)話性能ZooKeeper適用于主要負(fù)載為讀的應(yīng)用場(chǎng)合性能ZooKeeper適用于主要ZooKeeper
分布式應(yīng)用的協(xié)調(diào)器ZooKeeper
分布式應(yīng)用的協(xié)調(diào)器主要內(nèi)容ZooKeeper的數(shù)據(jù)模型ZooKeeper的數(shù)據(jù)讀寫機(jī)制ZooKeeper的使用方法主要內(nèi)容ZooKeeper的數(shù)據(jù)模型為什么需要ZooKeeper?大部分分布式應(yīng)用需要一個(gè)主控、協(xié)調(diào)器或控制器來管理物理分布的子進(jìn)程(如資源、任務(wù)分配等)目前,大部分應(yīng)用需要開發(fā)私有的協(xié)調(diào)程序,缺乏一個(gè)通用的機(jī)制協(xié)調(diào)程序的反復(fù)編寫浪費(fèi),且難以形成通用、伸縮性好的協(xié)調(diào)器ZooKeeper:提供通用的分布式鎖服務(wù),用以協(xié)調(diào)分布式應(yīng)用(如,為HBase提供服務(wù))為什么需要ZooKeeper?大部分分布式應(yīng)用需要一個(gè)主控、ZooKeeper的數(shù)據(jù)模型層次化目錄結(jié)構(gòu)命名符合常規(guī)文件系統(tǒng)規(guī)范,
不能包含/節(jié)點(diǎn)Znode可以包含數(shù)據(jù)與子
節(jié)點(diǎn)客戶端應(yīng)用可在節(jié)點(diǎn)上設(shè)置
監(jiān)視器節(jié)點(diǎn)數(shù)據(jù)不支持部分讀寫,
而是一次性完整讀寫臨時(shí)性節(jié)點(diǎn)ZooKeeper的數(shù)據(jù)模型層次化目錄結(jié)構(gòu)節(jié)點(diǎn)創(chuàng)建屬性臨時(shí)性節(jié)點(diǎn)創(chuàng)建的節(jié)點(diǎn)不是持久節(jié)點(diǎn)一旦與客戶端的會(huì)話結(jié)束,節(jié)點(diǎn)自動(dòng)刪除Sequence創(chuàng)建節(jié)點(diǎn)時(shí),編號(hào)自動(dòng)加1例如x-1,x-2,s-3,x-4等節(jié)點(diǎn)創(chuàng)建屬性臨時(shí)性節(jié)點(diǎn)ZooKeeper的讀寫機(jī)制ZooKeeper是一個(gè)由多個(gè)Server組成的集群一個(gè)Leader,多個(gè)Follower每個(gè)Server都保存了一份數(shù)據(jù)副本全局?jǐn)?shù)據(jù)一致分布式讀寫更新請(qǐng)求轉(zhuǎn)發(fā),由Leader實(shí)施ZooKeeper的讀寫機(jī)制ZooKeeper是一個(gè)由多個(gè)S使用ZooKeeper的約定更新請(qǐng)求順序執(zhí)行來自同一個(gè)Client的更新請(qǐng)求按其發(fā)送順序依次執(zhí)行數(shù)據(jù)更新原子性一次數(shù)據(jù)更新要么成功,要么失敗。不存在部分?jǐn)?shù)據(jù)寫入成功或失敗的情況全局唯一數(shù)據(jù)視圖Client無論連接哪個(gè)Server,數(shù)據(jù)視圖都是一致的實(shí)時(shí)性在一定時(shí)間范圍內(nèi),Client能讀到最新數(shù)據(jù)使用ZooKeeper的約定更新請(qǐng)求順序執(zhí)行ZooKeeper的APIStringcreate(path,data,acl,flags)voiddelete(path,expectedVersion)StatsetData(path,data,expectedVersion)(data,Stat)getData(path,watch)Statexists(path,watch)String[]getChildren(path,watch)voidsync(path)StatsetACL(path,acl,expectedVersion)(acl,Stat)getACL(path)包含監(jiān)視器調(diào)用參數(shù)均包含節(jié)點(diǎn)路徑ZooKeeper的APIStringcreate(pat對(duì)比:Chubby的APIhandleOpen(path,…)?Close(handle,…)?GetContentsAndStat(handle,…),GetStat(handle),ReadDir(handle,…)?SetContents(handle),SetACL(handle,…)?Delete(path)?Acquire(),TryAcquire(),Release()?GetSequencer(),SetSequencer(),CheckSequencer()?僅Open包含節(jié)點(diǎn)路徑,生成handle供其他API使用對(duì)比:Chubby的APIhandleOpen(path,如何使用ZooKeeper?關(guān)于ZooKeeper的鎖服務(wù)這里的“鎖”并非對(duì)ZooKeeper的資源加鎖,用于對(duì)第三方資源加鎖用例多個(gè)第三方分布式Server需要使用某第三方資源,誰獲取了ZooKeeper中的獨(dú)占鎖,誰就可以使用第三方資源,否則等待如何使用ZooKeeper?關(guān)于ZooKeeper的鎖服務(wù)如何使用ZooKeeper?Leader選舉用于在多個(gè)節(jié)點(diǎn)中選取主控,如GFS中對(duì)外服務(wù)Master節(jié)點(diǎn)的選取1)getData(“/servers/leader”,true)2)如果讀取成功則從數(shù)據(jù)中獲取leader信息,退出3)讀取失敗,執(zhí)行create(“.../servers/leader”,hostname,EPHEMERAL)(注意節(jié)點(diǎn)類型)如果創(chuàng)建成功則自己成為leader,寫入信息,退出5)如果寫入失敗,則返回步驟1getData設(shè)置了監(jiān)視器,如果數(shù)據(jù)發(fā)生變化,會(huì)重啟上述流程如何使用ZooKeeper?Leader選舉1)getDat如何使用ZooKeeper?獨(dú)占鎖如果分布式應(yīng)用需要對(duì)某資源獨(dú)占使用,可以申請(qǐng)獨(dú)占鎖1)id=create(“.../locks/x-”,SEQUENCE|EPHEMERAL)2)getChildren(“.../locks/”,false)3)如果id是第一個(gè)節(jié)點(diǎn),則獲取獨(dú)占鎖,退出4)exists(nameoflastchildbeforeid,true)(注意,設(shè)置了監(jiān)視器)5)如果id之前不存在節(jié)點(diǎn),返回步驟26)等待通知7)返回步驟2有且僅有一個(gè)Client可以獲取到獨(dú)占鎖如何使用ZooKeeper?獨(dú)占鎖1)id=create如何使用ZooKeeper?共享鎖1)id=create(“.../locks/s-”,SEQUENCE|EPHEMERAL)2)getChildren(“.../locks/”,false)3)如果id之前沒有x-類型的節(jié)點(diǎn),獲取共享鎖,退出4)exists(name
溫馨提示
- 1. 本站所有資源如無特殊說明,都需要本地電腦安裝OFFICE2007和PDF閱讀器。圖紙軟件為CAD,CAXA,PROE,UG,SolidWorks等.壓縮文件請(qǐng)下載最新的WinRAR軟件解壓。
- 2. 本站的文檔不包含任何第三方提供的附件圖紙等,如果需要附件,請(qǐng)聯(lián)系上傳者。文件的所有權(quán)益歸上傳用戶所有。
- 3. 本站RAR壓縮包中若帶圖紙,網(wǎng)頁內(nèi)容里面會(huì)有圖紙預(yù)覽,若沒有圖紙預(yù)覽就沒有圖紙。
- 4. 未經(jīng)權(quán)益所有人同意不得將文件中的內(nèi)容挪作商業(yè)或盈利用途。
- 5. 人人文庫網(wǎng)僅提供信息存儲(chǔ)空間,僅對(duì)用戶上傳內(nèi)容的表現(xiàn)方式做保護(hù)處理,對(duì)用戶上傳分享的文檔內(nèi)容本身不做任何修改或編輯,并不能對(duì)任何下載內(nèi)容負(fù)責(zé)。
- 6. 下載文件中如有侵權(quán)或不適當(dāng)內(nèi)容,請(qǐng)與我們聯(lián)系,我們立即糾正。
- 7. 本站不保證下載資源的準(zhǔn)確性、安全性和完整性, 同時(shí)也不承擔(dān)用戶因使用這些下載資源對(duì)自己和他人造成任何形式的傷害或損失。
最新文檔
- Γ-FE2O3行業(yè)商業(yè)計(jì)劃書
- 八年級(jí)勞動(dòng)教育《細(xì)品茶之清香趣識(shí)茶之文化》教學(xué)設(shè)計(jì)
- 黑龍江省雞西市八年級(jí)生物下冊(cè) 7.1.4 鳥的生殖和發(fā)育教案 (新版)新人教版
- 安全教育教案集
- 《航空航天飛行器用電磁純鐵(征求意見稿)》
- 勞動(dòng)課教案 洗碗筷勞動(dòng)
- 二級(jí)建造師《法律法規(guī)》10天夯基計(jì)劃
- 2025年江蘇省淮安市清江中學(xué)高三(實(shí)驗(yàn)班)第一次模擬生物試題試卷含解析
- 2025年黑龍江省鐵力市第一中學(xué)高三生物試題寒假作業(yè)含解析
- 2025年河南省三門峽市靈寶市實(shí)驗(yàn)高級(jí)中學(xué)高三3月網(wǎng)絡(luò)模擬考試生物試題含解析
- 關(guān)于自主研究開發(fā)(合作委托開發(fā))XXXX立項(xiàng)的決議
- 電梯安裝作業(yè)安全要求
- 辦公室室內(nèi)裝修工程技術(shù)規(guī)范
- 第5章人力資源管理中的倫理問題PPT課件
- 材料加工中的數(shù)值模擬方法-微觀組織數(shù)值模擬(8)
- 隧道襯砌拱頂帶模注漿技術(shù)要求
- 小學(xué)入門數(shù)獨(dú)100題(簡單)
- 小學(xué)音樂《3唱得幸福落滿坡》PPT課件-(2)ppt課件
- 有關(guān)我國跨學(xué)科教育的研究綜述
- 《數(shù)據(jù)結(jié)構(gòu)》課程標(biāo)準(zhǔn)
- 新材料研發(fā)中心項(xiàng)目項(xiàng)目建議書寫作范本
評(píng)論
0/150
提交評(píng)論