[RestHighLevelClient] 1. 기본 사용법

15 Sep 2020 java      

  • Java High Level REST Client 를 사용하여 Elasticsearch를 사용해보자!

pom.xml

  • version 은 사용 중인 es 버전으로 맞춰서 작업하는게 좋습니다.
<dependency>
    <groupId>org.elasticsearch.client</groupId>
    <artifactId>elasticsearch-rest-high-level-client</artifactId>
    <version>7.9.1</version>
</dependency>

gradle

compile 'org.elasticsearch.client:elasticsearch-rest-high-level-client:7.9.1'

RestHighLevelClient

RestHighLevelClient client = new RestHighLevelClient(
    RestClient.builder(
        new HttpHost("localhost", 9200, "http")
    )
);
client.close();
  • try with resources
try (
    RestHighLevelClient client = new RestHighLevelClient(
        RestClient.builder(
            new HttpHost("localhost", 9200, "http")
        )
    );
) {
} catch (IOException e) {
    log.error(e.getMessage(), e);
}

id, password 가 설정되어 있을 경우

CredentialsProvider credentialsProvider = new BasicCredentialsProvider();
credentialsProvider.setCredentials(AuthScope.ANY, new UsernamePasswordCredentials("username", "password"));
RestClientBuilder builder = RestClient.builder(new HttpHost("localhost", 9200, "http"))
    .setHttpClientConfigCallback(
        httpClientBuilder -> httpClientBuilder.setDefaultCredentialsProvider(credentialsProvider)
    );
try (
    RestHighLevelClient client = new RestHighLevelClient(builder);
) {
} catch (IOException e) {
    log.error(e.getMessage(), e);
}

timeout 설정

RestClientBuilder builder = RestClient.builder(new HttpHost("localhost", 9200))
    .setRequestConfigCallback(
        requestConfigBuilder -> requestConfigBuilder
            .setConnectTimeout(5000)
            .setSocketTimeout(60000)
    );
try (
    RestHighLevelClient client = new RestHighLevelClient(builder);
) {
} catch (IOException e) {
    log.error(e.getMessage(), e);
}

참고자료

  • https://www.elastic.co/guide/en/elasticsearch/client/java-rest/master/java-rest-high.html
  • https://www.elastic.co/guide/en/elasticsearch/client/java-rest/current/_timeouts.html

Related Posts