zookeeper的api使用
将zookeeper服务全部起来使用API来来替代命令行中的操作比如:
创建节点向节点中写入描述信息
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
private ZooKeeper zk = null;
@Before
public void init() throws Exception {
zk = new ZooKeeper("192.168.0.203:2181", 2000, new Watcher() {
/** 监听事件发生时的回调方法*/
@Override
public void process(WatchedEvent event) {
if (event.getType() == EventType.None)
return;
System.out.println(event.getType());
System.out.println(event.getPath());
try {
zk.getData("/test1", true, null);
zk.getChildren("/test1", true);
} catch (KeeperException | InterruptedException e) {
e.printStackTrace();
}
}
});
}
/**
* 向zookeeper服务集群中注册数据，添加znode
*/
@Test
public void testCreateZnode() throws UnsupportedEncodingException, KeeperException, InterruptedException {
// 该节点如果没创建了下次在创建就会报错
//zk.create("/test1", "diyigeceshi".getBytes("utf-8"), Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
/** 第一个参数:在已有的节点中创建文件节点
第二个参数:写入对该节点的描述信息
第三个参数:是否开发写入操作
第四个参数:指定该节点的生命周期,sequential的顺序维护是在一个父节点的范围之内*/
zk.create("/test1/a", "zijiedianA".getBytes("utf-8"), Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT_SEQUENTIAL);
zk.create("/test1/b", "zijiedianB".getBytes("utf-8"), Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT_SEQUENTIAL);
// 换一个父节点，序号的递增顺序重新开始
//zk.create("/test2/a", "如诗".getBytes("utf-8"), Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT_SEQUENTIAL);
zk.close();
}
}
页:
[1]