【ZooKeeper系列】3.ZooKeeper源码环境搭建

时间  2020-05-12
标签 ZooKeeper系列 3.zookeeper zookeeper 源码 环境 搭建 栏目 Zookeeper 繁體版
原文   原文链接

前文阅读： 【ZooKeeper系列】1.ZooKeeper单机版、伪集群和集群环境搭建 【ZooKeeper系列】2.用Java实现ZooKeeper API的调用html

在系列的前两篇文章中，介绍了ZooKeeper环境的搭建（包括单机版、伪集群和集群），对建立、删除、修改节点等场景用命令行的方式进行了测试，让你们对ZooKeeper环境搭建及经常使用命令行有初步的认识，也为搭建ZooKeeper的开发环境、生产环境起到了抛砖引玉的做用。也介绍了用Java来实现API的调用，包括节点的增、删、改、查。经过对这两篇的学习，让你们对ZooKeeper的使用有了初步认识，也可用于实现系列后面篇章要介绍的命名服务、集群管理、分布式锁、负载均衡、分布式队列等。java

在前两篇中，强调了阅读英文文档的重要性，也带领你们解读了部分官方文档，想传达出的理念是ZooKeeper没有想象中的那么难，阅读官方文档也没那么难。后面的篇章中，结合官方文档，在实战演练和解读源码的基础上加深理解。git

上联：说你行你就行不行也行 下联：说不行就不行行也不行 横批：不服不行 阅读源码就跟这个对联如出一辙，就看你选上联，仍是下联了！github

这一篇开始源码环境的搭建，here we go！apache

不少老铁留言说很想研读些github上的开源项目，但代码clone下来后总出现这样或那样奇奇怪怪的问题，很影响学习的积极性。学习ZooKeeper的源码尤为如此，不少人clone代码后，报各类错，提示少各类包。问了下度娘ZooKeeper源码环境，搜出来的文章真的差强人意，有些文章错的居然很是离谱。这里我从新搭建了一遍，也会介绍遇到的一些坑。安全

不少老铁上来一堆猛操做，从github上下载了ZooKeeper源码后，按常规方式导入IDEA，最后发现少各类包。起初我也是这样弄的，觉得ZooKeeper是用Maven来构建的，仔细去了解了下ZooKeeper的版本历史，实际上是用的Ant。现在通常用的Maven或Gradle，不多见到Ant的项目了，这里不对Ant多作介绍。app

1 Ant环境搭建

Ant官网地址：https://ant.apache.org/bindownload.cgi负载均衡

下载解压后，跟配置jdk同样配置几个环境变量：eclipse

//修改成本身本地安装的目录
ANT_HOMT=D:\apache-ant-1.10.7 
PATH=%ANT_HOME%/bin
CLASSPATH=%ANT_HOME%/lib

配置好后，测试下Ant是否安装成功。ant -version,获得以下信息则表明安装成功：socket

Apache Ant(TM) version 1.10.7 compiled on September 1 2019

Ant的安装跟JDK的安装和配置很是类似，这里不作过多介绍。

2 下载ZooKeeper源码

源码地址：https://github.com/apache/zookeeper

猿人谷在写本篇文章时，releases列表里的最新版本为release-3.5.6，咱们以此版原本进行源码环境的搭建。

3 编译ZooKeeper源码

切换到源码所在目录，运行ant eclipse将项目编译并转成eclipse的项目结构。 在这里插入图片描述 这个编译过程会比较长，差很少等了7分钟。若是编译成功，会出现以下结果： 在这里插入图片描述

4 导入IDEA

上面已经将项目编译并转成eclipse的项目结构，按eclipse的形式导入项目。 在这里插入图片描述

在这里插入图片描述

5 特别说明

将源码导入IDEA后在org.apache.zookeeper.Version中发现不少红色警告，很明显少了org.apache.zookeeper.version.Info类。 在这里插入图片描述 查询源码得知是用来发布的时候生成版本用的，咱们只是研读源码，又不发布版本因此直接写死就ok了。 在这里插入图片描述 即新增Info类：

package org.apache.zookeeper.version;

public interface Info {
    int MAJOR = 3;
    int MINOR = 5;
    int MICRO = 6;
    String QUALIFIER = null;
    String REVISION_HASH = "c11b7e26bc554b8523dc929761dd28808913f091";
    String BUILD_DATE = "10/08/2019 20:18 GMT";
}

6 启动zookeeper

针对单机版本和集群版本，分别对应两个启动类：

  • 单机：ZooKeeperServerMain
  • 集群：QuorumPeerMain

这里咱们只作单机版的测试。

在conf目录里有个zoo_sample.cfg，复制一份重命名为zoo.cfg。

zoo.cfg里的内容作点修改（也能够不作修改），方便日志查询。dataDir和dataLogDir根据本身的状况设定。

dataDir=E:\\02private\\1opensource\\zk\\zookeeper\\dataDir
dataLogDir=E:\\02private\\1opensource\\zk\\zookeeper\\dataLogDir

运行主类 org.apache.zookeeper.server.ZooKeeperServerMain，将zoo.cfg的完整路径配置在Program arguments。 在这里插入图片描述 运行ZooKeeperServerMain，获得的结果以下：

Connected to the target VM, address: '127.0.0.1:0', transport: 'socket'
log4j:WARN No appenders could be found for logger (org.apache.zookeeper.jmx.ManagedUtil).
log4j:WARN Please initialize the log4j system properly.
log4j:WARN See http://logging.apache.org/log4j/1.2/faq.html#noconfig for more info.

告知日志没法输出，日志文件配置有误。这里须要指定日志文件log4j.properties。 在这里插入图片描述 在VM options配置，即指定到conf目录下的log4j.properties：

-Dlog4j.configuration=file:E:/02private/1opensource/zk/zookeeper/conf/log4j.properties

配置后从新运行ZooKeeperServerMain，输出日志以下， 在这里插入图片描述 能够得知单机版启动成功，单机版服务端地址为127.0.0.1:2181。

7 启动客户端

经过运行ZooKeeperServerMain获得的日志，能够得知ZooKeeper服务端已经启动，服务的地址为127.0.0.1:2181。启动客户端来进行链接测试。

客户端的启动类为org.apache.zookeeper.ZooKeeperMain，进行以下配置： 在这里插入图片描述 即客户端链接127.0.0.1:2181，获取节点/yuanrengu的信息。

下面带领你们一块儿看看客户端启动的源码（org.apache.zookeeper.ZooKeeperMain）。这里要给你们说下我阅读源码的习惯，不少老铁觉得阅读源码就是顺着代码看，这样也没啥不对，只是不少开源项目代码量惊人，这么个干见解，容易注意力分散也容易看花眼。我通常是基于某个功能点，从入口开始debug跑一遍，弄清这个功能的“代码线”，就像跑马圈块地儿同样，弄清楚功能有关的代码，了解参数传递的过程，这样看代码时就更有针对性，也能排除不少干扰代码。

7.1 main

main里就两行代码，经过debug得知args里包含的信息就是上面咱们配置在Program arguments里的信息： 在这里插入图片描述

7.1.1 ZooKeeperMain

public ZooKeeperMain(String args[]) throws IOException, InterruptedException {
        // 用于解析参数里的命令行的
        cl.parseOptions(args);
        System.out.println("Connecting to " + cl.getOption("server"));
        // 用于链接ZooKeeper服务端
        connectToZK(cl.getOption("server"));
    }

经过下图能够看出，解析参数后，就尝试链接127.0.0.1:2181，即ZooKeeper服务端。cl.getOption("server")获得的就是127.0.0.1:2181。 在这里插入图片描述

7.1.2 parseOptions

在这里插入图片描述 能够很清楚的得知解析args的过程，主要从"-server"，"-timeout"，"-r"，"-"这几个维度来进行解析。

7.1.3 connectToZK

protected void connectToZK(String newHost) throws InterruptedException, IOException {
        // 用于判断如今ZooKeeper链接是否还有效
        // zk.getState().isAlive() 注意这个会话是否有效的判断，客户端与 Zookeeper链接断开不必定会话失效
        if (zk != null && zk.getState().isAlive()) {
            zk.close();
        }

        // 此时newHost为127.0.0.1:2181
        host = newHost;
        // 判断是否为只读模式，关于只读模式的概念在前一篇文章中有介绍
        boolean readOnly = cl.getOption("readonly") != null;
        // 用于判断是否创建安全链接
        if (cl.getOption("secure") != null) {
            System.setProperty(ZKClientConfig.SECURE_CLIENT, "true");
            System.out.println("Secure connection is enabled");
        }
        zk = new ZooKeeperAdmin(host, Integer.parseInt(cl.getOption("timeout")), new MyWatcher(), readOnly);
    }

ZKClientConfig.SECURE_CLIENT已经被标注为deprecation了：

/**
     * Setting this to "true" will enable encrypted client-server communication.
     */
    @SuppressWarnings("deprecation")
    public static final String SECURE_CLIENT = ZooKeeper.SECURE_CLIENT;

debug查看关键点处的信息，能够得知这是创建一个ZooKeeper链接的过程（【ZooKeeper系列】2.用Java实现ZooKeeper API的调用,这篇文章里详细介绍过ZooKeeper创建链接的过程）

下图看看几处关键信息： 在这里插入图片描述 Integer.parseInt(cl.getOption("timeout"))为30000。

至此完成了ZooKeeperMain main = new ZooKeeperMain(args);的整个过程。简短点说就是：

  1. 解析Program arguments里的参数
  2. 链接ZooKeeper服务端

7.2 main.run()

敲黑板，重头戏来了哦！

一块儿来看下run()的代码：

void run() throws CliException, IOException, InterruptedException {
        // cl.getCommand()获得的是 “get”，就是上文传进来的
        if (cl.getCommand() == null) {
            System.out.println("Welcome to ZooKeeper!");

            boolean jlinemissing = false;
            // only use jline if it's in the classpath
            try {
                Class<?> consoleC = Class.forName("jline.console.ConsoleReader");
                Class<?> completorC =
                    Class.forName("org.apache.zookeeper.JLineZNodeCompleter");

                System.out.println("JLine support is enabled");

                Object console =
                    consoleC.getConstructor().newInstance();

                Object completor =
                    completorC.getConstructor(ZooKeeper.class).newInstance(zk);
                Method addCompletor = consoleC.getMethod("addCompleter",
                        Class.forName("jline.console.completer.Completer"));
                addCompletor.invoke(console, completor);

                String line;
                Method readLine = consoleC.getMethod("readLine", String.class);
                while ((line = (String)readLine.invoke(console, getPrompt())) != null) {
                    executeLine(line);
                }
            } catch (ClassNotFoundException e) {
                LOG.debug("Unable to start jline", e);
                jlinemissing = true;
            } catch (NoSuchMethodException e) {
                LOG.debug("Unable to start jline", e);
                jlinemissing = true;
            } catch (InvocationTargetException e) {
                LOG.debug("Unable to start jline", e);
                jlinemissing = true;
            } catch (IllegalAccessException e) {
                LOG.debug("Unable to start jline", e);
                jlinemissing = true;
            } catch (InstantiationException e) {
                LOG.debug("Unable to start jline", e);
                jlinemissing = true;
            }

            if (jlinemissing) {
                System.out.println("JLine support is disabled");
                BufferedReader br =
                    new BufferedReader(new InputStreamReader(System.in));

                String line;
                while ((line = br.readLine()) != null) {
                    executeLine(line);
                }
            }
        } else {
            // 处理传进来的参数
            processCmd(cl);
        }
        System.exit(exitCode);
    }

经过下图能够看出processCmd(cl);里cl包含的信息： 在这里插入图片描述 debug到processCmd(MyCommandOptions co) 就到了决战时刻。里面的processZKCmd(MyCommandOptions co)就是核心了，代码太长，只说下processZKCmd里的重点代码，获取节点/yuanrengu的信息： 在这里插入图片描述 由于我以前没有建立过/yuanrengu节点，会抛异常org.apache.zookeeper.KeeperException$NoNodeException: KeeperErrorCode = NoNode for /yuanrengu ， 以下图所示： 在这里插入图片描述 通过上面的步骤后exitCode为1，执行System.exit(exitCode);退出。

至此带领你们dubug了一遍org.apache.zookeeper.ZooKeeperMain，上面我说过，阅读源码干看效果很小，只有debug才能有助于梳理流程和思路，也能清楚参数传递的过程发生了什么变化。

舒适提示

上面咱们介绍了源码环境的搭建过程，运行运行主类 org.apache.zookeeper.server.ZooKeeperServerMain 启动ZooKeeper服务端，运行org.apache.zookeeper.ZooKeeperMain链接服务端。

阅读源码最好能动起来(debug)读，这样代码才是活的，干看的话代码如死水同样，容易让人索然无味！

每一个人操做的方式不同，有可能遇到的问题也不同，搭建过程当中遇到什么问题，你们能够在评论区留言。

相关文章
相关标签/搜索
每日一句
    每一个你不满意的现在，都有一个你没有努力的曾经。
本站公众号
   欢迎关注本站公众号,获取更多信息
联系我们 最近搜索 最新文章 沪ICP备13005482号-10 MyBatis教程 SQL 教程 MySQL教程 Java 教程 Thymeleaf 教程 Hibernate教程 Spring教程 Redis教程