import io.searchbox.client.http.JestHttpClient; //导入依赖的package包/类
JestHttpClient build() {
  JestClientFactory factory = new JestClientFactory();
  Builder builder =
      new HttpClientConfig.Builder(cfg.urls)
          .multiThreaded(true)
          .discoveryEnabled(false)
          .connTimeout((int) cfg.connectionTimeout)
          .maxConnectionIdleTime(cfg.maxConnectionIdleTime, cfg.maxConnectionIdleUnit)
          .maxTotalConnection(cfg.maxTotalConnection)
          .readTimeout(cfg.readTimeout)
          .requestCompressionEnabled(cfg.requestCompression)
          .discoveryFrequency(1L, TimeUnit.MINUTES);

  if (cfg.username != null && cfg.password != null) {
    builder.defaultCredentials(cfg.username, cfg.password);
  }

  factory.setHttpClientConfig(builder.build());
  return (JestHttpClient) factory.getObject();
}
 

import io.searchbox.client.http.JestHttpClient; //导入依赖的package包/类
@Test
public void should_jest_auto_configuration_have_custom_httpbuilder() {
	RequestConfig config = ((Configurable) ((JestHttpClient) jestClient).getHttpClient()).getConfig();

	int connectTimeout = config.getConnectTimeout();

	assertThat(connectTimeout, is(3551));
}
 

import io.searchbox.client.http.JestHttpClient; //导入依赖的package包/类
@Before
public void setUp() throws Exception {
  super.setUp();
  final JestClientFactory factory = new JestClientFactory();
  factory.setHttpClientConfig(
      new HttpClientConfig
          .Builder("http://localhost:" + getPort())
          .multiThreaded(true).build()
  );
  client = (JestHttpClient) factory.getObject();
  converter = new DataConverter(true, BehaviorOnNullValues.IGNORE);
}
 

import io.searchbox.client.http.JestHttpClient; //导入依赖的package包/类
/**
	 * @param args
	 * @throws Exception 
	 */
	public static void main(String[] args) throws Exception {

		 // Construct a new Jest client according to configuration via factory
		 JestClientFactory factory = new JestClientFactory();
		 factory.setHttpClientConfig(new HttpClientConfig
		                        .Builder("http://api.exiletools.com/index")
		                        .multiThreaded(true)
		                        .build());
		 JestHttpClient client = (JestHttpClient) factory.getObject();
		 
		 SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
//		 searchSourceBuilder.query(QueryBuilders.matchQuery("info.name", "Tabula Rasa"));
		 searchSourceBuilder.query(QueryBuilders.matchQuery("info.name", "Mjolner"));
		 searchSourceBuilder.size(1);

		 System.out.println(searchSourceBuilder.toString());

		 ExileToolsSearchAction search = new ExileToolsSearchAction.Builder(searchSourceBuilder.toString())
		                                 .setHeader("Authorization", "DEVELOPMENT-Indexer")
		                                 .build();
		 
		 SearchResult result = client.execute(search);
		 
		 System.out.println(result.getPathToResult());
		 System.out.println(result.getJsonString());
		 
		 List<Hit<ExileToolsHit, Void>> articles = result.getHits(ExileToolsHit.class);
		 System.out.println(articles);
		 articles.stream().forEach( (e) -> {
			 System.out.println(e.source.getMd5sum());
			 System.out.println(e.source.getInfo());
			 System.out.println(e.source.getAttributes());
			 System.out.println(e.source.getShop());
			 System.out.println(e.source.getSockets());
		 } );
		 client.shutdownClient();
	}
 

import io.searchbox.client.http.JestHttpClient; //导入依赖的package包/类
public ExileToolsSearchClient(String url, String apiKey) {
	this.apiKey = apiKey;
	// Construct a new Jest client according to configuration via factory
	JestClientFactory factory = new JestClientFactory();
	factory.setHttpClientConfig(new HttpClientConfig.Builder(url).multiThreaded(true).build());
	client = (JestHttpClient) factory.getObject();
	logger.debug("~~~~~~~~~~~~~~~~~~ Successfully started ExileToolsESClient ~~~~~~~~~~~~~~~~~~~~");
}
 

import io.searchbox.client.http.JestHttpClient; //导入依赖的package包/类
@Test
public void testESInit() {
  JestHttpClient client = ElasticsearchInit.getClient();
  System.out.println("->> "+client.getServers());
  System.out.println("->> "+client.getAsyncClient());
  client.shutdownClient();
}
 

import io.searchbox.client.http.JestHttpClient; //导入依赖的package包/类
@Test
public void customGson() {
	load(CustomGson.class, "spring.elasticsearch.jest.uris=http://localhost:9200");
	JestHttpClient client = (JestHttpClient) this.context.getBean(JestClient.class);
	assertThat(client.getGson()).isSameAs(this.context.getBean("customGson"));
}