本文整理了Java中org.apache.solr.cloud.ZkController.getZkClient()方法的一些代码示例，展示了ZkController.getZkClient()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。ZkController.getZkClient()方法的具体详情如下：
包路径：org.apache.solr.cloud.ZkController
类名称：ZkController
方法名：getZkClient

ZkController.getZkClient介绍

暂无

代码示例

代码示例来源：origin: org.apache.solr/solr-dataimporthandler

@Override
public void init(DataImporter dataImporter, Map<String, String> params) {
 super.init(dataImporter, params);    
 zkClient = dataImporter.getCore().getCoreContainer().getZkController().getZkClient();
}

代码示例来源：origin: org.apache.solr/solr-test-framework

if (! cc.getCores().isEmpty() && cc.isZooKeeperAware()) {
 try {
  cc.getZkController().getZkClient().exists("/", false);
 } catch (KeeperException e) {
  log.error("Testing connectivity to ZK by checking for root path failed", e);

代码示例来源：origin: org.apache.solr/solr-test-framework

/**
 * Make the zookeeper session on a particular jetty expire
 */
public void expireZkSession(JettySolrRunner jetty) {
 CoreContainer cores = jetty.getCoreContainer();
 if (cores != null) {
  SolrZkClient zkClient = cores.getZkController().getZkClient();
  zkClient.getSolrZooKeeper().closeCnxn();
  long sessionId = zkClient.getSolrZooKeeper().getSessionId();
  zkServer.expire(sessionId);
  log.info("Expired zookeeper session {} from node {}", sessionId, jetty.getBaseUrl());
 }
}

代码示例来源：origin: org.apache.solr/solr-test-framework

public static void causeConnectionLoss(JettySolrRunner jetty) {
 CoreContainer cores = jetty.getCoreContainer();
 if (cores != null) {
  monkeyLog("Will cause connection loss on " + jetty.getLocalPort());
  SolrZkClient zkClient = cores.getZkController().getZkClient();
  zkClient.getSolrZooKeeper().closeCnxn();
 }
}

代码示例来源：origin: org.apache.solr/solr-test-framework

public void expireSession(final JettySolrRunner jetty) {
 CoreContainer cores = jetty.getCoreContainer();
 if (cores != null) {
  monkeyLog("expire session for " + jetty.getLocalPort() + " !");
  causeConnectionLoss(jetty);
  long sessionId = cores.getZkController().getZkClient()
    .getSolrZooKeeper().getSessionId();
  zkServer.expire(sessionId);
 }
}

代码示例来源：origin: org.apache.solr/solr-test-framework

public static void kill(JettySolrRunner jetty) throws Exception {
 CoreContainer cores = jetty.getCoreContainer();
 if (cores != null) {
  if (cores.isZooKeeperAware()) {
   int zklocalport = ((InetSocketAddress) cores.getZkController()
     .getZkClient().getSolrZooKeeper().getSocketAddress()).getPort();
   IpTables.blockPort(zklocalport);
  }
 }
 IpTables.blockPort(jetty.getLocalPort());
 
 monkeyLog("kill jetty! " + jetty.getLocalPort());
 
 jetty.stop();
 
 stop(jetty);
 
 if (!jetty.isStopped()) {
  throw new RuntimeException("could not kill jetty");
 }
}

代码示例来源：origin: org.apache.solr/solr-test-framework

if (cores.isZooKeeperAware()) {
 int zklocalport = ((InetSocketAddress) cores.getZkController()
   .getZkClient().getSolrZooKeeper().getSocketAddress()).getPort();
 IpTables.unblockPort(zklocalport);

代码示例来源：origin: com.sematext.solr/st-ReSearcher-core

headers.add("zkConnected", 
  zkController != null 
 ? !zkController.getZkClient().getConnectionManager().isLikelyExpired() 
 : false);