zookeeper 服务端客户端启动

zookeeper 服务端客户端启动

目录

​

2021SC@SDUSC

zookeeper 服务端客户端启动

1.创建ZooKeeperAdmin

2.初始化监听器

3.解析连接地址

4.创建客户端与服务器端通信的终端

(1).启动连接服务端

(2).接收服务端响应并处理

5.执行run

(1).—行一行读取命令

(2).处理客户端命令

(3).解析客户端命令

---

2021SC@SDUSC

---

zookeeper 服务端客户端启动

ZkCli.sh

org.apache.zookeeper.ZooKeeperMain

ZooKeeperMain.main()

new ZooKeeperMain(args)

1.创建ZooKeeperAdmin

connectToZK()

new ZooKeeperAdmin()

ZooKeeper

2.初始化监听器

watchManage.defaultWatcher = watcher

3.解析连接地址

new ConnectStringParser（）

split(connectString,".");
server Addresses.add()

4.创建客户端与服务器端通信的终端

createConnection()
new ClientCnxn()

new EventThread( )
new SendThread()

(1).启动连接服务端

ZookeeperThread.run()

startConnect()
clientCnxnSocket.connect()
registerAndConnect()
 

(2).接收服务端响应并处理

clientCnxnSocket.doTransport()
doIO()
sendThread.readResponse()

5.执行run

new ZooKeeperMain(args).run

(1).—行一行读取命令

executeLine()

(2).处理客户端命令

processCmd()

(3).解析客户端命令

processZKCmd()