Elasticsearch学习笔记_01【基础篇】概念 & HTTP操作 & JavaAPI

一时失言乱红尘 2024-03-23 14:11 85阅读 0赞

## [Elasticsearch][] ##

### 第1章 Elasticsearch 概述 ###

#### 1.1 Elasticsearch 是什么 ####

The Elastic Stack, 包括 Elasticsearch、Kibana、Beats 和 Logstash（也称为 ELK Stack）。 能够安全可靠地获取任何来源、任何格式的数据，然后实时地对数据进行搜索、分析和可视化。

Elaticsearch，简称为 ES，ES 是一个开源的`高扩展`的`分布式全文搜索引擎`，是整个 Elastic Stack [技术栈][Link 1]的核心。它可以`近乎实时的存储、检索数据`；本身扩展性很好，可以扩展到上百台服务器，处理 PB 级别的数据。

#### 1.2 全文搜索引擎 ####

Google，百度类的网站搜索，它们都是根据网页中的关键字生成索引，我们在搜索的时候输入关键字，它们会将该关键字即索引匹配到的所有网页返回；还有常见的项目中应用日 志的搜索等等。对于这些非结构化的数据文本，关系型数据库搜索不是能很好的支持。

一般传统数据库，全文检索都实现的很鸡肋，因为一般也没人用数据库存文本字段。进行全文检索需要扫描整个表，如果数据量大的话即使对 SQL 的语法优化，也收效甚微。建立了索引，但是维护起来也很麻烦，对于 insert 和 update 操作都会重新构建索引。

基于以上原因可以分析得出，在一些生产环境中，使用常规的搜索方式，性能是非常差的：

 搜索的数据对象是大量的非结构化的文本数据。

 文件记录量达到数十万或数百万个甚至更多。

 支持大量基于交互式文本的查询。

 需求非常灵活的全文搜索查询。

 对高度相关的搜索结果的有特殊需求，但是没有可用的关系数据库可以满足。

 对不同记录类型、非文本数据操作或安全事务处理的需求相对较少的情况。

为了解决结构化数据搜索和非结构化数据搜索性能问题，我们就需要专业，健壮，强大的全文搜索引擎 这里说到的全文搜索引擎指的是目前广泛应用的主流搜索引擎。

它的工作原理是计算机索引程序通过扫描文章中的每一个词，对每一个词建立一个索引，指明该词在文章中出现的次数和位置，当用户查询时，检索程序就根据事先建立的索引进行查找，并将查找的结果反 馈给用户的检索方式。这个过程类似于通过字典中的检索字表查字的过程。

#### 1.3 Elasticsearch And Solr ####

Lucene 是 Apache 软件基金会 Jakarta 项目组的一个子项目，提供了一个简单却强大的应用程式接口，能够做全文索引和搜寻。在 Java 开发环境里 Lucene 是一个成熟的免费开源工具。就其本身而言，Lucene 是当前以及最近几年最受欢迎的免费 Java 信息检索程序库。 但 Lucene 只是一个提供全文搜索功能类库的核心工具包，而真正使用它还需要一个完善的服务框架搭建起来进行应用。

目前市面上流行的搜索引擎软件，主流的就两款：Elasticsearch 和 Solr,这两款都是基 于 Lucene 搭建的，可以独立部署启动的搜索引擎服务软件。由于内核相同，所以两者除了服务器安装、部署、管理、集群以外，对于数据的操作修改、添加、保存、查询等等都十分类似。

在使用过程中，一般都会将 Elasticsearch 和 Solr 这两个软件对比，然后进行选型。这两个搜索引擎都是流行的，先进的的开源搜索引擎。它们都是围绕核心底层搜索库 - Lucene 构建的 - 但它们又是不同的。像所有东西一样，每个都有其优点和缺点：

![image-20210802140132106][]

#### 1.4 Elasticsearch Or Solr ####

Elasticsearch 和 Solr 都是开源搜索引擎，那么我们在使用时该如何选择呢？

*  Google 搜索趋势结果表明，与 Solr 相比，Elasticsearch 具有很大的吸引力，但这并不 意味着 Apache Solr 已经死亡。虽然有些人可能不这么认为，但 Solr 仍然是最受欢迎的 搜索引擎之一，拥有强大的社区和开源支持。
 *  Solr 拥有更大，更成熟的用户，开发者和贡献者社区。ES 虽拥有的规模较小但活跃的 用户社区以及不断增长的贡献者社区。 Solr 贡献者和提交者来自许多不同的组织，而 Elasticsearch 提交者来自单个公司。
 *  Solr 更成熟，但 ES 增长迅速，更稳定。
 *  Solr 是一个非常有据可查的产品，具有清晰的示例和 API 用例场景。 Elasticsearch 的 文档组织良好，但它缺乏好的示例和清晰的配置说明。
 *  与 Solr 相比，Elasticsearch 易于安装且非常轻巧。此外，你可以在几分钟内安装并运行 Elasticsearch。但是，如果 Elasticsearch 管理不当，这种易于部署和使用可能会成为一个问题。基于 JSON 的配置很简单，但如果要为文件中的每个配置指定注释，那么它不适合您。总的来说，如果你的应用使用的是 JSON，那么 Elasticsearch 是一个更好的选择。 否则，请使用 Solr，因为它的 schema.xml 和 solrconfig.xml 都有很好的文档记录。
    
    那么，到底是 Solr 还是 Elasticsearch？
    
    有时很难找到明确的答案。无论您选择 Solr 还是 Elasticsearch，首先需要了解正确的用 例和未来需求。总结他们的每个属性。
 *  由于易于使用，Elasticsearch 在新开发者中更受欢迎。一个下载和一个命令就可以启动 一切。
 *  如果除了搜索文本之外还需要它来处理分析查询，Elasticsearch 是更好的选择
 *  如果需要分布式索引，则需要选择 Elasticsearch。对于需要良好可伸缩性和以及性能分 布式环境，Elasticsearch 是更好的选择。
 *  Elasticsearch 在开源日志管理用例中占据主导地位，许多组织在 Elasticsearch 中索引它 们的日志以使其可搜索。
 *   如果你喜欢监控和指标，那么请使用 Elasticsearch，因为相对于 Solr，Elasticsearch 暴露 了更多的关键指标

#### 1.5 Elasticsearch 应用案例 ####

*  GitHub: 2013 年初，抛弃了 Solr，采取 Elasticsearch 来做 PB 级的搜索。“GitHub 使用 Elasticsearch 搜索 20TB 的数据，包括 13 亿文件和 1300 亿行代码”。
 *  维基百科：启动以 Elasticsearch 为基础的核心搜索架构  SoundCloud：“SoundCloud 使用 Elasticsearch 为 1.8 亿用户提供即时而精准的音乐搜索 服务”。
 *  百度：目前广泛使用 Elasticsearch 作为文本数据分析，采集百度所有服务器上的各类指 标数据及用户自定义数据，通过对各种数据进行多维分析展示，辅助定位分析实例异常 或业务层面异常。目前覆盖百度内部 20 多个业务线（包括云分析、网盟、预测、文库、 直达号、钱包、风控等），单集群最大 100 台机器，200 个 ES 节点，每天导入 30TB+ 数据。
 *  新浪：使用 Elasticsearch 分析处理 32 亿条实时日志。
 *  阿里：使用 Elasticsearch 构建日志采集和分析体系。
 *  Stack Overflow：解决 Bug 问题的网站，全英文，编程人员交流的网站。
    
    ### 第2章 Elasticsearch 入门 ###
 *  ### 2.1 Elasticsearch 安装 ###
 *  2.1.1 下载软件
    
    Elasticsearch 的官方地址：https://www.elastic.co/cn/
    
    Elasticsearch 最新的版本是 7.11.2（截止 2021.3.10），我们选择 7.8.0 版本（最新版本半 年前的版本）
    
    下载地址：https://www.elastic.co/cn/downloads/past-releases\#elasticsearch
    
    Elasticsearch 分为 Linux 和 Windows 版本，基于我们主要学习的是 Elasticsearch 的 Java 客户端的使用，所以课程中使用的是安装较为简便的 Windows 版本。
 *  2.1.2 安装软件
 *  Windows 版的 Elasticsearch 的安装很简单，解压即安装完毕，解压后的 Elasticsearch 的 目录结构如下
 *  解压后，进入 bin 文件目录，点击 elasticsearch.bat 文件启动 ES 服务
 *  注意：9300 端口为 Elasticsearch 集群间组件的通信端口，9200 端口为浏览器访问的 http 协议 RESTful 端口。
    
    打开浏览器（推荐使用谷歌浏览器），输入地址：http://localhost:9200，测试结果
 *  2.1.3 问题解决
 *  Elasticsearch 是使用 java 开发的，且 7.8 版本的 ES 需要 JDK 版本 1.8 以上，默认安装 包带有 jdk 环境，如果系统配置 JAVA\_HOME，那么使用系统默认的 JDK，如果没有配 置使用自带的 JDK，一般建议使用系统配置的 JDK。
 *  双击启动窗口闪退，通过路径访问追踪错误，如果是“空间不足”，请修改 config/jvm.options 配置文件
    
        # 设置 JVM 初始内存为 1G。此值可以设置与-Xmx 相同，以避免每次垃圾回收完成后 JVM 重新分配内存 
        # Xms represents the initial size of total heap space # 设置 JVM 最大可用内存为 1G 
        # Xmx represents the maximum size of total heap space 
        -Xms1g 
        -Xmx1g

#### 2.2 Elasticsearch 基本操作 ####

2.2.1 RESTful REST

指的是一组`架构约束条件和原则`。满足这些约束条件和原则的应用程序或设计就 是 RESTful。

Web 应用程序最重要的 REST 原则是，客户端和服务器之间的交互在请求之间是无状态的。从客户端到服务器的每个请求都必须包含理解请求所必需的信息。如果服务器在请求之间的任何时间点重启，客户端不会得到通知。此外，无状态请求可以由任何可用服务器回答，这十分适合云计算之类的环境。客户端可以缓存数据以改进性能。

在服务器端，应用程序状态和功能可以分为各种资源。资源是一个有趣的概念实体，它向客户端公开。资源的例子有：应用程序对象、数据库记录、算法等等。每个资源都使用 URI (Universal Resource Identifier) 得到一个唯一的地址。所有资源都共享统一的接口，以便在客户端和服务器之间传输状态。使用的是标准的 HTTP 方法，比如 GET、PUT、POST 和 DELETE。

在 REST 样式的 Web 服务中，每个资源都有一个地址。资源本身都是方法调用的目标，方法列表对所有资源都是一样的。这些方法都是标准方法，包括 HTTP GET、POST、 PUT、DELETE，还可能包括 HEAD 和 OPTIONS。简单的理解就是，如果想要访问互联网上的资源，就必须向资源所在的服务器发出请求，请求体中必须包含 资源的网络路径，以及对资源进行的操作(增删改查)。

2.2.2 客户端安装

如果直接通过浏览器向 Elasticsearch 服务器发请求，那么需要在发送的请求中包含 HTTP 标准的方法，而 HTTP 的大部分特性且仅支持 GET 和 POST 方法。所以为了能方便 地进行客户端的访问，可以使用 Postman 软件

Postman 是一款强大的网页调试工具，提供功能强大的 Web API 和 HTTP 请求调试。 软件功能强大，界面简洁明晰、操作方便快捷，设计得很人性化。Postman 中文版能够发送任何类型的 HTTP 请求 (GET, HEAD, POST, PUT…)，不仅能够表单提交，且可以附带任意 类型请求体。

Postman 官网：https://www.getpostman.com

Postman 下载：https://www.getpostman.com/apps

2.2.3 数据格式

Elasticsearch 是面向文档型数据库，一条数据在这里就是一个文档。为了方便大家理解， 我们将 Elasticsearch 里存储文档数据和关系型数据库 MySQL 存储数据的概念进行一个类比

ES 里的 Index 可以看做一个库，而 Types 相当于表，Documents 则相当于表的行。 这里 Types 的概念已经被逐渐弱化，Elasticsearch 6.X 中，一个 index 下已经只能包含一个 type，Elasticsearch 7.X 中, Type 的概念已经被删除了。

用 JSON 作为文档序列化的格式，比如一条用户信息：

{
    	"name": "John",
    	"sex": "Male",
    	"age": 25,
    	"birthDate": "1990/05/01",
    	"about": "I love to go rock climbing",
    	"interests": ["sports", "music"]
    }

### 第3章：HTTP 操作 ###

#### 3.1 索引操作 ####

1) 创建索引

对比关系型数据库，`创建索引`就等同于`创建数据库`

在 Postman 中，向 ES 服务器发 `PUT` 请求 ：

http://127.0.0.1:9200/shopping

请求后，服务器返回响应

{
     "acknowledged"【响应结果】: true, # true 操作成功
     "shards_acknowledged"【分片结果】: true, # 分片操作成功
     "index"【索引名称】: "shopping"
    }
    # 注意：创建索引库的分片数默认 1 片，在 7.0.0 之前的 Elasticsearch 版本中，默认 5 片

如果重复添加索引，会返回错误信息

2) 查看所有索引

在 Postman 中，向 ES 服务器发 `GET` 请求 ：

http://127.0.0.1:9200/_cat/indices?v

这里请求路径中的 `_cat 表示查看`的意思，`indices 表示索引`，所以整体含义就是查看当前 ES 服务器中的所有索引，就好像 MySQL 中的 show tables 的感觉，服务器响应结果如下

3) 查看单个索引

在 Postman 中，向 ES 服务器发 `GET` 请求 ：

http://127.0.0.1:9200/shopping

查看索引向 ES 服务器发送的请求路径和创建索引是一致的。但是 HTTP 方法不一致。这里 可以体会一下 RESTful 的意义， 请求后，服务器响应结果如下：

{
    	"shopping"【索引名】: {
    		"aliases"【别名】: {},
    		"mappings"【映射】: {},
    		"settings"【设置】: {
    			"index"【设置 - 索引】: {
    				"creation_date"【设置 - 索引 - 创建时间】: "1614265373911",
    				"number_of_shards"【设置 - 索引 - 主分片数量】: "1",
    				"number_of_replicas"【设置 - 索引 - 副分片数量】: "1",
    				"uuid"【设置 - 索引 - 唯一标识】: "eI5wemRERTumxGCc1bAk2A",
    				"version"【设置 - 索引 - 版本】: {
    					"created": "7080099"
    				},
    				"provided_name"【设置 - 索引 - 名称】: "shopping"
    			}
    		}
    	}
    }

4) 删除索引

在 Postman 中，向 ES 服务器发 DELETE 请求 ：

http://127.0.0.1:9200/shopping

重新访问索引时，服务器返回响应：`索引不存在`

#### 3.2 文档操作 ####

1) 创建文档

索引已经创建好了，接下来我们来创建文档，并添加数据。

这里的文档可以类比为关系型数据库中的`表数据`，添加的数据格式为 `JSON 格式`

在 Postman 中，向 ES 服务器发 POST 请求 ：

http://127.0.0.1:9200/shopping/_doc

请求体内容为：

{
     "title":"小米手机",
     "category":"小米",
     "images":"http://www.gulixueyuan.com/xm.jpg",
     "price":3999.00
    }

此处发送请求的方式必须为 `POST`，不能是 `PUT`，否则会发生错误

服务器响应结果如下：

{
    	"_index"【索引】: "shopping",
    		"_type"【类型 - 文档】: "_doc",
    		"_id"【唯一标识】: "Xhsa2ncBlvF_7lxyCE9G", #可以类比为 MySQL 中的主键， 随机生成 
            "_version"【版本】: 1,
    		"result"【结果】: "created", #这里的 create 表示创建成功 
            "_shards"【分片】: {
    			"total"【分片 - 总数】: 2,
    			"successful"【分片 - 成功】: 1,
    			"failed"【分片 - 失败】: 0
    		},
    		"_seq_no": 0,
    		"_primary_term": 1
    }

上面的数据创建后，由于没有`指定数据唯一性标识`（ID），默认情况下，ES 服务器会随机 生成一个。

如果想要自定义唯一性标识，需要在创建时指定：

http://127.0.0.1:9200/shopping/_doc/1

此处需要注意：如果增加数据时`明确数据主键`，那么请求方式也可以为 `PUT`

2) 查看文档

查看文档时，需要指明文档的唯一性标识，类似于 MySQL 中数据的主键查询

在 Postman 中，向 ES 服务器发 GET 请求 ：

http://127.0.0.1:9200/shopping/_doc/1

查询成功后，服务器响应结果：

{
     "_index"【索引】: "shopping",
     "_type"【文档类型】: "_doc",
     "_id": "1",
     "_version": 2,
     "_seq_no": 2,
     "_primary_term": 2,
     "found"【查询结果】: true, # true 表示查找到，false 表示未查找到
     "_source"【文档源信息】: {
     	"title": "华为手机",
     	"category": "华为",
     	"images": "http://www.gulixueyuan.com/hw.jpg",
     	"price": 4999.00
     }
    }

3) 修改文档

和新增文档一样，输入相同的 URL 地址请求，如果请求体变化，会将原有的`数据内容覆盖`

在 Postman 中，向 ES 服务器发 POST 请求 ：

http://127.0.0.1:9200/shopping/_doc/1

请求体内容为:

{
     "title":"华为手机",
     "category":"华为",
     "images":"http://www.gulixueyuan.com/hw.jpg",
     "price":4999.00
    }

修改成功后，服务器响应结果：

{
     "_index": "shopping",
     "_type": "_doc",
     "_id": "1",
     "_version"【版本】: 2,
     "result"【结果】: "updated", # updated 表示数据被更新
     "_shards": {
     	"total": 2,
     	"successful": 1,
     	"failed": 0
     },
     "_seq_no": 2,
     "_primary_term": 2
    }

4) 修改字段

修改数据时，也可以只修改某一给条数据的局部信息

在 Postman 中，向 ES 服务器发 POST 请求 ：

http://127.0.0.1:9200/shopping/_update/1

请求体内容为：

{ 
     "doc": {
     	"price":3000.00
     } 
    }

修改成功后，服务器响应结果：

![image-20210802151943787][]

5) 删除文档

删除一个文档不会立即从磁盘上移除，它只是被标记成已删除`（逻辑删除）`。

在 Postman 中，向 ES 服务器发 DELETE 请求 ：

http://127.0.0.1:9200/shopping/_doc/1

删除成功，服务器响应结果：

{
     "_index": "shopping",
     "_type": "_doc",
     "_id": "1",
     "_version"【版本】: 4, #对数据的操作，都会更新版本
     "result"【结果】: "deleted", # deleted 表示数据被标记为删除
     "_shards": {
     	"total": 2,
     	"successful": 1,
     	"failed": 0
     },
     "_seq_no": 4,
     "_primary_term": 2
    }

如果删除一个并不存在的文档

{
     "_index": "shopping",
     "_type": "_doc",
     "_id": "1",
     "_version": 1,
     "result"【结果】: "not_found", # not_found 表示未查找到
     "_shards": {
     	"total": 2,
     	"successful": 1,
     	"failed": 0
     },
     "_seq_no": 5,
     "_primary_term": 2
    }

6) 条件删除文档

一般删除数据都是根据文档的唯一性标识进行删除，实际操作时，也可以`根据条件`对多条数据进行删除

向 ES 服务器发 POST 请求 ：

http://127.0.0.1:9200/shopping/_delete_by_query

请求体内容为：

{
     "query":{
     "match":{
     "price":4000.00
     }
     }
    }

删除成功后，服务器响应结果：

>     {
>      "took"【耗时】: 175,
>      "timed_out"【是否超时】: false,
>      "total"【总数】: 2,
>      "deleted"【删除数量】: 2,
>      "batches": 1,
>      "version_conflicts": 0,
>      "noops": 0,
>      "retries": {
>      "bulk": 0,
>      "search": 0
>      },
>      "throttled_millis": 0,
>      "requests_per_second": -1.0,
>      "throttled_until_millis": 0,
>      "failures": []
>     }

#### 3.3 映射操作 ####

有了索引库，等于有了数据库中的 database。

接下来就需要建索引库(index)中的映射了，类似于数据库(database)中的表结构(table)。 创建数据库表需要设置字段名称，类型，长度，约束等；索引库也一样，需要知道这个类型下有哪些字段，每个字段有哪些约束信息，这就叫做映射(mapping)。

1) 创建映射

在 Postman 中，向 ES 服务器发 PUT 请求 ：

>     http://127.0.0.1:9200/student/_mapping

请求体内容为：

{
     "properties": {
     "name":{
     "type": "text",
     "index": true
     },
     "sex":{
     "type": "text",
     "index": false
     },
     "age":{
     "type": "long",
     "index": false
     }
     }
    }

服务器响应结果如下：

![image-20210802155152473][]

映射数据说明：

 字段名：任意填写，下面指定许多属性，例如：title、subtitle、images、price

 type：类型，Elasticsearch 中支持的数据类型非常丰富，说几个关键的：

 String 类型，又分两种：

text：可分词

keyword：不可分词，数据会作为完整字段进行匹配

 Numerical：数值类型，分两类

基本数据类型：long、integer、short、byte、double、float、half\_float

浮点数的高精度类型：scaled\_float

 Date：日期类型

 Array：数组类型

 Object：对象

 index：是否索引，默认为 true，也就是说你不进行任何配置，所有字段都会被索引。

true：字段会被索引，则可以用来进行搜索

false：字段不会被索引，不能用来搜索

 store：是否将数据进行独立存储，默认为 false

原始的文本会存储在\_source 里面，默认情况下其他提取出来的字段都不是独立存储 的，是从\_source 里面提取出来的。当然你也可以独立的存储某个字段，只要设置 “store”: true 即可，获取独立存储的字段要比从\_source 中解析快得多，但是也会占用 更多的空间，所以要根据实际业务需求来设置。

 analyzer：分词器，这里的 ik\_max\_word 即使用 ik 分词器,后面会有专门的章节学习

2) 查看映射

在 Postman 中，向 ES 服务器发 GET 请求 ：

http://127.0.0.1:9200/student/_mapping

服务器响应结果如下：

3) 索引映射关联

在 Postman 中，向 ES 服务器发 PUT 请求 ：http://127.0.0.1:9200/student1

{
     "settings": {},
     "mappings": {
     "properties": {
    "name":{
     "type": "text",
     "index": true
     
    },
    "sex":{
     "type": "text",
     "index": false
    },
    "age":{
     "type": "long",
     "index": false
    }
     }
     }
    }

#### 3.4 高级查询 ####

Elasticsearch 提供了基于 JSON 提供完整的查询 DSL 来定义查询

定义数据 :

# POST /student/_doc/1001
    {
    "name":"zhangsan",
    "nickname":"zhangsan",
     "sex":"男",
     "age":30
    }
    # POST /student/_doc/1002
    {
    "name":"lisi",
    "nickname":"lisi",
     "sex":"男",
     "age":20
    }
    # POST /student/_doc/1003
    {
    "name":"wangwu",
     "nickname":"wangwu",
     "sex":"女",
     "age":40
    }
    # POST /student/_doc/1004
    {
    "name":"zhangsan1",
    "nickname":"zhangsan1",
     "sex":"女",
     "age":50
    }
    # POST /student/_doc/1005
    {
    "name":"zhangsan2",
    "nickname":"zhangsan2",
     "sex":"女",
     "age":30
    }

1) 查询所有文档

在 Postman 中，向 ES 服务器发 GET 请求 ：http://127.0.0.1:9200/student/\_search

{
     "query": {
     "match_all": {}
     }
    }
    # "query"：这里的 query 代表一个查询对象，里面可以有不同的查询属性
    # "match_all"：查询类型，例如：match_all(代表查询所有)， match，term ， range 等等
    # {查询条件}：查询条件会根据类型的不同，写法也有差异

{
     "took【查询花费时间，单位毫秒】" : 1116,
     "timed_out【是否超时】" : false,
     "_shards【分片信息】" : {
     "total【总数】" : 1,
     "successful【成功】" : 1,
     "skipped【忽略】" : 0,
     "failed【失败】" : 0
     },
     "hits【搜索命中结果】" : {
     "total"【搜索条件匹配的文档总数】: {
     "value"【总命中计数的值】: 3,
     "relation"【计数规则】: "eq" # eq 表示计数准确， gte 表示计数不准确
     },
     "max_score【匹配度分值】" : 1.0,
     "hits【命中结果集合】" : [
     。。。
     }
     ]
     }
    }

2) 匹配查询

match 匹配类型查询，会把查询条件进行`分词`，然后进行查询，多个词条之间是`or 的关系`

在 Postman 中，向 ES 服务器发 GET 请求 ：

{
     "query": {
     "match": {
     "name":"zhangsan"
     }
     }
    }

3) 字段匹配查询

multi\_match 与 match 类似，不同的是它可以在多个字段中查询。

在 Postman 中，向 ES 服务器发 GET 请求 ：

http://127.0.0.1:9200/student/_search

{
     "query": {
     "multi_match": {
     "query": "zhangsan",
     "fields": ["name","nickname"]
     }
     }
    }

4) 关键字精确查询

term 查询，精确的关键词匹配查询，不对查询条件进行分词。

在 Postman 中，向 ES 服务器发 GET 请求 ：

http://127.0.0.1:9200/student/_search

{
     "query": {
     "term": {
     "name": {
     "value": "zhangsan"
     }
     }
     }
    }

5) 多关键字精确查询

terms 查询和 term 查询一样，但它允许你指定多值进行匹配。

如果这个字段包含了指定值中的任何一个值，那么这个文档满足条件，类似于 mysql 的 in

在 Postman 中，向 ES 服务器发 GET 请求 ：

http://127.0.0.1:9200/student/_search

{
     "query": {
     "terms": {
     "name": ["zhangsan","lisi"]
     }
     }
    }

6) 指定查询字段

默认情况下，Elasticsearch 在搜索的结果中，会把文档中保存在\_source 的所有字段都返回。如果我们只想获取其中的部分字段，我们可以添加`_source 的过滤`

在 Postman 中，向 ES 服务器发 GET 请求 ：

http://127.0.0.1:9200/student/_search

{
     "_source": ["name","nickname"], 
     "query": {
     "terms": {
     "nickname": ["zhangsan"]
     }
     }
    }

7) 过滤字段

我们也可以通过：

includes：来指定想要显示的字段

 excludes：来指定不想要显示的字段

在 Postman 中，向 ES 服务器发 GET 请求 ：

http://127.0.0.1:9200/student/_search

{
     "_source": {
     "includes": ["name","nickname"]
     }, 
     "query": {
     "terms": {
     "nickname": ["zhangsan"]
     }
     }
    }

在 Postman 中，向 ES 服务器发 GET 请求 ：http://127.0.0.1:9200/student/\_search

{
     "_source": {
     "excludes": ["name","nickname"]
     }, 
     "query": {
     "terms": {
     "nickname": ["zhangsan"]
     }
     }
    }

8) 组合查询

`bool`把各种其它查询通过`must`（必须 ）、`must_not`（必须不）、`should`（应该）的方式进行组合

在 Postman 中，向 ES 服务器发 GET 请求 ：http://127.0.0.1:9200/student/\_search

{
     "query": {
     	"bool": {
     		"must": [
     			{
     				"match": {
     					"name": "zhangsan"
     				}
    			 }
     		],
     		"must_not": [
     			{
    				 "match": {
    					 "age": "40"
     					}
    			 }
    		 ],
     		"should": [
    			 {
     				"match": {
     					"sex": "男"
     				}
     			}
     		]
        }
      }
    }

9) 范围查询

range 查询找出那些落在指定区间内的数字或者时间。range 查询允许以下字符

![image-20210803091841387][]

在 Postman 中，向 ES 服务器发 GET 请求 ：http://127.0.0.1:9200/student/\_search

{
     "query": {
     "range": {
     "age": {
     "gte": 30,
     "lte": 35
     }
     }
     }
    }

10) 模糊查询

返回包含与搜索字词相似的字词的文档。  
编辑距离是将一个术语转换为另一个术语所需的一个字符更改的次数。这些更改可以包括：

 更改字符（box → fox）  
 删除字符（black → lack）  
 插入字符（sic → sick）  
 转置两个相邻字符（act → cat）

为了找到相似的术语，fuzzy 查询会在指定的编辑距离内创建一组搜索词的所有可能的变体  
或扩展。然后查询返回每个扩展的完全匹配。  
通过 fuzziness 修改编辑距离。一般使用默认值 AUTO，根据术语的长度生成编辑距离。

在 Postman 中，向 ES 服务器发 GET 请求 ：http://127.0.0.1:9200/student/\_search

{
     "query": {
     "fuzzy": {
     "title": {
     "value": "zhangsan"
     }
     }
     }
    }

在 Postman 中，向 ES 服务器发 GET 请求 ：http://127.0.0.1:9200/student/\_search

{
     "query": {
     "fuzzy": {
     "title": {
     "value": "zhangsan",
    "fuzziness": 2
     }
     }
     }
    }

11) 单字段排序

sort 可以让我们按照不同的字段进行排序，并且通过 order 指定排序的方式。desc 降序，asc 升序。

在 Postman 中，向 ES 服务器发 GET 请求 ：http://127.0.0.1:9200/student/\_search

{
     "query": {
     "match": {
     "name":"zhangsan"
     }
     },
     "sort": [{
     "age": {
     "order":"desc"
     }
     }]
    }

12) 多字段排序

假定我们想要结合使用 \_age 和 \_score 进行查询，并且匹配的结果首先按照年龄排序，然后

按照相关性得分排序

在 Postman 中，向 ES 服务器发 GET 请求 ：http://127.0.0.1:9200/student/\_search

{
     "query": {
     "match_all": {}
     },
     "sort": [
     {
     "age": {
     "order": "desc"
     }
     },
     {
     "_score":{
     "order": "desc"
     }
     }
     ]
    }

13) 高亮查询

在进行关键字搜索时，搜索出的内容中的关键字会显示不同的颜色，称之为高亮。

在百度搜索"京东"

Elasticsearch 可以对查询内容中的关键字部分，进行标签和样式(高亮)的设置。  
在使用 match 查询的同时，加上一个 highlight 属性：

 pre\_tags：前置标签  
 post\_tags：后置标签  
 fields：需要高亮的字段  
 title：这里声明 title 字段需要高亮，后面可以为这个字段设置特有配置，也可以空

在 Postman 中，向 ES 服务器发 GET 请求 ：http://127.0.0.1:9200/student/\_search

{
     "query": {
     "match": {
     "name": "zhangsan"
     }
     },
     "highlight": {
     "pre_tags": "<font color='red'>",
     "post_tags": "</font>",
     "fields": {
     "name": {}
     }
     }
    }

14) 分页查询

from：当前页的起始索引，默认从 0 开始。 from = (pageNum - 1) \* size

size：每页显示多少条

在 Postman 中，向 ES 服务器发 GET 请求 ：http://127.0.0.1:9200/student/\_search

{
     "query": {
     "match_all": {}
     },
     "sort": [
     {
     "age": {
     "order": "desc"
     }
     }
     ],
     "from": 0,
     "size": 2
    }

15) 聚合查询

聚合允许使用者对 es 文档进行统计分析，类似与关系型数据库中的 group by，当然还有很  
多其他的聚合，例如取最大值、平均值等等。

 对某个字段取最大值 max

在 Postman 中，向 ES 服务器发 GET 请求 ：http://127.0.0.1:9200/student/\_search

{
     "aggs":{
     "max_age":{
     "max":{"field":"age"}
     }
     },
     "size":0
    }

对某个字段取最小值 min

在 Postman 中，向 ES 服务器发 GET 请求 ：http://127.0.0.1:9200/student/\_search

{
     "aggs":{
     "min_age":{
     "min":{"field":"age"}
     }
     },
     "size":0
    }

对某个字段取最小值 min

在 Postman 中，向 ES 服务器发 GET 请求 ：http://127.0.0.1:9200/student/\_search

{
     "aggs":{
     "min_age":{
     "min":{"field":"age"}
     }
     },
     "size":0
    }

对某个字段求和 sum

在 Postman 中，向 ES 服务器发 GET 请求 ：http://127.0.0.1:9200/student/\_search

{
     "aggs":{
     "sum_age":{
     "sum":{"field":"age"}
     }
     },
     "size":0
    }

对某个字段取平均值 avg

在 Postman 中，向 ES 服务器发 GET 请求 ：http://127.0.0.1:9200/student/\_search

{
     "aggs":{
     "avg_age":{
     "avg":{"field":"age"}
     }
     },
     "size":0
    }

对某个字段的值进行去重之后再取总数

在 Postman 中，向 ES 服务器发 GET 请求 ：http://127.0.0.1:9200/student/\_search

{
     "aggs":{
     "distinct_age":{
     "cardinality":{"field":"age"}
     }
     },
     "size":0
    }

State 聚合

stats 聚合，对某个字段一次性返回 count，max，min，avg 和 sum 五个指标

在 Postman 中，向 ES 服务器发 GET 请求 ：http://127.0.0.1:9200/student/\_search

{
     "aggs":{
     "stats_age":{
     "stats":{"field":"age"}
     }
     },
     "size":0
    }

16) 桶聚合查询

桶聚和相当于 sql 中的 group by 语句

 terms 聚合，分组统计

在 Postman 中，向 ES 服务器发 GET 请求 ：http://127.0.0.1:9200/student/_search
    {
     "aggs":{
     "age_groupby":{
     "terms":{"field":"age"}
     }
     },
     "size":0
    }

在 terms 分组下再进行聚合

在 Postman 中，向 ES 服务器发 GET 请求 ：http://127.0.0.1:9200/student/\_search

{
     "aggs":{
     "age_groupby":{
     "terms":{"field":"age"}
     }
     },
     "size":0
    }

### 第4章：Java API 操作 ###

Elasticsearch 软件是由 Java 语言开发的，所以也可以通过 Java API 的方式对 Elasticsearch 服务进行访问

#### 4.1 创建 Maven 项目 ####

<dependencies>
            <dependency>
                <groupId>org.elasticsearch</groupId>
                <artifactId>elasticsearch</artifactId>
                <version>7.8.0</version>
            </dependency>
            
            <dependency>
                <groupId>org.elasticsearch.client</groupId>
                <artifactId>elasticsearch-rest-high-level-client</artifactId>
                <version>7.8.0</version>
            </dependency>
            
            <dependency>
                <groupId>org.apache.logging.log4j</groupId>
                <artifactId>log4j-api</artifactId>
                <version>2.8.2</version>
            </dependency>
            <dependency>
                <groupId>org.apache.logging.log4j</groupId>
                <artifactId>log4j-core</artifactId>
                <version>2.8.2</version>
            </dependency>
            <dependency>
                <groupId>com.fasterxml.jackson.core</groupId>
                <artifactId>jackson-databind</artifactId>
                <version>2.9.9</version>
            </dependency>
            
            <dependency>
                <groupId>junit</groupId>
                <artifactId>junit</artifactId>
                <version>4.12</version>
            </dependency>
        </dependencies>

#### 4.2 客户端对象 ####

public class ES_Client {
        public static void main(String[] args) throws IOException {
            RestHighLevelClient restHighLevelClient=new RestHighLevelClient(
                    RestClient.builder(new HttpHost("localhost",9200,"http"))
            );
    
            restHighLevelClient.close();
        }
    }

注意：9200 端口为 Elasticsearch 的 Web 通信端口，localhost 为启动 ES 服务的主机名 执行代码，查看控制台信息：

#### 4.3 索引操作 ####

1）创建索引

public class ESTest_Index_Create {
        public static void main(String[] args) throws Exception {
    
            RestHighLevelClient esClient = new RestHighLevelClient(
                    RestClient.builder(new HttpHost("localhost", 9200, "http"))
            );
    
            // 创建索引
            CreateIndexRequest request = new CreateIndexRequest("user");
            CreateIndexResponse createIndexResponse =
                    esClient.indices().create(request, RequestOptions.DEFAULT);
    
            // 响应状态
            boolean acknowledged = createIndexResponse.isAcknowledged();
            System.out.println("索引操作 ：" + acknowledged);
    
            esClient.close();
        }
    }

2）查询索引

public class ESTest_Index_Search {
        public static void main(String[] args) throws Exception {
    
            RestHighLevelClient esClient = new RestHighLevelClient(
                    RestClient.builder(new HttpHost("localhost", 9200, "http"))
            );
    
            // 查询索引
            GetIndexRequest request = new GetIndexRequest("user");
    
            GetIndexResponse getIndexResponse =
                    esClient.indices().get(request, RequestOptions.DEFAULT);
    
            // 响应状态
            System.out.println(getIndexResponse.getAliases());
            System.out.println(getIndexResponse.getMappings());
            System.out.println(getIndexResponse.getSettings());
    
            esClient.close();
        }
    }

3）删除索引

public class ESTest_Index_Delete {
        public static void main(String[] args) throws Exception {
    
            RestHighLevelClient esClient = new RestHighLevelClient(
                    RestClient.builder(new HttpHost("localhost", 9200, "http"))
            );
    
            // 删除索引
            DeleteIndexRequest request = new DeleteIndexRequest("user");
    
            AcknowledgedResponse response = esClient.indices().delete(request, RequestOptions.DEFAULT);
    
            // 响应状态
            System.out.println(response.isAcknowledged());
    
            esClient.close();
        }
    }

#### 4.4 文档操作 ####

1）新增文档

public class User {
        private String name;
        private String sex;
        private Integer age;
        public String getName() {
            return name;
        }
        public void setName(String name) {
            this.name = name;
        }
        public String getSex() {
            return sex;
        }
        public void setSex(String sex) {
            this.sex = sex;
        }
        public Integer getAge() {
            return age;
        }
        public void setAge(Integer age) {
            this.age = age;
        }
    }

public class ESTest_Doc_Insert {
        public static void main(String[] args) throws Exception {
    
            RestHighLevelClient esClient = new RestHighLevelClient(
                    RestClient.builder(new HttpHost("localhost", 9200, "http"))
            );
    
            // 插入数据
            IndexRequest request = new IndexRequest();
            request.index("user").id("1001");
    
            User user = new User();
            user.setName("zhangsan");
            user.setAge(30);
            user.setSex("男");
    
            // 向ES插入数据，必须将数据转换位JSON格式
            ObjectMapper mapper = new ObjectMapper();
            String userJson = mapper.writeValueAsString(user);
            request.source(userJson, XContentType.JSON);
    
            IndexResponse response = esClient.index(request, RequestOptions.DEFAULT);
    
            System.out.println(response.getResult());
    
            esClient.close();
        }
    }

2）修改文档

public class ESTest_Doc_Update {
        public static void main(String[] args) throws Exception {
    
            RestHighLevelClient esClient = new RestHighLevelClient(
                    RestClient.builder(new HttpHost("localhost", 9200, "http"))
            );
    
            // 修改数据
            UpdateRequest request = new UpdateRequest();
            request.index("user").id("1001");
            request.doc(XContentType.JSON, "sex", "女");
    
            UpdateResponse response = esClient.update(request, RequestOptions.DEFAULT);
    
            System.out.println(response.getResult());
    
            esClient.close();
        }
    }

3）查询文档

public class ESTest_Doc_Search {
        public static void main(String[] args) throws Exception {
    
            RestHighLevelClient esClient = new RestHighLevelClient(
                    RestClient.builder(new HttpHost("localhost", 9200, "http"))
            );
    
            // 1. 查询索引的所有数据
            SearchRequest request = new SearchRequest();
            request.indices("user");
    
            // 构造查询条件
            SearchSourceBuilder builder = new SearchSourceBuilder();
            builder.query(QueryBuilders.matchAllQuery());
    
            request.source(builder);
    
            SearchResponse response = esClient.search(request, RequestOptions.DEFAULT);
    
            SearchHits hits = response.getHits();
    
            System.out.println(response.getTook());
            System.out.println(hits.getTotalHits());
            Iterator<SearchHit> iterator = hits.iterator();
            while (iterator.hasNext()) {
                SearchHit hit = iterator.next();
                System.out.println(hit.getSourceAsString());
            }
    
            esClient.close();
        }
    }

4）删除文档

public class ESTest_Doc_Delete {
        public static void main(String[] args) throws Exception {
    
            RestHighLevelClient esClient = new RestHighLevelClient(
                    RestClient.builder(new HttpHost("localhost", 9200, "http"))
            );
    
    
            DeleteRequest request = new DeleteRequest();
            request.index("user").id("1001");
    
            DeleteResponse response = esClient.delete(request, RequestOptions.DEFAULT);
            System.out.println(response.toString());
    
            esClient.close();
        }
    }

5）批量插入

public class ESTest_Doc_Insert_Batch {
        public static void main(String[] args) throws Exception {
    
            RestHighLevelClient esClient = new RestHighLevelClient(
                    RestClient.builder(new HttpHost("localhost", 9200, "http"))
            );
    
            // 批量插入数据
            BulkRequest request = new BulkRequest();
    
    //        request.add(new IndexRequest().index("user").id("1001").source(XContentType.JSON, "name", "zhangsan", "age",30,"sex","男"));
    //        request.add(new IndexRequest().index("user").id("1002").source(XContentType.JSON, "name", "lisi", "age",30,"sex","女"));
    //        request.add(new IndexRequest().index("user").id("1003").source(XContentType.JSON, "name", "wangwu", "age",40,"sex","男"));
    //        request.add(new IndexRequest().index("user").id("1004").source(XContentType.JSON, "name", "wangwu1", "age",40,"sex","女"));
    //        request.add(new IndexRequest().index("user").id("1005").source(XContentType.JSON, "name", "wangwu2", "age",50,"sex","男"));
    //        request.add(new IndexRequest().index("user").id("1006").source(XContentType.JSON, "name", "wangwu3", "age",50,"sex","男"));
            //request.add(new IndexRequest().index("user").id("1007").source(XContentType.JSON, "name", "wangwu44", "age",60,"sex","男"));
            //request.add(new IndexRequest().index("user").id("1008").source(XContentType.JSON, "name", "wangwu555", "age",60,"sex","男"));
            request.add(new IndexRequest().index("user").id("1009").source(XContentType.JSON, "name", "wangwu66666", "age",60,"sex","男"));
    
            BulkResponse response = esClient.bulk(request, RequestOptions.DEFAULT);
            System.out.println(response.getTook());
            System.out.println(response.getItems());
    
            esClient.close();
        }
    }

6）批量删除

public class ESTest_Doc_Delete_Batch {
        public static void main(String[] args) throws Exception {
    
            RestHighLevelClient esClient = new RestHighLevelClient(
                    RestClient.builder(new HttpHost("localhost", 9200, "http"))
            );
    
            // 批量删除数据
            BulkRequest request = new BulkRequest();
    
            request.add(new DeleteRequest().index("user").id("1001"));
            request.add(new DeleteRequest().index("user").id("1002"));
            request.add(new DeleteRequest().index("user").id("1003"));
    
            BulkResponse response = esClient.bulk(request, RequestOptions.DEFAULT);
            System.out.println(response.getTook());
            System.out.println(response.getItems());
    
            esClient.close();
        }
    }

#### 4.5 高级查询 ####

1）简单查询

public class ESTest_Doc_Get {
        public static void main(String[] args) throws Exception {
    
            RestHighLevelClient esClient = new RestHighLevelClient(
                    RestClient.builder(new HttpHost("localhost", 9200, "http"))
            );
    
            // 查询数据
            GetRequest request = new GetRequest();
            request.index("user").id("1001");
            GetResponse response = esClient.get(request, RequestOptions.DEFAULT);
    
            System.out.println(response.getSourceAsString());
    
            esClient.close();
        }
    }

2）各种查询

public class ESTest_Doc_Query {
        public static void main(String[] args) throws Exception {
    
            RestHighLevelClient esClient = new RestHighLevelClient(
                    RestClient.builder(new HttpHost("localhost", 9200, "http"))
            );
    
            // 1. 查询索引中全部的数据
    //        SearchRequest request = new SearchRequest();
    //        request.indices("user");
    //
    //        request.source(new SearchSourceBuilder().query(QueryBuilders.matchAllQuery()));
    //
    //        SearchResponse response = esClient.search(request, RequestOptions.DEFAULT);
    //
    //        SearchHits hits = response.getHits();
    //
    //        System.out.println(hits.getTotalHits());
    //        System.out.println(response.getTook());
    //
    //        for ( SearchHit hit : hits ) {
    //            System.out.println(hit.getSourceAsString());
    //        }
    
            // 2. 条件查询 : termQuery
    //        SearchRequest request = new SearchRequest();
    //        request.indices("user");
    //
    //        request.source(new SearchSourceBuilder().query(QueryBuilders.termQuery("age", 30)));
    //        SearchResponse response = esClient.search(request, RequestOptions.DEFAULT);
    //
    //        SearchHits hits = response.getHits();
    //
    //        System.out.println(hits.getTotalHits());
    //        System.out.println(response.getTook());
    //
    //        for ( SearchHit hit : hits ) {
    //            System.out.println(hit.getSourceAsString());
    //        }
    
            // 3. 分页查询
    //        SearchRequest request = new SearchRequest();
    //        request.indices("user");
    //
    //        SearchSourceBuilder builder = new SearchSourceBuilder().query(QueryBuilders.matchAllQuery());
    //        // (当前页码-1)*每页显示数据条数
    //        builder.from(2);
    //        builder.size(2);
    //        request.source(builder);
    //        SearchResponse response = esClient.search(request, RequestOptions.DEFAULT);
    //
    //        SearchHits hits = response.getHits();
    //
    //        System.out.println(hits.getTotalHits());
    //        System.out.println(response.getTook());
    //
    //        for ( SearchHit hit : hits ) {
    //            System.out.println(hit.getSourceAsString());
    //        }
    
    //        // 4. 查询排序
    //        SearchRequest request = new SearchRequest();
    //        request.indices("user");
    //
    //        SearchSourceBuilder builder = new SearchSourceBuilder().query(QueryBuilders.matchAllQuery());
    //        //
    //        builder.sort("age", SortOrder.DESC);
    //
    //        request.source(builder);
    //        SearchResponse response = esClient.search(request, RequestOptions.DEFAULT);
    //
    //        SearchHits hits = response.getHits();
    //
    //        System.out.println(hits.getTotalHits());
    //        System.out.println(response.getTook());
    //
    //        for ( SearchHit hit : hits ) {
    //            System.out.println(hit.getSourceAsString());
    //        }
    
    //        // 5. 过滤字段
    //        SearchRequest request = new SearchRequest();
    //        request.indices("user");
    //
    //        SearchSourceBuilder builder = new SearchSourceBuilder().query(QueryBuilders.matchAllQuery());
    //        //
    //        String[] excludes = {"age"};
    //        String[] includes = {};
    //        builder.fetchSource(includes, excludes);
    //
    //        request.source(builder);
    //        SearchResponse response = esClient.search(request, RequestOptions.DEFAULT);
    //
    //        SearchHits hits = response.getHits();
    //
    //        System.out.println(hits.getTotalHits());
    //        System.out.println(response.getTook());
    //
    //        for ( SearchHit hit : hits ) {
    //            System.out.println(hit.getSourceAsString());
    //        }
    
    //        // 6. 组合查询
    //        SearchRequest request = new SearchRequest();
    //        request.indices("user");
    //
    //        SearchSourceBuilder builder = new SearchSourceBuilder();
    //        BoolQueryBuilder boolQueryBuilder = QueryBuilders.boolQuery();
    //
    //        //boolQueryBuilder.must(QueryBuilders.matchQuery("age", 30));
    //        //boolQueryBuilder.must(QueryBuilders.matchQuery("sex", "男"));
    //        //boolQueryBuilder.mustNot(QueryBuilders.matchQuery("sex", "男"));
    //        boolQueryBuilder.should(QueryBuilders.matchQuery("age", 30));
    //        boolQueryBuilder.should(QueryBuilders.matchQuery("age", 40));
    //
    //        builder.query(boolQueryBuilder);
    //
    //        request.source(builder);
    //        SearchResponse response = esClient.search(request, RequestOptions.DEFAULT);
    //
    //        SearchHits hits = response.getHits();
    //
    //        System.out.println(hits.getTotalHits());
    //        System.out.println(response.getTook());
    //
    //        for ( SearchHit hit : hits ) {
    //            System.out.println(hit.getSourceAsString());
    //        }
    
    //        // 7. 范围查询
    //        SearchRequest request = new SearchRequest();
    //        request.indices("user");
    //
    //        SearchSourceBuilder builder = new SearchSourceBuilder();
    //        RangeQueryBuilder rangeQuery = QueryBuilders.rangeQuery("age");
    //
    //        rangeQuery.gte(30);
    //        rangeQuery.lt(50);
    //
    //        builder.query(rangeQuery);
    //
    //        request.source(builder);
    //        SearchResponse response = esClient.search(request, RequestOptions.DEFAULT);
    //
    //        SearchHits hits = response.getHits();
    //
    //        System.out.println(hits.getTotalHits());
    //        System.out.println(response.getTook());
    //
    //        for ( SearchHit hit : hits ) {
    //            System.out.println(hit.getSourceAsString());
    //        }
    
            // 8. 模糊查询
    //        SearchRequest request = new SearchRequest();
    //        request.indices("user");
    //
    //        SearchSourceBuilder builder = new SearchSourceBuilder();
    //        builder.query(QueryBuilders.fuzzyQuery("name", "wangwu").fuzziness(Fuzziness.TWO));
    //
    //        request.source(builder);
    //        SearchResponse response = esClient.search(request, RequestOptions.DEFAULT);
    //
    //        SearchHits hits = response.getHits();
    //
    //        System.out.println(hits.getTotalHits());
    //        System.out.println(response.getTook());
    //
    //        for ( SearchHit hit : hits ) {
    //            System.out.println(hit.getSourceAsString());
    //        }
    
    //        // 9. 高亮查询
    //        SearchRequest request = new SearchRequest();
    //        request.indices("user");
    //
    //        SearchSourceBuilder builder = new SearchSourceBuilder();
    //        TermsQueryBuilder termsQueryBuilder = QueryBuilders.termsQuery("name", "zhangsan");
    //
    //        HighlightBuilder highlightBuilder = new HighlightBuilder();
    //        highlightBuilder.preTags("<font color='red'>");
    //        highlightBuilder.postTags("</font>");
    //        highlightBuilder.field("name");
    //
    //        builder.highlighter(highlightBuilder);
    //        builder.query(termsQueryBuilder);
    //
    //        request.source(builder);
    //        SearchResponse response = esClient.search(request, RequestOptions.DEFAULT);
    //
    //        SearchHits hits = response.getHits();
    //
    //        System.out.println(hits.getTotalHits());
    //        System.out.println(response.getTook());
    //
    //        for ( SearchHit hit : hits ) {
    //            System.out.println(hit.getSourceAsString());
    //        }
    
    //        // 10. 聚合查询
    //        SearchRequest request = new SearchRequest();
    //        request.indices("user");
    //
    //        SearchSourceBuilder builder = new SearchSourceBuilder();
    //
    //        AggregationBuilder aggregationBuilder = AggregationBuilders.max("maxAge").field("age");
    //        builder.aggregation(aggregationBuilder);
    //
    //        request.source(builder);
    //        SearchResponse response = esClient.search(request, RequestOptions.DEFAULT);
    //
    //        SearchHits hits = response.getHits();
    //
    //        System.out.println(hits.getTotalHits());
    //        System.out.println(response.getTook());
    //
    //        for ( SearchHit hit : hits ) {
    //            System.out.println(hit.getSourceAsString());
    //        }
    
            // 11. 分组查询
            SearchRequest request = new SearchRequest();
            request.indices("user");
    
            SearchSourceBuilder builder = new SearchSourceBuilder();
    
            AggregationBuilder aggregationBuilder = AggregationBuilders.terms("ageGroup").field("age");
            builder.aggregation(aggregationBuilder);
    
            request.source(builder);
            SearchResponse response = esClient.search(request, RequestOptions.DEFAULT);
    
            SearchHits hits = response.getHits();
    
            System.out.println(hits.getTotalHits());
            System.out.println(response.getTook());
    
            for ( SearchHit hit : hits ) {
                System.out.println(hit.getSourceAsString());
            }
    
    
    
            esClient.close();
        }
    }

[Elasticsearch]: https://so.csdn.net/so/search?q=Elasticsearch&spm=1001.2101.3001.7020
[Link 1]: https://so.csdn.net/so/search?q=%E6%8A%80%E6%9C%AF%E6%A0%88&spm=1001.2101.3001.7020
[image-20210802140132106]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/23/cc2bfaca68da4d2786808bcfc7f9322f.png
[image-20210802151943787]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/23/495bd7446a8c4a85a448add028433e22.png
[image-20210802155152473]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/23/2ffe9049e878402f81d43033456e9950.png
[image-20210803091841387]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/23/a16ff27957754b4e89a5cb0fb5c2c995.png