zookeeper的简单使用

Matthewl

　　前言

　　
　　最近项目中要使用基于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改变该节点的数据。程序代码如下：



1 import java.util.UUID;
2
3 import org.I0Itec.zkclient.ZkClient;
4 import org.apache.zookeeper.CreateMode;
5
6
7 public class App {
8     
9     private ZkClient zkClient;
10     
11     public ZkClient getZkClient() {
12         return zkClient;
13     }
14
15     public void setZkClient(ZkClient zkClient) {
16         this.zkClient = zkClient;
17     }
18
19
20     /**
21      * 函数入口
22      * @param args
23      */
24     public static void main( String[] args ) {
25        
26         App bootStrap=new App();
27         bootStrap.initialize();
28         
29         try {
30             Thread.sleep(100000000);
31         } catch (InterruptedException e) {
32             e.printStackTrace();
33         }
34            
35     }
36     
37   
38     /**
39      * 初始化zookeeper
40      */
41     public void initialize() {
42         
43         String connectionString="192.168.19.128:2181";
44         int connectionTimeout=50000;
45         
46         zkClient=new ZkClient(connectionString, connectionTimeout);
47         
48         if(!zkClient.exists("/root1")) {
49             zkClient.create("/root1", new Long(System.currentTimeMillis()), CreateMode.EPHEMERAL);
50         }
51            
52         new Thread(new RootNodeChangeThread()).start();
53     }
54     
55     /**
56      * 每20s改变一次 'root1'节点的数据
57      * @author yang
58      *
59      */
60     private class RootNodeChangeThread implements Runnable{
61
62         public void run() {
63            
64             while(true) {
65            
66                 try {
67                     Thread.sleep(20000);
68                 } catch (InterruptedException e) {
69                     //ignore
70                 }
71                 
72                 String uuidStr=UUID.randomUUID().toString();   
73                 
74                 System.out.println(">>>>>>>>>> 产生随机的 uuid string,'uuidStr'===>"+uuidStr);
75                 
76                 zkClient.writeData("/root1", uuidStr);
77                 
78             }
79            
80         }
81         
82     }
83 }
slave app应用程序

　　
　　编写 slave app应用程序，该程序主要功能是监听"root1"的节点，当其数据发生变化时，在控制台中打印中相关信息。程序代码如下：



1 import org.I0Itec.zkclient.IZkDataListener;
2 import org.I0Itec.zkclient.ZkClient;
3
4 public class App {
5     
6     private ZkClient zkClient;
7     
8     public ZkClient getZkClient() {
9         return zkClient;
10     }
11
12     public void setZkClient(ZkClient zkClient) {
13         this.zkClient = zkClient;
14     }
15
16     /**
17      * 初始化zookeeper
18      */
19     public void initialize() {
20         
21         String connectionString="192.168.19.128:2181";
22         int connectionTimeout=500000;
23         
24         zkClient=new ZkClient(connectionString, connectionTimeout);
25         
26         new Thread(new Runnable() {
27            
28             public void run() {
29            
30                 zkClient.subscribeDataChanges("/root1", new IZkDataListener() {
31                     
32                     public void handleDataDeleted(String dataPath) throws Exception {
33                         System.out.println("the node 'dataPath'===>");   
34                     }
35                     
36                     public void handleDataChange(String dataPath, Object data) throws Exception {
37                         System.out.println("the node 'dataPath'===>"+dataPath+", data has changed.it's data is "+String.valueOf(data));
38                        
39                     }
40                 });
41                 
42             }
43            
44         }).start();
45     }
46     
47     /**
48      * 函数入口
49      * @param args
50      */
51     public static void main( String[] args ) {
52        
53         App bootStrap=new App();
54         bootStrap.initialize();
55         
56         try {
57             Thread.sleep(100000000);
58         } catch (InterruptedException e) {
59             e.printStackTrace();
60         }
61            
62     }
63 }
环境准备

　　
　　启动zookeeper，并关闭linux防火墙。


运行程序

　　
　　运行 master app和slave app 两个应用程序，截图如下：