基于ZK的优点：

1. 简单。尽管前期搭建ZooKeeper服务器集群较为麻烦,但是实现该方案后,修改配置整个过程变得简单很多。用户只要修改配置,无需进行其他任何操作,配置自动生效。
2. 可靠。ZooKeeper服务集群具有无单点失效的特性,使整个系统更加可靠。即使ZooKeeper 集群中的一台机器失效,也不会影响整体服务,更不会影响分布式应用配置信息的更新。
3. 实时。ZooKeeper的数据更新通知机制,可以在数据发生变化后,立即通知给分布式应用程序,具有很强的变化响应能力。

转自：http://www.cnblogs.com/yql1986/p/4116483.html

最近项目中要使用基于zookeeper的集中配置管理系统，而对于zookeeper仅在当初使用阿里开源分布式服务调用框架dubbo时简单的了解一下。本

文的主要目的，调用zkclient (maven 地址见下面)实现监听当某个节点的数据发生变化时，将变化的信息打印到控制台。

zkclient的maven地址

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

master app 应用程序

 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应用程序

 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 }

环境准备

运行程序