事情是這樣的。前兩天晚上在家突然想到zookeeper中的一個(gè)問(wèn)題，于是就考慮把源碼跑一下看看咋回事。然后就興致沖沖的跑到gitHub上，準(zhǔn)備下載開(kāi)擼。但顯然筆者對(duì)形勢(shì)做出了錯(cuò)誤的樂(lè)觀認(rèn)識(shí)。

構(gòu)建

ANT

我以為zookeeper就是用Maven來(lái)構(gòu)建的，沒(méi)想到是Ant。雖然筆者對(duì)它不熟，但還是下載并安裝了它的環(huán)境，并按照大部分博客中說(shuō)的那樣來(lái)試圖導(dǎo)入zookeeper。

1、在gitHub上下載zookeeper源碼

2、下載并安裝ant環(huán)境

3、定位到zookeeper源碼根目錄，并執(zhí)行ant eclipse

4、導(dǎo)入并運(yùn)行

博客中這樣寫(xiě)的人都自己試過(guò)么？導(dǎo)入之后的各種報(bào)錯(cuò)，找不到包，Build都過(guò)不去，你們是怎么運(yùn)行起來(lái)的。。

后來(lái)，又看到說(shuō)是因?yàn)镮DEA不認(rèn)識(shí)ant，需要手動(dòng)添加Sources目錄。搞了半天，還是跑不起，搞得我火大。。

點(diǎn)根煙，站起來(lái)走兩步，也許事情還有轉(zhuǎn)機(jī)。

JAR包

既然Ant搞不成，那就拋棄它，轉(zhuǎn)變下思路，不能被它牽著鼻子走。

1、下載zookeeper帶有源碼的Jar包，并解壓。比如zookeeper-3.4.13-sources.jar，下載地址在：https://repo1.maven.org/maven2/org/apache/zookeeper/zookeeper/。

2、在IDEA中新建Maven項(xiàng)目。

3、復(fù)制gitHub上zookeeper項(xiàng)目里pom文件的依賴內(nèi)容，放到新建項(xiàng)目中。

4、將解壓后的zookeeper源碼org目錄，復(fù)制到新建項(xiàng)目中。

這樣就完成了zookeeper源碼的導(dǎo)入，比Ant編譯手動(dòng)添加Sources之類的，方便很多。

不過(guò)，有兩點(diǎn)可能需要注意。

1、在pom文件中，修改netty的版本為3.x。
2、如果Completer類報(bào)錯(cuò)，就重新導(dǎo)下包路徑。

啟動(dòng)服務(wù)

找到ZooKeeperServerMain類，運(yùn)行Main方法即可啟動(dòng)服務(wù)器。

不過(guò)，在此之前，我們先要將zoo.cfg文件拷貝下來(lái)。內(nèi)容如下：

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";

測(cè)試

啟動(dòng)之后，會(huì)有日志顯示綁定端口。然后我們有兩種方式來(lái)測(cè)試。

1、zkCli

用zkCli工具來(lái)連接。

執(zhí)行：./zkCli.sh -server 192.168.100.139:2181

然后服務(wù)器輸出日志如下：

NIO服務(wù)器啟動(dòng)，綁定端口：0.0.0.0/0.0.0.0:2181
接收來(lái)自客戶端的連接：/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

執(zhí)行創(chuàng)建節(jié)點(diǎn)、查詢、刪除等操作，結(jié)果無(wú)誤。

2、zookeeper

如果沒(méi)有zkCli工具，我們也可以寫(xiě)測(cè)試程序來(lái)搞。

比如：

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);

好啦，至此我們?cè)诒镜丨h(huán)境中啟動(dòng)了zookeeper，接下來(lái)就蕩漾在zk源碼的世界中吧。。。