javaspringboot如何简单快速集成Elasticsearch文件检索

前言&＃xff1a;

• ElasticSearch是一个基于Lucene的搜索服务器。它提供了一个分布式多用户能力的全文搜索引擎&＃xff0c;基于RESTful web接口。Elasticsearch是用Java开发的&＃xff0c;并作为Apache许可条款下的开放源码发布&＃xff0c;是当前流行的企业级搜索引擎。设计用于云计算中&＃xff0c;能够达到实时搜索&＃xff0c;稳定&＃xff0c;可靠&＃xff0c;快速&＃xff0c;安装使用方便。
• 我们建立一个网站或应用程序&＃xff0c;并要添加搜索功能&＃xff0c;但是想要完成搜索工作的创建是非常困难的。我们希望搜索解决方案要运行速度快&＃xff0c;我们希望能有一个零配置和一个完全免费的搜索模式&＃xff0c;我们希望能够简单地使用JSON通过HTTP来索引数据&＃xff0c;我们希望我们的搜索服务器始终可用&＃xff0c;我们希望能够从一台开始并扩展到数百台&＃xff0c;我们要实时搜索&＃xff0c;我们要简单的多租户&＃xff0c;我们希望建立一个云的解决方案。因此我们利用Elasticsearch来解决所有这些问题以及可能出现的更多其它问题。

1.准备

• 在微服务集成es之前先安装Elasticsearch 以及可视化工具Kibana&＃xff1b;注意安装的版本一定要一致&＃xff0c;不能版本不相同。

• 推荐使用docker安装&＃xff0c;如何使用docker以及docker的容器安装请移步其他帖子。
  安装移步es安装以及配置.

• 安装Kibana之后创建索引及类型:
  

• 这是相关索引指令&＃xff1a;

  GET /_cat/indices/?v #查询所有索引

  DELETE user #删除索引

  PUT /user #添加索引

  PUT /user/userinfo/_mapping #增加索引 类型的映射关系 &＃xff08;相当于数据库建表&＃xff09;
  {
  “properties”: {
  “id”:{
  “type”: “long”,
  “store”: false
  },
  “name”:{
  “type”: “text”,
  “analyzer”: “ik_smart”,
  “search_analyzer”: “ik_smart”,
  “store”: false
  },
  “city”:{
  “type”: “text”,
  “analyzer”: “ik_smart”,
  “search_analyzer”: “ik_smart”,
  “store”: false
  },
  “age”:{
  “type”: “long”,
  “store”: false
  },
  “remark”:{
  “type”: “text”,
  “analyzer”: “ik_smart”,
  “search_analyzer”: “ik_smart”,
  “store”: false
  }
  }
  }

2.引入依赖

org.springframework.bootspring-boot-starter-data-elasticsearch


3.配置文件配置

spring:application:name: testdata:elasticsearch:cluster-name: my-application #elasticsearch.yml配置的节点名cluster-nodes: 10.10.0.233:9300 #es安装的ip及端口


4.准备实体类对应es索引类型的映射

package com.bwwl.hive.model;import lombok.Data;
import org.springframework.data.annotation.Id;
import org.springframework.data.elasticsearch.annotations.Document;
import org.springframework.data.elasticsearch.annotations.Field;
import org.springframework.data.elasticsearch.annotations.FieldType;import java.io.Serializable;/***&＃64;author liuxingying*&＃64;description*&＃64;date 2020/9/29*/
&＃64;Data
&＃64;Document(indexName &＃61; "user",type &＃61; "userinfo") //对应索引库和类型
public class Userinfo implements Serializable {&＃64;Idprivate long id;&＃64;Field(type &＃61; FieldType.Text,analyzer &＃61; "ik_smart",searchAnalyzer &＃61; "ik_smart")private String name;&＃64;Field(type &＃61; FieldType.Text,analyzer &＃61; "ik_smart",searchAnalyzer &＃61; "ik_smart")private String city;&＃64;Field(type &＃61; FieldType.Long)private Integer age;&＃64;Field(type &＃61; FieldType.Text,analyzer &＃61; "ik_smart",searchAnalyzer &＃61; "ik_smart")private String remark;
}


5.准备dao

package com.bwwl.hive.dao;import com.bwwl.hive.model.Userinfo;
import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;
import org.springframework.stereotype.Repository;&＃64;Repository
//Userinfo对应实体 Long对应主键
public interface ElasticsearchDao extends ElasticsearchRepository {
}


6.将数据库数据导入到es

package com.bwwl.hive.service.impl;import com.bwwl.hive.dao.ElasticsearchDao;
import com.bwwl.hive.model.Userinfo;
import com.bwwl.hive.service.ElasticsearchService;
import com.bwwl.hive.service.GetData;
import org.elasticsearch.index.query.QueryBuilders;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.elasticsearch.core.ElasticsearchTemplate;
import org.springframework.data.elasticsearch.core.aggregation.AggregatedPage;
import org.springframework.data.elasticsearch.core.query.NativeSearchQueryBuilder;
import org.springframework.stereotype.Service;import java.util.List;/***&＃64;author liuxingying*&＃64;description*&＃64;date 2020/9/29*/
&＃64;Service
public class ElasticsearchServiceImpl implements ElasticsearchService {&＃64;Autowiredprivate GetData getData;&＃64;Autowiredprivate ElasticsearchDao dao;&＃64;Autowiredprivate ElasticsearchTemplate elasticsearchTemplate;/** &＃64;description 导入数据* &＃64;params []* &＃64;return void* &＃64;author lxy* &＃64;date 2020/9/29 11:06**/&＃64;Overridepublic void importData(){//从mysql查出所有数据 一般来说可以先查出来是一个对象javabean&＃xff0c;然后转换成索引对象Userinfo就行&＃xff0c;我这里是直接用的userinfo对象List user &＃61; getData.getAll();//导入到esdao.saveAll(user);}}


7.查询条件的构建与检索实现

package com.bwwl.hive.service.impl;import com.bwwl.hive.dao.ElasticsearchDao;
import com.bwwl.hive.model.Userinfo;
import com.bwwl.hive.service.ElasticsearchService;
import com.bwwl.hive.service.GetData;
import org.elasticsearch.index.query.QueryBuilders;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.elasticsearch.core.ElasticsearchTemplate;
import org.springframework.data.elasticsearch.core.aggregation.AggregatedPage;
import org.springframework.data.elasticsearch.core.query.NativeSearchQueryBuilder;
import org.springframework.stereotype.Service;import java.util.List;/***&＃64;author liuxingying*&＃64;description*&＃64;date 2020/9/29*/
&＃64;Service
public class ElasticsearchServiceImpl implements ElasticsearchService {&＃64;Autowiredprivate GetData getData;&＃64;Autowiredprivate ElasticsearchDao dao;&＃64;Autowiredprivate ElasticsearchTemplate elasticsearchTemplate;/** &＃64;description 导入数据* &＃64;params []* &＃64;return void* &＃64;author lxy* &＃64;date 2020/9/29 11:06**/&＃64;Overridepublic void importData(){List user &＃61; getData.getAll();dao.saveAll(user);}/** &＃64;description es搜索* &＃64;params [parm]* &＃64;return java.util.List* &＃64;author lxy* &＃64;date 2020/9/29 11:32**/&＃64;Overridepublic List search(String parm) {//TODO 构建查询对象用于封装各种查询条件 NativeSearchQueryBuilderNativeSearchQueryBuilder nativeSearchQueryBuilder &＃61; new NativeSearchQueryBuilder();nativeSearchQueryBuilder.withQuery(QueryBuilders.queryStringQuery(parm).field("name"));//执行查询esAggregatedPage page &＃61; elasticsearchTemplate.queryForPage(nativeSearchQueryBuilder.build(), Userinfo.class);//查询结果集合List list &＃61; page.getContent();//查询结果总条数long totalElements &＃61; page.getTotalElements();//查询结果总页数long totalPages &＃61; page.getTotalPages();return list;}
}


• 最后再controller层调用接口就行&＃xff0c;一个简单的es检索就搭起来了&＃xff0c;我这里只实现了简单的查询检索&＃xff0c;还有很多比如排序、分页、范围限制、高亮和聚合查询等等都没实现&＃xff0c;es在搜索的方法上有很多api实现&＃xff0c;可以去官网看看怎么使用&＃xff0c;欢迎探讨。