zookeeper java调用及权限控制

时间：2014-06-26 10:30:19 阅读：206 评论：0 收藏：0 [点我收藏+]

import java.io.IOException;
import java.security.NoSuchAlgorithmException;
import java.util.ArrayList;
import java.util.List;

import org.apache.zookeeper.CreateMode;
import org.apache.zookeeper.KeeperException;
import org.apache.zookeeper.WatchedEvent;
import org.apache.zookeeper.Watcher;
import org.apache.zookeeper.ZooDefs;
import org.apache.zookeeper.ZooDefs.Ids;
import org.apache.zookeeper.ZooKeeper;
import org.apache.zookeeper.data.ACL;
import org.apache.zookeeper.data.Id;
import org.apache.zookeeper.server.auth.DigestAuthenticationProvider;

/**
* @author Keeny (2013-12-31)
**/
public class Test {
   public static void main(String[] args) throws IOException, KeeperException, InterruptedException, NoSuchAlgorithmException {
       ZooKeeper zk = new ZooKeeper("192.168.192.142:2181", 500000, new Watcher() {
           // 监控所有被触发的事件
           public void process(WatchedEvent event) {
               System.out.println("WatchedEvent=" + event.toString());
               // dosomething
           }
       });
       // 创建一个节点root，数据是mydata,不进行ACL权限控制，节点为永久性的(即客户端shutdown了也不会消失)


       List<ACL> acls = new ArrayList<ACL>(2);
       Id id1 = new Id("digest", DigestAuthenticationProvider.generateDigest("admin:admin123"));
       ACL acl1 = new ACL(ZooDefs.Perms.ALL, id1);

       Id id2 = new Id("digest", DigestAuthenticationProvider.generateDigest("guest:guest123"));
       ACL acl2 = new ACL(ZooDefs.Perms.READ, id2);

       acls.add(acl1);
       acls.add(acl2); //设置权限

//       String root = zk.create("/root/test1", "test".getBytes(), acls, CreateMode.PERSISTENT);
//       System.out.println("root=" + root);

       // 在root下面创建一个childone znode,数据为childone,不进行ACL权限控制，节点为永久性的
       // String childone = zk.create("/root/childone", "childone".getBytes(),
       // Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
       // System.out.println("childone=" + childone);

       // 取得/root节点下的子节点名称,返回List<String>
       zk.addAuthInfo("digest", "admin:chinatetadmin1234".getBytes());   //设置权限

       List<String> lsit = zk.getChildren("/root", true);
       for (String string : lsit) {
           System.out.println("节点：" + string);
       }

       // 取得/root/childone节点下的数据,返回byte[]
       byte[] childoneData = zk.getData("/root/msg", true, null);
       System.out.println("childoneData=" + new String(childoneData));

       // 修改节点/root/childone下的数据，第三个参数为版本，如果是-1，那会无视被修改的数据版本，直接改掉
       // zk.setData("/root/childone", "childonemodify".getBytes(), -1);

//       删除/root/childone这个节点，第二个参数为版本，－1的话直接删除，无视版本
//       zk.delete("/root/msg", -1);
       //
       // zk.delete("/root/msg", -1);
       // 关闭session
       zk.close();
   }
}

zookeeper java调用及权限控制,布布扣,bubuko.com

标签：class java get 数据 string os

原文地址：http://blog.csdn.net/main_xtgjfge/article/details/34454579

踩

(0)

评论一句话评论（0）

分享档案

更多>

2021年07月29日 (22)
2021年07月28日 (40)
2021年07月27日 (32)
2021年07月26日 (79)
2021年07月23日 (29)
2021年07月22日 (30)
2021年07月21日 (42)
2021年07月20日 (16)
2021年07月19日 (90)
2021年07月16日 (35)

周排行