zookeeper核心源码分析

zookeeper server单机启动流程

• (1) 加载zookeeper配置文件zoo.cfg
• (2) 创建Jetty Admin Server监听（监听zk server）
• (3) 创建ServerCnxnFactory（默认是NIO，可以配置为Netty）
• (4) ServerCnxnFactory启动
• (5) 第一次启动zk server初始化创建5个默认节点
• (6) 初始化事务日志与数据快照文件
• (7) 加载数据
• (8) zookeeper server启动
• (8.1) 启动session会话管理器
• (8.2) 通过责任链模式构建RequestProcessor链去处理后续请求
• (8.3) 启动zookeeper限流器RequestThrottler
• (8.4) 注册JMX监控（监控zk server）

zookeeper实例化与创建节点流程

zookeeper实例化流程

• (1) 创建连接ClientCnxn
• (2) 初始化pendingQueue,outgoingQueue,sendThread,eventThread
• (3) pendingQueue: 存放客户端待发送给服务端的数据
• (4) outgoingQueue: 存放客户端创建节点时网络层面存放的数据
• (5) sendThread: 发送数据到服务端的线程
• (6) eventThread: 处理节点watch监听事件的线程
• (7) 通过NIO / Netty 与服务端建立连接
• (8) 向服务端发送ping请求，证明当前服务还存活
• (9) 多路复用器 selector.select() 阻塞等待事件就绪，在创建节点时会通过 selector.wakeup() 唤醒此阻塞
• (10) 如果是从服务端读数据请求，代表收到了服务端response，反序列化为packet，将packet从pendingQueue中移除
• (11) 并通过notifyAll()唤醒创建节点的wait()阻塞，返回节点path
• (12) 如果是写数据到客户端请求，从网络层面outgoingQueue中取到packet
• (13) 将packet通过jute序列化，通过socket.write()写数据到服务端
• (14) 将写数据请求加入到pendingQueue中，直到收到服务端response再移除

创建节点流程

• (1) 校验节点path是否存在
• (2) 校验节点是否是TTL节点
• (3) 校验当前节点权限是否允许
• (4) 创建请求头、请求体、响应头、响应体
• (5) 将请求头、请求体、响应头、响应体封装为Packet，并加入到outgoingQueue中
• (6) 通过selector.wakeup()唤醒selector.select()
• (7) 通过packet.wait()阻塞等待服务端的响应
• (8) 一旦收到服务端的响应数据，代表创建节点成功，通过packet.notifyAll()唤醒wait()阻塞，返回创建的节点path

zookeeper集群启动与leader选举

• (1) 加载zookeeper配置文件zoo.cfg
• (2) 创建Jetty Admin Server监听（监听zk server）
• (3) 创建ServerCnxnFactory（默认是NIO，可以配置为Netty）
• (4) 第一次启动zk server初始化创建5个默认节点
• (5) 初始化事务日志与数据快照文件
• (6) 加载数据到内存数据库
• (7) 进行leader选举

leader选举流程

leader选举与数据同步核心源码