【分布式与微服务】Zookeeper详解（从安装—入门—使用）

🌰修改节点信息

触发监听，并且之后监听就失效了

🍋6.Java客户端操作

导入zookeeper的依赖包和junit的测试包

<dependency>
    <groupId>junit</groupId>
    <artifactId>junit</artifactId>
    <version>4.12</version>
    <scope>provided</scope>
</dependency>
<dependency>
    <groupId>com.101tec</groupId>
    <artifactId>zkclient</artifactId>
    <version>0.10</version>
</dependency>

🍊6.1连接zk server服务端

@Before
public void before() {
    //参数1  --> zk server 服务ip地址:端口号
    //参数2 -->  会话超时时间
    //参数3  --> 连接超时时间
    //参数4  --> 序列化方式
     zkClient = new ZkClient("ip:端口号", 60000 * 30, 60000, new SerializableSerializer());
 }

    private ZkClient zkClient;
   
@Test
    public void  test01(){
        System.out.println(zkClient);
    }

 @After
 public void after() {

     zkClient.close();
 }

打印出结果，成功连接！

🍊6.2创建节点

 @Test
public void test() {
     //创建持久节点
     zkClient.create("/app2", "xue", CreateMode.PERSISTENT);
   //创建持久顺序节点
     zkClient.create("/app3","yue", CreateMode.PERSISTENT_SEQUENTIAL);
     //创建临时节点
     zkClient.create("/app4","qing", CreateMode.EPHEMERAL);
     //创建临时顺序节点
     zkClient.create("/app5","haha",CreateMode.EPHEMERAL_SEQUENTIAL);

 }

🍊6.3查看某个节点信息

@Test
public void test2(){
    //查看某个节点数据，需要保证创建和获取的数据序列化方式相同，如果是在linux上创建的节点那么在Java上获取就会出现序列化不匹配的异常
    Object o = zkClient.readData("/app2");
    System.out.println(o);
    //查看节点状态
   Stat stat = new Stat();
      
         System.out.println(o);
    //查看节点创建时间
        System.out.println(stat.getCtime());
    //查看版本
        System.out.println(stat.getCversion());
    //查看id
        System.out.println(stat.getCzxid());

}

🍊6.4修改节点信息

zkClient.writeData("/app2","xueyueqing");

🍊6.5查看当前节点所有子节点

@Test
public  void test4(){

    List<String> children = zkClient.getChildren("/");
    for(String c : children ){
        System.out.println(c);
    }

}

🍊6.6监听

@Test
public  void test5() throws IOException {

  zkClient.subscribeDataChanges("/app1", new IZkDataListener() {
      //当前节点数据变化时触发
      @Override
      public void handleDataChange(String dataPath, Object o) throws Exception {
          System.out.println("当前节点路径"+dataPath);
          System.out.println("当前节点信息"+o);
      }
      //当前节点删除时触发
      @Override
      public void handleDataDeleted(String dataPath) throws Exception {
          System.out.println("当前节点路径"+dataPath);
      }
  });
     //阻塞当前监听
  System.in.read();
}

注意：在shell终端修改，Java是监听不了的，必须使用Java代码修改

   @Test
   public  void test6() throws IOException {
//监听节点目录变化
       zkClient.subscribeChildChanges("/app1", new IZkChildListener() {
           @Override
           public void handleChildChange(String s, List<String> list) throws Exception {
               System.out.println("父节点名称:"+s);
               System.out.println("发生变化后孩子节点名称:");
           for(String child : list){
               System.out.println(child);
           }
           }
       });
       //阻塞当前监听
       System.in.read();
   }