美文网首页JavaWeb 知识点
IDEA构建zookeeper源码环境小记

IDEA构建zookeeper源码环境小记

作者: 清幽之地 | 来源:发表于2019-03-03 22:42 被阅读43次

    事情是这样的。前两天晚上在家突然想到zookeeper中的一个问题,于是就考虑把源码跑一下看看咋回事。然后就兴致冲冲的跑到gitHub上,准备下载开撸。但显然笔者对形势做出了错误的乐观认识。

    构建

    ANT

    我以为zookeeper就是用Maven来构建的,没想到是Ant。虽然笔者对它不熟,但还是下载并安装了它的环境,并按照大部分博客中说的那样来试图导入zookeeper。

    1、在gitHub上下载zookeeper源码
    2、下载并安装ant环境
    3、定位到zookeeper源码根目录,并执行ant eclipse
    4、导入并运行

    博客中这样写的人都自己试过么?导入之后的各种报错,找不到包,Build都过不去,你们是怎么运行起来的。。

    后来,又看到说是因为IDEA不认识ant,需要手动添加Sources目录。搞了半天,还是跑不起,搞得我火大。。

    点根烟,站起来走两步,也许事情还有转机。

    JAR包

    既然Ant搞不成,那就抛弃它,转变下思路,不能被它牵着鼻子走。

    1、下载zookeeper带有源码的Jar包,并解压。比如zookeeper-3.4.13-sources.jar,下载地址在:https://repo1.maven.org/maven2/org/apache/zookeeper/zookeeper/
    2、在IDEA中新建Maven项目。
    3、复制gitHub上zookeeper项目里pom文件的依赖内容,放到新建项目中。
    4、将解压后的zookeeper源码org目录,复制到新建项目中。

    这样就完成了zookeeper源码的导入,比Ant编译手动添加Sources之类的,方便很多。


    不过,有两点可能需要注意。

    1、在pom文件中,修改netty的版本为3.x。
    2、如果Completer类报错,就重新导下包路径。

    启动服务

    找到ZooKeeperServerMain类,运行Main方法即可启动服务器。

    不过,在此之前,我们先要将zoo.cfg文件拷贝下来。内容如下:

    tickTime=2000
    initLimit=10
    syncLimit=5
    dataDir=E:\\zookeeper-data
    clientPort=2181
    

    并在main方法中,指定配置文件的路径。

    args = new String[1];
    args[0] = "E:\\zookeeper-data\\conf\\zoo.cfg";
    

    测试

    启动之后,会有日志显示绑定端口。然后我们有两种方式来测试。

    1、zkCli

    用zkCli工具来连接。

    执行:./zkCli.sh -server 192.168.100.139:2181

    然后服务器输出日志如下:

    NIO服务器启动,绑定端口:0.0.0.0/0.0.0.0:2181
    接收来自客户端的连接:/192.168.100.139:62241 
    Client attempting to establish new session at /192.168.100.139:62241
    Creating new log file: log.3
    Established session 0x100151428150000 with negotiated timeout 30000 
    for client /192.168.100.139:62241
    

    执行创建节点、查询、删除等操作,结果无误。

    2、zookeeper

    如果没有zkCli工具,我们也可以写测试程序来搞。

    比如:

    CountDownLatch countDownLatch = new CountDownLatch(1);
    ZooKeeper zooKeeper = new ZooKeeper("127.0.0.1:2181", 1000, new Watcher() {
        public void process(WatchedEvent event) {
            countDownLatch.countDown();
        }
    });
    countDownLatch.await();
    zooKeeper.create("/test","".getBytes(), 
                    ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL);
    

    好啦,至此我们在本地环境中启动了zookeeper,接下来就荡漾在zk源码的世界中吧。。。

    相关文章

      网友评论

        本文标题:IDEA构建zookeeper源码环境小记

        本文链接:https://www.haomeiwen.com/subject/hulxyqtx.html