import org.apache.solr.client.solrj.ResponseParser; //导入依赖的package包/类
public HttpSolrServer(String baseURL, HttpClient client, ResponseParser parser) {
  this.baseUrl = baseURL;
  if (baseUrl.endsWith("/")) {
    baseUrl = baseUrl.substring(0, baseUrl.length() - 1);
  }
  if (baseUrl.indexOf('?') >= 0) {
    throw new RuntimeException(
        "Invalid base url for solrj.  The base URL must not contain parameters: "
            + baseUrl);
  }
  
  if (client != null) {
    httpClient = client;
    internalClient = false;
  } else {
    internalClient = true;
    ModifiableSolrParams params = new ModifiableSolrParams();
    params.set(HttpClientUtil.PROP_MAX_CONNECTIONS, 128);
    params.set(HttpClientUtil.PROP_MAX_CONNECTIONS_PER_HOST, 32);
    params.set(HttpClientUtil.PROP_FOLLOW_REDIRECTS, followRedirects);
    httpClient =  HttpClientUtil.createClient(params);
  }
  
  this.parser = parser;
}
 

import org.apache.solr.client.solrj.ResponseParser; //导入依赖的package包/类
/**
 * @lucene.experimental
 */
public HttpUriRequestResponse httpUriRequest(final SolrRequest request, final ResponseParser processor) throws SolrServerException, IOException {
  HttpUriRequestResponse mrr = new HttpUriRequestResponse();
  final HttpRequestBase method = createMethod(request);
  ExecutorService pool = Executors.newFixedThreadPool(1, new SolrjNamedThreadFactory("httpUriRequest"));
  try {
    mrr.future = pool.submit(new Callable<NamedList<Object>>(){

      @Override
      public NamedList<Object> call() throws Exception {
        return executeMethod(method, processor);
      }});
 
  } finally {
    pool.shutdown();
  }
  assert method != null;
  mrr.httpUriRequest = method;
  return mrr;
}
 

import org.apache.solr.client.solrj.ResponseParser; //导入依赖的package包/类
private void assertResponse(String responseString) throws IOException {
  ResponseParser xmlResponseParser = new XMLResponseParser();
  NamedList expectedResponse = xmlResponseParser.processResponse(IOUtils.toInputStream(responseString, "UTF-8"), "UTF-8");
  List<SolrDocument> documentList = (List<SolrDocument>) expectedResponse.getAll("response").get(0);
  assertEquals(1, documentList.size());
  SolrDocument solrDocument = documentList.get(0);
  assertEquals("1234", String.valueOf(solrDocument.getFieldValue("id")));
}
 

import org.apache.solr.client.solrj.ResponseParser; //导入依赖的package包/类
/**
 * Test method for {@link org.apache.solr.client.solrj.impl.LBHttpSolrServer#LBHttpSolrServer(org.apache.http.client.HttpClient, org.apache.solr.client.solrj.ResponseParser, java.lang.String[])}.
 * 
 * Validate that the parser passed in is used in the <code>HttpSolrServer</code> instances created.
 * 
 * @throws MalformedURLException If URL is invalid, no URL passed, so won't happen.
 */
@Test
public void testLBHttpSolrServerHttpClientResponseParserStringArray() throws MalformedURLException {
  LBHttpSolrServer testServer = new LBHttpSolrServer(HttpClientUtil.createClient(new ModifiableSolrParams()), (ResponseParser) null);
  HttpSolrServer httpServer = testServer.makeServer("http://127.0.0.1:8080");
  assertNull("Generated server should have null parser.", httpServer.getParser());

  ResponseParser parser = new BinaryResponseParser();
  testServer = new LBHttpSolrServer(HttpClientUtil.createClient(new ModifiableSolrParams()), parser);
  httpServer = testServer.makeServer("http://127.0.0.1:8080");
  assertEquals("Invalid parser passed to generated server.", parser, httpServer.getParser());
}
 

import org.apache.solr.client.solrj.ResponseParser; //导入依赖的package包/类
public void testGetRawFile() throws SolrServerException, IOException {
  SolrServer server = getSolrServer();
  //assertQ(req("qt", "/admin/file")); TODO file bug that SolrJettyTestBase extends SolrTestCaseJ4
  QueryRequest request = new QueryRequest(params("file","schema.xml"));
  request.setPath("/admin/file");
  final AtomicBoolean readFile = new AtomicBoolean();
  request.setResponseParser(new ResponseParser() {
    @Override
    public String getWriterType() {
      return "mock";//unfortunately this gets put onto params wt=mock but it apparently has no effect
    }

    @Override
    public NamedList<Object> processResponse(InputStream body, String encoding) {
      try {
        if (body.read() >= 0)
          readFile.set(true);
      } catch (IOException e) {
        throw new RuntimeException(e);
      }
      return null;
    }

    @Override
    public NamedList<Object> processResponse(Reader reader) {
      throw new UnsupportedOperationException("TODO unimplemented");//TODO
    }
  });

  server.request( request );//runs request
  //request.process(server); but we don't have a NamedList response
  assertTrue(readFile.get());
}
 

import org.apache.solr.client.solrj.ResponseParser; //导入依赖的package包/类
public void setResponseParser(ResponseParser responseParser)
{
  this.responseParser = responseParser;
}
 

import org.apache.solr.client.solrj.ResponseParser; //导入依赖的package包/类
public ResponseParser getResponseParser()
{
  return responseParser;
}
 

import org.apache.solr.client.solrj.ResponseParser; //导入依赖的package包/类
public void setParser(ResponseParser responseParser) {
  server.setParser(responseParser);
}
 

import org.apache.solr.client.solrj.ResponseParser; //导入依赖的package包/类
public ResponseParser getParser() {
  return parser;
}
 

import org.apache.solr.client.solrj.ResponseParser; //导入依赖的package包/类
public ResponseParser getParser() {
  return lbServer.getParser();
}
 

import org.apache.solr.client.solrj.ResponseParser; //导入依赖的package包/类
/**
 * set the response parser the SolrServer to be build use as default.
 * 
 * @param responseParser
 *            the response parser the SolrServer to be build use as
 *            default.<strong>NOT BE NULL</strong>
 */
public void setResponseParser(ResponseParser responseParser) {
	if (responseParser == null) {
		throw new IllegalAccessError("response parset should not be null");
	}
	this.responseParser = responseParser;
}
 

import org.apache.solr.client.solrj.ResponseParser; //导入依赖的package包/类
/**
 * Note: This setter method is <b>not thread-safe</b>.
 * 
 * @param processor
 *          Default Response Parser chosen to parse the response if the parser
 *          were not specified as part of the request.
 * @see org.apache.solr.client.solrj.SolrRequest#getResponseParser()
 */
public void setParser(ResponseParser processor) {
  parser = processor;
}
 

import org.apache.solr.client.solrj.ResponseParser; //导入依赖的package包/类
/**
 * Note: This setter method is <b>not thread-safe</b>.
 * 
 * @param processor
 *          Default Response Parser chosen to parse the response if the parser
 *          were not specified as part of the request.
 * @see org.apache.solr.client.solrj.SolrRequest#getResponseParser()
 */
public void setParser(ResponseParser processor) {
  lbServer.setParser(processor);
}
 

import org.apache.solr.client.solrj.ResponseParser; //导入依赖的package包/类
/**
 * the response parser the SolrServer to be build use as default.
 * 
 * @return
 */
public ResponseParser getResponseParser() {
	return responseParser;
}