xml 连接到动物园管理员

Posted 2021-05-16

            // path 数据 xxxx 节点类型
            zk.create("/testRoot", "testRoot".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);

            //创建子节点，使用EPHEMERAL，主程序执行完成后该节点被删除，只在本次会话内有效，可以用作分布式锁。
            zk.create("/testRoot/children", "children data".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL);

            //获取节点信息
            byte[] data = zk.getData("/testRoot", false, null);
            System.out.println(new String(data));
            System.out.println(zk.getChildren("/testRoot", false));

            //修改节点的值，-1表示跳过版本检查，其他正数表示如果传入的版本号与当前版本号不一致，则修改不成功，删除是同样的道理。
         \!h   zk.setData("/testRoot", "modify data root".getBytes(), -1);
            byte[] data2 = zk.getData("/testRoot", false, null);
            System.out.println(new String(data2));

            //判断节点是否存在
            System.out.println(zk.exists("/testRoot/children", false));
            //删除节点
            zk.delete("/testRoot/children", -1);
            System.out.println(zk.exists("/testRoot/children", false));

    zk.close();

   // zookeeper地址
    String CONNECT_ADDR = "119.29.135.249:2181,119.29.135.249:2182,119.29.135.249:2183";

    // session超时时间
    int SESSION_OUTTIME = 2000;//ms

    // 信号量，阻塞程序执行，用于等待zookeeper连接成功，发送成功信号
    final CountDownLatch connectedSemaphore = new CountDownLatch(1);

    ZooKeeper zk = null;
    try {
        zk = new ZooKeeper(CONNECT_ADDR, SESSION_OUTTIME, new Watcher() {
            @Override
            public void process(WatchedEvent event) {
                //获取事件的状态
                Event.KeeperState keeperState = event.getState();
                Event.EventType eventType = event.getType();
                //如果是建立连接
                if (Event.KeeperState.SyncConnected == keeperState) {
                    if (Event.EventType.None == eventType) {
                        //如果建立连接成功，则发送信号量，让后续阻塞程序向下执行
                        connectedSemaphore.countDown();
                        System.out.println("zookeeper建立连接");
                    }
                }
            }
        });


        //进行阻塞
        connectedSemaphore.await();


        System.out.println("对zookeeper进行操作------------------->");

  <!--最常用的版本-->
  <dependency>
      <groupId>org.apache.zookeeper</groupId>
      <artifactId>zookeeper</artifactId>
      <version>3.4.6</version>
  </dependency>