在Zookeeper中从AuthenticationProvider连接到Zookeeper

Question

我正在使身份验证提供程序在身份验证期间连接到Zookeeper（与运行它相同）并签入节点，如果此用户提供了正确的密码。

基本上，流程看起来像这样：

@Override
public KeeperException.Code handleAuthentication(ServerCnxn cnxn, byte[] authData) {
        final String usernameColonPassword = new String(authData);
        String[] split = usernameColonPassword.split(":");
        final String username = split[0];
        final String password = split[1];

        byte[] binary = curator.getData().forPath(ATUH_NODE); // here error is thrown
        // check is password is correct
}

问题是，当策展人获取数据时，我总是在线获取KeeperErrorCode=ConnectionLoss。这种行为的原因是什么？在身份验证期间，我不被允许连接到授权客户端的动物园管理员？

低于满堆轨道:

    org.apache.zookeeper.KeeperException$ConnectionLossException: KeeperErrorCode = ConnectionLoss for XXX
        at org.apache.zookeeper.KeeperException.create(KeeperException.java:99)
        at org.apache.zookeeper.KeeperException.create(KeeperException.java:51)
        at org.apache.zookeeper.ZooKeeper.exists(ZooKeeper.java:1045)
        at org.apache.curator.framework.imps.ExistsBuilderImpl$2.call(ExistsBuilderImpl.java:172)
        at org.apache.curator.framework.imps.ExistsBuilderImpl$2.call(ExistsBuilderImpl.java:161)
        at org.apache.curator.RetryLoop.callWithRetry(RetryLoop.java:107)
        at org.apache.curator.framework.imps.ExistsBuilderImpl.pathInForeground(ExistsBuilderImpl.java:157)
        at org.apache.curator.framework.imps.ExistsBuilderImpl.forPath(ExistsBuilderImpl.java:148)
        at org.apache.curator.framework.imps.ExistsBuilderImpl.forPath(ExistsBuilderImpl.java:36)

Answer 1

因为我发现这是不可能的。在这一点上，zookeeper有某种锁/信号量，他不接受来自这个线程的新连接。