Elasticsearch 的官方地址: Elasticsearch官网
下载地址:下载地址
我们选择7.8.0版本
Elasticsearch 分为 Linux 和 Windows 版本,基于我们主要学习的是 Elasticsearch 的 Java客户端的使用,所以,本次使用的是安装较为简便的 Windows 版本 。
Windows 版的 Elasticsearch 的安装很简单,解压即安装完毕,解压后的 Elasticsearch 的目录结构如下:
解压后,进入bin 文件目录,点击 elasticsearch.bat 文件启动 ES 服务
注意:
9300 端口为 Elasticsearch 集群间组件的通信端口, 9200 端口为浏览器访问的 http协议 RESTful 端口。
打开浏览器(推荐使用谷歌浏览器),输入地址:http://localhost:9200/ ,测试结果
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
二、Elasticsearch基本操作
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 客户端安装如果直接通过浏览器向Elasticsearch 服务器发请求,那么需要在发送的请求中包含HTTP 标准的方法,而 HTTP 的大部分特性且仅支持 GET 和 POST 方法。
所以为了能方便地进行客户端的访问,可以使用 Postman 软件。Postman是一款强大 的 网页调试工具,提供功能强大的 Web API 和 HTTP 请求调试。
软件功能强大,界面简洁明晰、操作方便快捷,设计得很人性化。 Postman 中文版能够发送任何类型的 HTTP 请求 (GET, POST, PUT..) ,
不仅能够表单提交,且可以附带任意类型请求体。
Postman官网: https://www.postman.com/
Postman下载: https://www.postman.com/downloads/
Elasticsearch 是面向文档型数据库,一条数据在这里就是一个文档。 为了方便大家理解,
我们将 Elasticsearch 里 存储 文档 数据和关系型数据库 MySQL 存储数据的概念进行一个类比。
ES里的 Index 可以看做一个库,而 Types 相当于表, Documents 则相当于表的行。这里Types 的概念已经被逐渐弱化,
Elasticsearch 6.X 中,一个 index 下已经只能包含一个type Elasticsearch 7.X 中 , Type 的概念已经被删除了。
用 JSON 作为文档序列化的格式,比如一条用户信息:
{
"name" : "
"sex" : "Male",
"age" :
"birthDate": "1990/05/
"about" : "I love to go rock
"interests": [ "sports", "music"
}
2.4 HTTP操作
2.4.1 索引操作
1. 创建索引
对比关系型数据库,创建索引就等同于创建数据库
在Postman 中,向 ES 服务器发 PUT 请求 http://127.0.0.1:9200/shopping
请求后,服务器返回响应
如果重复添加索引,会返回错误信息
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 的意义,
请求后,服务器响应结果如下:
4.删除索引
在Postman 中,向 ES 服务器发 DELETE 请求 http://127.0.0.1:9200/shopping
重新访问索引时,服务器返回响应:索引不存在
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 ,否则会发生错误
服务器响应结果如下:
上面的数据创建后,由于没有指定数据唯一性标识(ID ),默认情况下 ES 服务器会随机生成一个 。
如果想要自定义唯一性标识,需要在创建时指定 。
此处需要注意:如果增加数据时明确数据主键,那么请求方式也可以为PUT
2. 查看文档
查看文档时,需要指明文档的唯一性标识,类似于MySQL 中数据的主键查询在Postman 中,向 ES 服务器发 GET 请求 http://127.0.0.1:9200/shopping/_doc/1
3. 修改文档
和新增文档一样,输入相同的URL 地址请求,如果请求体变化,会将原有的数据内容覆盖
在Postman 中,向 ES 服 务器发 POST 请求 http://127.0.0.1:9200/shopping/_doc/1
请求体内容为
{
"title": "华为手机",
"category": "华为",
"images": "http://www.gulixueyuan.com/xm.jpg",
"price": 4999.00
}
修改成功后,服务器响应结果:
4、修改字段
修改数据时,也可以只修改某一条数据的局部信息
在Postman 中,向 ES 服务器发 POST 请求 http://127.0.0.1:9200/shopping/_update/1
请求体内容为:
{
"doc": {
"price": 3000.00
}
}
修改成功后,服务器响应结果:
根据唯一性标识,查询文档数据,文档数据已经更新
5. 删除文档
删除一个文档不会立即从磁盘上移除,它只是被标记成已删除(逻辑删除)。
在Postman 中,向 ES 服务器发 DELETE 请求:http://127.0.0.1:9200/shopping/_doc/1
删除成功,服务器响应结果:
删除后再查询当前文档信息
如果删除一个并不存在的文档
6. 条件删除文档
一般删除数据都是根据文档的唯一性标识进行删除,实际操作时,也可以根据条件对多条数据进行删除
首先分别增加多条数据
{
"title":"小米手机",
"category": "小米",
"images": "http://www.gulixueyuan.com/xm.jpg",
"price": 4000.00
}
{
"title":"华为手机",
"category":"华为",
"images": "http://www.gulixueyuan.com/ hw.jpg",
"price": 4000.00
}
向ES 服务器发 POST 请求 http://127.0.0.1:9200/shopping/_delete_by_query
删除成功后,服务器响应结果:
有了索引库,等于有了数据库中的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
}
}
}
映射数据说明:
字段名:任意填写,下面指定许多属性,例如: 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
}
}
}
}
Elasticsearch提供了基于 JSON
提供完整的查询 DSL 来定义查询
定义数据:
# Post http://127.0.0.1:9200/student/_doc/1001
{
"name": "zhangsan",
"nickname": "zhangsan",
"sex": "男",
"age": 30
}
# Post http://127.0.0.1:9200/student/_doc/1002
{
"name": "lisi",
"nickname": "lisi",
"sex": "男",
"age": 20
}
# Post http://127.0.0.1:9200/student/_doc/1003
{
"name": "wangwu",
"nickname": "wangwu",
"sex": "女",
"age": 40
}
# Post http://127.0.0.1:9200/student/_doc/1004
{
"name": "zhangsan1",
"nickname": "zhangsan1",
"sex": "女",
"age": 50
}
# Post http://127.0.0.1:9200/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 等等
# {查询条件}:查询条件会根据类型的不同,写法也有差异
2. 匹配查询
match匹配类型查询,会把查询条件进行分词,然后进行查询,多个词条之间是 or 的关系
在Postman 中,向 ES 服务器发 GET 请求 http://127.0.0.1:9200/student/_search
服务器响应结果为:
{
"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 查询允许以下字符
在Postman 中,向 ES 服务器发 GET 请求 http://127.0.0.1:9200/student/_search
{
"query": {
"range": {
"age": {
"gte": 30,
"lt": 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": {
"name": {
"value": "zhangsan"
}
}
}
}
{
"query": {
"fuzzy": {
"name": {
"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 属性:
1. pre_tags :前置标签
2. post_tags :后置标签
3. fields :需要高亮的字段
4. title :这里声明 title 字段需要高亮,后面可以为这个字段设置特有配置, 也可以空
在Postman 中,向 ES 服务器发 GET 请求 http://127.0.0.1:9200/student/_search
{
"query": {
"match": {
"name": "zhangsan"
}
},
"highlight": {
"pre_tags": "",
"post_tags": "",
"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"}
}
}
}
对某个字段取最小值 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
}
在term分组下再进行聚合
在Postman 中,向 ES 服务器发 GET 请求 http://127.0.0.1:9200/student/_search
{
"aggs": {
"age_groupby": {
"terms": {"field": "age"},
"aggs": {
"sum_age": {
"sum": {"field": "age"}
}
}
}
},
"size": 0
}
视频教程