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

ZkStateReader.close介绍

暂无

代码示例

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

@Override
public void close() throws IOException {
 if (zkStateReader != null && closeZkStateReader) {
  synchronized (this) {
   if (zkStateReader != null)
    zkStateReader.close();
   zkStateReader = null;
  }
 }
}

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

@Override
public void connect() {
 if (zkStateReader == null) {
  synchronized (this) {
   if (zkStateReader == null) {
    ZkStateReader zk = null;
    try {
     zk = new ZkStateReader(zkHost, zkClientTimeout, zkConnectTimeout);
     zk.createClusterStateWatchersAndUpdate();
     zkStateReader = zk;
     log.info("Cluster at {} ready", zkHost);
    } catch (InterruptedException e) {
     zk.close();
     Thread.currentThread().interrupt();
     throw new ZooKeeperException(SolrException.ErrorCode.SERVER_ERROR, "", e);
    } catch (KeeperException e) {
     zk.close();
     throw new ZooKeeperException(SolrException.ErrorCode.SERVER_ERROR, "", e);
    } catch (Exception e) {
     if (zk != null) zk.close();
     // do not wrap because clients may be relying on the underlying exception being thrown
     throw e;
    }
   }
  }
 }
}

代码示例来源：origin: com.hynnet/solr-solrj

@Override
@Deprecated
public void shutdown() {
 if (zkStateReader != null) {
  synchronized(this) {
   if (zkStateReader!= null)
    zkStateReader.close();
   zkStateReader = null;
  }
 }
 
 if (shutdownLBHttpSolrServer) {
  lbClient.shutdown();
 }
 
 if (clientIsInternal && myClient!=null) {
  HttpClientUtil.close(myClient);
 }
 if(this.threadPool != null && !this.threadPool.isShutdown()) {
  this.threadPool.shutdown();
 }
}

代码示例来源：origin: com.hynnet/solr-solrj

/**
 * Connect to the zookeeper ensemble.
 * This is an optional method that may be used to force a connect before any other requests are sent.
 *
 */
public void connect() {
 if (zkStateReader == null) {
  synchronized (this) {
   if (zkStateReader == null) {
    ZkStateReader zk = null;
    try {
     zk = new ZkStateReader(zkHost, zkClientTimeout, zkConnectTimeout);
     zk.createClusterStateWatchersAndUpdate();
     zkStateReader = zk;
    } catch (InterruptedException e) {
     zk.close();
     Thread.currentThread().interrupt();
     throw new ZooKeeperException(SolrException.ErrorCode.SERVER_ERROR, "", e);
    } catch (KeeperException e) {
     zk.close();
     throw new ZooKeeperException(SolrException.ErrorCode.SERVER_ERROR, "", e);
    } catch (Exception e) {
     if (zk != null) zk.close();
     // do not wrap because clients may be relying on the underlying exception being thrown
     throw e;
    }
   }
  }
 }
}