在ZooKeeper客戶端與服務(wù)端成功完成建立連接后聋迎，就建立了一個(gè)會(huì)話阁簸。ZooKeeper會(huì)話在整個(gè)運(yùn)行期間的生命周期中淌铐，會(huì)在不同的會(huì)話狀態(tài)之間進(jìn)行切換澜驮，這些狀態(tài)一般可以分為CONNECTING、CONNECTED艺蝴、RECONNECTING猬腰、RECONNECTED和CLOSE等。
Session 是ZooKeeper中最重要的概念之一猜敢。它包括4個(gè)基本屬性：
sessionID:會(huì)話ID姑荷，唯一標(biāo)識(shí)一個(gè)會(huì)話，每次客戶端創(chuàng)建新會(huì)話的時(shí)候缩擂，ZooKeeper都會(huì)為其分配一個(gè)全局唯一的sessionID鼠冕。TimeOut：會(huì)話超時(shí)時(shí)間】瓒ⅲ客戶端在構(gòu)造ZooKeeper實(shí)例的時(shí)候懈费，會(huì)配置一個(gè)sessionTimeOut參數(shù)用于指定會(huì)話超時(shí)時(shí)間。ZooKeeper客戶端向服務(wù)器發(fā)送這個(gè)超時(shí)時(shí)間后博脑，服務(wù)器會(huì)根據(jù)自己的超時(shí)時(shí)間限制最終確定會(huì)話的超時(shí)時(shí)間憎乙。TickTime：下次會(huì)話超時(shí)時(shí)間點(diǎn)。為了便于ZooKeeper對(duì)會(huì)話實(shí)行“分桶策略”管理叉趣，同時(shí)也是為了高效低耗地實(shí)現(xiàn)的超時(shí)檢測(cè)與清理泞边，ZooKeeper會(huì)為每個(gè)會(huì)話標(biāo)識(shí)一個(gè)下次會(huì)話超時(shí)時(shí)間。isClosing：該屬性用于標(biāo)記一個(gè)會(huì)話是否被關(guān)閉疗杉。通常當(dāng)服務(wù)端檢測(cè)到一個(gè)會(huì)話已經(jīng)超時(shí)失效的時(shí)候阵谚，會(huì)將該會(huì)話的isClosing屬性標(biāo)記為“已關(guān)閉”，這樣就能確保不再處理來(lái)自該會(huì)話的新請(qǐng)求了烟具。
SessionTracker
SessionTracker是ZooKeeper服務(wù)端的會(huì)話管理器梢什，負(fù)責(zé)會(huì)話的創(chuàng)建、管理和清理工作朝聋。每一個(gè)會(huì)話在SessionTracker內(nèi)部都保留三份嗡午，具體如下。
sessionById：這是一個(gè)HashMap<Long,SessionImpl>類型的數(shù)據(jù)結(jié)構(gòu)玖翅，用于根據(jù)sessionID來(lái)管理Session實(shí)體翼馆。sessionWithTimeout：這是一個(gè)ConcurrentHashMap<Long,Integer>類型的數(shù)據(jù)結(jié)構(gòu)，用于根據(jù)sessionID來(lái)管理會(huì)話的超時(shí)時(shí)間金度。該數(shù)據(jù)結(jié)構(gòu)和ZooKeeper內(nèi)存數(shù)據(jù)庫(kù)相連通应媚，會(huì)被定期持久化到快照文件中。sessionSets：這是一個(gè)HashMap<Long,SessionSet>類型的數(shù)據(jù)結(jié)構(gòu)猜极，用于根據(jù)下次會(huì)話超時(shí)時(shí)間點(diǎn)來(lái)歸檔會(huì)話中姜，便于進(jìn)行會(huì)話管理和超時(shí)檢查。在下文“分桶策略”會(huì)話管理的介紹中跟伏，我們還會(huì)對(duì)該數(shù)據(jù)結(jié)構(gòu)進(jìn)行詳細(xì)講解丢胚。
創(chuàng)建連接
服務(wù)端對(duì)于客戶端的“會(huì)話創(chuàng)建”處理，大體可以分為四大步驟受扳，分別是處理ConnectRequest請(qǐng)求携龟、會(huì)話創(chuàng)建、處理器鏈路處理和會(huì)話響應(yīng)勘高。在ZooKeeper服務(wù)端首先將會(huì)由NIOServerCnxn來(lái)負(fù)責(zé)接收來(lái)自客戶端的“會(huì)話創(chuàng)建”請(qǐng)求峡蟋，并反序列化出ConnectRequest請(qǐng)求，然后根據(jù)ZooKeeper服務(wù)端的配置完成會(huì)話超時(shí)時(shí)間的協(xié)商华望。隨后SessionTracker將會(huì)為該會(huì)話分配一個(gè)sessionID蕊蝗，并將其注冊(cè)到sessionById和sessionWithTimeout中，同時(shí)進(jìn)行會(huì)話激活赖舟。之后蓬戚，該“會(huì)話請(qǐng)求”還會(huì)在ZooKeeper服務(wù)端的各個(gè)請(qǐng)求處理器之間進(jìn)行順序流轉(zhuǎn)，最終完成會(huì)話的創(chuàng)建宾抓。
接下來(lái)分析一下session狀態(tài)之間的轉(zhuǎn)換：
Session從NOT_CONNECTED狀態(tài)開(kāi)始子漩，并隨著Zookeeper客戶端初始化，轉(zhuǎn)移到CONNECTING狀態(tài)（在圖1中的箭頭1）石洗。 正常情況下痛单，客戶端會(huì)與Zookeeper服務(wù)器連接成功，并且轉(zhuǎn)移到CONNECTED狀態(tài)（箭頭2）劲腿。當(dāng)客戶端失去了與ZooKeeper服務(wù)器的連接或者不能聽(tīng)到服務(wù)器旭绒，它會(huì)轉(zhuǎn)移回CONNECTING（箭頭3），并且嘗試尋找另一個(gè)ZooKeeper服務(wù)器焦人。如果它能找到另一個(gè)服務(wù)器或者重新連接到之前的服務(wù)器挥吵，并確認(rèn)了這個(gè)Session仍然有效，它會(huì)轉(zhuǎn)移回CONNECTED狀態(tài)花椭。否則忽匈，它會(huì)定義這個(gè)Session失效，并轉(zhuǎn)移到CLOSED（箭頭4）矿辽。應(yīng)用可以顯示關(guān)閉Session丹允。（箭頭4和5）
如果客戶端因?yàn)槌瑫r(shí)和服務(wù)器斷開(kāi)連接郭厌，它會(huì)保持在CONNECTING狀態(tài)。如果這個(gè)斷開(kāi)是因?yàn)榭蛻舳撕蚙ookeepe集群的網(wǎng)絡(luò)中斷雕蔽，它將保持在CONNECTING狀態(tài)直到它顯示地關(guān)閉Session折柠，或者網(wǎng)絡(luò)中斷恢復(fù)后客戶端從Zookeeper服務(wù)器聽(tīng)到了Session超時(shí)消息。我們?cè)O(shè)計(jì)這樣的行為是因?yàn)橹挥衂ookeeper集群負(fù)責(zé)定義Session失效批狐，而不是客戶端扇售。客戶端不能定義Session失效嚣艇，直到聽(tīng)到Zookeeper Session超時(shí)消息承冰。然而，客戶端可以選擇主動(dòng)關(guān)閉這個(gè)Session食零。
在創(chuàng)建Session時(shí)困乒，需要設(shè)置Session Timeout這個(gè)重要參數(shù)。這是Zookeeper服務(wù)允許一個(gè)Session在定義它失效之前的時(shí)間贰谣。如果服務(wù)在時(shí)間t內(nèi)不能看到與一個(gè)Session關(guān)聯(lián)的消息顶燕，它將定義這個(gè)Session失效。如果客戶端在1/3 t時(shí)間內(nèi)沒(méi)有聽(tīng)到任何從服務(wù)器過(guò)來(lái)的消息冈爹，它將發(fā)送一個(gè)心跳消息給服務(wù)器涌攻。在(2/3)t時(shí)間， Zookeeper客戶端開(kāi)始尋找另一個(gè)Zookeeper服務(wù)器频伤，并且它有另外的(1/3)t的時(shí)間尋找恳谎。
客戶端將連接哪一個(gè)服務(wù)器
在Quorum模式，一個(gè)客戶端擁有多個(gè)服務(wù)器可以連接憋肖。然而在Standalone模式因痛，它必須嘗試重新有效地連接到那個(gè)唯一的服務(wù)器。在Quorum模式岸更，應(yīng)該會(huì)傳一個(gè)服務(wù)器列表到客戶端鸵膏，客戶端從中選擇一個(gè)連接。
當(dāng)嘗試連接另一個(gè)服務(wù)器時(shí)怎炊，很重要的一點(diǎn)是這個(gè)服務(wù)器的ZooKeeper狀態(tài)至少要和客戶端已經(jīng)觀察到的最近ZooKeeper狀態(tài)是一樣新的谭企。客戶端不能連接到一個(gè)這樣的服務(wù)器评肆。它沒(méi)有看到客戶端可能已經(jīng)看到的更新债查。Zookeeper通過(guò)在服務(wù)中排序更新操作來(lái)決定新鮮程度(Freshness)。每一個(gè)對(duì)Zookeeper布局狀態(tài)的改動(dòng)操作相對(duì)于所有其它執(zhí)行的更新操作都是全序的瓜挽，所以如果一個(gè)客戶端已經(jīng)在位置i觀察到一個(gè)更新盹廷，它不能連接一個(gè)僅看到i' < i的服務(wù)器。在ZooKeeper的實(shí)現(xiàn)中久橙，系統(tǒng)分配給每個(gè)更新操作一個(gè)事務(wù)ID來(lái)建立這個(gè)順序俄占。
更多精彩內(nèi)容管怠，歡迎關(guān)注微信公眾號(hào)：Java小筆記（ijavanote）
