Zookeeper 内建ACL访问控制权限代码

标签：

这里我只用了基于用户名密码的digest 模式，还有world  auth  ip 三种模式

ZooKeeper有下列内建模式：

• world  有独立id，anyone，代表任何用户。

• auth 不使用任何id，代表任何已经认证过的用户

• digest 之前使用了格式为username:pathasowrd的字符串来生成一个MD5哈希表作为ACL ID标识。在空文档中发送username:password来完成认证。现在的ACL表达式格式为username:base64, 用SHA1编码密码。

• ip 用客户端的ip作为ACL ID标识。ACL表达式的格式为addr/bits，addr中最有效的位匹配上主机ip最有效的位。

@Test
	public void test() throws IOException, InterruptedException, KeeperException, NoSuchAlgorithmException {

		/**
		 * 连接zookeeper
		 */
			zk = new ZooKeeper("localhost:2182", 5000, new Watcher() {
				public void process(WatchedEvent event) {
					if (event.getType() == EventType.NodeChildrenChanged && ("/" + groupNode).equals(event.getPath())) {
						try {
							System.out.println("此处监听");
						} catch (Exception e) {
							e.printStackTrace();
						}
					}
				}
			});
			while(zk.getState() != ZooKeeper.States.CONNECTED ){
				Thread.sleep(3000);
			}
			//zk链接的用户
			zk.addAuthInfo("digest", "admin:admin123".getBytes());
			//创建开放节点，允许任意操作
			zk.create("/xxx", "xxx".getBytes("utf-8"), Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
			//创建只读节点
			zk.create("/yyy", "yyy".getBytes("utf-8"), Ids.READ_ACL_UNSAFE, CreateMode.PERSISTENT);
			//创建者全部权限
			zk.create("/zzzs", "zzz".getBytes("utf-8"), Ids.CREATOR_ALL_ACL, CreateMode.PERSISTENT);

			//设置访问权限列表
			List<ACL> lists = new ArrayList<ACL>();
			Id id1 = new Id("digest", DigestAuthenticationProvider.generateDigest("admin:admin123"));
			Id id3 = new Id("digest", DigestAuthenticationProvider.generateDigest("readadmin:admin123"));
			lists.add(new ACL(ZooDefs.Perms.CREATE,id1));  //创建权限
			lists.add(new ACL(ZooDefs.Perms.READ,id3));	   //只读权限 
			//testa 节点将根据权限列表进行acl
			zk.create("/testa", "testacl".getBytes("utf-8"), lists, CreateMode.PERSISTENT);
			
			
			byte[] value = zk.getData("/testa", null, new Stat()); 
			System.out.println(value);
			
			
	}

Zookeeper 内建ACL访问控制权限代码

标签：

原文地址：http://my.oschina.net/UpBoy/blog/420115