Zookeeper客户端和服务端NIO网络通信源码剖析

文章目录

  • 服务端的ServerCnxFactory到底是个什么东西?
      • ServerCnxFactory 的作用
      • ServerCnxFactory 的实现
      • 使用 ServerCnxFactory 的示例
      • 注意事项
  • ServerCnxFactory是什么时候完成初始化的?
      • 初始化流程
      • 代码示例
      • 详细步骤
        • 1. 创建实例
        • 2. 配置
        • 3. 启动
      • 初始化时机
      • 总结
  • 服务端基于NIO的ServerSocket是什么时候启动的?
      • NIOServerCnxnFactory 的启动过程
      • 代码示例
      • 启动时机
      • 启动过程详解
      • 总结
  • 创建一个ZooKeeper对象实例就是与服务端建立一个长连接?
      • 创建 ZooKeeper 对象实例
      • 连接建立过程
      • 代码示例
      • 详细步骤
        • 1. 创建 Watcher 对象
        • 2. 创建 ZooKeeper 对象
        • 3. 连接建立
        • 4. 协商会话
        • 5. 建立会话
        • 6. 心跳检测
        • 7. 完成连接
      • 总结
  • ZooKeeper初始化的时候会干什么?
      • 初始化过程
        • 1. 创建 `ZooKeeper` 实例
        • 2. 连接字符串解析
        • 3. 创建会话
        • 4. 协商会话参数
        • 5. 设置状态监听器
        • 6. 连接建立
        • 7. 等待连接确认
        • 8. 开始会话
        • 9. 心跳检测
        • 10. 错误处理
      • 代码示例
      • 总结
  • ClientCnxn是如何进行初始化的?
      • 初始化过程
        • 1. 创建 `ClientCnxn` 实例
        • 2. 解析连接字符串
        • 3. 创建会话
        • 4. 协商会话参数
        • 5. 设置状态监听器
        • 6. 连接建立
        • 7. 等待连接确认
        • 8. 开始会话
        • 9. 心跳检测
        • 10. 错误处理
      • 代码示例
      • 初始化过程详解
        • 1. 创建 `ClientCnxn` 实例
        • 2. 解析连接字符串
        • 3. 创建会话
        • 4. 协商会话参数
        • 5. 设置状态监听器
        • 6. 连接建立
        • 7. 等待连接确认
        • 8. 开始会话
        • 9. 心跳检测
        • 10. 错误处理
      • 总结
  • 启动ClientCnxn的时候是在干什么?
      • 启动过程
        • 1. 创建 `ClientCnxn` 实例
        • 2. 解析连接字符串
        • 3. 创建会话
        • 4. 协商会话参数
        • 5. 设置状态监听器
        • 6. 连接建立
        • 7. 等待连接确认
        • 8. 开始会话
        • 9. 心跳检测
        • 10. 错误处理
      • 代码示例
      • 启动过程详解
        • 1. 创建 `ClientCnxn` 实例
        • 2. 解析连接字符串
        • 3. 创建会话
        • 4. 协商会话参数
        • 5. 设置状态监听器
        • 6. 连接建立
        • 7. 等待连接确认
        • 8. 开始会话
        • 9. 心跳检测
        • 10. 错误处理
      • 总结
  • 客户端如何采用NIO的方式与服务端建立长连接?
      • ZooKeeper 客户端 NIO 连接机制
        • 1. 创建 `ClientCnxn` 实例
        • 2. 解析连接字符串
        • 3. 创建会话
        • 4. 协商会话参数
        • 5. 设置状态监听器
        • 6. 连接建立
        • 7. 等待连接确认
        • 8. 开始会话
        • 9. 心跳检测
        • 10. 错误处理
      • NIO 连接机制详解
        • 1. 创建 `SocketChannel`
        • 2. 连接服务端
        • 3. 注册选择器
        • 4. 监听连接事件
        • 5. 读写操作
        • 6. 心跳检测
        • 7. 错误处理
      • 总结
  • 服务接收到连接之后会做什么事情?
      • 服务端处理流程
        • 1. 接收连接请求
        • 2. 创建 `ServerCnxn` 实例
        • 3. 接受连接
        • 4. 协商参数
        • 5. 创建会话
        • 6. 会话管理
        • 7. 数据传输
        • 8. 心跳检测
        • 9. 错误处理
      • 代码示例
      • 详细步骤
        • 1. 接收连接请求
        • 2. 创建 `ServerCnxn` 实例
        • 3. 接受连接
        • 4. 协商参数
        • 5. 创建会话
        • 6. 会话管理
        • 7. 数据传输
        • 8. 心跳检测
        • 9. 错误处理
      • 总结
  • 客户端在连接建立之后会做什么事情?
      • 客户端连接建立之后的操作
        • 1. 确认连接状态
        • 2. 等待连接确认
        • 3. 执行 ZooKeeper 操作
        • 4. 发送心跳消息
        • 5. 处理会话事件
        • 6. 错误处理
      • 代码示例
      • 总结
  • Session的建立以及工业级的Session管理机制
      • 会话建立过程
        • 1. 连接建立
        • 2. 发起会话请求
        • 3. 协商会话参数
        • 4. 创建会话
        • 5. 会话确认
        • 6. 状态变更通知
      • 工业级的会话管理机制
        • 1. 会话超时
        • 2. 心跳检测
        • 3. 会话过期处理
        • 4. 会话迁移
        • 5. 会话恢复
        • 6. 会话唯一性
        • 7. 数据一致性保证
      • 代码示例
      • 总结

服务端的ServerCnxFactory到底是个什么东西?

在 ZooKeeper 中，ServerCnxFactory 是一个非常重要的类，它负责处理服务端（也就是 ZooKeeper 服务器）与客户端之间的网络通信。ServerCnxFactory 实现了服务器与客户端之间的连接管理、数据传输以及会话管理等功能。

ServerCnxFactory 的作用

  1. 连接管理：建立并维护与客户端之间的连接。
  2. 数据传输：读取来自客户端的数据包，并发送响应给客户端。
  3. 会话管理：管理客户端与服务器之间的会话，包括会话的创建、过期检查等。
  4. 安全性：如果启用了安全特性，ServerCnxFactory 还会负责认证客户端的身份。

ServerCnxFactory 的实现

ServerCnxFactory 有几个不同的实现，每种实现都采用了不同的网络模型和技术。ZooKeeper 提供了多种 ServerCnxFactory 实现，以适应不同的性能需求和环境要求。

  • NIOServerCnxFactory：基于 Java NIO（非阻塞 I/O）技术实现，可以处理大量并发连接，适用于高性能场景。

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

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

[tomato]靶机复现漏洞详解！

[tomato]靶机复现漏洞详解！

靶机地址： https://download.vulnhub.com/tomato/Tomato.ova 靶机环境：Vmware 网络：NAT模式 信息收集： arp-scan -l 扫描靶机ip地址 扫描开放的端口信息 nmap -sS -sV -p- 192.168.77.135 发现开放端口21&#xff…
阅读更多...
2024年7月30日 十二生肖 今日运势

2024年7月30日 十二生肖 今日运势

小运播报：2024年7月30日，星期二，农历六月廿五 （甲辰年辛未月乙未日），法定工作日。 红榜生肖：兔、马、猴 需要注意：狗、鼠、牛 喜神方位：西北方 财神方位：…
阅读更多...
git 推送时出现错误 Locking support detected on remote “origin“

git 推送时出现错误 Locking support detected on remote “origin“

背景：代码托管是局域网搭建的gitlab 按照提示配置 lfs.locksverify true 还是没有用。 网上搜索了一番，其中有人提到可能时服务器磁盘满了，连到服务器上 df -h 查看， 发现根目录已经写满了： 使用命令行： d…
阅读更多...
C/C++进阶 （8）哈希表（STL）

C/C++进阶 （8）哈希表（STL）

个人主页：仍有未知等待探索-CSDN博客 专题分栏：C 本文着重于模拟实现哈希表，并非是哈希表的使用。 实现的哈希表的底层用的是线性探测法，并非是哈希桶。 目录 一、标准库中的哈希表 1、unordered_map 2、unordered_set 二、模…
阅读更多...
redis放在三层架构中的哪一层

redis放在三层架构中的哪一层

文章目录 Redis放在controller还是service以下是一些常见的考虑因素：一、数据访问频率二、数据共享性三、数据更新频率四、数据的一致性要求 Redis放在controller还是service 在三层架构中，将 Redis 数据放置在 Controller 层还是 Service 层&#xff0c…
阅读更多...
Laravel认证与授权：打造安全的Web应用

Laravel认证与授权：打造安全的Web应用

Laravel认证与授权：打造安全的Web应用 在构建现代Web应用时，用户认证和授权是两个核心功能。Laravel框架提供了一套完整的解决方案，使得开发者可以轻松实现这些功能。本文将详细解释如何在Laravel中实现用户认证和授权，并提供相应…
阅读更多...
【参会邀请】第四届区块链技术与信息安全国际会议（ICBCTIS 2024）诚邀相聚江城！

【参会邀请】第四届区块链技术与信息安全国际会议（ICBCTIS 2024）诚邀相聚江城！

我们诚挚地邀请您参与第四届区块链技术与信息安全国际会议（ICBCTIS 2024）。本届会议将于2024年8月17日~19日在中国武汉召开。会议将围绕区块链技术与信息安全等相关研究领域，特邀国内外数位在此领域学术卓越的学者专家做相关致辞与报告&#…
阅读更多...
如何使用虚拟机如何安装 Kali Linux ？

如何使用虚拟机如何安装 Kali Linux ？

1.下载虚拟机：https://www.virtualbox.org/wiki/Downloads 选择你的系统版本 2.下载kali linux系统镜像：https://www.kali.org/get-kali/#kali-virtual-machines 全部下载完成后，我们会得到以下文件！ 1.压缩Kali Linux压缩包 2.安…
阅读更多...
Django实战：开启数字化任务管理的新纪元

Django实战：开启数字化任务管理的新纪元

🚀 Django实战：开启数字化任务管理的新纪元 🌐 📖 引言 在数字化转型的浪潮中，任务管理的智能化成为提升组织效能的关键。今天，我将带领大家深入了解我们最新开发的OFTS系统——一款创新的组织任务管理软…
阅读更多...
Robot Operating System——深度解析日志功能的实现

Robot Operating System——深度解析日志功能的实现

大纲 enable_logger_service的作用创建获取日志等级的Service创建设置日志等级的Service 不同等级日志的底层实现总结 在《Robot Operating System——远程修改日志等级》中，我们学习了日志相关的功能，但是没有进行深入分析。本文将分析下列几个课题 en…
阅读更多...
【Opencv】色彩空间 color space

【Opencv】色彩空间 color space

import os import cv2 img cv2.imread(os.path.join(.,dog.jpg)) # 在opencv中使用imread,读取的图片每个像素都是bgr色彩，蓝色，绿色，红色 cv2.imshow(img,img) cv2.waitKey(0) # 颜色空间转化：BGR2RGB img_rgb cv2.cvtC…
阅读更多...
树深度对决策树性能的影响：深入分析

树深度对决策树性能的影响：深入分析

树深度对决策树性能的影响：深入分析 决策树是一种广泛应用于分类和回归任务的机器学习算法。它通过一系列决策规则将数据集划分为更小的子集，从而做出预测。决策树的深度是影响其性能的关键因素之一。本文将深入探讨树深度对决策树性能的影响&#xff0…
阅读更多...
【Python学习手册（第四版）】学习笔记10-语句编写的通用规则

【Python学习手册（第四版）】学习笔记10-语句编写的通用规则

个人总结难免疏漏，请多包涵。更多内容请查看原文。本文以及学习笔记系列仅用于个人学习、研究交流。 本文较简单，5-10分钟即可阅读完成。介绍Python基本过程语句并讨论整体语法模型通用规则（冒号、省略、终止、缩进、其他特殊情况&#xff0…
阅读更多...
Python里lambda怎么使用呢？

Python里lambda怎么使用呢？

lambda 函数在Python中是一种简洁定义单行小函数的方式。它允许你快速定义一个简单的、可以在需要函数对象的地方使用的匿名函数。lambda 函数的一般语法如下： python lambda 参数: 表达式 这里，参数 是传递给函数的参数，可以有一个或多个&a…
阅读更多...
【CAN通讯系列5】CAN数据帧及其仲裁

【CAN通讯系列5】CAN数据帧及其仲裁

在CAN通讯系列3-CAN通讯如何传递信号中，由于传递信号的分析需要，引出了CAN数据帧的ID，长度和数据段的概念，它们都与CAN协议帧相关。CAN协议帧有5种类型，如下表： 而我们当前使用到的是数据帧，故本…
阅读更多...
常用命令git branch

常用命令git branch

Git Branch 命令总结 列出分支 git branch&#xff1a;显示本地分支&#xff0c;当前分支会被标记。git branch -r&#xff1a;显示远程分支。git branch -a&#xff1a;显示所有本地和远程分支。 创建分支 git branch <branch_name>&#xff1a;创建一个新分支但不自…
阅读更多...
【WEB安全】 PHP基础与数据库教学下（超详细）

【WEB安全】 PHP基础与数据库教学下（超详细）

文章目录 php与mysql 简述 MySQLi 和 PDO 连接 MySQL 实例 Linux 和 Windows: 在 php5 mysql 包安装时 MySQLi 扩展多事情况下是自动安装的。 PDO 安装 实例 (MySQLi - 面向对象) 实例 (MySQLi - 面向过程) 实例 (PDO) 使用 MySQLi 和 PDO 向 MySQL 插入数据 实例 (M…
阅读更多...
正向解析、反向解析、DNS主从、多区域、ntp时间同步

正向解析、反向解析、DNS主从、多区域、ntp时间同步

DNS配置回顾 编号主机名IP地址说明1web服务器192.168.1.17发布部署web服务2dns服务器192.168.1.20用于解析域名和IP地址3clien主机192.168.1.18用于模拟客户机 修改 client主机&#xff1a;修改了dns的访问主机&#xff1b;临时修改echo "nameserver IP地址"&…
阅读更多...
docker 常用管理命令及数据备份

docker 常用管理命令及数据备份

docker 常用管理命令及数据备份 常用管理命令 重启 cd share docker compose restart 停止 cd share docker compose stop 启动 cd share ./deploy.sh 升级 cd share ./deploy.sh 查看日志 cd share docker compose logs -f 数据备份 以下备份相关命令均要求在doc…
阅读更多...
【Web开发手礼】探索Web开发的秘密（十三）-Vue（3）好友列表、登录

【Web开发手礼】探索Web开发的秘密（十三）-Vue（3）好友列表、登录

前言 主要介绍了好友列表、登录界面所涉及的vue知识点&#xff01;&#xff01;&#xff01; 好友列表 从云端API读取数据信息 地址 https://app165.acapp.acwing.com.cn/myspace/userlist/方法&#xff1a;GET是否验证jwt&#xff1a;否输入参数&#xff1a;无返回结果&…
阅读更多...
最新文章

Copyright @ 2022~2023