马士兵

Elasticsearch支持3种脚本语言：Groovy(1.4.x - 5.0 )、painless、experssion。Groovy： 安全性问题Elasticsearch5.0以后已经放弃。painless：painless是一种专门用于Elasticsearch的简单,用于内联和存储脚本，类似于Java,也有注释、关键字、类型、变量、函数等，安全的脚本语言。它是Elasticsearch的默认脚本语言，可以安全地用于内联和存储脚本。expression: 每个文档的开销较低：表达式的作用更多，可以非常快速地执行，甚至比编写native脚本还要快，支持javascript语法的子集：单个表达式。缺点：只能访问数字，布尔值，日期和geo_point字段，存储的字段不可用.

脚本模板：

使用 painless 脚本将 _index 为“order”_id 为 “1”的premium 字段减1

使用 painless 脚本将 _index 为“order”_id 为 “1”的tenderAddress字段后面拼接一个字符串”666”

使用 painless 脚本删除 _index 为“order”_id 为 “1”的doc

upsert是update+insert的简写。所以使用upsert后，如果doc存在的话则是更新操作， 如果doc不存在则是插入操作。 _index 为“order”_id 为 “1”的doc下的tags字段是一个数组。

使用expression表达式查询一个premium字段

使用expression表达式对premium字段打9折

使用painless 查询一个premium字段打9折、打8折，使用参数

Stored script

先保存一个script模板

使用模板

使用自定义脚本，类似于存储过程，可以在里面写一些逻辑， if for 或者一些自定义运算。

查找premium大于等于10小于等于205的数据，并统计查找到的数据的insuranceCompany字段字符的总数。

GET my-index/_analyze { “analyzer”: “my-analyzer”, “text”: [“666&77&&8||”] }

{ “tokens” : [ { “token” : “666and77and8or”, “start_offset” : 0, “end_offset” : 11, “type” : “word”, “position” : 0 } ] }

hello word

GET my-index3/_analyze { “analyzer”: “my-analyzer”, “text”: “My credit card is 123-456-789” }

结果： { “tokens” : [ { “token” : “My”, “start_offset” : 0, “end_offset” : 2, “type” : ““, “position” : 0 }, { “token” : “credit”, “start_offset” : 3, “end_offset” : 9, “type” : ““, “position” : 1 }, { “token” : “card”, “start_offset” : 10, “end_offset” : 14, “type” : ““, “position” : 2 }, { “token” : “is”, “start_offset” : 15, “end_offset” : 17, “type” : ““, “position” : 3 }, { “token” : “123_456_789”, “start_offset” : 18, “end_offset” : 29, “type” : ““, “position” : 4 } ] }

带脚本的

停用词

ik是一个java项目，使用maven构建，我们把它clone下来，使用maven命令package。在target/release/下面有个zip文件。elasticsearch-analysis-ik-7.4.0.zip把 elasticsearch-analysis-ik-7.4.0.zip解压后是这个样子将这些文件全部copy至{``ES_source_path``}``/plugins/ik文件夹下面（需要在plugins下面创建ik文件夹）。然后重启Elasticsearch。

测试 ik中文分词器 ：

安装过程中可能遇到的问题：

java.lang.IllegalArgumentException: Plugin [analysis-ik] was built for Elasticsearch version 7.10.0 but version 7.10.1 is running

一看就是ik和Elasticsearch版本不匹配，我们需要把ik分词器内的Elasticsearch版本改为ik对应的版本。编辑plugin-descriptor.properties文件：里面有个“elasticsearch.version” 将它改为Elasticsearch版本即可。

ik_max_word：细粒度，一般都使用这个。ik_smart：粗粒度

方案一：修改IK源码，定时链接数据库，查询主词和停用词，更新到本机IK中。

方案二：定时调接口目前该插件支持热更新 IK 分词，通过在 IKAnalyzer.cfg.xml 配置文件中提到的如下配置

其中 words_location 是指一个 URL接口地址，该请求只需满足以下两点即可完成分词热更新。

满足上面两点要求就可以实现热更新分词了，不需要重启 ES 实例。

下面是用spring boot模拟的一个接口：

官网的资料才是最新的，最全的：https://www.elastic.co/guide/en/elasticsearch/client/java-rest/current/java-rest-overview.html

引入maven

创建索引结果: true插入数据结果: IndexResponse[index=order1,type=_doc,id=1,version=1,result=created,seqNo=0,primaryTerm=1,shards={“total”:3,”successful”:1,”failed”:0}] 查询数据结果: {“_index”:”order1”,”_type”:”_doc”,”_id”:”1”,”_version”:1,”found”:true,”_source”:{“createTime”:”2020-02-02 12:00:00”,”name”:”王帆”,”id”:1,”age”:28,”email”:”[email protected]”},”fields”:{“_seq_no”:[0],”_primary_term”:[1]}}修改数据结果: UpdateResponse[index=order1,type=_doc,id=1,version=2,seqNo=1,primaryTerm=1,result=updated,shards=ShardInfo{total=3, successful=1, failures=[]}]查询数据结果: {“_index”:”order1”,”_type”:”_doc”,”_id”:”1”,”_version”:2,”found”:true,”_source”:{“createTime”:”2020-02-02 12:00:00”,”name”:”王帆”,”id”:1,”age”:29,”email”:”[email protected]”},”fields”:{“_seq_no”:[1],”_primary_term”:[1]}}删除数据结果: DeleteResponse[index=order1,type=_doc,id=1,version=3,result=deleted,shards=ShardInfo{total=3, successful=1, failures=[]}]删除索引结果: true批量操作结果: org.elasticsearch.action.bulk.BulkResponse@793be5ca

配置文件说明：

整个集群的名称，整个集群使用一个名字，其他节点通过cluster.name发现集群。

集群内某个节点的名称，其他节点可通过node.name发现节点，默认是机器名。

数据存放地址，生产环境必须不能设置为es内部，否则es更新时会直接抹除数据

日志存在地址，生产环境必须不能设置为es内部，否则es更新时会直接抹除数据

是否禁用swap交换区(swap交换区为系统内存不够时使用磁盘作为临时空间)， 生产环境必须禁用

当前节点绑定的Ip地址，切记一旦指定，则必须是这个地址才能访问，比如：如果配置为，127.0.0.1， 则必须只能是127.0.0.1才能访问， localhost 也不行。

当前节点的服务端口号

当前节点的通讯端口号，集群内节点之间通讯使用此端口号， 比如选举master节点时。

必须把所有master节点的地址+端口都写进去。

集群初始化时会从这个列表中取出一个node.name选为master节点。

整个集群搭建模型：

机器内网ip：172.27.229.9集器外网ip：8.140.122.156

node01 配置：

node02 配置：

node03 配置：

node04 配置：

node05 配置：

node05 配置：