[Elasticsearch] SpringBoot에 Elasticsearch 연동하기

이번 프로젝트에서 Elasticsearch로 검색엔진을 담당하게 되었다.

프론트에서 검색어를 SpringBoot 서버로 넘겨주면 SpringBoot에서 Elasticsearch에 api를 호출해서 결과를 반환하도록 로직을 짜야한다.

나의 경우는 Elasticsearch의 Search API만 사용할 예정이다!!!

---

🛠 개발 환경

• SpringBoot 2.7.3
• Java 8
• Elasticsearch 7.9.1

📓 참고자료

[엘라스틱서치 실무 가이드]

내가 원하는 내용이 너무 잘 나와있어서 참고하였다.

아쉬운 점은 저자는 엘라스틱서치 6버전을 사용하고 있다는 점...

 

나는 이 책의 High Level Rest 클라이언트로 통신하는 법을 적용해보았다.

---

👩🏻‍💻 build.gradle

dependency 추가!

dependencies {

   implementation 'org.springframework.data:spring-data-elasticsearch:4.2.2'

}

 

👩🏻‍💻 Configuration 파일

AbstractElasticsearchConfiguration 을 상속받은 후 elasticsearchClient 를 재정의 한다. 

connectedTo의 매개변수에는 elasticsearch의 호스트네임 + 포트번호 (예. localhost:9200)를 String으로 넘겨주면 된다.

 

나는 application.yml 파일을 생성하여 host와 port를  저장하고 변수를 가져와 사용했다.

굳이 이렇게 안해도 된다....!

@EnableElasticsearchRepositories
@Configuration
public class ElasticSearchConfig extends AbstractElasticsearchConfiguration {

    @Value("${es.host}")
    private String host;

    @Override
    public RestHighLevelClient elasticsearchClient() {
        ClientConfiguration clientConfiguration = ClientConfiguration.builder()
                .connectedTo(host)
                .build();
        return RestClients.create(clientConfiguration).rest();
    }

}

 

👩🏻‍💻 검색 API 사용하기 - YoutuberServiceImpl.java

위에서 재정의를 통해 RestHighLevelClient가 Bean으로 만들어졌고, ServiceImpl에서 이를 사용해야한다.

private final RestHighLevelClient restHighLevelClient;

 

SearchSourceBuilder를 통해 검색 쿼리를 설정한다.

org.elasticsearch.index.query.QueryBuilders.matchQuery

• "channel_name" : 검색할 필드명
• keyword : 검색어

SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
searchSourceBuilder.query(matchQuery("channel_name", keyword));

 

SearchRequest로 검색 요청을 보낸다.

생성자의 파라미터에 검색할 인덱스를 넘겨준다.

SearchRequest searchRequest = new SearchRequest(index);
searchRequest.source(searchSourceBuilder);

 

SearchResponse로 응답을 받는다.

searchResponse.getHits()로 SearchHits를 얻을 수 있다. 여기에는 실제 결과뿐만아니라 부가적인 정보들도 담겨있다.

SearchHis.getHits() (아래에선 searchResponse.getHits().getHits()) 으로 검색 결과 리스트를 받을 수 있다.

필자는 이 결과를 Dto로 변환해야해서 아래와 같이 코드를 작성하였다.

try{
    SearchResponse searchResponse = restHighLevelClient.search(searchRequest, RequestOptions.DEFAULT);

    return Arrays.stream(searchResponse.getHits().getHits())
            .map(hit -> YoutuberResponseDto.toResponseDto(hit.getSourceAsMap()))
            .collect(Collectors.toList());

} catch (IOException e) {
    throw new RuntimeException(e);
}

 

< 전체코드 >

public List<YoutuberResponseDto> searchYoutuber(String keyword) {
    SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
    searchSourceBuilder.query(matchQuery("channel_name", keyword));

    SearchRequest searchRequest = new SearchRequest(index);
    searchRequest.source(searchSourceBuilder);

    try{
        SearchResponse searchResponse = restHighLevelClient.search(searchRequest, RequestOptions.DEFAULT);

        return Arrays.stream(searchResponse.getHits().getHits())
                .map(hit -> YoutuberResponseDto.toResponseDto(hit.getSourceAsMap()))
                .collect(Collectors.toList());

    } catch (IOException e) {
        throw new RuntimeException(e);
    }
}

---

이렇게 완성이 되었고 동작도 잘된다..

하나 찝찝한 점은 바로 RestHighLevelClient가 바로 Deprecated 되었다는 것이다... 하🤦🏻‍♀️

수정해야 될 듯 하다...ㅎㅎ

 

그리고 Repository를 만들어서 도큐먼트 저장이나 조회 등이 전부 가능하다던데 이 부분도 기회가 되면 사용해보고 포스팅해야겠다.