import org.trustedanalytics.cfbroker.store.zookeeper.service.ZookeeperClient; //导入依赖的package包/类
@Bean(initMethod = "init", destroyMethod = "destroy")
@Profile(Profiles.CLOUD)
@Qualifier(Qualifiers.BROKER_INSTANCE)
public ZookeeperClient getZKClient() throws IOException, LoginException {
  if (kerberosProperties.isKerberosEnabled()) {
    LOGGER.info("Found kerberos configuration - trying to authenticate");
    KrbLoginManager loginManager =
        KrbLoginManagerFactory.getInstance().getKrbLoginManagerInstance(
            kerberosProperties.getKdc(), kerberosProperties.getRealm());
    loginManager.loginWithCredentials(config.getUser(), config.getPassword().toCharArray());
  } else {
    LOGGER.warn("kerberos configuration empty or invalid - will not try to authenticate.");
  }

  return new ZookeeperClientBuilder(config.getZkClusterHosts(), config.getUser(),
      config.getBrokerRootNode(), config.getBrokerRootNode()).build();
}
 

import org.trustedanalytics.cfbroker.store.zookeeper.service.ZookeeperClient; //导入依赖的package包/类
@Bean(initMethod = "init", destroyMethod = "destroy")
@Qualifier(Qualifiers.BROKER_STORE)
@Profile("integration-test")
public ZookeeperClient getZkClient(TestingServer zkServer) throws IOException {
  return new ZookeeperClientBuilder(zkServer.getConnectString(), user, password, brokerStoreNode)
      .build();
}
 

import org.trustedanalytics.cfbroker.store.zookeeper.service.ZookeeperClient; //导入依赖的package包/类
private void testZookeeperClientWithoutRootCreation() throws Exception {
  ZookeeperClient zkClient =
      new ZookeeperClientBuilder(connectionString, USERNAME, PASSWORD, ROOT_DIR).build();
  zkClient.init();
  zkClient.exists(ROOT_DIR);
  zkClient.destroy();
}
 

import org.trustedanalytics.cfbroker.store.zookeeper.service.ZookeeperClient; //导入依赖的package包/类
private void testZookeeperClientWithRootCreation() throws Exception {
  String digest =
      DigestAuthenticationProvider.generateDigest(String.format("%s:%s", USERNAME, PASSWORD));
  List<ACL> acl = Arrays.asList(new ACL(ZooDefs.Perms.ALL, new Id("digest", digest)));

  ZookeeperClient zkClient =
      new ZookeeperClientBuilder(connectionString, USERNAME, PASSWORD, ROOT_DIR)
          .withRootCreation(acl).build();
  zkClient.init();
  zkClient.exists(ROOT_DIR);
  zkClient.destroy();
}
 

import org.trustedanalytics.cfbroker.store.zookeeper.service.ZookeeperClient; //导入依赖的package包/类
private ZookeeperClient getZookeeperClient(String node) throws Exception {
  String absoluteNode = zkBaseNode + node;
  createIfNotExist(zkUri, absoluteNode);
  ZookeeperClient zkClient =
      new ZookeeperClientBuilder(zkUri, zkUser, zkPass, absoluteNode).build();
  zkClient.init();
  return zkClient;
}
 

import org.trustedanalytics.cfbroker.store.zookeeper.service.ZookeeperClient; //导入依赖的package包/类
@Bean(initMethod = "init", destroyMethod = "destroy")
@Qualifier(Qualifiers.BROKER_STORE)
@Profile("integration-test")
public ZookeeperClient getZkClient(TestingServer zkServer) throws IOException {
  ZookeeperClient client =
      new ZookeeperClientBuilder(zkServer.getConnectString(), user, password, brokerStoreNode).build();
  return client;
}
 

import org.trustedanalytics.cfbroker.store.zookeeper.service.ZookeeperClient; //导入依赖的package包/类
@Bean(initMethod = "init", destroyMethod = "destroy")
@Qualifier(Qualifiers.BROKER_STORE)
@Profile("integration-test")
public ZookeeperClient getZkClient() throws Exception {
  String zkClusterHosts = "localhost:" + utility.getZkCluster().getClientPort();
  ZooKeeperCredentials credendials =
      new ZooKeeperCredentials(zkClusterHosts, user, password);
  ZooKeeperTestOperations.createSecuredNode(credendials, brokerStoreNode);
  ZookeeperClient client =
      new ZookeeperClientBuilder(zkClusterHosts, user, password, brokerStoreNode)
          .build();
  return client;
}
 

import org.trustedanalytics.cfbroker.store.zookeeper.service.ZookeeperClient; //导入依赖的package包/类
@Bean(initMethod = "init", destroyMethod = "destroy")
@Qualifier(org.trustedanalytics.servicebroker.framework.Qualifiers.BROKER_STORE)
@Profile("integration-test")
public ZookeeperClient getZkClient(TestingServer zkServer) throws IOException {
  ZookeeperClient client =
      new ZookeeperClientBuilder(zkServer.getConnectString(), user, password, brokerStoreNode)
          .build();
  return client;
}
 

import org.trustedanalytics.cfbroker.store.zookeeper.service.ZookeeperClient; //导入依赖的package包/类
@Bean(initMethod = "init", destroyMethod = "destroy")
@Qualifier(Qualifiers.BROKER_INSTANCE)
@Profile("integration-test")
public ZookeeperClient getInstanceZkClient(TestingServer zkServer) throws IOException {
  ZookeeperClient client =
      new ZookeeperClientBuilder(zkServer.getConnectString(), user, password, brokerRootNode)
          .build();
  return client;
}
 

import org.trustedanalytics.cfbroker.store.zookeeper.service.ZookeeperClient; //导入依赖的package包/类
@Bean
public ZookeeperClient brokerZKClient() throws Exception {
  LOGGER.info("Creating zkClient with zkUri='{}' zkNode='{}'", zkUri, zkBrokerNode);
  return getZookeeperClient(zkBrokerNode);
}
 

import org.trustedanalytics.cfbroker.store.zookeeper.service.ZookeeperClient; //导入依赖的package包/类
@Bean
public ZookeeperClient credentialsZKClient() throws Exception {
  LOGGER.info("Creating zkClient with zkUri='{}' zkNode='{}'", zkUri, zkCredentialsNode);
  return getZookeeperClient(zkCredentialsNode);
}
 

import org.trustedanalytics.cfbroker.store.zookeeper.service.ZookeeperClient; //导入依赖的package包/类
@Bean(initMethod = "init", destroyMethod = "destroy")
public ZookeeperClient brokerZKClient() throws Exception {
  return getZookeeperClient(zkServer.getConnectString(), config.getZookeeperMetadataNode());
}
 

import org.trustedanalytics.cfbroker.store.zookeeper.service.ZookeeperClient; //导入依赖的package包/类
@Bean(initMethod = "init", destroyMethod = "destroy")
public ZookeeperClient credentialsZKClient() throws Exception {
  return getZookeeperClient(zkServer.getConnectString(), config.getZookeeperCredentialsNode());
}
 

import org.trustedanalytics.cfbroker.store.zookeeper.service.ZookeeperClient; //导入依赖的package包/类
private ZookeeperClient getZookeeperClient(String connectionString, String rootNode)
    throws IOException {
  return new ZookeeperClientBuilder(connectionString, "user", "password", rootNode).build();
}