pom.xml
1
2
3
4
5
6
7
|
< dependencies >
< dependency >
< groupId >org.apache.hadoop</ groupId >
< artifactId >zookeeper</ artifactId >
< version >3.3.1</ version >
</ dependency >
</ dependencies >
|
client.java
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
|
import org.apache.zookeeper.CreateMode;
import org.apache.zookeeper.ZooDefs;
import org.apache.zookeeper.ZooKeeper;
public class client {
private static final int TIME_OUT = 3000 ;
private static final String HOST = "localhost:2181" ;
public static void main(String[] args) throws Exception{
ZooKeeper zookeeper = new ZooKeeper(HOST, TIME_OUT, null );
System.out.println( "=========创建节点===========" );
if (zookeeper.exists( "/zk" , false ) == null )
{
zookeeper.create( "/zk" , "zk data" .getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
}
System.out.println( "=============查看节点是否安装成功===============" );
System.out.println( new String(zookeeper.getData( "/zk" , false , null )));
System.out.println( "=========修改节点的数据==========" );
String data = "zNode2" ;
zookeeper.setData( "/zk" , data.getBytes(), - 1 );
System.out.println( "========查看修改的节点是否成功=========" );
System.out.println( new String(zookeeper.getData( "/zk" , false , null )));
System.out.println( "=======删除节点==========" );
zookeeper.delete( "/zk" , - 1 );
System.out.println( "==========查看节点是否被删除============" );
System.out.println( "节点状态:" + zookeeper.exists( "/test" , false ));
Thread.sleep( 1000 );
zookeeper.close();
}
} |