后端開發必備：ElasticSearch入門與進階
ES 是一個分布式的開源搜索和分析引擎，適用于文本、數字、地理空間、結構化數據、非結構化數據等數據的搜索。ES 是在 Apache Lucene 的基礎上完成開發。由 Elastic 于 2010 年發布。ES 通過其簡單的 REST 風格的 API、分布式特性、速度和可擴容聞名世界。是 Elastic Stack 的核心組件。Elastic Stack 是一套用于數據采集、擴充、保存、分析、可視化的開源工具。Elastic Stack 稱之為 ELK。目前 ELK 包含一系列豐富的輕量數據采集代理，這些代理被稱之為 Beats。
ES 的用途
主要有以下的用途：
? 應用程序搜索
? 網站搜索
? 企業搜索
? 日志處理
? 基礎設施指標和容器監測
? 應用程序性能監測
? 地理空間數據分析和可視化
? 安全分析
? 業務分析
工作原理
從多個來源輸入到 ES 中，數據在 ES 中進行索引和解析，標準化并充實這些數據。這些數據在 ES 中索引完成之后，用戶就可以針對他們的數據進行復雜的查詢，并使用聚合來檢索這些數據，在 Kibana 中，用戶可以創建數據可視化面板，并對 ELK 進行管理。
索引
ES 索引是指相互關聯的文檔集合。ES 是會以 JSON 文檔的形式保存數據，每個文檔都會在一組鍵值對中建立聯系。
ES 使用的是一種倒排序索引的數據結構。這個結構可以允許十分快速的進行全文本的搜索。
在索引的過程中，ES 會保存文檔并構建倒排序索引，這樣用戶就可以實時的對文檔數據進行搜索。索引是在添加過程中就啟動的。
Logstash
Logstash 是 ELK 的核心菜品，可以對數據進行聚合和處理。并將數據發送到 ES 中。Logstash 是一個開源的服務器端數據處理管道。
Kibana
Kibana 是一款 ES 的數據可視化和管理工具，可以提供直方圖，線形圖，餅狀圖，地圖。Kibana 還包含 Canvas 和 Elastic Maps 等應用程序。Canvas 可以基于用戶創建動態信息。Elastic Maps 可以對空間數據進行可視化處理。
為什么要使用 ES
? ES 很快：ES 是在 Lucene 基礎上構建，所以全文本搜索相當的出色。ES 還是一個實時搜索平臺。文檔索引操作到文檔變為可搜索之間速度很快。
? ES 具有分布式的特征：ES 中保存的文檔分布在不同的容器中，這些容器為分片，可以對分片進行復制并形成冗余副本。ES 可以擴充到數百臺，并處理 PB 級別的數據。
? ES 包含一系列廣泛的功能：ES 擁有大量的內置功能，方便用戶管理數據。
? ES 簡化了數據采集，可視化報告的過程：通過與 Beats 和 Logstash 集成，用戶可以在 ES 中索引數據并處理數據，
ES 搭建
安裝鏡像：
docker pull docker.elastic.co/elasticsearch/elasticsearch:7.3.2啟動容器：
docker run -d --name es -p 9200:9200 -p 9300:9300 -e "discovery.type=single-node" docker.elastic.co/elasticsearch/elasticsearch:7.3.2修改配置：
#進入 docker 容器內部
docker exec -it es /bin/bash
#打開配置文件
vim config/elasticsearch.yml
## 加入跨域配置
http.cors.enabled: true
http.cors.allow-origin: "*"進入容器，安裝分詞器：
docker exec -it es /bin/bash
./bin/elasticsearch-plugin install https://github.com/medcl/elasticsearch-analysis-ik/releases/download/v7.3.2/elasticsearch-analysis-ik-7.3.2.zip重啟 ES：
docker restart es測試：
圖片
查看分詞器是否安裝上：
圖片
ES 查詢
空查詢
空查詢將會返回一個索引庫中所有文檔：
curl -X GET "localhost:9200/_search?pretty" -H 'Content-Type: application/json' -d'
{}
'在一個或者多個索引庫或者所有的 _type 中查詢：
GET /index_2014*/type1,type2/_search
{}使用分頁：
GET /_search
{
"from": 30,
"size": 10
}查詢表達式
只需要在查詢上，將語句傳遞給 queue 參數：
GET /_search
{
"query": YOUR_QUERY_HERE
}查詢語句的結構
一個查詢的典型結構：
{
QUERY_NAME: {
ARGUMENT: VALUE,
ARGUMENT: VALUE,...
}
}針對某個字段：
{
QUERY_NAME: {
FIELD_NAME: {
ARGUMENT: VALUE,
ARGUMENT: VALUE,...
}
}
}如果想要使用 match 查詢 tewwt 字段中包含 elasticsesh 的內容。
curl -X GET "localhost:9200/_search?pretty" -H 'Content-Type: application/json' -d'
{
"query": {
"match": {
"tweet": "elasticsearch"
}
}
}
'合并查詢
分為葉子語句，被用于將查詢字符串和字段進行對比，復合語句用于合并其他查詢語句。
例如下面語句：找出信件正文包含 business opportunity 的星標郵件，或者在郵件正文包含 business opportunity 的非垃圾郵件：
{
"bool": {
"must": { "match": { "email": "business opportunity" }},
"should": [
{ "match": { "starred": true }},
{ "bool": {
"must": { "match": { "folder": "inbox" }},
"must_not": { "match": { "spam": true }}
}}
],
"minimum_should_match": 1
}
}常用查詢
match_all 查詢
該查詢匹配所有文檔：
{ "match_all": {}}match 查詢
用于使用分詞器進行查詢：
{ "match": { "tweet": "About Search" }}multi_match 查詢
用于在多個字段上執行相同更多 match 查詢：
{
"multi_match": {
"query": "full text search",
"fields": [ "title", "body" ]
}
}range 查詢
用于找出在指定區間內的數字或者時間：
{
"range": {
"age": {
"gte": 20,
"lt": 30
}
}
}term 查詢
用于進行精確匹配：
{ "term": { "age": 26 }}
{ "term": { "date": "2014-09-01" }}
{ "term": { "public": true }}
{ "term": { "tag": "full_text" }}terms 查詢
用于進行多值匹配：
{ "terms": { "tag": [ "search", "full_text", "nosql" ] }}exists 查詢和 missing 查詢
用于查詢在指定字段中有值或者無值的文檔：
{
"exists": {
"field": "title"
}
}ES 索引
創建一個索引
PUT /my_index
{
"settings": { ... any settings ... },
"mappings": {
"type_one": { ... any mappings ... },
"type_two": { ... any mappings ... },
...
}
}此刻，ES 會自動創建一個索引。
刪除一個索引
DELETE /my_index索引設置
? number_of_shards：每個索引的主分片數
? number_of_replicas：每個主分片的副本數
創建只有 一個主分片，沒有副本的小索引：
PUT /my_temp_index
{
"settings": {
"number_of_shards" : 1,
"number_of_replicas" : 0
}
}配置分析器
standard 分析器是用于全文字段的默認分析器，包含以下部分：
? standard 分詞器，通過單詞邊界分割輸入的文本。
? standard 語匯單元過濾器，目的是整理分詞器觸發的語匯單元（但是目前什么都沒做）。
? lowercase 語匯單元過濾器，轉換所有的語匯單元為小寫。
? stop 語匯單元過濾器，刪除停用詞—對搜索相關性影響不大的常用詞，如 a、the、and、is。
在下面的例子中，創建了一個新的分析器 es_std，并使用預定義的西班牙語停用詞列表。
PUT /spanish_docs
{
"settings": {
"analysis": {
"analyzer": {
"es_std": {
"type": "standard",
"stopwords": "_spanish_"
}
}
}
}
}進行測試：
curl -X GET "localhost:9200/spanish_docs/_analyze?analyzer=es_std&pretty" -H 'Content-Type: application/json' -d'
El veloz zorro marrón
'通過結果進行查看：
{
"tokens" : [
{ "token" : "veloz", "position" : 2 },
{ "token" : "zorro", "position" : 3 },
{ "token" : "marrón", "position" : 4 }
]
}自定義分析器
在 analysis 下的相應位置設置字符過濾器，分詞過濾器，詞單元過濾器。
PUT /my_index
{
"settings": {
"analysis": {
"char_filter": { ... custom character filters ... },
"tokenizer": { ... custom tokenizers ... },
"filter": { ... custom token filters ... },
"analyzer": { ... custom analyzers ... }
}
}
}接著創建一個自定義分析器，用于清楚 html 部分，將 & 映射為 and：
"char_filter": {
"&_to_and": {
"type": "mapping",
"mappings": [ "&=> and "]
}
}使用標準分詞器諷刺，小寫詞條使用小寫過濾，使用自定義停止詞過濾器移除自定義的停止詞列表中包含的詞。
"filter": {
"my_stopwords": {
"type": "stop",
"stopwords": [ "the", "a" ]
}
}最后使用分析器，自定義組合過濾器和分詞器。
"analyzer": {
"my_analyzer": {
"type": "custom",
"char_filter": [ "html_strip", "&_to_and" ],
"tokenizer": "standard",
"filter": [ "lowercase", "my_stopwords" ]
}
}總和如下所示：
curl -X PUT "localhost:9200/my_index?pretty" -H 'Content-Type: application/json' -d'
{
"settings": {
"analysis": {
"char_filter": {
"&_to_and": {
"type": "mapping",
"mappings": [ "&=> and "]
}},
"filter": {
"my_stopwords": {
"type": "stop",
"stopwords": [ "the", "a" ]
}},
"analyzer": {
"my_analyzer": {
"type": "custom",
"char_filter": [ "html_strip", "&_to_and" ],
"tokenizer": "standard",
"filter": [ "lowercase", "my_stopwords" ]
}}
}}}
'測試一下：
curl -X GET "localhost:9200/my_index/_analyze?analyzer=my_analyzer&pretty" -H 'Content-Type: application/json' -d'
The quick & brown fox
'可以看到結果如下所示：
{
"tokens" : [
{ "token" : "quick", "position" : 2 },
{ "token" : "and", "position" : 3 },
{ "token" : "brown", "position" : 4 },
{ "token" : "fox", "position" : 5 }
]
}最后，把這個分詞器用在 string 字段上：
curl -X PUT "localhost:9200/my_index/_mapping/my_type?pretty" -H 'Content-Type: application/json' -d'
{
"properties": {
"title": {
"type": "string",
"analyzer": "my_analyzer"
}
}
}
'類型和映射
Lucene 如何處理文檔
在 Lucene 中一個文檔由鍵值對組成。在索引文檔的時候，每個字段的值都會添加到相關字段的倒排序中。
類型如何實現
每個文檔的類型名稱將會保存在 _type 字段上，當要檢索字段的時候，ES 會自動在 _type 字段上檢索。
例如在 User 類型中，name 字段會映射聲明為 string 類型，并索引到 name 的倒排序中，需要使用 whitespace 分詞器分析。
"name": {
"type": "string",
"analyzer": "whitespace"
}Lucene 索引的每個字段都包含一個單一的扁平的模式
在 Lucene 中，一個特定的字段可以映射到 string 類型或者是 number 類型，但是不能兩者兼具。因為 ES 添加的優于 lucene 的額外機制（以元數據 _type 字段的形式。）在 ES 中所有類型都最終共享相同的映射。
{
"data": {
"mappings": {
"people": {
"properties": {
"name": {
"type": "string",
},
"address": {
"type": "string"
}
}
},
"transactions": {
"properties": {
"timestamp": {
"type": "date",
"format": "strict_date_optional_time"
},
"message": {
"type": "string"
}
}
}
}
}
}在上方中，"name"/"address" 和 "timestamp"/"message" 雖然是獨立的，但是在 Lucene 中是一個映射。
{
"data": {
"mappings": {
"_type": {
"type": "string",
"index": "not_analyzed"
},
"name": {
"type": "string"
}
"address": {
"type": "string"
}
"timestamp": {
"type": "long"
}
"message": {
"type": "string"
}
}
}
}對于整個索引，映射在本質上被 扁平化 成一個單一的、全局的模式。
Java 連接 ES
添加依賴：
<!-- TransportClient 依賴包-->
<dependency>
<groupId>org.elasticsearch.client</groupId>
<artifactId>transport</artifactId>
<version>6.2.2</version>
</dependency>
<!-- 測試包，與 JAVA 連接 ES 無關 -->
<dependency>
<groupId>junit</groupId>
<artifactId>junit</artifactId>
<version>4.12</version>
<scope>test</scope>
</dependency>創建 ES 集群：
圖片
連接 ES：
package cn.zsm.es;
import org.elasticsearch.client.transport.TransportClient;
import org.elasticsearch.common.settings.Settings;
import org.elasticsearch.common.transport.TransportAddress;
import org.elasticsearch.transport.client.PreBuiltTransportClient;
import org.junit.Before;
import org.junit.Test;
import java.net.InetAddress;
import java.net.UnknownHostException;
public class JavaEsTest {
private String IP;
private int PORT;
@Before
public void init(){
this.IP = "192.168.？.？";
this.PORT = 9300;
}
@Test
public void esClient(){
try {
Settings settings = Settings.builder().put("cluster.name", "my-application").build();
TransportClient client = new PreBuiltTransportClient(settings)
.addTransportAddresses(new TransportAddress(InetAddress.getByName(IP), PORT));
System.out.println(client.toString());
} catch (UnknownHostException e) {
e.printStackTrace();
}
}
}測試結果：
圖片
