>我正在尝试为节点创建一个ACL:
ZooKeeper client = new ZooKeeper("host:port/rootNode", 3000, null);
ACL acl = new ACL(Perms.CREATE,new Id("digest","user:pass"));
client.create("/testNode",new String("test").getBytes(), Arrays.asList(acl), CreateMode.PERSISTENT);
client.close();
然后我尝试访问该节点并在"testNode"下创建一个节点:
ZooKeeper client = new ZooKeeper(" host:port/rootNode", 3000, null);
client.addAuthInfo("digest", new String("user:pass").getBytes());
Stat stat;
try {
stat = client.exists("/testNode", false);
if(stat!=null){
client.create("/testNode/clientTest", new String("clienttest").getBytes(),Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL);
}
} catch (KeeperException e) {
e.printStackTrace();
}
client.close();
但它给了我:
org.apache.zookeeper.KeeperException$NoAuthException: KeeperErrorCode = NoAuth for /testNode/clientTest
当我错了?
谢谢!
该文件说:
摘要使用用户名:密码字符串生成 MD5 哈希,即 然后用作 ACL ID 标识。身份验证是通过发送 用户名:明文密码。在 ACL 中使用时,表达式 将是用户名:base64 编码的 SHA1 密码摘要。
所以在创建节点的时候,ACL表达式不能只是user:pass
,必须编码。这样做:
String s = Base64.getEncoder().encodeToString(MessageDigest.getInstance("SHA1").digest("user:pass".getBytes()));
ACL acl = new ACL(ZooDefs.Perms.ALL, new Id("digest","user:" + s));
顺便说一句,该文件有点错误。因为根据这一点,你应该digest("pass")
.但这行不通,您必须对整个字符串进行哈希处理digest("user:pass")