import org.apache.solr.client.solrj.embedded.JettyConfig; //导入依赖的package包/类
void startJetty() throws Exception {
  Properties props = new Properties();
  props.setProperty("solrconfig", "solrconfig.xml");
  props.setProperty("solr.data.dir", getDataDir());
  
  JettyConfig jettyConfig = JettyConfig.builder(buildJettyConfig("/solr")).setPort(port).build();
  
  jetty = new JettySolrRunner( getHomeDir(), props, jettyConfig );
  jetty.start();
  int newPort = jetty.getLocalPort();
  if (port != 0 && newPort != port) {
    throw new Exception( "TESTING FAILURE: could not grab requested port." );
  }
      
  this.port = newPort;
}
 

import org.apache.solr.client.solrj.embedded.JettyConfig; //导入依赖的package包/类
@BeforeClass
public static void startCluster() throws Exception {
  TEMP_DIR = Files.createTempDirectory("MiniSolrCloudCluster");

  JettyConfig.Builder jettyConfig = JettyConfig.builder();
  jettyConfig.waitForLoadingCoresToFinish(null);

  cluster = new MiniSolrCloudCluster(1, TEMP_DIR, jettyConfig.build());
  cloudSolrClient = cluster.getSolrClient();
  cloudSolrClient.connect();
  assertTrue(!cloudSolrClient.getZkStateReader().getClusterState().getLiveNodes().isEmpty());

  uploadDefaultConfigSet();
  createDefaultCollection();
  verifyCluster();
  log.info("Start Solr Cluster");
}
 

import org.apache.solr.client.solrj.embedded.JettyConfig; //导入依赖的package包/类
@Override
public void start() throws UnableToStartException {
  try {
    File baseDir = Files.createTempDirectory("solrcomponent").toFile();
    baseDir.deleteOnExit();
    miniSolrCloudCluster = new MiniSolrCloudCluster(1, baseDir, new File(solrXmlPath), JettyConfig.builder().setPort(port).build());
    for(String name: collections.keySet()) {
      String configPath = collections.get(name);
      miniSolrCloudCluster.uploadConfigDir(new File(configPath), name);
    }
    miniSolrCloudCluster.createCollection("metron", 1, 1, "metron", new HashMap<String, String>());
    if (postStartCallback != null) postStartCallback.apply(this);
  } catch(Exception e) {
    throw new UnableToStartException(e.getMessage(), e);
  }
}
 

import org.apache.solr.client.solrj.embedded.JettyConfig; //导入依赖的package包/类
@BeforeClass
public static void init() {
	System.setProperty("solr.data.dir", initCoreDataDir.getAbsolutePath());

	try {
		SOLR = createJetty("src/solr",
				JettyConfig.builder()
					.setPort(8983)
					.setContext("/solr")
					.stopAtShutdown(true)
					.build());
	} catch (final Exception exception) {
		throw new RuntimeException(exception);
	}
}
 

import org.apache.solr.client.solrj.embedded.JettyConfig; //导入依赖的package包/类
/**
 * Start a new Solr instance on a particular servlet context
 *
 * @param name the instance name
 * @param hostContext the context to run on
 * @param config a JettyConfig for the instance's {@link org.apache.solr.client.solrj.embedded.JettySolrRunner}
 *
 * @return a JettySolrRunner
 */
public JettySolrRunner startJettySolrRunner(String name, String hostContext, JettyConfig config) throws Exception {
  Path runnerPath = createInstancePath(name);
  String context = getHostContextSuitableForServletContext(hostContext);
  JettyConfig newConfig = JettyConfig.builder(config).setContext(context).build();
  JettySolrRunner jetty = new JettySolrRunner(runnerPath.toString(), newConfig);
  jetty.start();
  jettys.add(jetty);
  return jetty;
}
 

import org.apache.solr.client.solrj.embedded.JettyConfig; //导入依赖的package包/类
@BeforeClass
public static void beforeSolrJettyTestBase() throws Exception {
	final File origSolrHome = new File(SolrJettyTestBase.class.getResource("/solr").toURI());
	final File tempSolrHome = tempSolrFolder.getRoot();
	final File tempSolrData = tempSolrFolder.newFolder("data");

	FileUtils.copyDirectory(origSolrHome, tempSolrHome);

	final JettyConfig jettyConfig = JettyConfig.builder()
		.setContext("/solr")
		.setPort(8888)
		.stopAtShutdown(true)
		.build();

	final Properties nodeProperties = new Properties();

	nodeProperties.setProperty("solr.data.dir", tempSolrData.getCanonicalPath());
	nodeProperties.setProperty("coreRootDirectory", tempSolrHome.toString());
	nodeProperties.setProperty("configSetBaseDir", tempSolrHome.toString());

	System.setProperty("jetty.testMode", "true");

	jetty = new JettySolrRunner(tempSolrHome.toString(), nodeProperties, jettyConfig);
	jetty.start();

	client = createNewSolrClient();
}
 

import org.apache.solr.client.solrj.embedded.JettyConfig; //导入依赖的package包/类
public void startJetty(int delay) throws Exception {
  Properties props = new Properties();
  props.setProperty("solrconfig", "bad_solrconfig.xml");
  props.setProperty("solr.data.dir", getDataDir());

  JettyConfig.Builder jettyConfigBuilder = JettyConfig.builder().setContext("/solr").setPort(port);
  jetty = new SlowJettySolrRunner(getHomeDir(), props, jettyConfigBuilder, delay);

  jetty.start();
  int newPort = jetty.getLocalPort();
  if (port != 0 && newPort != port) {
    fail("TESTING FAILURE: could not grab requested port.");
  }
  this.port = newPort;
}
 

import org.apache.solr.client.solrj.embedded.JettyConfig; //导入依赖的package包/类
private static JettyConfig finalizeBuilder(JettyConfig.Builder config, int initDelay) {
  if (initDelay >= 0) {
    setDelay(initDelay);
    config.withFilter(SlowFilter.class, "*");
  }
  return config.build();
}
 

import org.apache.solr.client.solrj.embedded.JettyConfig; //导入依赖的package包/类
/**
 * Initilisation procedure for this test case.
 * 
 * @throws UnableToBuildSolRDFClientException in case the client cannot be built.
 * @throws Exception in case of Solr startup failure.
 */
@BeforeClass
public static void initITTest() {
	System.setProperty("tests.asserts", "false");	
	System.setProperty("jetty.port", "8080");
	System.setProperty("solr.core.name", "store");
	System.setProperty("solr.data.dir", initCoreDataDir.getAbsolutePath());
		
	try {
		SOLR = createJetty(
				"target/solrdf-integration-tests-1.1-dev/solrdf",
				JettyConfig.builder()
					.setPort(8080)
					.setContext("/solr")
					.stopAtShutdown(true)
					.build());		
		
		final HttpClient httpClient = HttpClientBuilder.create()
				.setRoutePlanner(
						new DefaultRoutePlanner(
								new SchemePortResolver() {
									@Override
									public int resolve(final HttpHost host) throws UnsupportedSchemeException {
										return SOLR.getLocalPort();
									}
								})).build();
		
		
		SOLRDF_CLIENT = SolRDF.newBuilder()
	              .withEndpoint("http://127.0.0.1:8080/solr/store")
	              .withGraphStoreProtocolEndpointPath("/rdf-graph-store")
	              .withHttpClient(httpClient)
	              .withSPARQLEndpointPath("/sparql")
	              .build();
		
		PLAIN_SOLR_CLIENT = new HttpSolrClient(SOLR_URI);
	} catch (final Exception exception) {
		throw new RuntimeException(exception);
	}
}
 

import org.apache.solr.client.solrj.embedded.JettyConfig; //导入依赖的package包/类
JettyConfig buildJettyConfig( String context ) {
  return JettyConfig.builder().setContext( context ).withSSLConfig( null ).build();
}
 

import org.apache.solr.client.solrj.embedded.JettyConfig; //导入依赖的package包/类
public SlowJettySolrRunner(String solrHome, Properties nodeProperties, JettyConfig.Builder config, int initDelay) {
  super(solrHome, nodeProperties, finalizeBuilder(config, initDelay));
}
 

import org.apache.solr.client.solrj.embedded.JettyConfig; //导入依赖的package包/类
/**
 * Create a MiniSolrCloudCluster
 *
 * @param numServers number of Solr servers to start
 * @param hostContext context path of Solr servers used by Jetty
 * @param baseDir base directory that the mini cluster should be run from
 * @param solrXml solr.xml file to be uploaded to ZooKeeper
 * @param extraServlets Extra servlets to be started by Jetty
 * @param extraRequestFilters extra filters to be started by Jetty
 * @param sslConfig SSL configuration
 *
 * @throws Exception if there was an error starting the cluster
 */
public MiniSolrCloudCluster(int numServers, String hostContext, Path baseDir, String solrXml,
    SortedMap<ServletHolder, String> extraServlets,
    SortedMap<Class<? extends Filter>, String> extraRequestFilters,
    SSLConfig sslConfig, String chroot) throws Exception {
  this(numServers, baseDir, solrXml, JettyConfig.builder()
      .setContext(hostContext)
      .withSSLConfig(sslConfig)
      .withFilters(extraRequestFilters)
      .withServlets(extraServlets)
      .build(),
      chroot);
}