Zookeeper單機模式下啟動類為ZooKeeperServerMain#runFromConfig， 調(diào)用過程可參考：http://naotu.baidu.com/file/2...

ZooKeeperServerMain會開啟一些線程協(xié)作處理不同請求：

NIOServerCxnFactory.SelectorThread

功能：

處理隊列acceptedQueue(由AcceptThread入隊), 將里面的SocketChannel注冊到selector中

selector.select(), handleIO循環(huán)處理IO請求

當(dāng)有請求時, 創(chuàng)建IOWorkRequest遞交給線程池workerPool處理

調(diào)用NIOServerCnxn#doIO, 封裝Request給線程ProcessThread處理， 入隊到ProcessThread的submittedRequests隊列

NIOServerCxnFactory.AcceptThread:

功能：循環(huán)處理接收客戶端請求, 并將接收到的SocketChannel放入SelectorThread的acceptedQueue中

ProcessThread

功能：處理隊列submittedRequests
對應(yīng)程序片段：org.apache.zookeeper.server.PrepRequestProcessor.run(PrepRequestProcessor.java:134)

SyncThread

功能：請求處理鏈2
對應(yīng)程序片段: org.apache.zookeeper.server.SyncRequestProcessor.run(SyncRequestProcessor.java:109)

SessionTracker

功能：待完善

ConnnectionExpirer

功能：關(guān)閉超時的連接NIOServerCnxn

主要流程如下:

AcceptThread(接收連接請求SocketChannel)
-------> SelectorThread(從Socket讀取數(shù)據(jù), 封裝成Request)
-------------> ProcessThread(處理Request)

持續(xù)完善中。。。

總結(jié)

以上是生活随笔為你收集整理的Zookeeper服务端线程分析（单机）的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。