java类org.apache.zookeeper.client.ZooKeeperSaslClient的实例源码-面圈网

ClientCnxn.java 文件源码项目：fuck_zookeeper 阅读 25 收藏 0 点赞 0 评论 0

public boolean clientTunneledAuthenticationInProgress() {
    // 1. SASL client is disabled.
    if (!ZooKeeperSaslClient.isEnabled()) {
        return false;
    }

    // 2. SASL login failed.
    if (saslLoginFailed == true) {
        return false;
    }

    // 3. SendThread has not created the authenticating object yet,
    // therefore authentication is (at the earliest stage of being) in progress.
    if (zooKeeperSaslClient == null) {
        return true;
    }

    // 4. authenticating object exists, so ask it for its progress.
    return zooKeeperSaslClient.clientTunneledAuthenticationInProgress();
}

SaslAuthDesignatedClientTest.java 文件源码项目：fuck_zookeeper 阅读 23 收藏 0 点赞 0 评论 0

@Test
public void testSaslConfig() throws Exception {
    ZooKeeper zk = createClient();
    try {
        zk.getChildren("/", false);
        Assert.assertFalse(zk.getSaslClient().
            clientTunneledAuthenticationInProgress());
        Assert.assertEquals(zk.getSaslClient().getSaslState(),
            ZooKeeperSaslClient.SaslState.COMPLETE);
        Assert.assertNotNull(
            javax.security.auth.login.Configuration.getConfiguration().
                getAppConfigurationEntry("MyZookeeperClient"));
        Assert.assertSame(zk.getSaslClient().getLoginContext(),
            "MyZookeeperClient");
    } catch (KeeperException e) {
        Assert.fail("test failed :" + e);
    } finally {
        zk.close();
    }
}

SaslAuthDesignatedClientTest.java 文件源码项目：https-github.com-apache-zookeeper 阅读 24 收藏 0 点赞 0 评论 0

@Test
public void testSaslConfig() throws Exception {
    ZooKeeper zk = createClient();
    try {
        zk.getChildren("/", false);
        Assert.assertFalse(zk.getSaslClient().
            clientTunneledAuthenticationInProgress());
        Assert.assertEquals(zk.getSaslClient().getSaslState(),
            ZooKeeperSaslClient.SaslState.COMPLETE);
        Assert.assertNotNull(
            javax.security.auth.login.Configuration.getConfiguration().
                getAppConfigurationEntry("MyZookeeperClient"));
        Assert.assertSame(zk.getSaslClient().getLoginContext(),
            "MyZookeeperClient");
    } catch (KeeperException e) {
        Assert.fail("test failed :" + e);
    } finally {
        zk.close();
    }
}

ClientCnxn.java 文件源码项目：ZooKeeper 阅读 34 收藏 0 点赞 0 评论 0

public boolean clientTunneledAuthenticationInProgress() {
    // 1. SASL client is disabled.
    if (!ZooKeeperSaslClient.isEnabled()) {
        return false;
    }

    // 2. SASL login failed.
    if (saslLoginFailed == true) {
        return false;
    }

    // 3. SendThread has not created the authenticating object yet,
    // therefore authentication is (at the earliest stage of being) in progress.
    if (zooKeeperSaslClient == null) {
        return true;
    }

    // 4. authenticating object exists, so ask it for its progress.
    return zooKeeperSaslClient.clientTunneledAuthenticationInProgress();
}

SaslAuthDesignatedClientTest.java 文件源码项目：ZooKeeper 阅读 28 收藏 0 点赞 0 评论 0

@Test
public void testSaslConfig() throws Exception {
    ZooKeeper zk = createClient();
    try {
        zk.getChildren("/", false);
        Assert.assertFalse(zk.getSaslClient().
            clientTunneledAuthenticationInProgress());
        Assert.assertEquals(zk.getSaslClient().getSaslState(),
            ZooKeeperSaslClient.SaslState.COMPLETE);
        Assert.assertNotNull(
            javax.security.auth.login.Configuration.getConfiguration().
                getAppConfigurationEntry("MyZookeeperClient"));
        Assert.assertSame(zk.getSaslClient().getLoginContext(),
            "MyZookeeperClient");
    } catch (KeeperException e) {
        Assert.fail("test failed :" + e);
    } finally {
        zk.close();
    }
}

ClientCnxn.java 文件源码项目：StreamProcessingInfrastructure 阅读 23 收藏 0 点赞 0 评论 0

public boolean clientTunneledAuthenticationInProgress() {
    // 1. SASL client is disabled.
    if (!ZooKeeperSaslClient.isEnabled()) {
        return false;
    }

    // 2. SASL login failed.
    if (saslLoginFailed == true) {
        return false;
    }

    // 3. SendThread has not created the authenticating object yet,
    // therefore authentication is (at the earliest stage of being) in progress.
    if (zooKeeperSaslClient == null) {
        return true;
    }

    // 4. authenticating object exists, so ask it for its progress.
    return zooKeeperSaslClient.clientTunneledAuthenticationInProgress();
}

SaslAuthDesignatedClientTest.java 文件源码项目：StreamProcessingInfrastructure 阅读 31 收藏 0 点赞 0 评论 0

@Test
public void testSaslConfig() throws Exception {
    ZooKeeper zk = createClient();
    try {
        zk.getChildren("/", false);
        Assert.assertFalse(zk.getSaslClient().
            clientTunneledAuthenticationInProgress());
        Assert.assertEquals(zk.getSaslClient().getSaslState(),
            ZooKeeperSaslClient.SaslState.COMPLETE);
        Assert.assertNotNull(
            javax.security.auth.login.Configuration.getConfiguration().
                getAppConfigurationEntry("MyZookeeperClient"));
        Assert.assertSame(zk.getSaslClient().getLoginContext(),
            "MyZookeeperClient");
    } catch (KeeperException e) {
        Assert.fail("test failed :" + e);
    } finally {
        zk.close();
    }
}

SaslAuthDesignatedClientTest.java 文件源码项目：bigstreams 阅读 20 收藏 0 点赞 0 评论 0

@Test
public void testSaslConfig() throws Exception {
    ZooKeeper zk = createClient();
    try {
        zk.getChildren("/", false);
        Assert.assertFalse(zk.getSaslClient().
            clientTunneledAuthenticationInProgress());
        Assert.assertEquals(zk.getSaslClient().getSaslState(),
            ZooKeeperSaslClient.SaslState.COMPLETE);
        Assert.assertNotNull(
            javax.security.auth.login.Configuration.getConfiguration().
                getAppConfigurationEntry("MyZookeeperClient"));
        Assert.assertSame(zk.getSaslClient().getLoginContext(),
            "MyZookeeperClient");
    } catch (KeeperException e) {
        Assert.fail("test failed :" + e);
    } finally {
        zk.close();
    }
}

ClientCnxn.java 文件源码项目：zookeeper 阅读 31 收藏 0 点赞 0 评论 0

public boolean clientTunneledAuthenticationInProgress() {
    // 1. SASL client is disabled.
    if (!ZooKeeperSaslClient.isEnabled()) {
        return false;
    }

    // 2. SASL login failed.
    if (saslLoginFailed == true) {
        return false;
    }

    // 3. SendThread has not created the authenticating object yet,
    // therefore authentication is (at the earliest stage of being) in progress.
    if (zooKeeperSaslClient == null) {
        return true;
    }

    // 4. authenticating object exists, so ask it for its progress.
    return zooKeeperSaslClient.clientTunneledAuthenticationInProgress();
}

SaslAuthDesignatedClientTest.java 文件源码项目：zookeeper 阅读 29 收藏 0 点赞 0 评论 0

@Test
public void testSaslConfig() throws Exception {
    ZooKeeper zk = createClient();
    try {
        zk.getChildren("/", false);
        Assert.assertFalse(zk.getSaslClient().
            clientTunneledAuthenticationInProgress());
        Assert.assertEquals(zk.getSaslClient().getSaslState(),
            ZooKeeperSaslClient.SaslState.COMPLETE);
        Assert.assertNotNull(
            javax.security.auth.login.Configuration.getConfiguration().
                getAppConfigurationEntry("MyZookeeperClient"));
        Assert.assertSame(zk.getSaslClient().getLoginContext(),
            "MyZookeeperClient");
    } catch (KeeperException e) {
        Assert.fail("test failed :" + e);
    } finally {
        zk.close();
    }
}

ClientCnxn.java 文件源码项目：SecureKeeper 阅读 34 收藏 0 点赞 0 评论 0

public boolean tunnelAuthInProgress() {
    // 1. SASL client is disabled.
    if (!ZooKeeperSaslClient.isEnabled()) {
        return false;
    }

    // 2. SASL login failed.
    if (saslLoginFailed == true) {
        return false;
    }

    // 3. SendThread has not created the authenticating object yet,
    // therefore authentication is (at the earliest stage of being) in progress.
    if (zooKeeperSaslClient == null) {
        return true;
    }

    // 4. authenticating object exists, so ask it for its progress.
    return zooKeeperSaslClient.clientTunneledAuthenticationInProgress();
}

SaslAuthDesignatedClientTest.java 文件源码项目：SecureKeeper 阅读 27 收藏 0 点赞 0 评论 0

@Test
public void testSaslConfig() throws Exception {
    ZooKeeper zk = createClient();
    try {
        zk.getChildren("/", false);
        Assert.assertFalse(zk.getSaslClient().
            clientTunneledAuthenticationInProgress());
        Assert.assertEquals(zk.getSaslClient().getSaslState(),
            ZooKeeperSaslClient.SaslState.COMPLETE);
        Assert.assertNotNull(
            javax.security.auth.login.Configuration.getConfiguration().
                getAppConfigurationEntry("MyZookeeperClient"));
        Assert.assertSame(zk.getSaslClient().getLoginContext(),
            "MyZookeeperClient");
    } catch (KeeperException e) {
        Assert.fail("test failed :" + e);
    } finally {
        zk.close();
    }
}

ClientCnxn.java 文件源码项目：SecureKeeper 阅读 26 收藏 0 点赞 0 评论 0

public boolean tunnelAuthInProgress() {
    // 1. SASL client is disabled.
    if (!ZooKeeperSaslClient.isEnabled()) {
        return false;
    }

    // 2. SASL login failed.
    if (saslLoginFailed == true) {
        return false;
    }

    // 3. SendThread has not created the authenticating object yet,
    // therefore authentication is (at the earliest stage of being) in progress.
    if (zooKeeperSaslClient == null) {
        return true;
    }

    // 4. authenticating object exists, so ask it for its progress.
    return zooKeeperSaslClient.clientTunneledAuthenticationInProgress();
}

SaslAuthDesignatedClientTest.java 文件源码项目：SecureKeeper 阅读 27 收藏 0 点赞 0 评论 0

@Test
public void testSaslConfig() throws Exception {
    ZooKeeper zk = createClient();
    try {
        zk.getChildren("/", false);
        Assert.assertFalse(zk.getSaslClient().
            clientTunneledAuthenticationInProgress());
        Assert.assertEquals(zk.getSaslClient().getSaslState(),
            ZooKeeperSaslClient.SaslState.COMPLETE);
        Assert.assertNotNull(
            javax.security.auth.login.Configuration.getConfiguration().
                getAppConfigurationEntry("MyZookeeperClient"));
        Assert.assertSame(zk.getSaslClient().getLoginContext(),
            "MyZookeeperClient");
    } catch (KeeperException e) {
        Assert.fail("test failed :" + e);
    } finally {
        zk.close();
    }
}

ClientCnxn.java 文件源码项目：StreamBench 阅读 35 收藏 0 点赞 0 评论 0

public boolean clientTunneledAuthenticationInProgress() {
    // 1. SASL client is disabled.
    if (!ZooKeeperSaslClient.isEnabled()) {
        return false;
    }

    // 2. SASL login failed.
    if (saslLoginFailed == true) {
        return false;
    }

    // 3. SendThread has not created the authenticating object yet,
    // therefore authentication is (at the earliest stage of being) in progress.
    if (zooKeeperSaslClient == null) {
        return true;
    }

    // 4. authenticating object exists, so ask it for its progress.
    return zooKeeperSaslClient.clientTunneledAuthenticationInProgress();
}

SaslAuthDesignatedClientTest.java 文件源码项目：StreamBench 阅读 30 收藏 0 点赞 0 评论 0

@Test
public void testSaslConfig() throws Exception {
    ZooKeeper zk = createClient();
    try {
        zk.getChildren("/", false);
        Assert.assertFalse(zk.getSaslClient().
            clientTunneledAuthenticationInProgress());
        Assert.assertEquals(zk.getSaslClient().getSaslState(),
            ZooKeeperSaslClient.SaslState.COMPLETE);
        Assert.assertNotNull(
            javax.security.auth.login.Configuration.getConfiguration().
                getAppConfigurationEntry("MyZookeeperClient"));
        Assert.assertSame(zk.getSaslClient().getLoginContext(),
            "MyZookeeperClient");
    } catch (KeeperException e) {
        Assert.fail("test failed :" + e);
    } finally {
        zk.close();
    }
}

SaslAuthDesignatedClientTest.java 文件源码项目：LoadBalanced_zk 阅读 25 收藏 0 点赞 0 评论 0

@Test
public void testSaslConfig() throws Exception {
    ZooKeeper zk = createClient();
    try {
        zk.getChildren("/", false);
        Assert.assertFalse(zk.getSaslClient().
            clientTunneledAuthenticationInProgress());
        Assert.assertEquals(zk.getSaslClient().getSaslState(),
            ZooKeeperSaslClient.SaslState.COMPLETE);
        Assert.assertNotNull(
            javax.security.auth.login.Configuration.getConfiguration().
                getAppConfigurationEntry("MyZookeeperClient"));
        Assert.assertSame(zk.getSaslClient().getLoginContext(),
            "MyZookeeperClient");
    } catch (KeeperException e) {
        Assert.fail("test failed :" + e);
    } finally {
        zk.close();
    }
}

SaslAuthDesignatedClientTest.java 文件源码项目：LoadBalanced_zk 阅读 27 收藏 0 点赞 0 评论 0

@Test
public void testSaslConfig() throws Exception {
    ZooKeeper zk = createClient();
    try {
        zk.getChildren("/", false);
        Assert.assertFalse(zk.getSaslClient().
            clientTunneledAuthenticationInProgress());
        Assert.assertEquals(zk.getSaslClient().getSaslState(),
            ZooKeeperSaslClient.SaslState.COMPLETE);
        Assert.assertNotNull(
            javax.security.auth.login.Configuration.getConfiguration().
                getAppConfigurationEntry("MyZookeeperClient"));
        Assert.assertSame(zk.getSaslClient().getLoginContext(),
            "MyZookeeperClient");
    } catch (KeeperException e) {
        Assert.fail("test failed :" + e);
    } finally {
        zk.close();
    }
}

SaslAuthDesignatedClientTest.java 文件源码项目：zookeeper-pkg 阅读 26 收藏 0 点赞 0 评论 0

@Test
public void testSaslConfig() throws Exception {
    ZooKeeper zk = createClient();
    try {
        zk.getChildren("/", false);
        Assert.assertFalse(zk.getSaslClient().
            clientTunneledAuthenticationInProgress());
        Assert.assertEquals(zk.getSaslClient().getSaslState(),
            ZooKeeperSaslClient.SaslState.COMPLETE);
        Assert.assertNotNull(
            javax.security.auth.login.Configuration.getConfiguration().
                getAppConfigurationEntry("MyZookeeperClient"));
        Assert.assertSame(zk.getSaslClient().getLoginContext(),
            "MyZookeeperClient");
    } catch (KeeperException e) {
        Assert.fail("test failed :" + e);
    } finally {
        zk.close();
    }
}

ClientCnxn.java 文件源码项目：fuck_zookeeper 阅读 32 收藏 0 点赞 0 评论 0

private void startConnect() throws IOException {
    state = States.CONNECTING;

    InetSocketAddress addr;
    if (rwServerAddress != null) {
        addr = rwServerAddress;
        rwServerAddress = null;
    } else {
        addr = hostProvider.next(1000);
    }

    setName(getName().replaceAll("\\(.*\\)",
            "(" + addr.getHostName() + ":" + addr.getPort() + ")"));
    if (ZooKeeperSaslClient.isEnabled()) {
        try {
            String principalUserName = System.getProperty(
                    ZK_SASL_CLIENT_USERNAME, "zookeeper");
            zooKeeperSaslClient =
                new ZooKeeperSaslClient(
                        principalUserName+"/"+addr.getHostName());
        } catch (LoginException e) {
            // An authentication error occurred when the SASL client tried to initialize:
            // for Kerberos this means that the client failed to authenticate with the KDC.
            // This is different from an authentication error that occurs during communication
            // with the Zookeeper server, which is handled below.
            LOG.warn("SASL configuration failed: " + e + " Will continue connection to Zookeeper server without "
              + "SASL authentication, if Zookeeper server allows it.");
            eventThread.queueEvent(new WatchedEvent(
              Watcher.Event.EventType.None,
              Watcher.Event.KeeperState.AuthFailed, null));
            saslLoginFailed = true;
        }
    }
    logStartConnect(addr);

    clientCnxnSocket.connect(addr);
}

Login.java 文件源码项目：fuck_zookeeper 阅读 55 收藏 0 点赞 0 评论 0

private synchronized LoginContext login(final String loginContextName) throws LoginException {
    if (loginContextName == null) {
        throw new LoginException("loginContext name (JAAS file section header) was null. " +
                "Please check your java.security.login.auth.config (=" +
                System.getProperty("java.security.login.auth.config") +
                ") and your " + ZooKeeperSaslClient.LOGIN_CONTEXT_NAME_KEY + "(=" + 
                System.getProperty(ZooKeeperSaslClient.LOGIN_CONTEXT_NAME_KEY, "Client") + ")");
    }
    LoginContext loginContext = new LoginContext(loginContextName,callbackHandler);
    loginContext.login();
    LOG.info("successfully logged in.");
    return loginContext;
}

SaslClientTest.java 文件源码项目：fuck_zookeeper 阅读 26 收藏 0 点赞 0 评论 0

@After
public void tearDown() {
    // Restore the System property if it was set previously
    if (existingPropertyValue != null) {
        System.setProperty(ZooKeeperSaslClient.ENABLE_CLIENT_SASL_KEY, existingPropertyValue);
    }
}

ClientCnxn.java 文件源码项目：ZooKeeper 阅读 23 收藏 0 点赞 0 评论 0

private void startConnect() throws IOException {
    state = States.CONNECTING;

    InetSocketAddress addr;
    if (rwServerAddress != null) {
        addr = rwServerAddress;
        rwServerAddress = null;
    } else {
        addr = hostProvider.next(1000);
    }

    setName(getName().replaceAll("\\(.*\\)",
            "(" + addr.getHostName() + ":" + addr.getPort() + ")"));
    if (ZooKeeperSaslClient.isEnabled()) {
        try {
            String principalUserName = System.getProperty(
                    ZK_SASL_CLIENT_USERNAME, "zookeeper");
            zooKeeperSaslClient =
                new ZooKeeperSaslClient(
                        principalUserName+"/"+addr.getHostName());
        } catch (LoginException e) {
            // An authentication error occurred when the SASL client tried to initialize:
            // for Kerberos this means that the client failed to authenticate with the KDC.
            // This is different from an authentication error that occurs during communication
            // with the Zookeeper server, which is handled below.
            LOG.warn("SASL configuration failed: " + e + " Will continue connection to Zookeeper server without "
              + "SASL authentication, if Zookeeper server allows it.");
            eventThread.queueEvent(new WatchedEvent(
              Watcher.Event.EventType.None,
              Watcher.Event.KeeperState.AuthFailed, null));
            saslLoginFailed = true;
        }
    }
    logStartConnect(addr);

    clientCnxnSocket.connect(addr);
}

Login.java 文件源码项目：ZooKeeper 阅读 43 收藏 0 点赞 0 评论 0

private synchronized LoginContext login(final String loginContextName) throws LoginException {
    if (loginContextName == null) {
        throw new LoginException("loginContext name (JAAS file section header) was null. " +
                "Please check your java.security.login.auth.config (=" +
                System.getProperty("java.security.login.auth.config") +
                ") and your " + ZooKeeperSaslClient.LOGIN_CONTEXT_NAME_KEY + "(=" + 
                System.getProperty(ZooKeeperSaslClient.LOGIN_CONTEXT_NAME_KEY, "Client") + ")");
    }
    LoginContext loginContext = new LoginContext(loginContextName,callbackHandler);
    loginContext.login();
    LOG.info("{} successfully logged in.", loginContextName);
    return loginContext;
}

SaslClientTest.java 文件源码项目：ZooKeeper 阅读 26 收藏 0 点赞 0 评论 0

@After
public void tearDown() {
    // Restore the System property if it was set previously
    if (existingPropertyValue != null) {
        System.setProperty(ZooKeeperSaslClient.ENABLE_CLIENT_SASL_KEY, existingPropertyValue);
    }
}

ClientCnxn.java 文件源码项目：StreamProcessingInfrastructure 阅读 34 收藏 0 点赞 0 评论 0

private void startConnect() throws IOException {
    state = States.CONNECTING;

    InetSocketAddress addr;
    if (rwServerAddress != null) {
        addr = rwServerAddress;
        rwServerAddress = null;
    } else {
        addr = hostProvider.next(1000);
    }

    setName(getName().replaceAll("\\(.*\\)",
            "(" + addr.getHostName() + ":" + addr.getPort() + ")"));
    if (ZooKeeperSaslClient.isEnabled()) {
        try {
            String principalUserName = System.getProperty(
                    ZK_SASL_CLIENT_USERNAME, "zookeeper");
            zooKeeperSaslClient =
                new ZooKeeperSaslClient(
                        principalUserName+"/"+addr.getHostName());
        } catch (LoginException e) {
            // An authentication error occurred when the SASL client tried to initialize:
            // for Kerberos this means that the client failed to authenticate with the KDC.
            // This is different from an authentication error that occurs during communication
            // with the Zookeeper server, which is handled below.
            LOG.warn("SASL configuration failed: " + e + " Will continue connection to Zookeeper server without "
              + "SASL authentication, if Zookeeper server allows it.");
            eventThread.queueEvent(new WatchedEvent(
              Watcher.Event.EventType.None,
              Watcher.Event.KeeperState.AuthFailed, null));
            saslLoginFailed = true;
        }
    }
    logStartConnect(addr);

    clientCnxnSocket.connect(addr);
}

Login.java 文件源码项目：StreamProcessingInfrastructure 阅读 58 收藏 0 点赞 0 评论 0

private synchronized LoginContext login(final String loginContextName) throws LoginException {
    if (loginContextName == null) {
        throw new LoginException("loginContext name (JAAS file section header) was null. " +
                "Please check your java.security.login.auth.config (=" +
                System.getProperty("java.security.login.auth.config") +
                ") and your " + ZooKeeperSaslClient.LOGIN_CONTEXT_NAME_KEY + "(=" + 
                System.getProperty(ZooKeeperSaslClient.LOGIN_CONTEXT_NAME_KEY, "Client") + ")");
    }
    LoginContext loginContext = new LoginContext(loginContextName,callbackHandler);
    loginContext.login();
    LOG.info("successfully logged in.");
    return loginContext;
}

SaslClientTest.java 文件源码项目：StreamProcessingInfrastructure 阅读 27 收藏 0 点赞 0 评论 0

@After
public void tearDown() {
    // Restore the System property if it was set previously
    if (existingPropertyValue != null) {
        System.setProperty(ZooKeeperSaslClient.ENABLE_CLIENT_SASL_KEY, existingPropertyValue);
    }
}

ClientCnxn.java 文件源码项目：bigstreams 阅读 36 收藏 0 点赞 0 评论 0

private void startConnect() throws IOException {
    state = States.CONNECTING;

    InetSocketAddress addr;
    if (rwServerAddress != null) {
        addr = rwServerAddress;
        rwServerAddress = null;
    } else {
        addr = hostProvider.next(1000);
    }

    setName(getName().replaceAll("\\(.*\\)",
            "(" + addr.getHostName() + ":" + addr.getPort() + ")"));
    try {
        zooKeeperSaslClient = new ZooKeeperSaslClient("zookeeper/"+addr.getHostName());
    } catch (LoginException e) {
        // An authentication error occurred when the SASL client tried to initialize:
        // for Kerberos this means that the client failed to authenticate with the KDC.
        // This is different from an authentication error that occurs during communication
        // with the Zookeeper server, which is handled below.
        LOG.warn("SASL configuration failed: " + e + " Will continue connection to Zookeeper server without "
          + "SASL authentication, if Zookeeper server allows it.");
        eventThread.queueEvent(new WatchedEvent(
          Watcher.Event.EventType.None,
          Watcher.Event.KeeperState.AuthFailed, null));
        saslLoginFailed = true;
    }
    logStartConnect(addr);

    clientCnxnSocket.connect(addr);
}

Login.java 文件源码项目：bigstreams 阅读 53 收藏 0 点赞 0 评论 0

private synchronized LoginContext login(final String loginContextName) throws LoginException {
    if (loginContextName == null) {
        throw new LoginException("loginContext name (JAAS file section header) was null. " +
                "Please check your java.security.login.auth.config (=" +
                System.getProperty("java.security.login.auth.config") +
                ") and your " + ZooKeeperSaslClient.LOGIN_CONTEXT_NAME_KEY + "(=" + 
                System.getProperty(ZooKeeperSaslClient.LOGIN_CONTEXT_NAME_KEY, "Client") + ")");
    }
    LoginContext loginContext = new LoginContext(loginContextName,callbackHandler);
    loginContext.login();
    LOG.info("successfully logged in.");
    return loginContext;
}