zookeeper的簡單使用

前言

---

 

最近項目中要使用基於zookeeper的集中配置管理系統，而對於zookeeper僅在當初使用阿里開源分布式服務調用框架dubbo時簡單的了解一下。本

文的主要目的，調用zkclient (maven 地址見下面)實現監聽當某個節點的數據發生變化時，將變化的信息打印到控制台。

zkclient的maven地址

<dependency>
 <groupId>com.101tec</groupId>
 <artifactId>zkclient</artifactId>
 <version>0.4</version>
</dependency>

master app 應用程序

---

 

編寫 master app應用程序，該程序主要功能是創建一個"root1"的節點，並每20s改變該節點的數據。程序代碼如下：

import java.util.UUID;

import org.I0Itec.zkclient.ZkClient;
import org.apache.zookeeper.CreateMode;


public class App {
    
    private ZkClient zkClient;
    
    public ZkClient getZkClient() {
        return zkClient;
    }

    public void setZkClient(ZkClient zkClient) {
        this.zkClient = zkClient;
    }


    /**
     * 函數入口
     * @param args
     */
    public static void main( String[] args ) {
       
        App bootStrap=new App();
        bootStrap.initialize();
        
        try {
            Thread.sleep(100000000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
            
    }
    
  
    /**
     * 初始化zookeeper
     */
    public void initialize() {
        
        String connectionString="192.168.19.128:2181";
        int connectionTimeout=50000;
        
        zkClient=new ZkClient(connectionString, connectionTimeout);
        
        if(!zkClient.exists("/root1")) {
            zkClient.create("/root1", new Long(System.currentTimeMillis()), CreateMode.EPHEMERAL);
        }
            
        new Thread(new RootNodeChangeThread()).start();
    }
    
    /**
     * 每20s改變一次 'root1'節點的數據
     * @author yang
     *
     */
    private class RootNodeChangeThread implements Runnable{

        public void run() {
            
            while(true) {
            
                try {
                    Thread.sleep(20000);
                } catch (InterruptedException e) {
                    //ignore
                }
                
                String uuidStr=UUID.randomUUID().toString();    
                
                System.out.println(">>>>>>>>>> 產生隨機的 uuid string,'uuidStr'===>"+uuidStr);
                
                zkClient.writeData("/root1", uuidStr);
                
            }
            
        }
        
    }
}

slave app應用程序

---

 

編寫 slave app應用程序，該程序主要功能是監聽"root1"的節點，當其數據發生變化時，在控制台中打印中相關信息。程序代碼如下：

import org.I0Itec.zkclient.IZkDataListener;
import org.I0Itec.zkclient.ZkClient;

public class App {
    
    private ZkClient zkClient;
    
    public ZkClient getZkClient() {
        return zkClient;
    }

    public void setZkClient(ZkClient zkClient) {
        this.zkClient = zkClient;
    }

    /**
     * 初始化zookeeper
     */
    public void initialize() {
        
        String connectionString="192.168.19.128:2181";
        int connectionTimeout=500000;
        
        zkClient=new ZkClient(connectionString, connectionTimeout);
        
        new Thread(new Runnable() {
            
            public void run() {
            
                zkClient.subscribeDataChanges("/root1", new IZkDataListener() {
                    
                    public void handleDataDeleted(String dataPath) throws Exception {
                        System.out.println("the node 'dataPath'===>");    
                    }
                    
                    public void handleDataChange(String dataPath, Object data) throws Exception {
                        System.out.println("the node 'dataPath'===>"+dataPath+", data has changed.it's data is "+String.valueOf(data));
                        
                    }
                });
                
            }
            
        }).start();
    }
    
    /**
     * 函數入口
     * @param args
     */
    public static void main( String[] args ) {
       
        App bootStrap=new App();
        bootStrap.initialize();
        
        try {
            Thread.sleep(100000000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
            
    }
}

環境准備

---

 

啟動zookeeper，並關閉linux防火牆。

運行程序

---

 

運行 master app和slave app 兩個應用程序，截圖如下：