Zookeeper系列（五）Zookeeper客户端（JAVA）API之创建节点

节点"/>

Zookeeper系列（五）Zookeeper客户端（JAVA）API之创建节点

本篇博客主要讲一下使用Zookeeper原生的客户API来创建一个数据节点。

创建数据节点方法

Zookeeper提供了两个创建数据节点的方法。

同步创建数据节点方法：

public String create(final String path, byte data[], List<ACL> acl,CreateMode createMode)throws KeeperException, InterruptedException
1
2
3
1
2
3

异步创建数据节点方法：

public void create(final String path, byte data[], List<ACL> acl,CreateMode createMode,  StringCallback cb, Object ctx)
1
2
1
2

参数说明

创建节点demo

下面以具体代码来说明不同方法的使用，针对不同的方法有相应的注释说明：

package com.secbro.learn;import org.apache.zookeeper.*;import java.util.concurrent.CountDownLatch;/*** Created by zhuzs on 2017/3/23.*/
public class TestCreateNode implements Watcher {private static CountDownLatch countDownLatch = new CountDownLatch(1);public static void main(String[] args) throws Exception {ZooKeeper zooKeeper = new ZooKeeper("127.0.0.1:2181", 5000, new TestCreateNode());countDownLatch.await();// 同步创建临时节点String ephemeralPath = zooKeeper.create("/zk-test-create-ephemeral-", "123".getBytes(),ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL);System.out.println("同步创临时建节点成功：" + ephemeralPath);// 同步创建临时顺序节点String sequentialPath = zooKeeper.create("/zk-test-create-sequential-", "456".getBytes(),ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL_SEQUENTIAL);System.out.println("同步创建临时顺序节点成功：" + sequentialPath);// 异步创建临时节点zooKeeper.create("/zk-test-create-async-ephemeral-", "abc".getBytes(),ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL, new MyStringCallBack(), "我是传递内容");// 异步创建临时顺序节点zooKeeper.create("/zk-test-create-async-sequential-","def".getBytes(),ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL_SEQUENTIAL,new MyStringCallBack(),"我是传递内容");Thread.sleep(10000); // 验证等待回调结果使用，可根据实际情况自行调整}public void process(WatchedEvent event) {if (Event.KeeperState.SyncConnected == event.getState()) {countDownLatch.countDown();}}
}class MyStringCallBack implements AsyncCallback.StringCallback {public void processResult(int rc, String path, Object ctx, String name) {System.out.println("异步创建回调结果：状态：" + rc +"；创建路径：" +path + "；传递信息：" + ctx + "；实际节点名称：" + name);}
}
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
53
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
53

输出结果为：

同步创临时建节点成功：/zk-test-create-ephemeral-
同步创建临时顺序节点成功：/zk-test-create-sequential-0000000023
异步创建回调结果：状态：0；创建路径：/zk-test-create-async-ephemeral-；传递信息：我是传递内容；实际节点名称：/zk-test-create-async-ephemeral-
异步创建回调结果：状态：0；创建路径：/zk-test-create-async-sequential-；传递信息：我是传递内容；实际节点名称：/zk-test-create-async-sequential-0000000025
1
2
3
4
1
2
3
4

根据上面的代码和结果，很容易得知不同方法的使用方式。

注意事项

（1）Zookeeper不支持递归创建数据节点（也不支持递归删除），无法在父节点不存在的情况下创建子节点。否则会抛出类似以下异常：

Exception in thread "main" org.apache.zookeeper.KeeperException$NoNodeException: KeeperErrorCode = NoNode for /zk-test-create-sequential-/11at org.apache.zookeeper.KeeperException.create(KeeperException.java:111)at org.apache.zookeeper.KeeperException.create(KeeperException.java:51)at org.apache.zookeeper.ZooKeeper.create(ZooKeeper.java:783)at com.secbro.learn.TestCreateNode.main(TestCreateNode.java:24)at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)at java.lang.reflect.Method.invoke(Method.java:606)at com.intellij.rt.execution.application.AppMain.main(AppMain.java:147)
1
2
3
4
5
6
7
8
9
10
1
2
3
4
5
6
7
8
9
10

（2）如果节点已经存在，再创建同名节点，会抛出NodeExistsException。 
（3）关于权限控制，如果没有特殊要求，可按照上面例子中直接设置为ZooDefs.Ids.OPEN_ACL_UNSAFE，表明之后对节点的任何操作都不受权限控制。

StringCallback接口相关

StringCallback接口集成了AsyncCallback接口，来实现回调时的业务处理。其中AsyncCallback接口还包8个回调接口：StatCallback、DataCallback、ACLCallback、ChildrenCallback、Children2Callback、VoidCallback、MultiCallback、StringCallback。可以在不同的异步接口中实现不同的回调接口。

StringCallback接口的public void processResult(int rc, String path, Object ctx, String name)方法。 
从上面的实例中已经可以看出。 
int rc为服务器的响应码，0表示调用成功，-4表示连接已断开，-110表示指定节点已存在，-112表示会话已过期。 
String path调用create方法时传入的path。 
Object ctx调用create方法时传入的ctx。 
String name创建成功的节点名称。