本文源碼：GitHub·點(diǎn)這里 || GitEE·點(diǎn)這里

成都創(chuàng)新互聯(lián)是一家專業(yè)從事成都做網(wǎng)站、網(wǎng)站設(shè)計(jì)、網(wǎng)頁設(shè)計(jì)的品牌網(wǎng)絡(luò)公司。如今是成都地區(qū)具影響力的網(wǎng)站設(shè)計(jì)公司,作為專業(yè)的成都網(wǎng)站建設(shè)公司,成都創(chuàng)新互聯(lián)依托強(qiáng)大的技術(shù)實(shí)力、以及多年的網(wǎng)站運(yùn)營經(jīng)驗(yàn),為您提供專業(yè)的成都網(wǎng)站建設(shè)、營銷型網(wǎng)站建設(shè)及網(wǎng)站設(shè)計(jì)開發(fā)服務(wù)！

一、安裝和簡介

ElasticSearch是一個(gè)基于Lucene的搜索服務(wù)器。它提供了一個(gè)分布式多用戶能力的全文搜索引擎，基于RESTful web接口。Elasticsearch是用Java開發(fā)的，并作為Apache許可條款下的開放源碼發(fā)布，是當(dāng)前流行的企業(yè)級(jí)搜索引擎。

搭建運(yùn)行環(huán)境

Linux系統(tǒng)：centos7下搭建ElasticSearch中間件，常用接口演示

二、與SpringBoot2整合

1、核心依賴

    org.springframework.boot
    spring-boot-starter-data-elasticsearch
    ${spring-boot.version}

2、配置文件

spring:
  application:
    name: ware-elastic-search
  data:
    elasticsearch:
      # 默認(rèn) elasticsearch
      cluster-name: elasticsearch
      # 9200作為Http協(xié)議，主要用于外部通訊
      # 9300作為Tcp協(xié)議，jar之間就是通過tcp協(xié)議通訊
      cluster-nodes: 192.168.72.130:9300

3、實(shí)體類配置

Document 配置
加上了@Document注解之后，默認(rèn)情況下這個(gè)實(shí)體中所有的屬性都會(huì)被建立索引、并且分詞。

br/>加上了@Document注解之后，默認(rèn)情況下這個(gè)實(shí)體中所有的屬性都會(huì)被建立索引、并且分詞。


type 理解為數(shù)據(jù)庫的表名稱

shards = 5 默認(rèn)分區(qū)數(shù)

replicas = 1 每個(gè)分區(qū)默認(rèn)的備份數(shù)

refreshInterval = "1s" 刷新間隔

indexStoreType = "fs" 索引文件存儲(chǔ)類型

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

4、數(shù)據(jù)交互層

實(shí)現(xiàn)ElasticsearchRepository接口。

public interface RequestLogRepository 
extends ElasticsearchRepository {
}

5、演示案例

數(shù)據(jù)增加，修改，查詢，排序，多條件查詢。

@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 esFindAll (){
        return requestLogRepository.findAll() ;
    }
    @Override
    public String esUpdateById(RequestLog requestLog) {
        requestLogRepository.save(requestLog);
        return "success" ;
    }
    @Override
    public Optional esSelectById(Long id) {
        return requestLogRepository.findById(id) ;
    }
    @Override
    public Iterable esFindOrder() {
        // 用戶名倒序
        // Sort sort = new Sort(Sort.Direction.DESC,"userName.keyword") ;
        // 創(chuàng)建時(shí)間正序
        Sort sort = new Sort(Sort.Direction.ASC,"createTime.keyword") ;
        return requestLogRepository.findAll(sort) ;
    }
    @Override
    public Iterable esFindOrders() {
        List 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 search() {
        // 全文搜索關(guān)鍵字
        /*
        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
碼云地址：知了一笑
https://gitee.com/cicadasmile