最近正在搞元資料架構，學了一下zookeeper和kafka，在這裡把它們的搭建方法記錄一下，以便供大家和自己以後參考。
zookeeper：顧名思義，動物園管理者，國外程式猿愛把各種軟體起一個動物的名字，諸如tomcat之類的;因此可以把zookeeper當做
是一個管理各種軟體的工具，在這裡只介紹一下zookeeper管理kafka的示例，其他的大家可以自行研究。
下載zookeeper後可以直接執行zkserver（需要先建一個配置檔案zoo.cfg[可直接複製備份檔案]）；

kafka：訊息佇列，簡單點說，就是傳送訊息，一方傳送，乙方接收；
    至於kafka的原理可參考：  http://www.infoq.com/cn/articles/apache-kafka
http://cailin.iteye.com/blog/2014486/
 

安裝方法可參考：http://blog.csdn.net/evankaka/article/details/52421314（windows）
http://czj4451.iteye.com/blog/2041096（linux）
以上網址中的部落格已經把操作步驟寫的很清楚了，我也就不再贅述了，大家可以參照部落格中的方法進行安裝和執行；
當然了，安裝並執行軟體永遠都不是最終目的，程式猿的最終目的是要在程式碼上自動執行才是關鍵；
該專案主要是新增節點，監聽節點以及刪除節點；
首先將zookeeper的server服務端啟動，即可執行下面的專案
然後可以啟動zookeeper的client端來檢視當前的服務節點，其實就是目錄結構；
只需要在pop.xml中加入

<dependency>  
           <groupId>org.apache.zookeeper</groupId>  
           <artifactId>zookeeper</artifactId>  
           <version>3.4.6</version>  
       </dependency>  
  </dependencies>

package com.zoo;

import java.util.Arrays;
import java.util
 
.List;

import org.apache.zookeeper.CreateMode;
import org.apache.zookeeper.WatchedEvent;
import org.apache.zookeeper.Watcher;
import org.apache.zookeeper.ZooDefs;
import org.apache.zookeeper.ZooKeeper;


//啟動客戶端之後輸入ls+空格+/
public class ZookeeperTest {

    // 根節點
    public static final String ROOT = "/root-ktv1";

    public static void main(String[] args) throws Exception {
        // 建立一個與伺服器的連線
        Watcher watcher = new Watcher(){
             public void process(WatchedEvent event) {
                 System.out.println("狀態:" + event.getState()+":"+event.getType()+":"+event.getWrapper()+":"+event.getPath());
             }
        };

       ZooKeeper zk = new ZooKeeper("localhost:2181", 300, watcher);
        // 建立一個總的目錄ktv，並不控制權限，這裡需要用持久化節點，不然下面的節點建立容易出錯
        zk.create(ROOT, "root-ktv1".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);

        // 然後杭州開一個快遞 ,       PERSISTENT_SEQUENTIAL 型別會自動加上 0000000000 自增的字尾
        zk.create(ROOT+"/杭州快遞", "杭州快遞".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT_SEQUENTIAL);

        // 也可以在北京開一個,       EPHEMERAL session 過期了就會自動刪除
        zk.create(ROOT+"/北京快遞", "北京快遞".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL);

        // 同理，我可以在北京開多個，EPHEMERAL_SEQUENTIAL  session 過期自動刪除，也會加數字的字尾
        zk.create(ROOT+"/北京快遞-分店", "北京快遞-分店".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL_SEQUENTIAL);

        // 我們也可以 來看看 一共監視了多少家的ktv
        List<String> ktvs = zk.getChildren(ROOT, true);
        System.out.println(Arrays.toString(ktvs.toArray()));
        for(String node : ktvs){
            // 刪除節點
            zk.delete(ROOT+"/"+node,-1);
        }
        // 根目錄得最後刪除的
        zk.delete(ROOT, -1);
        zk.close();  
    }
}

以後再加幾個java以及與springmvc合成的例子，今天先寫到這兒
下面寫一個kafka的例子：

不知道為什麼我的消費者老是接收不到資訊，大夥兒有跑起來的可以給我留個言啊

正好需要（檢視zokeeper和kafka的程序是否啟動），先記錄一下windows和linux簡單檢視進行的方法
windows：（通過搜尋埠）
1)檢視佔用8080埠的程序號

netstat –aon | findstr “8080”

結果：TCP 0.0.0.0:8080 0.0.0.0:0 LISTENING 3500

可知，程序號為3500的程序佔用了8080埠

可以使用命令 tasklist | findstr “3500”進一步檢視3500程序的具體資訊。

tasklist | findstr “3500”

結果：javaw.exe 3500 Console 0 28,792 K

可知3500程序為javaw.exe。

2）殺掉程序

tskill 3500

linux：ps aux | grep ‘zookeeper’