IDEA构建zookeeper源码环境小记

冷不防 2022-03-14 12:22 404阅读 0赞

> 事情是这样的。前两天晚上在家突然想到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源码的世界中吧。。。