blog/BigData-Notes
2
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

zookeeper cuator客户端

Browse Source
This commit is contained in:
luoxiang
2019-05-25 17:44:26 +08:00
parent 92ccbfcbee
commit 7d717f8a08
2 changed files with 2 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
code/Zookeeper/curator/src/main/java/com/heibaiying/AclOperation.java
View File

@@ -86,7 +86,7 @@ public class AclOperation {
public void getAcl() throws Exception { public void getAcl() throws Exception {
List<ACL> aclList = client.getACL().forPath(nodePath); List<ACL> aclList = client.getACL().forPath(nodePath);
ACL acl = aclList.get(0); ACL acl = aclList.get(0);
System.out.println(acl.getId().getId()+"是否有删读权限:" + (acl.getPerms() == (Perms.READ | Perms.DELETE))); System.out.println(acl.getId().getId() + "是否有删读权限:" + (acl.getPerms() == (Perms.READ | Perms.DELETE)));
} }

3
code/Zookeeper/curator/src/main/java/com/heibaiying/BasicOperation.java
View File

@@ -16,7 +16,6 @@ import org.junit.After;
import org.junit.Before; import org.junit.Before;
import org.junit.Test; import org.junit.Test;
import java.util.Arrays;
import java.util.List; import java.util.List;
/** /**
@@ -178,7 +177,7 @@ public class BasicOperation {
List<ChildData> childDataList = childrenCache.getCurrentData(); List<ChildData> childDataList = childrenCache.getCurrentData();
System.out.println("当前数据节点的子节点列表："); System.out.println("当前数据节点的子节点列表：");
childDataList.forEach(x->System.out.println(x.getPath())); childDataList.forEach(x -> System.out.println(x.getPath()));
childrenCache.getListenable().addListener(new PathChildrenCacheListener() { childrenCache.getListenable().addListener(new PathChildrenCacheListener() {