《Zookeeper》源码分析(二十二)之 客户端核心类

news2024/11/13 15:25:50

目录

  • CliCommand
    • 数据结构
    • parse()
    • exec()
  • ZooKeeper
  • HostProvider
  • ZKClientConfig
  • ClientCnxnSocket
    • 数据结构
    • 构造函数
  • ClientCnxn
    • 数据结构
    • 构造函数
    • start()

CliCommand

数据结构

在这里插入图片描述

CliCommand定义了两个抽象方法,以CreateCommand为例来看下它的parse()exec()方法。

先看下CreateCommand的类信息:
在这里插入图片描述

parse()

在这里插入图片描述

exec()

执行命令
在这里插入图片描述

CliCommand介绍到此。

ZooKeeper

ZooKeeperMainconnectToZK()中创建了客户端的实例ZooKeeperAdmin,在执行命令的时候通过将命令转成方法的参数最终传入客户端进行处理,因此本章来分析客户端ZooKeeperAdmin

ZooKeeperAdmin父类是ZooKeeper,先看下他们的数据结构:
在这里插入图片描述

我们以ZooKeeperMainconnectToZK()中的构造函数为切入点,
在这里插入图片描述

ZooKeeper中涉及到的4个对象:

  1. 获取服务端地址的HostProvider
  2. 客户端配置ZKClientConfig
  3. 处理IO事务的ClientCnxn
  4. 更底层的IO处理ClientCnxnSocket

在开始介绍Zookeeper的功能之前先了解这个几个类。

HostProvider

在这里插入图片描述

ZKClientConfig

默认情况下传入的clientConfig为null,所以需要调用ZKClientConfig的无参构造函数创建。

如果启动命令设置了client-configuration参数,即配置文件的路径,那么在ZooKeeperMain的启动过程中会去读取配置文件的内容并存入ZKClientConfig中。

如果没有设置client-configuration参数则仅仅读取java的一些默认属性,详细参数可以分析ZKClientConfig的无参构造函数分析。

ClientCnxnSocket

ClientCnxnSocketClientCnxn底层IO处理器,在Zookeeper中通过调用getClientCnxnSocket()方法进行初始化:
在这里插入图片描述

默认创建的是ClientCnxnSocketNIO实例

数据结构

在这里插入图片描述

构造函数

在这里插入图片描述

ClientCnxn

在Zookeeper的构造函数中调用createConnection()方法创建ClientCnxn,与服务器端类似,服务端使用的是ServerCnxn,客户端使用的是ClientCnxn,他们的功能就是处理客户端与服务端的交互。
在这里插入图片描述

数据结构

ClientCnxn的数据结构:
在这里插入图片描述

这里需要注意的是两个队列和两个线程:

  1. 待发送数据的outgoingQueue
  2. 已发送等待结果的pendingQueue
  3. 发送线程sendThread
  4. 处理服务端相应的eventThread

构造函数

在这里插入图片描述

start()

在Zookeeper的构造函数中,当ClientCnxn创建好了以后立即调用start()方法。
在这里插入图片描述

这个方法很简单,就是将两个线程启动。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.coloradmin.cn/o/932146.html

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈,一经查实,立即删除!

相关文章

c语言每日一练(11)

前言:每日一练系列,每一期都包含5道选择题,2道编程题,博主会尽可能详细地进行讲解,令初学者也能听的清晰。每日一练系列会持续更新,暑假时三天之内必有一更,到了开学之后,将看学业情…

在驱动中创建sysfs接口、procfs接口、debugfs接口

前言 在一些linux开发板中,经常可以看到通过echo的方式来直接控制硬件或者修改驱动,例如: //灯灭 echo 0 >/sys/class/leds/firefly:blue:power/brightness //灯亮 echo 1 >/sys/class/leds/firefly:blue:power/brightness 这是怎么…

老人摔倒智能识别检测算法

老人摔倒智能识别检测算法通过yolov8深度学习算法模型架构,老人摔倒智能识别检测算法能够实时监测老人的活动状态及时发现摔倒事件,系统会立即触发告警,向相关人员发送求助信号,减少延误救援的时间。YOLOv8 算法的核心特性和改动可…

内嵌功能强大、低功耗STM32WB55CEU7、STM32WB55CGU7 射频微控制器 - MCU, 48-UFQFN

一、概述: STM32WB55xx多协议无线和超低功耗器件内嵌功能强大的超低功耗无线电模块(符合蓝牙 低功耗SIG规范5.0和IEEE 802.15.4-2011标准)。该器件内含专用的Arm Cortex -M0,用于执行所有的底层实时操作。这些器件基于高性能Arm …

分享一种针对uni-app相对通用的抓包方案

PART1,前言 近年来混合开发APP逐渐成为主流的开发模式,与传统的开发模式相比混合开发极大的提升了开发效率,同时跨平台的特性也降低了开发成本,一直以来混合开发被诟病的性能问题随着技术的发展也得到改善。技术的发展往往是一把…

vue3+uni——watch监听props中的数据(组件参数接收与传递defineProps、defineEmits)

案例说明 A页面引用的子组件B A页面 <template><view>//引用组件<serviceOrder change"change" :list"list" :current"type"></serviceOrder></view> </template><script setup>import serviceOrd…

智慧课堂学生行为检测评估算法

智慧课堂学生行为检测评估算法通过yolov5系列图像识别和行为分析&#xff0c;智慧课堂学生行为检测评估算法评估学生的表情、是否交头接耳行为、课堂参与度以及互动质量&#xff0c;并提供相应的反馈和建议。智慧课堂学生行为检测评估算法能够实时监测学生的上课行为&#xff0…

基于Jenkins自动化部署PHP环境---基于rsync部署

基于基于Jenkins自动打包并部署Tomcat环境_学习新鲜事物的博客-CSDN博客环境 准备git仓库 [rootgit ~]# su - git 上一次登录&#xff1a;五 8月 25 15:09:12 CST 2023从 192.168.50.53pts/2 上 [gitgit ~]$ mkdir php.git [gitgit ~]$ cd php.git/ [gitgit php.git]$ git --b…

Heikin-Ashi怎么用,FPmarkets澳福找到3个使用环境

所有赚到钱的交易者都在告诉你Heikin-Ashi是个能赚到钱的交易指标&#xff0c;但是没有一个赚到钱的交易者告诉你如何使用Heikin-Ashi交易指标赚到钱。其实很简单&#xff0c;只要理解Heikin-Ashi的这3个使用环境&#xff0c;如果不好使&#xff0c;FPmarkets澳福帮你账户充值1…

pytest pytest.ini 配置日志输出至文件

创建pytest.ini 文件 [pytest] log_file pytest_log.txt log_file_level INFO log_file_date_format %Y-%m-%d %H:%M:%S log_file_format %(asctime)s | %(filename)s | %(funcName)s | line:%(lineno)d | %(levelname)s | %(message)s import pytest import loggingdef …

基于Hadoop的MapReduce网站日志大数据分析(含预处理MapReduce程序、hdfs、flume、sqoop、hive、mysql、hbase组件、echarts)

需要本项目的可以私信博主&#xff01;&#xff01;&#xff01; 本项目包含&#xff1a;PPT&#xff0c;可视化代码&#xff0c;项目源码&#xff0c;配套Hadoop环境&#xff08;解压可视化&#xff09;&#xff0c;shell脚本&#xff0c;MapReduce代码&#xff0c;文档以及相…

【附安装包】EViews 13.0安装教程|计量经济学|数据处理|建模分析

软件下载 软件&#xff1a;EViews版本&#xff1a;13.0语言&#xff1a;英文大小&#xff1a;369.46M安装环境&#xff1a;Win11/Win10/Win8/Win7硬件要求&#xff1a;CPU2.0GHz 内存4G(或更高&#xff09;下载通道①百度网盘丨64位下载链接&#xff1a;https://pan.baidu.com…

Win系统设置开机自启项及自定义自启程序

Win系统设置开机自启项及自定义自启程序 分用户自启动和系统自启动两种形式&#xff1a; 1. 用户自启动目录&#xff1a;C:\Users\Administrator\AppData\Roaming\Microsoft\Windows\Start Menu\Programs\Startup 用快速键打开&#xff1a; Win键R键&#xff0c;输入shell:…

连接数据库报错:2003-Can’t connect to Mysql server on ‘localhost’(10061)

今天在进行配置数据库的时候发现如下问题&#xff1a; 数据库出现2003错误&#xff0c;连接失败。 主要原因是我们的数据库服务没有开&#xff0c;winr&#xff0c;输入services.msc&#xff0c;打开本地服务 找到Mysql服务&#xff0c;右键启动即可。

响应式布局bootstrap使用

响应式布局 学习目标 能够说出响应式原理 能够使媒体查询完成响应式导航 能够使用Bootstrap的栅格系统 能够使用bootstrap的响应式工具 1.响应式原理 1.1响应式开发原理 就是使用媒体查询针对不同宽度的设备进行布局和样式的设置,从而适配不同设备的目的 1.2响应式布局容器…

什么是Promise对象?它的状态有哪些?如何使用Promise处理异步操作?以及 async、await

聚沙成塔每天进步一点点 ⭐ 专栏简介⭐ Promise对象⭐ 创建Promise对象⭐ 使用Promise处理异步操作⭐ async、await⭐ 写在最后 ⭐ 专栏简介 前端入门之旅&#xff1a;探索Web开发的奇妙世界 记得点击上方或者右侧链接订阅本专栏哦 几何带你启航前端之旅 欢迎来到前端入门之旅…

FFmpeg5.0源码阅读——FFmpeg大体框架

摘要&#xff1a;前一段时间熟悉了下FFmpeg主流程源码实现&#xff0c;对FFmpeg的整体框架有了个大概的认识&#xff0c;因此在此做一个笔记&#xff0c;希望以比较容易理解的文字描述FFmpeg本身的结构&#xff0c;加深对FFmpeg的框架进行梳理加深理解&#xff0c;如果文章中有…

一篇文章带你实现队列的接口

目录 一&#xff0c;什么是队列 二&#xff0c; 队列的存储结构 1.顺序队列 2.循环队列 3.链队列 三&#xff0c;队列的接口实现 3.1初始化队列 3.2队尾入队列 3.3队头出队列 3.4获取队列头部&#xff0c;尾部元素 3.5获取队列中有效元素个数 3.6销毁队列 四&#x…

python实现卡尔曼滤波代码详解

Kalman滤波算法的原理可以参考&#xff1a; 卡尔曼滤波理解 python中filterpy库中实现了各种滤波算法&#xff0c; 其中就包括了kalman滤波算法。 具体实现代码&#xff1a; https://github.com/rlabbe/filterpy/blob/master/filterpy/kalman/kalman_filter.py 本文针对该代码…

0825hw

//冒泡排序 void Bubble_sort(Sp p) {for(int i1;i<p->len;i){for(int j0;j<p->len-i;j){if(p->arr[j]>p->arr[j1]){int tp->arr[j];p->arr[j]p->arr[j1];p->arr[j1]t;}}} } //简单选择排序 void Simple_sort(Sp p) {for(int i1;i<p->l…