Springboot 集成 ElasticSearch 踩坑

這里只涉及到基礎使用

1. 導包

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-elasticsearch</artifactId>
</dependency>

2. 配置application.yml

server:
  port: 8069
spring:
  data:
    elasticsearch:
      cluster-nodes: 127.0.0.1:9300 #配置java訪問elasticsearch端口
      repositories:
        enabled: true
      cluster-name: elasticsearch #需與elasticsearch配置文件的名字一致，也可以不配置

2. 創建普通的entity

@Data
@Document(indexName = "索引名稱（只能小寫）",type = "類型名")
public class Study{
    private Integer id;
    private String name;
    private String sex;
    private Integer age; 
}

3. 創建倉庫 StudyRepository 並繼承 ElasticsearchCrudRepository<Study, Integer>

public interface StudyRepository extends ElasticsearchCrudRepository<Study, Integer> {
}

4. 創建service和實現類，以及Controller

public interface StudyService {

    Study save(Study study);

    void delete(Integer id);

    Study update(Study study);

    Study get(Integer id);

    Page<Study> getAll(String name,Pageable pageable);
}


@Service
@RequiredArgsConstructor
public class StudyServiceImpl implements StudyService {

    private final StudyRepository studyRepository;

    private final ElasticsearchTemplate elasticsearchTemplate;

    @Override
    public Study save(Study study) {
        return studyRepository.save(study);
    }

    @Override
    public void delete(Integer id) {
        studyRepository.deleteById(id);
    }

    @Override
    public Study update(Study study) {
        Optional<Study> studyOptional = studyRepository.findById(study.getId());
        studyOptional.ifPresent(s -> {
            studyRepository.save(study);
        });
        return study;
    }

    @Override
    public Study get(Integer id) {
        return studyRepository.findById(id).orElse(null);
    }
	/**
	 * 根據name查詢(使用template進行復雜查詢)
	 */
    @Override
    public Page<Study> getAll(String name, Pageable pageable) {
        NativeSearchQueryBuilder query = new NativeSearchQueryBuilder().withPageable(pageable);
        if (!StringUtils.isEmpty(name)) {
            query.withQuery(QueryBuilders.matchQuery("name", name));
        }
        NativeSearchQuery buildQuery = query.build();
        List<Study> studies = elasticsearchTemplate.queryForList(buildQuery , Study.class);
        return new PageImpl<>(studies);
    }

注意：

1. 目前ElasticSearch沒有7.2的jar包~~使用7.2會報找不到nodes，建議降低版本~

2. ElasticSearch提供的可視化工具 Kibana 的版本必須與你安裝的ElasticSearch版本一一對應，不然無法啟動~

參考：

1. https://segmentfault.com/a/1190000018625101