分布式鎖服務的設計與實現(xiàn)

分布式鎖服務的設計與實現(xiàn)第一頁，共三十六頁，編輯于2023年，星期日主要內(nèi)容Debby系統(tǒng)整體設計服務器端設計與實現(xiàn)數(shù)據(jù)存儲的設計與實現(xiàn)客戶端設計與實現(xiàn)容錯日志(paxos)的設計與實現(xiàn)第二頁，共三十六頁，編輯于2023年，星期日系統(tǒng)的整體結(jié)構第三頁，共三十六頁，編輯于2023年，星期日Debbyserver實現(xiàn)服務器和客戶端的通信一致性的保證文件、目錄的實現(xiàn)Session的實現(xiàn)事件（Event）管理的實現(xiàn)SnapShot第四頁，共三十六頁，編輯于2023年，星期日服務器和客戶端的通信用戶調(diào)用客戶端庫于服務器通信通過ICE遠程過程調(diào)用實現(xiàn)提供的接口

connect,close,keepAlive,addEvent

getData,setData,create,mkdir,remove,isDir,exists...第五頁，共三十六頁，編輯于2023年，星期日服務器一致性的保證調(diào)用底層Paxos協(xié)議對文件的操作時，把操作提交給PaxosPaxos保證在3臺服務器上操作的一致性Paxos提供的接口

sendProposal()?第六頁，共三十六頁，編輯于2023年，星期日Session的實現(xiàn)服務器維護一個Debby管理器Session通過KeepAlive來保證每個KeepAlive會捎帶事件信息KeepAlive:客戶端等待，服務器受到請求立即返回第七頁，共三十六頁，編輯于2023年，星期日文件、目錄的實現(xiàn)文件、目錄放在內(nèi)存常規(guī)文件系統(tǒng)和臨時文件系統(tǒng)常規(guī)文件系統(tǒng)

map<path,debbyfile>

MemDir<INode>用tree.hh實現(xiàn)臨時文件系統(tǒng)

map<handle,pathlist>第八頁，共三十六頁，編輯于2023年，星期日事件管理的實現(xiàn)Debby維護了一個事件管理器已注冊的事件和已發(fā)生的事件對于已注冊的事件，系統(tǒng)維護一個事件到handle列表的map當心跳發(fā)生時，將發(fā)生的事件返回給訂閱的客戶第九頁，共三十六頁，編輯于2023年，星期日SnapShot只用log恢復服務器帶來的問題：日志將會越來越多恢復時間越來越長本系統(tǒng)采用snapshot(快照)機制解決此問題第十頁，共三十六頁，編輯于2023年，星期日SnapShot將內(nèi)存中的文件系統(tǒng)數(shù)據(jù)結(jié)構直接序列化到磁盤上Snapshot過程執(zhí)行成功后，比snapshot備份時間早的log信息不再需要，可通知paxos將log刪除。第十一頁，共三十六頁，編輯于2023年，星期日SnapShotSnapShot方法增加了額外的復雜性實現(xiàn)SnapShot之前，crush掉的服務器只需從其他機器獲得最近的log即可進行恢復。

實現(xiàn)SnapShot之后，需同時考慮log和snapshot信息。第十二頁，共三十六頁，編輯于2023年，星期日SnapShotclassSnapShot{privatestaticstringDIR_PATH;publicstaticvoidserialize(MemDir&md);publicMemDir&voidUnserialize();}第十三頁，共三十六頁，編輯于2023年，星期日DebbyClient00448161第十四頁，共三十六頁，編輯于2023年，星期日APIvoidcreate(conststring&path,boolephemeral)voidmkdir(conststring&path)voidremove(conststring&path)boolexists(conststring&path)boolisdir(conststring&path)vector<string>list(conststring&path)boollock(conststring&path,boolshare)voidrelease(conststring&path)stringread(conststring&path)voidwrite(conststring&path,conststring&content)voidregcb(conststring&path,EventTypee,shared_ptr<Callback>cb)voidclearcb(conststring&path)第十五頁，共三十六頁，編輯于2023年，星期日LockServerdon’tsupportlockdirectly,clientuseephemeralfiletoimplementlockservice.Whenclientobtainalockonfile,createfilename.lck~ephemeralfile.Iffilealreadyexists,serverwouldthrowaexception,andclientreturnsfailure.Whenclientreleasethelock,simplydeletethefile.第十六頁，共三十六頁，編輯于2023年，星期日Lock(2)Whenclientloseconnectionwithserver,ephemeralfileisdeleted,includingthoseindicatelocks,thuslocksisreleased.Topreventambiguity,userfileisnotallowedtoendwith“~”,sotheyareeasytobedifferentiatedfromfilesusedtoimplementlocks.第十七頁，共三十六頁，編輯于2023年，星期日EventsEventTypeEventCreatedEventRemovedEventChangedEventLockChangedEventArbitraryAlleventwouldapplyonbothdirectoriesandfiles第十八頁，共三十六頁，編輯于2023年，星期日Events(2)Allcallbacksaremanagedbyclient,whenacallbackisfirstregisteredonaevent,theclientregisterstheeventonmaster.Whenaclientreceivesaevent,itinvokeallcallbacksregisteredontheevent.Usercouldcancelallcallbacksonacertainpath,andclientwouldunregistereventsonserver.第十九頁，共三十六頁，編輯于2023年，星期日Event(3)ClientsupplyaCallbackclasstoimplementusecallback,itcontainsapurevirtualfunctionrun().UserimplementtheirownclassbasedonCallback,andimplementtherun()function.Usercouldsaveanynecessaryinformationintheclass.WhenclientinvokeaCallback,itcreateathreadtoinvoketherun()function.第二十頁，共三十六頁，編輯于2023年，星期日ChooseServerTherea5serverinadebbycell,whileonlyoneofthemisthemaster.ClientuseICEmulti-endpointsmechanismtofindtheonlymaster.Clientregistertheaddressofall5serverstoICE,andICEwilltryall5addressestoautomaticallyfindtherightserver,aslongasthereisonlyonemasteratonetime.第二十一頁，共三十六頁，編輯于2023年，星期日GracePeriodWhenthemasterelectionisgoingon,noserviceisavailable,andclientmustwaitfornewmastertobeelected.UseICEretrymechanismtoenablethisfunction,useindicatearetrytimeseriesinwhichICEwillretryconnection,forexample,[3,5,10].Weretryconnectionin[10,30,60]第二十二頁，共三十六頁，編輯于2023年，星期日PaxosFrameworkImplement

forfault-tolerancelog單棟棟10748200網(wǎng)絡實驗室第二十三頁，共三十六頁，編輯于2023年，星期日系統(tǒng)結(jié)構Apiforfault-tolerantlogFromPaxosmadelive第二十四頁，共三十六頁，編輯于2023年，星期日Paxosnormal-caseoperationclientrequetproposalacceptreply012相當于leader客戶的兩種提交方式：1.只能由leader接受請求并提交(我們的做法,chubby)2.所有服務器都可以接受請求，并把這些請求轉(zhuǎn)給leader，由leader提交。(zookeeper)第二十五頁，共三十六頁，編輯于2023年，星期日Paxos消息類型ViewChangeMessage(選leader)HeartBeatMessage(leader租約)PrepareMessage(成leader前的內(nèi)容同步)PrepareOKMessageProposalMessage(提議)AcceptMessage第二十六頁，共三十六頁，編輯于2023年，星期日LeaderElection何時選leader系統(tǒng)啟動時檢測到當前l(fā)eader宕機，并已過leader的租約每次選leader都要提交一個全序的view號View號的產(chǎn)生兩種選leader的方法每臺服務器只提自己當leader可以提別的服務器為leader(我們的實現(xiàn))第二十七頁，共三十六頁，編輯于2023年，星期日PreparePhareLeader被選出后，由leader執(zhí)行，并只執(zhí)行一次保證系統(tǒng)安全的過渡Leadercatchup第二十八頁，共三十六頁，編輯于2023年，星期日ProposalPhare由leader發(fā)起Proposal兩種proposal同步proposal，客戶提交決議后一直等待，直到?jīng)Q定被完成(有可以失敗)異步proposal，客戶提交決議后馬上返回，paxos執(zhí)行完決議后再通知客戶Proposal的限時,重發(fā)第二十九頁，共三十六頁，編輯于2023年，星期日消息的發(fā)送與接收使用boost的asio庫進行網(wǎng)絡通訊采用多播的方式點對點的catchup使用TCP連接接受消息使用異步socket采用多線程多類型的消息傳輸?shù)谌?，共三十六頁，編輯?023年，星期日實驗向paxos不停的提交proposal，讓paxos到保證每臺服務器數(shù)據(jù)的一致性(log)每臺服務器都記log，并且同步寫磁盤對于一個proposal有1秒來還沒答成一致，作提交失敗處理總共4組實驗，每組各進行3次，每次5000個proposal(在單臺機器上模擬)3臺(運行