SpringBoot如何实现第73集的Elasticsearch深度整合教程？
- 内容介绍
- 文章标签
- 相关推荐
本文共计4639个文字，预计阅读时间需要19分钟。
Elasticsearch是一款分布式、高扩展、高实时的搜索引擎与数据分析引擎。它轻松处理海量数据，具备强大的搜索、分析和探索能力。利用Elasticsearch的水平伸缩特性，数据可在生产环境中灵活变动。
v基础概念Elasticsearch 是一个分布式、高扩展、高实时的搜索与数据分析引擎。它能很方便的使大量数据具有搜索、分析和探索的能力。充分利用Elasticsearch的水平伸缩性，能使数据在生产环境变得更有价值。Elasticsearch 的实现原理主要分为以下几个步骤，首先用户将数据提交到Elasticsearch 数据库中，再通过分词控制器去将对应的语句分词，将其权重和分词结果一并存入数据，当用户搜索数据时候，再根据权重将结果排名，打分，再将返回结果呈现给用户。
在上一篇文章linux安装elasticsearch中，已经介绍了在linux安装elasticsearch，这篇文章主要介绍介绍es的一些基础的入门教程、docker安装elasticsearch以及在springboot中整合elasticsearch。
1.0 Node与Cluster
Node:单个Elastic实例称为一个节点（node）
Cluster:一组节点构成一个集群（cluster）
当然，这也正是集群和节点最通俗的解释，这个解释适用于绝大部分，类似elasticsearch这种分布式架构。如之前讲过的《详解Redis Cluster集群》。你可以可以说node就是单个redis实例，这样的实例我们称为一个节点，多个这样的节点组成的集群。正因为如此，我们在设计架构的时候，需要考虑不同环境的不同节点的节点名注意不要重复，避免配置集群遇到尴尬。
1.1 Index
由一个和多个分片组成，通过索引的名字在集群内进行唯一标识。索引是具有某种相似特征的文档的集合，Elastic数据管理的顶层设计就叫做 Index（索引）。类似mysql中的database。
索引也分为名次索引和动词索引。
- 索引（名词）：如前所述，一个 索引 类似于传统关系数据库中的一个 数据库 ，是一个存储关系型文档的地方。 索引 (index) 的复数词为 indices 或 indexes 。
- 索引（动词）：索引一个文档 就是存储一个文档到一个 索引 （名词）中以便被检索和查询。这非常类似于 SQL 语句中的 INSERT 关键词，除了文档已存在时，新文档会替换旧文档情况之外。
这个也好理解，类似词组"表演"，看她的表演，表演的很精彩。这是两个意思。
1.2 Document
Elasticsearch是面向文档的，意味着它存储整个对象或文档。文档是可以被索引的基本信息单元，文档用JSON表示。
例如：存储员工信息，那就是一个员工信息代表一个文档，多个文档组成一个index。类似于关系型数据库中的一条数据通过id在Type内进行唯一标识。
1.3 Type
类别，指索引内部的逻辑分区，通过type的名字在索引内进行唯一标识。在查询时如果没有该值，则表示在整个索引中查询。
例如：在员工表里，可以按照员工籍贯分组(北上、上海、广州)，也可以按照员工工种分组（职能、产品、运营）。这种分组可以理解为type。
在7.x版会移除Type。Elasticsearch为何要在7.X版本中去除type
1.4 与关系型数据库对比
1.5 Mapping
定义文档及其包含的字段是如何存储和索引的过程，类似于数据库中的表结构定义，主要作用如下：
- 定义index下的字段名
- 定义字段类型，比如数值型、浮点型、布尔型等
- 定义倒排索引相关的设置，比如是否索引、记录position等
在上一篇文章中，已经详细介绍了linux安装elasticsearch，这篇文章讲解的elasticsearch主要围绕docker展开。
2.0 拉取镜像
docker pull docker.io/elasticsearch:版本号
版本号是可选的，默认使用latest
2.1 创建&运行容器
docker run -d --name=es7 \ -p 9200:9200 -p 9300:9300 \ -e "discovery.type=single-node" elasticsearch:7.5.1
注意：若创建es持久化目录，则按下面的命令执行。
mkdir -p /data/elasticsearch docker cp es7:/usr/share/elasticsearch/data /data/elasticsearch/ docker cp es7:/usr/share/elasticsearch/logs /data/elasticsearch/ docker rm -f es7 docker run -d --name=es7 \ --restart=always \ -p 9200:9200 -p 9300:9300 \ -e "discovery.type=single-node" \ -v /data/elasticsearch/data:/usr/share/elasticsearch/data \ -v /data/elasticsearch/logs:/usr/share/elasticsearch/logs \ elasticsearch:7.5.1
注意：若es起不来，可能是容器没有宿主机挂载的目录的读写权限，那就需要赋予它读写权限： chmod 777 /data/elasticsearch
2.2 验证效果
输入ip + 端口号(9200)验证。
2.3 安装elasticsearch-head
docker pull mobz/elasticsearch-head:5
2.4 创建&运行head容器
docker run -d --name elasticsearch-head -p 9100:9100 mobz/elasticsearch-head:5
2.5 跨域问题
url访问toutou.com:9100之后发现无法连接toutou.com:9200，需要在es服务端做CORS的配置。
修改docker中es7的elasticsearch.yml文件
[root@localhost data]# docker exec -it es7 /bin/bash [root@f1358d18c9be elasticsearch]# vi config/elasticsearch.yml
在elasticsearch.yml底部追加如下配置：
github.com/medcl/elasticsearch-analysis-ik/releases/download/v7.5.1/elasticsearch-analysis-ik-7.5.1.zip -> Downloading github.com/medcl/elasticsearch-analysis-ik/releases/download/v7.5.1/elasticsearch-analysis-ik-7.5.1.zip
进入plugins可以看到IK分词器已经安装成功，重启docker实例即可。
vRESTful API任何语言都可以使用RESTful API通过9200端口(默认端口号)和Elasticsearch进行通信，也可以用web客户端(浏览器Sense插件、postman)访问 Elasticsearch ，甚至直接使用curl命令就可以和Elasticsearch交互。
Elasticsearch为很多语言（Groovy、JavaScript、.NET、 PHP、 Perl、 Python 和 Ruby）提供了官方客户端。详情：Elasticsearch Clients。
3.0 Elasticsearch请求格式：
Elasticsearch请求和我们认识的其它HTTP请求一样，由多个部件组成，具体格式如下：
curl -X<VERB> '<PROTOCOL>://<HOST>:<PORT>/<PATH>?<QUERY_STRING>' -d '<BODY>'
被 < > 标记的部件释义：
- VERB：HTTP请求方法: GET、POST、PUT、DELETE、HEAD...
GET:标识该操作是用于获取服务端的资源，可以理解为select操作 POST:用于向服务端新增数据，常用于提交表单。可以理解为insert操作 PUT:用于向服务端更新数据，与post的使用很相似。可以理解为update操作 DELETE:标识该操作是：用于删除服务端的资源，可以理解为delete操作 HEAD:只请求页面首部，响应报文中没有实体的主体部分(没有body体) 点击查看几种test.com:9200/_count?pretty
当然，也可以考虑使用其他工具，例如postman。
3.2 集群健康
Elasticsearch的集群监控信息中包含了许多的统计数据，其中最为重要的一项就是集群健康 ， 它在 status 字段中展示为green、yellow或者red。
curl test.com:9200/_cluster/healthpostman请求返回结果如下：
{ "cluster_name": "my-application", "status": "green", "timed_out": false, "number_of_nodes": 1,//集群节点数 "number_of_data_nodes": 1,//数据节点数量 "active_primary_shards": 0,//主分片数量 "active_shards": 0,//可用的分片数量 "relocating_shards": 0,//正在重新分配的分片数量，在新加或者减少节点的时候会发生 "initializing_shards": 0,//正在初始化的分片数量，新建索引或者刚启动会存在，时间很短 "unassigned_shards": 0,//没有分配的分片，一般就是那些名存实不存的副本分片 "delayed_unassigned_shards": 0, "number_of_pending_tasks": 0, "number_of_in_flight_fetch": 0, "task_max_waiting_in_queue_millis": 0, "active_shards_percent_as_number": 100 }
3.3 status三种状态值：
- green:所有的主分片和副本分片都正常运行。
- yellow:所有的主分片都正常运行，但不是所有的副本分片都正常运行。
- red:有主分片没能正常运行。
更多参数介绍：
索引级别集群状态，可以细致查看到底是哪个索引引起集群的故障的
curl test.com:9200/_cluster/health?level=indices分片级别集群状态，可以细致查看到底是哪个分片引起的集群故障
curl test.com:9200/_cluster/health?level=shards阻塞查看集群状态，适用于自动化脚本。当状态变为指定状态或者更好就返回继续执行。
v操作Elasticsearch 4.1 索引操作curl test.com:9200/_cluster/health?wait_for_status=yellow4.1.1 查看索引是否存在
curl -i -XHEAD 'toutou.com:9200/city'若索引存在：
HTTP/1.1 200 OK content-type: application/json; charset=UTF-8 content-length: 239
若索引不存在：
HTTP/1.1 404 Not Found content-type: application/json; charset=UTF-8 content-length: 395
4.1.2 创建Index
创建一个非结构化的索引，需要使用PUT请求。例如创建一个名为city的索引。
curl -X PUT '127.0.0.1:9200/city'返回结果：
{ "acknowledged":true," shards_acknowledged":true, "index":"city" }
acknowledged=true表示操作成功。
创建一个结构化的索引：
{ "settings":{ "number_of_shards":3, "number_of_replicas":1 }, "mappings":{ "properties":{ "name":{ "type":"text", "analyzer":"ik_max_word", "search_analyzer":"ik_max_word" }, "level":{ "type":"integer" }, "address":{ "type":"text", "analyzer":"ik_smart", "search_analyzer":"ik_smart" }, "createTime":{ "type":"date", "format":"yyyy-MM-dd HH:mm:ss || yyyy-MM-dd || epoch_millis" } } } } View Code
number_of_shards表示分片个数，number_of_replicas表示备份个数。
注意：在上文中已经介绍了，在在7.x版会移除Type。所以这里不需要再指定type, 相反若指定type了的话会报错。
Root mapping definition has unsupported parameters建议使用elasticsearch最新版本，若安装的是低于elasticsearch7版本的elasticsearch,可以使用下面的方式创建索引。
{ "settings":{ "number_of_shards":3, "number_of_replicas":1 }, "mappings":{ "hotel":{ "properties":{ "level":{ "type":"integer" }, "address":{ "type":"text", "analyzer":"ik_max_word" }, "createTime":{ "type":"date", "format":"yyyy-MM-dd HH:mm:ss || yyyy-MM-dd || epoch_millis" } } }, "restaurant":{ "properties":{ "type":{ "type":"text", "analyzer":"ik_smart" }, "price":{ "type":"integer" } } } } } View Code
4.1.3 删除Index
$ curl -X DELETE '127.0.0.1:9200/city'返回结果：
4.2 插入数据{"acknowledged":true}4.2.1 插入指定id的数据
在 es 中，插入数据分为指定文档id插入和自动产生文档id插入
指定文档id插入，其中我们指定数据ID为1。
生成id=1的数据。
注意，在在7.x版会移除Type，所以插入数据的url需要加上
_doc,即：toutou.com:9200/city/_doc/1。具体规则可以看看这里自动产生文档id插入。
4.3 修改数据 4.4 查询数据4.4.1 ID查询GET
4.4.2 条件查询POST
查询5星级酒店。
4.5 删除数据
vSpringBoot整合Elasticsearchcurl -X DELETE 'toutou.com:9200/city/_doc/2'spring-boot-starter-data-elasticsearch调试了很久，尝试的很多方法，始终报错：
NoNodeAvailableException[None of the configured nodes are available: [{#transport#-1}{wlOJEdIeQqKrmiBiUuJVzQ}{toutou.com}{192.168.118.137:9300}]]。看了一些相关介绍和博客，Spring Data Elasticsearch和Elasticsearch还有Spring Boot的版本需要全部一一对应上，才能使用。感觉太麻烦，新项目还好说，线上项目谁有功夫去跟你协调这些版本统一啊，费老劲了。果断弃用了。如果有大佬这块有好上手的兼容办法，还请多多指点。5.1 添加pom引用
<dependency> <groupId>org.elasticsearch.client</groupId> <artifactId>elasticsearch-rest-high-level-client</artifactId> <!--<version>7.5.1</version>--> </dependency>
注意：如果是springboot程序的话，
org.elasticsearch.client引用的版本号7.5.1最好注释掉，不然会报下面这个错：org.springframework.beans.factory.UnsatisfiedDependencyException: Error creating bean with name 'indexController': Unsatisfied dependency expressed through field 'cityEsService'; nested exception is org.springframework.beans.factory.UnsatisfiedDependencyException: Error creating bean with name 'cityEsServiceImpl': Unsatisfied dependency expressed through field 'client'; nested exception is org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'client' defined in class path resource [learn/service/impl/EsConfig.class]: Post-processing of merged bean definition failed; nested exception is java.lang.IllegalStateException: Failed to introspect Class [org.elasticsearch.client.RestHighLevelClient] from ClassLoader [sun.misc.Launcher$AppClassLoader@18b4aac2] at org.springframework.beans.factory.annotation.AutowiredAnnotationBeanPostProcessor$AutowiredFieldElement.inject(AutowiredAnnotationBeanPostProcessor.java:596) at org.springframework.beans.factory.annotation.InjectionMetadata.inject(InjectionMetadata.java:90) at org.springframework.beans.factory.annotation.AutowiredAnnotationBeanPostProcessor.postProcessProperties(AutowiredAnnotationBeanPostProcessor.java:374) at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.populateBean(AbstractAutowireCapableBeanFactory.java:1411) at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.doCreateBean(AbstractAutowireCapableBeanFactory.java:592) at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBean(AbstractAutowireCapableBeanFactory.java:515) at org.springframework.beans.factory.support.AbstractBeanFactory.lambda$doGetBean$0(AbstractBeanFactory.java:320) at org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.getSingleton(DefaultSingletonBeanRegistry.java:222) at org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:318) at org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:199) at org.springframework.beans.factory.support.DefaultListableBeanFactory.preInstantiateSingletons(DefaultListableBeanFactory.java:845) at org.springframework.context.support.AbstractApplicationContext.finishBeanFactoryInitialization(AbstractApplicationContext.java:877) at org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:549) at org.springframework.boot.web.servlet.context.ServletWebServerApplicationContext.refresh(ServletWebServerApplicationContext.java:140) at org.springframework.boot.SpringApplication.refresh(SpringApplication.java:742) at org.springframework.boot.SpringApplication.refreshContext(SpringApplication.java:389) at org.springframework.boot.SpringApplication.run(SpringApplication.java:311) at org.springframework.boot.SpringApplication.run(SpringApplication.java:1213) at org.springframework.boot.SpringApplication.run(SpringApplication.java:1202) at learn.web.Application.main(Application.java:18) Caused by: org.springframework.beans.factory.UnsatisfiedDependencyException: Error creating bean with name 'cityEsServiceImpl': Unsatisfied dependency expressed through field 'client'; nested exception is org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'client' defined in class path resource [learn/service/impl/EsConfig.class]: Post-processing of merged bean definition failed; nested exception is java.lang.IllegalStateException: Failed to introspect Class [org.elasticsearch.client.RestHighLevelClient] from ClassLoader [sun.misc.Launcher$AppClassLoader@18b4aac2] at org.springframework.beans.factory.annotation.AutowiredAnnotationBeanPostProcessor$AutowiredFieldElement.inject(AutowiredAnnotationBeanPostProcessor.java:596) at org.springframework.beans.factory.annotation.InjectionMetadata.inject(InjectionMetadata.java:90) at org.springframework.beans.factory.annotation.AutowiredAnnotationBeanPostProcessor.postProcessProperties(AutowiredAnnotationBeanPostProcessor.java:374) at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.populateBean(AbstractAutowireCapableBeanFactory.java:1411) at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.doCreateBean(AbstractAutowireCapableBeanFactory.java:592) at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBean(AbstractAutowireCapableBeanFactory.java:515) at org.springframework.beans.factory.support.AbstractBeanFactory.lambda$doGetBean$0(AbstractBeanFactory.java:320) at org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.getSingleton(DefaultSingletonBeanRegistry.java:222) at org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:318) at org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:199) at org.springframework.beans.factory.config.DependencyDescriptor.resolveCandidate(DependencyDescriptor.java:277) at org.springframework.beans.factory.support.DefaultListableBeanFactory.doResolveDependency(DefaultListableBeanFactory.java:1251) at org.springframework.beans.factory.support.DefaultListableBeanFactory.resolveDependency(DefaultListableBeanFactory.java:1171) at org.springframework.beans.factory.annotation.AutowiredAnnotationBeanPostProcessor$AutowiredFieldElement.inject(AutowiredAnnotationBeanPostProcessor.java:593) ... 19 common frames omitted Caused by: org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'client' defined in class path resource [learn/service/impl/EsConfig.class]: Post-processing of merged bean definition failed; nested exception is java.lang.IllegalStateException: Failed to introspect Class [org.elasticsearch.client.RestHighLevelClient] from ClassLoader [sun.misc.Launcher$AppClassLoader@18b4aac2] at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.doCreateBean(AbstractAutowireCapableBeanFactory.java:570) at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBean(AbstractAutowireCapableBeanFactory.java:515) at org.springframework.beans.factory.support.AbstractBeanFactory.lambda$doGetBean$0(AbstractBeanFactory.java:320) at org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.getSingleton(DefaultSingletonBeanRegistry.java:222) at org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:318) at org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:199) at org.springframework.beans.factory.config.DependencyDescriptor.resolveCandidate(DependencyDescriptor.java:277) at org.springframework.beans.factory.support.DefaultListableBeanFactory.doResolveDependency(DefaultListableBeanFactory.java:1251) at org.springframework.beans.factory.support.DefaultListableBeanFactory.resolveDependency(DefaultListableBeanFactory.java:1171) at org.springframework.beans.factory.annotation.AutowiredAnnotationBeanPostProcessor$AutowiredFieldElement.inject(AutowiredAnnotationBeanPostProcessor.java:593) ... 32 common frames omitted Caused by: java.lang.IllegalStateException: Failed to introspect Class [org.elasticsearch.client.RestHighLevelClient] from ClassLoader [sun.misc.Launcher$AppClassLoader@18b4aac2] at org.springframework.util.ReflectionUtils.getDeclaredMethods(ReflectionUtils.java:507) at org.springframework.util.ReflectionUtils.doWithLocalMethods(ReflectionUtils.java:367) at org.springframework.beans.factory.annotation.InitDestroyAnnotationBeanPostProcessor.buildLifecycleMetadata(InitDestroyAnnotationBeanPostProcessor.java:207) at org.springframework.beans.factory.annotation.InitDestroyAnnotationBeanPostProcessor.findLifecycleMetadata(InitDestroyAnnotationBeanPostProcessor.java:189) at org.springframework.beans.factory.annotation.InitDestroyAnnotationBeanPostProcessor.postProcessMergedBeanDefinition(InitDestroyAnnotationBeanPostProcessor.java:128) at org.springframework.context.annotation.CommonAnnotationBeanPostProcessor.postProcessMergedBeanDefinition(CommonAnnotationBeanPostProcessor.java:297) at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.applyMergedBeanDefinitionPostProcessors(AbstractAutowireCapableBeanFactory.java:1077) at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.doCreateBean(AbstractAutowireCapableBeanFactory.java:567) ... 41 common frames omitted Caused by: java.lang.NoClassDefFoundError: org/elasticsearch/client/Cancellable at java.lang.Class.getDeclaredMethods0(Native Method) at java.lang.Class.privateGetDeclaredMethods(Class.java:2701) at java.lang.Class.getDeclaredMethods(Class.java:1975) at org.springframework.util.ReflectionUtils.getDeclaredMethods(ReflectionUtils.java:489) ... 48 common frames omitted Caused by: java.lang.ClassNotFoundException: org.elasticsearch.client.Cancellable at java.net.URLClassLoader.findClass(URLClassLoader.java:381) at java.lang.ClassLoader.loadClass(ClassLoader.java:424) at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:335) at java.lang.ClassLoader.loadClass(ClassLoader.java:357) ... 52 common frames omitted View Code
因为就像上文提到的data与es version冲突似的，
org.elasticsearch.client也有版本之间的兼容性问题，把org.elasticsearch.client的版本号去掉由SpringBoot来管理依赖的版本即可。5.2 添加EsConfig
import com.google.gson.Gson; import org.apache.www.cnblogs.com/toutou */ @Slf4j @RestController public class IndexController { @Autowired private CityEsService cityEsService; @GetMapping("es/search") public Result esSearch(@RequestParam("id") String id) { return Result.setSuccessResult(cityEsService.getCityById(id)); } }
5.3.3 效果验证
由于service层和Controller大部分代码都是重复的，下面就只贴service层代码实现了，感兴趣的可以在文章底部的源码中查看更多细节。
5.4 根据id删除城市酒店信息
5.4.1 删除方法实现代码
@Override public String delCityById(String id){ try { DeleteRequest request=new DeleteRequest("city","_doc",id); DeleteResponse response= client.delete(request,RequestOptions.DEFAULT); return response.status().name(); } catch (IOException e) { throw new RuntimeException("删除失败."); } }
5.4.2 效果验证
5.5 添加数据
@Override public String addCityByInfo(String id, String name, Integer level, String address, String createTime){ Map<String, Object> jsonMap = new HashMap<>(); jsonMap.put("name", name); jsonMap.put("level", level); jsonMap.put("address", address); jsonMap.put("createTime", createTime); // 若不需要创建指定id的数据，则不需要再IndexRequest的构造函数中传入id // IndexRequest indexRequest = new IndexRequest("city", "_doc"); IndexRequest indexRequest = new IndexRequest("city", "_doc", id); indexRequest.source(jsonMap); try { IndexResponse rp = client.index(indexRequest); return rp.status().name(); } catch (IOException e) { throw new RuntimeException("添加失败."); } }
5.6 修改数据
@Override public String updateCityByInfo(String id, String name){ UpdateRequest request=new UpdateRequest("city","_doc", id); Map<String, Object> jsonMap = new HashMap<>(); jsonMap.put("name", name); request.doc(jsonMap); try { return client.update(request,RequestOptions.DEFAULT).status().name(); } catch (IOException e) { throw new RuntimeException("修改失败."); } }
5.7 复合查询
public List<Map<String, Object>> query(String name, Integer level, Integer index, Integer size){ SearchRequest request = new SearchRequest("city"); BoolQueryBuilder boolQueryBuilder = QueryBuilders.boolQuery(); boolQueryBuilder.must(QueryBuilders.matchQuery("name", name)); boolQueryBuilder.must(QueryBuilders.matchQuery("level", level)); SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder(); //排序 searchSourceBuilder.sort(SortBuilders.fieldSort("createTime").order(SortOrder.DESC)); //分页 searchSourceBuilder.from(index).size(size).query(boolQueryBuilder); request.searchType(SearchType.DEFAULT).source(searchSourceBuilder); List<Map<String, Object>> list = new ArrayList<>(); try { SearchResponse rp = client.search(request, RequestOptions.DEFAULT); for (SearchHit item : rp.getHits().getHits()) { list.add(item.getSourceAsMap()); } } catch (IOException e) { throw new RuntimeException("查询失败."); } return list; }
其他参考资料：
- Elasticsearch: 权威指南
- elasticsearch - Docker Hub
- Java High Level REST Client
github.com/toutouge/javademosecond/tree/master/hellospringboot
作 者：请叫我头头哥
出 处：www.cnblogs.com/toutou/
关于
本文共计4639个文字，预计阅读时间需要19分钟。
Elasticsearch是一款分布式、高扩展、高实时的搜索引擎与数据分析引擎。它轻松处理海量数据，具备强大的搜索、分析和探索能力。利用Elasticsearch的水平伸缩特性，数据可在生产环境中灵活变动。
v基础概念Elasticsearch 是一个分布式、高扩展、高实时的搜索与数据分析引擎。它能很方便的使大量数据具有搜索、分析和探索的能力。充分利用Elasticsearch的水平伸缩性，能使数据在生产环境变得更有价值。Elasticsearch 的实现原理主要分为以下几个步骤，首先用户将数据提交到Elasticsearch 数据库中，再通过分词控制器去将对应的语句分词，将其权重和分词结果一并存入数据，当用户搜索数据时候，再根据权重将结果排名，打分，再将返回结果呈现给用户。
在上一篇文章linux安装elasticsearch中，已经介绍了在linux安装elasticsearch，这篇文章主要介绍介绍es的一些基础的入门教程、docker安装elasticsearch以及在springboot中整合elasticsearch。
1.0 Node与Cluster
Node:单个Elastic实例称为一个节点（node）
Cluster:一组节点构成一个集群（cluster）
当然，这也正是集群和节点最通俗的解释，这个解释适用于绝大部分，类似elasticsearch这种分布式架构。如之前讲过的《详解Redis Cluster集群》。你可以可以说node就是单个redis实例，这样的实例我们称为一个节点，多个这样的节点组成的集群。正因为如此，我们在设计架构的时候，需要考虑不同环境的不同节点的节点名注意不要重复，避免配置集群遇到尴尬。
1.1 Index
由一个和多个分片组成，通过索引的名字在集群内进行唯一标识。索引是具有某种相似特征的文档的集合，Elastic数据管理的顶层设计就叫做 Index（索引）。类似mysql中的database。
索引也分为名次索引和动词索引。
- 索引（名词）：如前所述，一个 索引 类似于传统关系数据库中的一个 数据库 ，是一个存储关系型文档的地方。 索引 (index) 的复数词为 indices 或 indexes 。
- 索引（动词）：索引一个文档 就是存储一个文档到一个 索引 （名词）中以便被检索和查询。这非常类似于 SQL 语句中的 INSERT 关键词，除了文档已存在时，新文档会替换旧文档情况之外。
这个也好理解，类似词组"表演"，看她的表演，表演的很精彩。这是两个意思。
1.2 Document
Elasticsearch是面向文档的，意味着它存储整个对象或文档。文档是可以被索引的基本信息单元，文档用JSON表示。
例如：存储员工信息，那就是一个员工信息代表一个文档，多个文档组成一个index。类似于关系型数据库中的一条数据通过id在Type内进行唯一标识。
1.3 Type
类别，指索引内部的逻辑分区，通过type的名字在索引内进行唯一标识。在查询时如果没有该值，则表示在整个索引中查询。
例如：在员工表里，可以按照员工籍贯分组(北上、上海、广州)，也可以按照员工工种分组（职能、产品、运营）。这种分组可以理解为type。
在7.x版会移除Type。Elasticsearch为何要在7.X版本中去除type
1.4 与关系型数据库对比
1.5 Mapping
定义文档及其包含的字段是如何存储和索引的过程，类似于数据库中的表结构定义，主要作用如下：
- 定义index下的字段名
- 定义字段类型，比如数值型、浮点型、布尔型等
- 定义倒排索引相关的设置，比如是否索引、记录position等
在上一篇文章中，已经详细介绍了linux安装elasticsearch，这篇文章讲解的elasticsearch主要围绕docker展开。
2.0 拉取镜像
docker pull docker.io/elasticsearch:版本号
版本号是可选的，默认使用latest
2.1 创建&运行容器
docker run -d --name=es7 \ -p 9200:9200 -p 9300:9300 \ -e "discovery.type=single-node" elasticsearch:7.5.1
注意：若创建es持久化目录，则按下面的命令执行。
mkdir -p /data/elasticsearch docker cp es7:/usr/share/elasticsearch/data /data/elasticsearch/ docker cp es7:/usr/share/elasticsearch/logs /data/elasticsearch/ docker rm -f es7 docker run -d --name=es7 \ --restart=always \ -p 9200:9200 -p 9300:9300 \ -e "discovery.type=single-node" \ -v /data/elasticsearch/data:/usr/share/elasticsearch/data \ -v /data/elasticsearch/logs:/usr/share/elasticsearch/logs \ elasticsearch:7.5.1
注意：若es起不来，可能是容器没有宿主机挂载的目录的读写权限，那就需要赋予它读写权限： chmod 777 /data/elasticsearch
2.2 验证效果
输入ip + 端口号(9200)验证。
2.3 安装elasticsearch-head
docker pull mobz/elasticsearch-head:5
2.4 创建&运行head容器
docker run -d --name elasticsearch-head -p 9100:9100 mobz/elasticsearch-head:5
2.5 跨域问题
url访问toutou.com:9100之后发现无法连接toutou.com:9200，需要在es服务端做CORS的配置。
修改docker中es7的elasticsearch.yml文件
[root@localhost data]# docker exec -it es7 /bin/bash [root@f1358d18c9be elasticsearch]# vi config/elasticsearch.yml
在elasticsearch.yml底部追加如下配置：
github.com/medcl/elasticsearch-analysis-ik/releases/download/v7.5.1/elasticsearch-analysis-ik-7.5.1.zip -> Downloading github.com/medcl/elasticsearch-analysis-ik/releases/download/v7.5.1/elasticsearch-analysis-ik-7.5.1.zip
进入plugins可以看到IK分词器已经安装成功，重启docker实例即可。
vRESTful API任何语言都可以使用RESTful API通过9200端口(默认端口号)和Elasticsearch进行通信，也可以用web客户端(浏览器Sense插件、postman)访问 Elasticsearch ，甚至直接使用curl命令就可以和Elasticsearch交互。
Elasticsearch为很多语言（Groovy、JavaScript、.NET、 PHP、 Perl、 Python 和 Ruby）提供了官方客户端。详情：Elasticsearch Clients。
3.0 Elasticsearch请求格式：
Elasticsearch请求和我们认识的其它HTTP请求一样，由多个部件组成，具体格式如下：
curl -X<VERB> '<PROTOCOL>://<HOST>:<PORT>/<PATH>?<QUERY_STRING>' -d '<BODY>'
被 < > 标记的部件释义：
- VERB：HTTP请求方法: GET、POST、PUT、DELETE、HEAD...
GET:标识该操作是用于获取服务端的资源，可以理解为select操作 POST:用于向服务端新增数据，常用于提交表单。可以理解为insert操作 PUT:用于向服务端更新数据，与post的使用很相似。可以理解为update操作 DELETE:标识该操作是：用于删除服务端的资源，可以理解为delete操作 HEAD:只请求页面首部，响应报文中没有实体的主体部分(没有body体) 点击查看几种test.com:9200/_count?pretty
当然，也可以考虑使用其他工具，例如postman。
3.2 集群健康
Elasticsearch的集群监控信息中包含了许多的统计数据，其中最为重要的一项就是集群健康 ， 它在 status 字段中展示为green、yellow或者red。
curl test.com:9200/_cluster/healthpostman请求返回结果如下：
{ "cluster_name": "my-application", "status": "green", "timed_out": false, "number_of_nodes": 1,//集群节点数 "number_of_data_nodes": 1,//数据节点数量 "active_primary_shards": 0,//主分片数量 "active_shards": 0,//可用的分片数量 "relocating_shards": 0,//正在重新分配的分片数量，在新加或者减少节点的时候会发生 "initializing_shards": 0,//正在初始化的分片数量，新建索引或者刚启动会存在，时间很短 "unassigned_shards": 0,//没有分配的分片，一般就是那些名存实不存的副本分片 "delayed_unassigned_shards": 0, "number_of_pending_tasks": 0, "number_of_in_flight_fetch": 0, "task_max_waiting_in_queue_millis": 0, "active_shards_percent_as_number": 100 }
3.3 status三种状态值：
- green:所有的主分片和副本分片都正常运行。
- yellow:所有的主分片都正常运行，但不是所有的副本分片都正常运行。
- red:有主分片没能正常运行。
更多参数介绍：
索引级别集群状态，可以细致查看到底是哪个索引引起集群的故障的
curl test.com:9200/_cluster/health?level=indices分片级别集群状态，可以细致查看到底是哪个分片引起的集群故障
curl test.com:9200/_cluster/health?level=shards阻塞查看集群状态，适用于自动化脚本。当状态变为指定状态或者更好就返回继续执行。
v操作Elasticsearch 4.1 索引操作curl test.com:9200/_cluster/health?wait_for_status=yellow4.1.1 查看索引是否存在
curl -i -XHEAD 'toutou.com:9200/city'若索引存在：
HTTP/1.1 200 OK content-type: application/json; charset=UTF-8 content-length: 239
若索引不存在：
HTTP/1.1 404 Not Found content-type: application/json; charset=UTF-8 content-length: 395
4.1.2 创建Index
创建一个非结构化的索引，需要使用PUT请求。例如创建一个名为city的索引。
curl -X PUT '127.0.0.1:9200/city'返回结果：
{ "acknowledged":true," shards_acknowledged":true, "index":"city" }
acknowledged=true表示操作成功。
创建一个结构化的索引：
{ "settings":{ "number_of_shards":3, "number_of_replicas":1 }, "mappings":{ "properties":{ "name":{ "type":"text", "analyzer":"ik_max_word", "search_analyzer":"ik_max_word" }, "level":{ "type":"integer" }, "address":{ "type":"text", "analyzer":"ik_smart", "search_analyzer":"ik_smart" }, "createTime":{ "type":"date", "format":"yyyy-MM-dd HH:mm:ss || yyyy-MM-dd || epoch_millis" } } } } View Code
number_of_shards表示分片个数，number_of_replicas表示备份个数。
注意：在上文中已经介绍了，在在7.x版会移除Type。所以这里不需要再指定type, 相反若指定type了的话会报错。
Root mapping definition has unsupported parameters建议使用elasticsearch最新版本，若安装的是低于elasticsearch7版本的elasticsearch,可以使用下面的方式创建索引。
{ "settings":{ "number_of_shards":3, "number_of_replicas":1 }, "mappings":{ "hotel":{ "properties":{ "level":{ "type":"integer" }, "address":{ "type":"text", "analyzer":"ik_max_word" }, "createTime":{ "type":"date", "format":"yyyy-MM-dd HH:mm:ss || yyyy-MM-dd || epoch_millis" } } }, "restaurant":{ "properties":{ "type":{ "type":"text", "analyzer":"ik_smart" }, "price":{ "type":"integer" } } } } } View Code
4.1.3 删除Index
$ curl -X DELETE '127.0.0.1:9200/city'返回结果：
4.2 插入数据{"acknowledged":true}4.2.1 插入指定id的数据
在 es 中，插入数据分为指定文档id插入和自动产生文档id插入
指定文档id插入，其中我们指定数据ID为1。
生成id=1的数据。
注意，在在7.x版会移除Type，所以插入数据的url需要加上
_doc,即：toutou.com:9200/city/_doc/1。具体规则可以看看这里自动产生文档id插入。
4.3 修改数据 4.4 查询数据4.4.1 ID查询GET
4.4.2 条件查询POST
查询5星级酒店。
4.5 删除数据
vSpringBoot整合Elasticsearchcurl -X DELETE 'toutou.com:9200/city/_doc/2'spring-boot-starter-data-elasticsearch调试了很久，尝试的很多方法，始终报错：
NoNodeAvailableException[None of the configured nodes are available: [{#transport#-1}{wlOJEdIeQqKrmiBiUuJVzQ}{toutou.com}{192.168.118.137:9300}]]。看了一些相关介绍和博客，Spring Data Elasticsearch和Elasticsearch还有Spring Boot的版本需要全部一一对应上，才能使用。感觉太麻烦，新项目还好说，线上项目谁有功夫去跟你协调这些版本统一啊，费老劲了。果断弃用了。如果有大佬这块有好上手的兼容办法，还请多多指点。5.1 添加pom引用
<dependency> <groupId>org.elasticsearch.client</groupId> <artifactId>elasticsearch-rest-high-level-client</artifactId> <!--<version>7.5.1</version>--> </dependency>
注意：如果是springboot程序的话，
org.elasticsearch.client引用的版本号7.5.1最好注释掉，不然会报下面这个错：org.springframework.beans.factory.UnsatisfiedDependencyException: Error creating bean with name 'indexController': Unsatisfied dependency expressed through field 'cityEsService'; nested exception is org.springframework.beans.factory.UnsatisfiedDependencyException: Error creating bean with name 'cityEsServiceImpl': Unsatisfied dependency expressed through field 'client'; nested exception is org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'client' defined in class path resource [learn/service/impl/EsConfig.class]: Post-processing of merged bean definition failed; nested exception is java.lang.IllegalStateException: Failed to introspect Class [org.elasticsearch.client.RestHighLevelClient] from ClassLoader [sun.misc.Launcher$AppClassLoader@18b4aac2] at org.springframework.beans.factory.annotation.AutowiredAnnotationBeanPostProcessor$AutowiredFieldElement.inject(AutowiredAnnotationBeanPostProcessor.java:596) at org.springframework.beans.factory.annotation.InjectionMetadata.inject(InjectionMetadata.java:90) at org.springframework.beans.factory.annotation.AutowiredAnnotationBeanPostProcessor.postProcessProperties(AutowiredAnnotationBeanPostProcessor.java:374) at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.populateBean(AbstractAutowireCapableBeanFactory.java:1411) at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.doCreateBean(AbstractAutowireCapableBeanFactory.java:592) at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBean(AbstractAutowireCapableBeanFactory.java:515) at org.springframework.beans.factory.support.AbstractBeanFactory.lambda$doGetBean$0(AbstractBeanFactory.java:320) at org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.getSingleton(DefaultSingletonBeanRegistry.java:222) at org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:318) at org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:199) at org.springframework.beans.factory.support.DefaultListableBeanFactory.preInstantiateSingletons(DefaultListableBeanFactory.java:845) at org.springframework.context.support.AbstractApplicationContext.finishBeanFactoryInitialization(AbstractApplicationContext.java:877) at org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:549) at org.springframework.boot.web.servlet.context.ServletWebServerApplicationContext.refresh(ServletWebServerApplicationContext.java:140) at org.springframework.boot.SpringApplication.refresh(SpringApplication.java:742) at org.springframework.boot.SpringApplication.refreshContext(SpringApplication.java:389) at org.springframework.boot.SpringApplication.run(SpringApplication.java:311) at org.springframework.boot.SpringApplication.run(SpringApplication.java:1213) at org.springframework.boot.SpringApplication.run(SpringApplication.java:1202) at learn.web.Application.main(Application.java:18) Caused by: org.springframework.beans.factory.UnsatisfiedDependencyException: Error creating bean with name 'cityEsServiceImpl': Unsatisfied dependency expressed through field 'client'; nested exception is org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'client' defined in class path resource [learn/service/impl/EsConfig.class]: Post-processing of merged bean definition failed; nested exception is java.lang.IllegalStateException: Failed to introspect Class [org.elasticsearch.client.RestHighLevelClient] from ClassLoader [sun.misc.Launcher$AppClassLoader@18b4aac2] at org.springframework.beans.factory.annotation.AutowiredAnnotationBeanPostProcessor$AutowiredFieldElement.inject(AutowiredAnnotationBeanPostProcessor.java:596) at org.springframework.beans.factory.annotation.InjectionMetadata.inject(InjectionMetadata.java:90) at org.springframework.beans.factory.annotation.AutowiredAnnotationBeanPostProcessor.postProcessProperties(AutowiredAnnotationBeanPostProcessor.java:374) at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.populateBean(AbstractAutowireCapableBeanFactory.java:1411) at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.doCreateBean(AbstractAutowireCapableBeanFactory.java:592) at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBean(AbstractAutowireCapableBeanFactory.java:515) at org.springframework.beans.factory.support.AbstractBeanFactory.lambda$doGetBean$0(AbstractBeanFactory.java:320) at org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.getSingleton(DefaultSingletonBeanRegistry.java:222) at org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:318) at org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:199) at org.springframework.beans.factory.config.DependencyDescriptor.resolveCandidate(DependencyDescriptor.java:277) at org.springframework.beans.factory.support.DefaultListableBeanFactory.doResolveDependency(DefaultListableBeanFactory.java:1251) at org.springframework.beans.factory.support.DefaultListableBeanFactory.resolveDependency(DefaultListableBeanFactory.java:1171) at org.springframework.beans.factory.annotation.AutowiredAnnotationBeanPostProcessor$AutowiredFieldElement.inject(AutowiredAnnotationBeanPostProcessor.java:593) ... 19 common frames omitted Caused by: org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'client' defined in class path resource [learn/service/impl/EsConfig.class]: Post-processing of merged bean definition failed; nested exception is java.lang.IllegalStateException: Failed to introspect Class [org.elasticsearch.client.RestHighLevelClient] from ClassLoader [sun.misc.Launcher$AppClassLoader@18b4aac2] at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.doCreateBean(AbstractAutowireCapableBeanFactory.java:570) at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBean(AbstractAutowireCapableBeanFactory.java:515) at org.springframework.beans.factory.support.AbstractBeanFactory.lambda$doGetBean$0(AbstractBeanFactory.java:320) at org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.getSingleton(DefaultSingletonBeanRegistry.java:222) at org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:318) at org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:199) at org.springframework.beans.factory.config.DependencyDescriptor.resolveCandidate(DependencyDescriptor.java:277) at org.springframework.beans.factory.support.DefaultListableBeanFactory.doResolveDependency(DefaultListableBeanFactory.java:1251) at org.springframework.beans.factory.support.DefaultListableBeanFactory.resolveDependency(DefaultListableBeanFactory.java:1171) at org.springframework.beans.factory.annotation.AutowiredAnnotationBeanPostProcessor$AutowiredFieldElement.inject(AutowiredAnnotationBeanPostProcessor.java:593) ... 32 common frames omitted Caused by: java.lang.IllegalStateException: Failed to introspect Class [org.elasticsearch.client.RestHighLevelClient] from ClassLoader [sun.misc.Launcher$AppClassLoader@18b4aac2] at org.springframework.util.ReflectionUtils.getDeclaredMethods(ReflectionUtils.java:507) at org.springframework.util.ReflectionUtils.doWithLocalMethods(ReflectionUtils.java:367) at org.springframework.beans.factory.annotation.InitDestroyAnnotationBeanPostProcessor.buildLifecycleMetadata(InitDestroyAnnotationBeanPostProcessor.java:207) at org.springframework.beans.factory.annotation.InitDestroyAnnotationBeanPostProcessor.findLifecycleMetadata(InitDestroyAnnotationBeanPostProcessor.java:189) at org.springframework.beans.factory.annotation.InitDestroyAnnotationBeanPostProcessor.postProcessMergedBeanDefinition(InitDestroyAnnotationBeanPostProcessor.java:128) at org.springframework.context.annotation.CommonAnnotationBeanPostProcessor.postProcessMergedBeanDefinition(CommonAnnotationBeanPostProcessor.java:297) at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.applyMergedBeanDefinitionPostProcessors(AbstractAutowireCapableBeanFactory.java:1077) at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.doCreateBean(AbstractAutowireCapableBeanFactory.java:567) ... 41 common frames omitted Caused by: java.lang.NoClassDefFoundError: org/elasticsearch/client/Cancellable at java.lang.Class.getDeclaredMethods0(Native Method) at java.lang.Class.privateGetDeclaredMethods(Class.java:2701) at java.lang.Class.getDeclaredMethods(Class.java:1975) at org.springframework.util.ReflectionUtils.getDeclaredMethods(ReflectionUtils.java:489) ... 48 common frames omitted Caused by: java.lang.ClassNotFoundException: org.elasticsearch.client.Cancellable at java.net.URLClassLoader.findClass(URLClassLoader.java:381) at java.lang.ClassLoader.loadClass(ClassLoader.java:424) at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:335) at java.lang.ClassLoader.loadClass(ClassLoader.java:357) ... 52 common frames omitted View Code
因为就像上文提到的data与es version冲突似的，
org.elasticsearch.client也有版本之间的兼容性问题，把org.elasticsearch.client的版本号去掉由SpringBoot来管理依赖的版本即可。5.2 添加EsConfig
import com.google.gson.Gson; import org.apache.www.cnblogs.com/toutou */ @Slf4j @RestController public class IndexController { @Autowired private CityEsService cityEsService; @GetMapping("es/search") public Result esSearch(@RequestParam("id") String id) { return Result.setSuccessResult(cityEsService.getCityById(id)); } }
5.3.3 效果验证
由于service层和Controller大部分代码都是重复的，下面就只贴service层代码实现了，感兴趣的可以在文章底部的源码中查看更多细节。
5.4 根据id删除城市酒店信息
5.4.1 删除方法实现代码
@Override public String delCityById(String id){ try { DeleteRequest request=new DeleteRequest("city","_doc",id); DeleteResponse response= client.delete(request,RequestOptions.DEFAULT); return response.status().name(); } catch (IOException e) { throw new RuntimeException("删除失败."); } }
5.4.2 效果验证
5.5 添加数据
@Override public String addCityByInfo(String id, String name, Integer level, String address, String createTime){ Map<String, Object> jsonMap = new HashMap<>(); jsonMap.put("name", name); jsonMap.put("level", level); jsonMap.put("address", address); jsonMap.put("createTime", createTime); // 若不需要创建指定id的数据，则不需要再IndexRequest的构造函数中传入id // IndexRequest indexRequest = new IndexRequest("city", "_doc"); IndexRequest indexRequest = new IndexRequest("city", "_doc", id); indexRequest.source(jsonMap); try { IndexResponse rp = client.index(indexRequest); return rp.status().name(); } catch (IOException e) { throw new RuntimeException("添加失败."); } }
5.6 修改数据
@Override public String updateCityByInfo(String id, String name){ UpdateRequest request=new UpdateRequest("city","_doc", id); Map<String, Object> jsonMap = new HashMap<>(); jsonMap.put("name", name); request.doc(jsonMap); try { return client.update(request,RequestOptions.DEFAULT).status().name(); } catch (IOException e) { throw new RuntimeException("修改失败."); } }
5.7 复合查询
public List<Map<String, Object>> query(String name, Integer level, Integer index, Integer size){ SearchRequest request = new SearchRequest("city"); BoolQueryBuilder boolQueryBuilder = QueryBuilders.boolQuery(); boolQueryBuilder.must(QueryBuilders.matchQuery("name", name)); boolQueryBuilder.must(QueryBuilders.matchQuery("level", level)); SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder(); //排序 searchSourceBuilder.sort(SortBuilders.fieldSort("createTime").order(SortOrder.DESC)); //分页 searchSourceBuilder.from(index).size(size).query(boolQueryBuilder); request.searchType(SearchType.DEFAULT).source(searchSourceBuilder); List<Map<String, Object>> list = new ArrayList<>(); try { SearchResponse rp = client.search(request, RequestOptions.DEFAULT); for (SearchHit item : rp.getHits().getHits()) { list.add(item.getSourceAsMap()); } } catch (IOException e) { throw new RuntimeException("查询失败."); } return list; }
其他参考资料：
- Elasticsearch: 权威指南
- elasticsearch - Docker Hub
- Java High Level REST Client
github.com/toutouge/javademosecond/tree/master/hellospringboot
作 者：请叫我头头哥
出 处：www.cnblogs.com/toutou/
关于