天天看點

Zookeeper Client端流程

1.ClientConn封裝RequstHeader,Request并送出到outgoing Queue,阻塞等待

2.SendThread喚醒ClientConnSocket,由其從outgoing queue取請求并進行資料傳輸,包括Xid的配置設定也是在這裡進行;并将Packet加入pending queue

3.當ClientConnSocket接收到消息時,調用SendThread進行讀請求處理,建構ReplyHeader并調用EventThread将WatchEvent(如果設定的話)加入waitingEvent清單

4.EventThread異步檢查waitingEvent,發現後調用Watcher的process流程,由watcher具體實作

<a href="http://blog.51cto.com/attachment/201310/020539338.png" target="_blank"></a>

本文轉自MIKE老畢 51CTO部落格,原文連結:http://blog.51cto.com/boylook/1314170,如需轉載請自行聯系原作者

繼續閱讀