SpringBoot + Elasticsearch 6.2.3

一、下載 Elasticsearch

https://www.elastic.co/downloads/elasticsearch

二、修改Gradle

compile "org.elasticsearch:elasticsearch:6.2.3"
compile 'org.elasticsearch.client:elasticsearch-rest-high-level-client:6.2.3'

三、EsConfig

import java.io.IOException;

import org.apache.http.HttpHost;
import org.apache.http.client.config.RequestConfig.Builder;
import org.apache.http.impl.nio.client.HttpAsyncClientBuilder;
import org.elasticsearch.client.RestClient;
import org.elasticsearch.client.RestClientBuilder;
import org.elasticsearch.client.RestClientBuilder.HttpClientConfigCallback;
import org.elasticsearch.client.RestClientBuilder.RequestConfigCallback;
import org.elasticsearch.client.RestHighLevelClient;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class EsConfig {

  private String host = "127.0.0.1";
  private int port = 9200;
  private String schema = "http";
  private int connectTimeOut = 1000;
  private int socketTimeOut = 30000;
  private int connectionRequestTimeOut = 500;

  private int maxConnectNum = 100;
  private int maxConnectPerRoute = 100;

  private HttpHost httpHost = new HttpHost(host, port, schema);
  private boolean uniqueConnectTimeConfig = true;
  private boolean uniqueConnectNumConfig = true;
  private RestClientBuilder builder;
  private RestHighLevelClient client;

  @Bean
  public RestHighLevelClient client() {
    builder = RestClient.builder(httpHost);
    if (uniqueConnectTimeConfig) {
      setConnectTimeOutConfig();
    }
    if (uniqueConnectNumConfig) {
      setMutiConnectConfig();
    }
    client=new RestHighLevelClient(builder);
    return client;
  }

  // 主要關於異步httpclient的連接延時配置
  public void setConnectTimeOutConfig() {
    builder.setRequestConfigCallback(new RequestConfigCallback() {

      @Override
      public Builder customizeRequestConfig(Builder requestConfigBuilder) {
        requestConfigBuilder.setConnectTimeout(connectTimeOut);
        requestConfigBuilder.setSocketTimeout(socketTimeOut);
        requestConfigBuilder.setConnectionRequestTimeout(connectionRequestTimeOut);
        return requestConfigBuilder;
      }
    });
  }

  // 主要關於異步httpclient的連接數配置
  public void setMutiConnectConfig() {
    builder.setHttpClientConfigCallback(new HttpClientConfigCallback() {

      @Override
      public HttpAsyncClientBuilder customizeHttpClient(HttpAsyncClientBuilder httpClientBuilder) {
        httpClientBuilder.setMaxConnTotal(maxConnectNum);
        httpClientBuilder.setMaxConnPerRoute(maxConnectPerRoute);
        return httpClientBuilder;
      }
    });
  }
  
  public void close() {
    if (client != null) {
      try {
        client.close();
      } catch (IOException e) {
        e.printStackTrace();
      }
    }
}
}

 四、調用

@Autowired
private RestHighLevelClient client;

 1.創建index

CreateIndexRequest request = new CreateIndexRequest("indexname");//index名必須全小寫，否則報錯
2 try {
  client.indices().create(request);
4 } catch (IOException e) {
  e.printStackTrace();
6 }

2.添加數據

IndexRequest indexRequest = new IndexRequest("indexname", "typename", "id");//id為自定義
2 ObjectMapper mapper = new ObjectMapper();
3 try {
  indexRequest.source(mapper.writeValueAsString(object), XContentType.JSON);
  client.index(indexRequest);
6 } catch (Exception e) {
  e.printStackTrace();
8 }

3.刪除數據

DeleteRequest deleteRequest = new DeleteRequest("indexname", "typename", id);
2 DeleteResponse response = null;
3 try {
  response = client.delete(deleteRequest);
5 } catch (IOException e) {
  e.printStackTrace();
7 }

4.批量插入數據

BulkRequest bulkRequest = new BulkRequest();
IndexRequest indexRequest = null;
ObjectMapper mapper = new ObjectMapper();
try {
  for (Object o : objects) {
    indexRequest = new IndexRequest(index, type, p.getId());
    indexRequest.source(mapper.writeValueAsString(o), XContentType.JSON);
    bulkRequest.add(indexRequest);
  }
client.bulk(bulkRequest);
} catch (Exception e) {
  e.printStackTrace();
}

5.批量刪除數據

BulkRequest bulkRequest = new BulkRequest();
 2 DeleteRequest deleteRequest = null;
 3 try {
  for (String id : ids) {
    deleteRequest = new DeleteRequest(index, type, id);
    bulkRequest.add(deleteRequest);
  }
  client.bulk(bulkRequest);
 9 } catch (Exception e) {
  e.printStackTrace();
11 }

6.未完待續