zk client会话过程是怎样的

这篇文章主要介绍“zk client会话过程是怎样的”，在日常操作中，相信很多人在zk client会话过程是怎样的问题上存在疑惑，小编查阅了各式资料，整理出简单好用的操作方法，希望对大家解答”zk client会话过程是怎样的”的疑惑有所帮助！接下来，请跟着小编一起来学习吧！client会话过程zk客户端的主要核心组件zk客户端会话过程初始化阶段创建阶段响应阶段UML图zk客户端主要组件zookeeper 客户端入口ClientWatchManager:客户端Watch管理器HostProvider:客户端地址管理器ClientCnxn:核心线程，包含SendThread和EventThread两个线程SendThread为i/o线程，主要负责客户端和服务器之间网络ioEventTrhead为事件线程初始化阶段主要分为：1 初始化ZooKeeper对象通过调用zookeeper的构造方法实例化一个对象，初始化过程中会创建一个watcher管理器ClientWatcherManager2 设置会话默认watcher如果构造中传入一个watcher,就将它作为默认watcher保存到ClientWatcherManager3 构建zk服务地址列表管理器HostProvider通过构造器传入的服务端地址列表，将其保存在服务器地址列表管理器中HostProvider4 创建并初始化客户端网络连接zookeeper客户端创建一个网络连接器ClientCnxn,用来管理客户端和服务端网络交互创建ClientCnxn过程中还会初始化客户端两个核心队列outGoingQueue和pendingQueue作为客户端发送请求队列和服务端响应等待队列5初始化SendThread和EventThread会话创建阶段6启动SendThread和EventThreadsendTHread首先会判断当前客户端的状态，进行一系列清理性工作，为客户端发送“会话创建”请求准备7获取一个服务地址在创建TCP之前，SendThread首先需要获取一个ZooKeeper服务器的目标地址，通常就是从HostProvider中随机获取出一个地址，然后委托给ClientCnxnSocket去创建与Zookeeper服务器之间的TCP连接8 创建tcp连接，获取一个服务器地址后，clientCnxnSocket负责和服务器创建一个TCP长连接9构建ConnectRequest请求在TCP连接创建完毕后，就说明已经和zookeeper服务器完成了连接呢？其实不是，上面的步骤只是从网络tcp层完成了socket连接，但没有完成zookeeper客户端和服务端的连接SendThread会负责当前请求参数，构造出一个ConnectRequest请求，同时将包装成网络io层的Packet对象，放入发送队列outgoingQueue中10 发送请求ClientCnxnSocket将从outgoingQueue中取出待发送的Packet,序列化成bytebuffer，进行发送响应处理阶段11响应处理接收到服务端响应后，首先判断当前客户端状态是否是“已初始化”，如果没有完成初始化，那么认为该响应一定是会话创建请求的响应，交给readConnnectResult方法处理响应12 处理respinseClientCnxnSocket会对接收到的服务端响应进行反序列化，得到ConnectResponse对象，并从中获取到zookeeper服务端分配的会话sessionId,13 连接成功通知SendThread线程，处理会话参数设置，包括时间设置等等另一个方面，需要通知地址管理器HostProvider当前成功连接的服务器地址14 生成事件为了能够让上层应用感应到会话成功创建，SendThread会生成一个事件SyncConnected-None,代表会话创建成功，并将事件传递给EventTread线程15 查询WatcherEventThread收到事件后香港云主机，从ClientWatchManager管理器中查询出对应的watcher,放入waitingEvents队列中16 处理事件取出事件对应的watcher列表，调用process接口，达到出发watcher目的到此，关于“zk client会话过程是怎样的”的学习就结束了，希望能够解决大家的疑惑。理论与实践的搭配能更好的帮助大家学习，快去试试吧！若想继续学习更多相关知识，请继续关注开发云网站，小编会继续努力为大家带来更多实用的文章！