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();
     }
}