天天看點

SpringBoot2.0 整合 ElasticSearch架構,實作高性能搜尋引擎

本文源碼:GitHub·點這裡 || GitEE·點這裡

一、安裝和簡介

ElasticSearch是一個基于Lucene的搜尋伺服器。它提供了一個分布式多使用者能力的全文搜尋引擎,基于RESTful web接口。Elasticsearch是用Java開發的,并作為Apache許可條款下的開放源碼釋出,是目前流行的企業級搜尋引擎。

搭建運作環境

Linux系統:centos7下搭建ElasticSearch中間件,常用接口示範

二、與SpringBoot2整合

1、核心依賴

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-elasticsearch</artifactId>
    <version>${spring-boot.version}</version>
</dependency>
           

2、配置檔案

spring:
  application:
    name: ware-elastic-search
  data:
    elasticsearch:
      # 預設 elasticsearch
      cluster-name: elasticsearch
      # 9200作為Http協定,主要用于外部通訊
      # 9300作為Tcp協定,jar之間就是通過tcp協定通訊
      cluster-nodes: 192.168.72.130:9300
           

3、實體類配置

Document 配置

加上了@Document注解之後,預設情況下這個實體中所有的屬性都會被建立索引、并且分詞。

indexName索引名稱 了解為資料庫名 限定小寫

type 了解為資料庫的表名稱

shards = 5 預設分區數

replicas = 1 每個分區預設的備份數

refreshInterval = "1s" 重新整理間隔

indexStoreType = "fs" 索引檔案存儲類型

@Document(indexName = "requestlogindex",type = "requestlog")
public class RequestLog {
    //Id注解Elasticsearch裡相應于該列就是主鍵,查詢時可以使用主鍵查詢
    @Id
    private Long id;
    private String orderNo;
    private String userId;
    private String userName;
    private String createTime;
}
           

4、資料互動層

實作ElasticsearchRepository接口。

public interface RequestLogRepository 
extends ElasticsearchRepository<RequestLog,Long> {
}
           

5、示範案例

資料增加,修改,查詢,排序,多條件查詢。

@Service
public class RequestLogServiceImpl implements RequestLogService {
    @Resource
    private RequestLogRepository requestLogRepository ;
    @Override
    public String esInsert(Integer num) {
        for (int i = 0 ; i < num ; i++){
            RequestLog requestLog = new RequestLog() ;
            requestLog.setId(System.currentTimeMillis());
            requestLog.setOrderNo(DateUtil.formatDate(new Date(),DateUtil.DATE_FORMAT_02)+System.currentTimeMillis());
            requestLog.setUserId("userId"+i);
            requestLog.setUserName("張三"+i);
            requestLog.setCreateTime(DateUtil.formatDate(new Date(),DateUtil.DATE_FORMAT_01));
            requestLogRepository.save(requestLog) ;
        }
        return "success" ;
    }
    @Override
    public Iterable<RequestLog> esFindAll (){
        return requestLogRepository.findAll() ;
    }
    @Override
    public String esUpdateById(RequestLog requestLog) {
        requestLogRepository.save(requestLog);
        return "success" ;
    }
    @Override
    public Optional<RequestLog> esSelectById(Long id) {
        return requestLogRepository.findById(id) ;
    }
    @Override
    public Iterable<RequestLog> esFindOrder() {
        // 使用者名倒序
        // Sort sort = new Sort(Sort.Direction.DESC,"userName.keyword") ;
        // 建立時間正序
        Sort sort = new Sort(Sort.Direction.ASC,"createTime.keyword") ;
        return requestLogRepository.findAll(sort) ;
    }
    @Override
    public Iterable<RequestLog> esFindOrders() {
        List<Sort.Order> sortList = new ArrayList<>() ;
        Sort.Order sort1 = new Sort.Order(Sort.Direction.ASC,"createTime.keyword") ;
        Sort.Order sort2 = new Sort.Order(Sort.Direction.DESC,"userName.keyword") ;
        sortList.add(sort1) ;
        sortList.add(sort2) ;
        Sort orders = Sort.by(sortList) ;
        return requestLogRepository.findAll(orders) ;
    }
    @Override
    public Iterable<RequestLog> search() {
        // 全文搜尋關鍵字
        /*
        String queryString="張三";
        QueryStringQueryBuilder builder = new QueryStringQueryBuilder(queryString);
        requestLogRepository.search(builder) ;
        */
        /*
         * 多條件查詢
         */
         QueryBuilder builder = QueryBuilders.boolQuery()
                // .must(QueryBuilders.matchQuery("userName.keyword", "曆張")) 搜尋不到
               .must(QueryBuilders.matchQuery("userName", "張三")) // 可以搜尋
               .must(QueryBuilders.matchQuery("orderNo", "20190613736278243"));
        return requestLogRepository.search(builder) ;
    }
}
           

三、源代碼位址

GitHub·位址
https://github.com/cicadasmile/middle-ware-parent
GitEE·位址
https://gitee.com/cicadasmile/middle-ware-parent
           
SpringBoot2.0 整合 ElasticSearch架構,實作高性能搜尋引擎

繼續閱讀