大數(shù)據(jù)生態(tài)之zookeeper（API）

在使用maven項目編寫zookeeper程序時導入相關(guān)的jar包：

        <dependency>
            <groupId>org.apache.zookeeper</groupId>
            <artifactId>zookeeper</artifactId>
            <version>3.4.10</version>
        </dependency>

1.創(chuàng)建集群連接

  //集群節(jié)點節(jié)點，之間使用逗號隔開
    static String url="hadoop01:2181,hadoop02:2181,hadoop03:2181";
    //集群編程入口
    static ZooKeeper zk;
    //超時時間
    static long time=5000;
    //使用靜態(tài)代碼塊，初始化ZooKeeper對象
    static {
        try {
            zk=new ZooKeeper(url,(int)time,null);
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

2.創(chuàng)建節(jié)點

    public void createZnode(ZooKeeper zk){
        //必須使用絕對路徑
        String path="/test/test04";
        //在創(chuàng)建創(chuàng)建節(jié)點時，必須指定節(jié)點內(nèi)容
        byte data[]="I am a good boy!".getBytes();
        try {
            /**
             * zk.create的四個參數(shù)表示：
             * arg1:節(jié)點路徑
             * arg2:節(jié)點存放的內(nèi)容
             * arg3:權(quán)限設(shè)置：默認
             * arg4:節(jié)點類型（永久無順序、永久有順序、臨時無順序、臨時有順序）
             */
            String info = zk.create(path, data, ZooDefs.Ids.OPEN_ACL_UNSAFE
                    , CreateMode.EPHEMERAL);
            System.out.println(info==null?"fail":"success");
        } catch (KeeperException e) {
            e.printStackTrace();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }

3.查看節(jié)點信息

    public void getInfo(ZooKeeper zk,String path){
        try {
            /**

             * zk.getData(path, null, null);
             *  參數(shù)1:節(jié)點的絕對路徑  string
             *  參數(shù)2:節(jié)點的監(jiān)聽
             *  參數(shù)3：節(jié)點的狀態(tài)對象
             */
            byte[] data = zk.getData(path, null, null);
            System.out.println("節(jié)點："+path+"的信息是："+(new String(data)));
        } catch (KeeperException e) {
            e.printStackTrace();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }

4.修改節(jié)點數(shù)據(jù)

 public void updateData(ZooKeeper zk,String path){
        try {
            /**
             * zk.setData(path, data, version);
             * path：修改內(nèi)容的節(jié)點
             * data：更新的數(shù)據(jù)
             * version：修改的版本：如果不知道，寫-1，表示最新版本 
             */
            zk.setData(path,"haha".getBytes(),-1);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

5.刪除節(jié)點

 public void deleteZnode(ZooKeeper zk,String path){
        try {
            /**
             * zk.delete(path, version);
             * path：路徑
             * version：刪除的版本，如果不知道，寫-1，表示刪除最新版本  int
             */
            zk.delete(path,-1);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

6.獲取znode節(jié)點的權(quán)限信息

public void getACL(ZooKeeper zk,String path){
        try {
            /**
             * zk.getACL(path,stat)
             * path:路徑
             * stat:狀態(tài)信息
             */
            List<ACL> acls = zk.getACL(path, null);
            for(ACL acl:acls){
                System.out.println(acl.getPerms());
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

7.獲取子節(jié)點

public void getChildren(ZooKeeper zk, String path) {
        try {
            //判斷節(jié)點是否存在
            if (zk.exists(path, null) == null) {
                List<String> childrens = zk.getChildren(path, null);
                for(String children:childrens){
                    //注意這里面收到的都是當前節(jié)點下的子節(jié)點的相對路徑
                    System.out.println(children);
                }
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

8.znode的測試監(jiān)聽

public class testZKWatcher {
    static String url="hadoop01:2181,hadoop02:2181,hadoop03:2181";
    static ZooKeeper zk;
    static long time=5000;
    static {
        try {
            zk=new ZooKeeper(url,(int) time,null);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
    //設(shè)置監(jiān)聽
    public static void liisten(String path,ZooKeeper zk){
        try {
            zk.exists(path, new Watcher() {
                @Override
                //WatchedEvent event監(jiān)聽事件對象
                public void process(WatchedEvent event) {
                    //節(jié)點觸發(fā)的類型（新增、修改、創(chuàng)建...）
                    Event.EventType type = event.getType();
                    //獲取觸發(fā)的節(jié)點的路徑
                    event.getPath();
                    System.out.println("觸發(fā)事件的路徑"+path+",觸發(fā)的事件的類型"+type);
                }
            });
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    public static void main(String[] args) {
        String path="/test/test01";
        liisten(path,zk);
        try {
            //觸發(fā)監(jiān)聽
            zk.create("jj","zzy".getBytes(),
                    ZooDefs.Ids.OPEN_ACL_UNSAFE,CreateMode.EPHEMERAL);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

| 這里需要注意的是，監(jiān)聽事件是一次性的，如果需要一直監(jiān)聽，那么需要設(shè)置循環(huán)監(jiān)聽。