zookeeper server启动源码解析

悠悠 2022-10-14 00:47 179阅读 0赞

> 原创不易，转载请注明出处  
> 基于3.4.5版本源码

### 文章目录 ###

*   *   *  前言
         *  源码解析
         *  总结

--------------------

### 前言 ###

本文主要介绍zookeeper 服务端启动流程，解析启动流程源代码，看看zk server启动都干了些什么，这里不说多了，直接github将zk3.4.5源码clone下来，按照《[zookeeper老版本源码编译踩坑记][zookeeper]》一文将源码编译好，导入到idea中，直接看源码就好了。

### 源码解析 ###

在zkserver 启动脚本中，有这么两行代码可以找出zk server启动main类  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3l1YW5zaGFuZ3NoZW5naHVv_size_16_color_FFFFFF_t_70]  
这个就是定义一个ZOOMAIN ，可以看到它的值就是org.apache.zookeeper.server.quorum.QuorumPeerMain了  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3l1YW5zaGFuZ3NoZW5naHVv_size_16_color_FFFFFF_t_70 1]  
start 直接就是 `java .... $ZOOMAIN "$ZOOCFG"`  
ZOOMAIN其实就是启动类，后面这个 “$ZOOCFG” 就是传入的参数，是zk 配置文件的路径。  
可以得到org.apache.zookeeper.server.quorum 包中的QuorumPeerMain就是zk server 的启动类，它里面有个main方法，调用直接就启动了  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3l1YW5zaGFuZ3NoZW5naHVv_size_16_color_FFFFFF_t_70 2]  
可以看到，上来就new 了一个当前类（QuorumPeerMain）的对象，然后调用initializeAndRun 方法进行初始化和启动。  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3l1YW5zaGFuZ3NoZW5naHVv_size_16_color_FFFFFF_t_70 3]  
这个initializeAndRun 方法其实就是干了3件事，首先是创建一个QuorumPeerConfig 配置类对象，判断你main方法传入的参数个数是不是1个，如果是的话，就认为是配置文件的路径，接着就会调用QuorumPeerConfig 配置类对象的parse方法进行解析配置文件。  
然后创建DatadirCleanupManager 对象，从名字上其实也能看出来，datadir 清理管理器，一看就知道清理datadir这个目录的，创建完对象并启动，这块我们先放过，后面的文章会就介绍。  
最后就是通过判断你配置文件中配置的server个数来集群启动运行还是单机运行。我们在搭建配置zk集群的话，一般都会在配置文件中写如下配置：

server.1=127.0.0.1:2888:3888
    server.2=127.0.0.1:2888:3888
    ...

这里我们就是集群模式，走runFromConfig 方法就好了，将config传进去  
接着我们看下runFromConfig 方法都干了些啥  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3l1YW5zaGFuZ3NoZW5naHVv_size_16_color_FFFFFF_t_70 4]  
上来ManagedUtil.registerLog4jMBeans() 这玩意就是jmx监控的一些东西，暂时可以不care。  
往下走重点来了，创建一个ServerCnxnFactory 对象，然后调用configure 方法进行配置，传入和客户端交互的端口，与最大客户端连接数作为参数，这里介绍一下ServerCnxnFactory ，它主要就是创建ServerSocketChannel，与客户端建立连接，接收客户端请求，发送客户端响应的，其实从名字上也能看出来，就是zk server连接工厂，创建客户端连接的。  
接着就是创建QuorumPeer 对象，先说说这个对象是干啥的，peer其实就是平等的意思，这里的QuorumPeer 你可以理解为一个zk server 集群的一个节点，它主要就是用来集群选举，数据同步的，我们可以看到为这个对象设置了一堆参数，这堆参数多数是配置文件拿出来的，需要注意`quorumPeer.setZKDatabase(new ZKDatabase(quorumPeer.getTxnFactory()));`这行代码，创建了一个zkdatabase 对象设置了进去，这个ZKDatabase 其实就是zk存放数据的，里面有个znode树。最后调用start方法启动线程（这个QuorumPeer其实就是个线程），调用join方法hang住主线程，只要这个QuorumPeer 线程不执行完，主线程就一直hang在这里。

### 总结 ###

好了，zk server 启动源码就介绍完了，这里只是粗略的看了一下流程，并没有深入每个组件的创建，可以看到，zk server 的启动源码思路还是很清晰的，首先是创建配置类解析配置文件，创建datadir清理器并启动，接着就是创建ServerCnxnFactory 工厂，并启动，最后就是创建QuorumPeer 对象，设置一堆配置参数，创建zk database，最后启动QuorumPeer 这个线程，hang住主线程。

[zookeeper]: https://inetyoung.blog.csdn.net/article/details/117232560
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3l1YW5zaGFuZ3NoZW5naHVv_size_16_color_FFFFFF_t_70]: /images/20221014/be76d58be59c4c5497227d056f325d39.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3l1YW5zaGFuZ3NoZW5naHVv_size_16_color_FFFFFF_t_70 1]: /images/20221014/8c54e6936b624e7c9c025cc86aab4ba5.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3l1YW5zaGFuZ3NoZW5naHVv_size_16_color_FFFFFF_t_70 2]: /images/20221014/4bd9e1aecfcb45389ff6fd9217421057.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3l1YW5zaGFuZ3NoZW5naHVv_size_16_color_FFFFFF_t_70 3]: /images/20221014/3653282d0ed24566b8455f4c424db2a4.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3l1YW5zaGFuZ3NoZW5naHVv_size_16_color_FFFFFF_t_70 4]: /images/20221014/8512a80fdedc4a3681d6610691ddbf68.png