org.apache.solr.cloud.ZkTestServer类的使用及代码示例

x33g5p2x  于2022-02-05 转载在 其他  
字(9.2k)|赞(0)|评价(0)|浏览(80)

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

ZkTestServer介绍

暂无

代码示例

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

public String getZkAddress() {
 return getZkAddress("/solr");
}

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

@BeforeClass
public static void azt_beforeClass() throws Exception {
 zkDir = createTempDir("zkData").toFile().getAbsolutePath();
 zkServer = new ZkTestServer(zkDir);
 zkServer.run();
 
 System.setProperty("solrcloud.skip.autorecovery", "true");
 System.setProperty("zkHost", zkServer.getZkAddress());
 System.setProperty("jetty.port", "0000");
 System.setProperty(ZOOKEEPER_FORCE_SYNC, "false");
 
 buildZooKeeper(zkServer.getZkHost(), zkServer.getZkAddress(), SOLRHOME,
   "solrconfig.xml", "schema.xml");
 initCore("solrconfig.xml", "schema.xml");
}

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

public ZkTestServer(String zkDir, int port) {
 this.zkDir = zkDir;
 this.clientPort = port;
 String reportAction = System.getProperty("tests.zk.violationReportAction");
 if (reportAction != null) {
  log.info("Overriding violation report action to: {}", reportAction);
  setViolationReportAction(LimitViolationAction.valueOf(reportAction));
 }
 String limiterAction = System.getProperty("tests.zk.limiterAction");
 if (limiterAction != null) {
  log.info("Overriding limiter action to: {}", limiterAction);
  getLimiter().setAction(LimitViolationAction.valueOf(limiterAction));
 }
}

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

protected void restartZk(int pauseMillis) throws Exception {
  log.info("Restarting ZK with a pause of {}ms in between", pauseMillis);
  zkServer.shutdown();
  // disconnect enough to test stalling, if things stall, then clientSoTimeout w""ill be hit
  Thread.sleep(pauseMillis);
  zkServer = new ZkTestServer(zkServer.getZkDir(), zkServer.getPort());
  zkServer.run();
 }
}

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

/**
 * Shutdown the serving instance
 * @throws IOException If there is a low-level I/O error.
 */
protected void shutdown() throws IOException {
 zooKeeperServer.shutdown();
 ZKDatabase zkDb = zooKeeperServer.getZKDatabase();
 if (cnxnFactory != null && cnxnFactory.getLocalPort() != 0) {
  waitForServerDown(getZkHost() + ":" + getPort(), 5000);
 }
 if (cnxnFactory != null) {
  cnxnFactory.shutdown();
  try {
   cnxnFactory.join();
  } catch (InterruptedException e) {
   Thread.currentThread().interrupt();
  }
 }
 if (zkDb != null) {
  zkDb.close();
 }
}

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

/**
 * Check that a path exists in this server
 * @param path the path to check
 * @throws IOException if an IO exception occurs
 */
public void ensurePathExists(String path) throws IOException {
 try (SolrZkClient client = new SolrZkClient(getZkHost(), 10000)) {
  client.makePath(path, false);
 } catch (InterruptedException | KeeperException e) {
  throw new IOException("Error checking path " + path, SolrZkClient.checkInterrupted(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

int port = -1;
try {
  port = getPort();
} catch(IllegalStateException e) {
 Thread.sleep(100);
 try {
  port = getPort();
 } catch(IllegalStateException e) {

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

public void injectChaos(Random random) throws Exception {

  // sometimes we restart one of the jetty nodes
  if (random.nextBoolean()) {
   JettySolrRunner jetty = jettys.get(random.nextInt(jettys.size()));
   ChaosMonkey.stop(jetty);
   log.info("============ Restarting jetty");
   ChaosMonkey.start(jetty);
  }

  // sometimes we restart zookeeper
  if (random.nextBoolean()) {
   zkServer.shutdown();
   log.info("============ Restarting zookeeper");
   zkServer = new ZkTestServer(zkServer.getZkDir(), zkServer.getPort());
   zkServer.run();
  }

  // sometimes we cause a connection loss - sometimes it will hit the overseer
  if (random.nextBoolean()) {
   JettySolrRunner jetty = jettys.get(random.nextInt(jettys.size()));
   ChaosMonkey.causeConnectionLoss(jetty);
  }
 }
}

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

private void waitForAllNodes(int numServers, int timeout) throws IOException, InterruptedException {
 try (SolrZkClient zkClient = new SolrZkClient(zkServer.getZkHost(), AbstractZkTestCase.TIMEOUT)) {
  int numliveNodes = 0;
  int retries = timeout;
  String liveNodesPath = "/solr/live_nodes";
  // Wait up to {timeout} seconds for number of live_nodes to match up number of servers
  do {
   if (zkClient.exists(liveNodesPath, true)) {
    numliveNodes = zkClient.getChildren(liveNodesPath, null, true).size();
    if (numliveNodes == numServers) {
     break;
    }
   }
   retries--;
   if (retries == 0) {
    throw new IllegalStateException("Solr servers failed to register with ZK."
      + " Current count: " + numliveNodes + "; Expected count: " + numServers);
   }
   Thread.sleep(1000);
  } while (numliveNodes != numServers);
 }
 catch (KeeperException e) {
  throw new IOException("Error communicating with zookeeper", e);
 }
}

代码示例来源：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: apache/atlas

public static String getZookeeperUrls() {
  return miniSolrCloudCluster.getZkServer().getZkAddress();
}

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

@Override
public void distribSetUp() throws Exception {
 super.distribSetUp();
 
 String zkDir = testDir.getAbsolutePath() + File.separator
 + "zookeeper/server1/data";
 zkServer = new ZkTestServer(zkDir);
 zkServer.run();
 
 System.setProperty(ZK_HOST, zkServer.getZkAddress());
 System.setProperty(ENABLE_UPDATE_LOG, "true");
 System.setProperty(REMOVE_VERSION_FIELD, "true");
 System.setProperty(ZOOKEEPER_FORCE_SYNC, "false");
 System.setProperty(MockDirectoryFactory.SOLR_TESTS_ALLOW_READING_FILES_STILL_OPEN_FOR_WRITE, "true");
 String schema = getCloudSchemaFile();
 if (schema == null) schema = "schema.xml";
 AbstractZkTestCase.buildZooKeeper(zkServer.getZkHost(), zkServer.getZkAddress(), getCloudSolrConfig(), schema);
 // set some system properties for use by tests
 System.setProperty("solr.test.sys.prop1", "propone");
 System.setProperty("solr.test.sys.prop2", "proptwo");
}

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

protected void printLayout() throws Exception {
 SolrZkClient zkClient = new SolrZkClient(zkServer.getZkHost(), AbstractZkTestCase.TIMEOUT);
 zkClient.printLayoutToStdOut();
 zkClient.close();
}

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

protected CloudSolrClient buildSolrClient() {
 return new Builder(Collections.singletonList(getZkServer().getZkAddress()), Optional.empty())
   .build();
}

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

if (!externalZkServer) {
 String zkDir = baseDir.resolve("zookeeper/server1/data").toString();
 zkTestServer = new ZkTestServer(zkDir);
 zkTestServer.run();
try (SolrZkClient zkClient = new SolrZkClient(zkServer.getZkHost(), AbstractZkTestCase.TIMEOUT)) {
 zkClient.makePath("/solr/solr.xml", solrXml.getBytes(Charset.defaultCharset()), true);
 if (jettyConfig.sslConfig != null && jettyConfig.sslConfig.isSSLMode()) {
System.setProperty("zkHost", zkServer.getZkAddress());

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

protected CloudSolrClient createCloudClient(String defaultCollection) {
 CloudSolrClient client = getCloudSolrClient(zkServer.getZkAddress(), random().nextBoolean(), 30000, 60000);
 if (defaultCollection != null) client.setDefaultCollection(defaultCollection);
 return client;
}

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

public CloudSolrClientBuilder(MiniSolrCloudCluster cluster) {
 if (random().nextBoolean()) {
  this.zkHosts.add(cluster.getZkServer().getZkAddress());
 } else {
  populateSolrUrls(cluster);
 }
 
 randomizeCloudSolrClient();
}

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

/**
 * Upload a config set
 * @param configDir a path to the config set to upload
 * @param configName the name to give the configset
 */
public void uploadConfigSet(Path configDir, String configName) throws IOException, KeeperException, InterruptedException {
 try(SolrZkClient zkClient = new SolrZkClient(zkServer.getZkAddress(),
   AbstractZkTestCase.TIMEOUT, AbstractZkTestCase.TIMEOUT, null)) {
  ZkConfigManager manager = new ZkConfigManager(zkClient);
  manager.uploadConfigDir(configDir, configName);
 }
}

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

protected CloudSolrClient getCommonCloudSolrClient() {
 synchronized (this) {
  if (commonCloudSolrClient == null) {
   commonCloudSolrClient = getCloudSolrClient(zkServer.getZkAddress(),
     random().nextBoolean(), 5000, 120000);
   commonCloudSolrClient.setDefaultCollection(DEFAULT_COLLECTION);
   commonCloudSolrClient.connect();
   log.info("Created commonCloudSolrClient with updatesToLeaders={} and parallelUpdates={}",
     commonCloudSolrClient.isUpdatesToLeaders(), commonCloudSolrClient.isParallelUpdates());
  }
 }
 return commonCloudSolrClient;
}

内容来源于网络，如有侵权，请联系作者删除！

ZkTestServer

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多

    ZkTestServer类方法

    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com