pom.xml

<dependency>
    <groupId>org.springframework.data</groupId>
    <artifactId>spring-data-elasticsearch</artifactId>
    <version>4.1.3</version>
</dependency>
<dependency>
    <groupId>org.elasticsearch.client</groupId>
    <artifactId>elasticsearch-rest-high-level-client</artifactId>
    <version>7.10.2</version>
</dependency>
<dependency>
    <groupId>org.elasticsearch.client</groupId>
    <artifactId>elasticsearch-rest-client</artifactId>
    <version>7.10.2</version>
</dependency>
<dependency>
    <groupId>org.elasticsearch</groupId>
    <artifactId>elasticsearch</artifactId>
    <version>7.10.2</version>
</dependency>

application.properties

spring.elasticsearch.uris=elasticsearch.ap-northeast-2.es.amazonaws.com:443
spring.elasticsearch.username=admin
spring.elasticsearch.password=admin

config class

import org.elasticsearch.client.RestHighLevelClient;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.core.convert.converter.Converter;
import org.springframework.data.convert.ReadingConverter;
import org.springframework.data.elasticsearch.client.ClientConfiguration;
import org.springframework.data.elasticsearch.client.RestClients;
import org.springframework.data.elasticsearch.config.AbstractElasticsearchConfiguration;
import org.springframework.data.elasticsearch.core.convert.ElasticsearchCustomConversions;

import java.sql.Timestamp;
import java.util.ArrayList;
import java.util.List;

@Configuration
public class ElasticSearchConfig extends AbstractElasticsearchConfiguration {

    @Value("${spring.elasticsearch.uris}")
    public String elasticSearchUris;

    @Value("${spring.elasticsearch.username}")
    public String username;

    @Value("${spring.elasticsearch.password}")
    public String password;

    @Override
    @Bean
    public RestHighLevelClient elasticsearchClient() {
        final ClientConfiguration clientConfiguration = ClientConfiguration.builder()
                .connectedTo(elasticSearchUris)
                .usingSsl()
                .withBasicAuth(username, password)
                .build();

        return RestClients.create(clientConfiguration).rest();
    }


    @Bean
    @Override
    public ElasticsearchCustomConversions elasticsearchCustomConversions() {
        List<Converter> converters = new ArrayList<>();
        converters.add(LongToTimestampConverter.INSTANCE);
        converters.add(TimestampToLongConverter.INSTANCE);
        return new ElasticsearchCustomConversions(converters);
    }


    @ReadingConverter
    enum LongToTimestampConverter implements Converter<Long, Timestamp> {
        INSTANCE;

        @Override
        public java.sql.Timestamp convert(Long longTime) {
            if (longTime != null) {
                return new Timestamp(longTime);
            }
            return null;
        }
    }

    @ReadingConverter
    enum TimestampToLongConverter implements Converter<Timestamp, Long> {
        INSTANCE;

        @Override
        public Long convert(Timestamp source) {
            return source.getTime();
        }
    }


}

Model

spring data에서 역직렬화할 때 기본 생성자가 필요하다.

base

import lombok.Builder;
import lombok.Getter;
import lombok.NoArgsConstructor;
import lombok.NonNull;
import lombok.experimental.SuperBuilder;

import java.sql.Timestamp;

@Getter
@NoArgsConstructor
@SuperBuilder(toBuilder = true)
public abstract class BaseMessage {
    @NonNull
    private String sessionId;
    @NonNull
    private TopicType topicType;

    @Builder.Default
    private Timestamp time = new Timestamp(System.currentTimeMillis());

}

main

import com.fasterxml.jackson.annotation.JsonSetter;
import com.fm.webinar.domain.message.base.BaseMessage;
import com.fm.webinar.util.ByteUtil;
import lombok.*;
import lombok.experimental.SuperBuilder;
import lombok.extern.jackson.Jacksonized;

import java.io.Serializable;
import java.sql.Timestamp;
import java.util.List;

@Getter
@Jacksonized
@NoArgsConstructor
@SuperBuilder(toBuilder = true)
public class VoteTemplateMessage extends BaseMessage implements Serializable {

    private static final long serialVersionUID = -997358307524748792L;

    @Builder.Default
    private String id = ByteUtil.newId();

    private String subject;

    private boolean isRealtime;

    @JsonSetter
    private int seconds;

    private Timestamp endTime;

    @NonNull
    @Singular
    private List<VoteQuestionTemplate> questions;

}

sample code

import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.elasticsearch.index.query.QueryBuilder;
import org.elasticsearch.index.query.QueryBuilders;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.data.elasticsearch.core.ElasticsearchOperations;
import org.springframework.data.elasticsearch.core.SearchHits;
import org.springframework.data.elasticsearch.core.mapping.IndexCoordinates;
import org.springframework.data.elasticsearch.core.query.IndexQuery;
import org.springframework.data.elasticsearch.core.query.IndexQueryBuilder;
import org.springframework.data.elasticsearch.core.query.NativeSearchQueryBuilder;
import org.springframework.data.elasticsearch.core.query.Query;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Service;

import java.sql.Timestamp;
import java.util.ArrayList;
import java.util.List;


@Slf4j
@RequiredArgsConstructor
@Service
public class VoteService {

    private final ElasticsearchOperations elasticsearchOperations;

    private final String INDEX_PREFIX = "vote_";

    private String saveTemplate(VoteTemplateMessage message) {
        IndexQuery indexQuery = new IndexQueryBuilder()
                .withId(message.getId())
                .withObject(message)
                .build();
        return elasticsearchOperations
                .index(indexQuery, IndexCoordinates.of(INDEX_PREFIX + message.getSessionId().toLowerCase()));
    }

    public List<VoteTemplateMessage> findVoteTemplateById(String sessionId, String id) {
        QueryBuilder queryBuilder = QueryBuilders.matchQuery("_id", id);

        Query searchQuery = new NativeSearchQueryBuilder()
                .withQuery(queryBuilder)
                .build();

        SearchHits<VoteTemplateMessage> voteTemplateMessageSearchHits = elasticsearchOperations
                .search(searchQuery, VoteTemplateMessage.class, IndexCoordinates.of(INDEX_PREFIX + sessionId.toLowerCase()));

        List<VoteTemplateMessage> voteTemplateMessageList = new ArrayList<>();
        voteTemplateMessageSearchHits.getSearchHits().forEach(searchHit -> {
            voteTemplateMessageList.add(searchHit.getContent());
        });
        return voteTemplateMessageList;
    }


}

spring data elasticsearch restTemplate 설정