2. 程式人生 > >ElasticSearch 入門總結

ElasticSearch 入門總結

阿新 • • 發佈：2018-12-25

ElasticSearch 入門

本篇為 ElasticSearch 入門學習總結筆記，課程視訊地址：ElasticSearch 入門

一、ElasticSearch 簡介

1.1、什麼是ElasticSearch

​ 簡稱 ES

  • 基於Apache Lucene 構建的 開源搜尋引擎，提供一個分散式多使用者能力的全文搜尋引擎
  • 採用 JAVA 編寫的 ，提供簡單易用的 RESTFul API（RESTFul web介面），當前流行的企業級搜尋引擎
  • 輕鬆的 橫向擴充套件，可支援PB級 的結構化或非結構化資料處理
  • 可以準實時地快速儲存、搜尋、分析海量的資料。（用於雲端計算中，能夠達到實時搜尋）

1.2、應用場景

  • 海量資料分析引擎（聚合搜尋）
  • 站內搜尋引擎
  • 資料倉庫

1.3、誰在用ES呢?

英國衛報— 實時分析公眾對文章的迴應

維基百科、GitHub - 站內實時搜尋

百度—實時日誌監控平臺

阿里、Google、小米、京東….

1.4、環境要求

工具 版本
IDE IDEA或Eclipse
JAVA JDK8
Maven 3.x 以上
NodeJS 6.0以上

二、ElasticSearch 安裝

2.1、ES版本問題

  • 版本歷史 ： 1.x-》2.x-》5.x -》最新6.0
  • 版本選擇 ： 選擇6.0進行演練！

2.2、ES安裝-單例項

下載地址：ES Downloads，windows環境下載 ZIP sha ，Linux或者Mac環境下，下載TAR sha。

2.2.1 單例項的安裝(Windows)

1、下載ES zip包

2、安裝Jdk8,並檢視環境變數配置

3、解壓ES包

  • 目錄說明：
目錄名 說明
config 配置檔案
modules 模組存放目錄
bin 指令碼
lib 第三方庫
plugins 第三方外掛

4、啟動驗證服務

​ windows環境在/bin 下載雙擊 elasticsearch.bat

。啟動成功，看到starting….最後是started！

[2018-08-18T22:18:41,578][INFO ][o.e.n.Node               ] [-Jy0w6-] starting ...
[2018-08-18T22:18:44,044][INFO ][o.e.t.TransportService   ] [-Jy0w6-] publish_address {127.0.0.1:9300}, bound_addresses {127.0.0.1:9300}, {[::1]:9300}
{ml.machine_memory=8441524224, xpack.installed=true, ml.max_open_jobs=20, ml.enabled=true}, reason: apply cluster state (from master [master {-Jy0w6-}{-Jy0w6-QTKquaudbtTAQMQ}
[2018-08-18T22:18:48,923][INFO ][o.e.x.s.t.n.SecurityNetty4HttpServerTransport] [-Jy0w6-] publish_address {127.0.0.1:9200}, bound_addresses {127.0.0.1:9200}, {[::1]:9200}
[2018-08-18T22:18:48,924][INFO ][o.e.n.Node               ] [-Jy0w6-] started

訪問ElasticSeach

2.2.2 實用外掛Head安裝（Windows）

ES 預設返回的資訊在頁面上是Json格式顯示!不太友好！

Head外掛的優點：

  • 提供了友好的web介面，解決資料在介面顯示問題
  • 實現基本資訊的檢視和Restful 請求的模擬以及資料的基本檢索

1、安裝Head的步驟

​ 1）、安裝Node 6.x以上J環境，安裝 執行指令npm install -g grunt -cli進行安裝grunt。

​ 2）、 下載elasticsearch-head包，在Github【elasticsearch-head】上面,直接選擇下載的DownLoad zip到本地！

​ 3）、儲存在 F:\elasticsearch_learn\ 資料夾下面並對 elasticsearch-head 進行解壓！

​ 4）、在 F:\elasticsearch_learn\elasticsearch-head-master資料夾目錄下面，使用 npm install ! 

F:\elasticsearch_learn\elasticsearch-head-master>npm install

注意：第一次==執行失敗了！==報了下面的錯誤（可能是網路不好的原因，網路好的時候在嘗試執行一次），但是服務啟動沒有問題！

npm WARN optional SKIPPING OPTIONAL DEPENDENCY: [email protected]^1.0.0 
npm ERR! node v6.10.3
npm ERR! npm  v3.10.10
npm ERR! code ELIFECYCLE
npm ERR! [email protected]2.1.16 install: `node install.js`
npm ERR! Exit status 1
....
npm ERR! Please include the following file with any support request:
npm ERR!     F:\elasticsearch_learn\elasticsearch-head-master\npm-debug.log

​ 5）、doc視窗 在 F:\elasticsearch_learn\elasticsearch-head-master資料夾目錄下面執行

 # npm run start  或者  grunt server 
 F:\elasticsearch_learn\elasticsearch-head-master>npm run start

啟動elasticsearch-head並驗證

2、修改相應的配置

ElasticSearch和 elasticsearch-head 本質上是兩個服務程序，訪問存在跨域問題，需要進行一些設定。

在 elasticsearch安裝目錄 /config/elasticsearch.yml ,在這個配置檔案的末尾追加下面兩行配置資訊並儲存！

http.cors.enabled: true
http.cors.allow-origin: "*"
屬性 預設值 描述
http.cors.enabled true 如果啟用了 HTTP 埠，那麼此屬性會指定是否允許跨源 REST 請求。
http.cors.allowed.origin localhost 如果 http.cors.enabled 的值為 true，那麼該屬性會指定允許 REST 請求來自何處。

3、驗證elasticsearch和 elasticsearch-head

  • 啟動 elasticsearch服務
  • 啟動elasticsearch-head 服務

訪問 http://localhost:9100 地址！檢視elasticsearch 叢集健康值是否正常！正常如下圖：

==注： 叢集健康值==

red（差）：叢集 健康狀況很差，雖然可以查詢，但是已經出現了丟失資料的現象 ；

yellow（中）：叢集健康狀況不是很好，但是叢集可以正常使用 ；

green（優）：叢集健康狀況良好，叢集正常使用。

驗證elasticsearch和 elasticsearch-head組合

2.3、ES安裝-分散式安裝

1）、安裝說明，安裝三個節點，一個master ，兩個slave。

叢集名稱 ip-埠
myEsCluster （master） 127.0.0.1:9500
myEsCluster（slave） 127.0.0.1:9600
myEsCluster（slave） 127.0.0.1:9700

2）、Es安裝包解壓出三份ES，修改每個 elasticsearch安裝目錄 /config/elasticsearch.yml 這個配置檔案

master配置說明:

# 設定支援elasticsearch-head
http.cors.enabled: true
http.cors.allow-origin: "*"

# 設定叢集master配置資訊
# 首先要指定 叢集的名字 ,名字隨便起，符合常規命名規則
cluster.name: myEsCluster
# 節點的名字，一般為master 或者 slave
node.name: master
# 節點是否為master，設定為true的話，說明此節點為master節點
node.master: true
# 設定網路,如果是本機的話就是127.0.0.1，其他伺服器配置對應的IP地址即可
network.host: 127.0.0.1
# 預設埠為 9200,可以修改預設設定
http.port: 9500

slave配置說明:

# 設定叢集slave配置資訊
# 首先要指定 叢集的名字 ,名字隨便起，符合常規命名規則
cluster.name: myEsCluster
# 節點的名字，一般為master 或者 slave
node.name: slave1
# 節點是否為master，設定為true的話，說明此節點為master節點
node.master: false
# 預設埠為 9200,可以修改預設設定
http.port: 9600
# 設定網路,如果是本機的話就是127.0.0.1，其他伺服器配置對應的IP地址即可
network.host: 127.0.0.1
# 設定叢集中master節點的初始列表，可以通過這些節點來自動發現新加入叢集的節點。可以是一個數組。
# #discovery.zen.ping.unicast.hosts: ["host1", "host2"]
discovery.zen.ping.unicast.hosts: ["127.0.0.1"]

==兩個slave配置只需要改相應的埠號即可！一個slave1：9600 ，一個slave2：9700。==

更多配置參考：

3）、配置後完成後，啟動master的，然後啟動Slave，也啟動elasticsearch-head服務，此時頁面可以檢視Es叢集的狀態！如下圖所示:

Es叢集

2.4、 總結

從上面的安裝來看，Es的安裝相對還是比較簡單，並且在安裝分散式的時候，通過簡單的配置就可以快速擴充套件多個ES節點，能夠快速的進行擴容，非常靈活，方便！

三、ElasticSearch 基礎概念

3.1、基本概念

叢集和節點

叢集：是由一個或者多個ES節點組成的集合。 每一個叢集都有一個唯一的名字，預設是ElasticSearch。每個節點也都有唯一名字。

叢集和節點

索引

索引： 含有相同屬性的文件集合，比如產品的索引，使用者的索引等

型別：索引可以定義一個或多個型別，文件必須屬於一個型別（一般會定義有相同欄位的文件為一個型別）

文件：文件是可以被所有的基本資料單位，是整個ES中最小的儲存單位

==索引在Es中是通過一個名字來識別的，而且它的名字必須是 英文字母小寫，且不能有中劃線。==

都是通過這個名字來進行增刪查改。

ES 資料庫
索引 例項database
型別 表-table
文件 一行記錄

舉例：圖書索引 —> 文學型別、技能型別…—->每一本書可以看成一個文件

分片和備份

分片： 每個索引都有多個分片，每個分片是一個Lucene索引

​ 分片的好處：假如資料量很大的話，就會造成硬碟的壓力很大，同時搜尋速度也會出現瓶頸，將索引分成多個分片，從而分攤壓力提供效率。

備份：拷貝一份分片就完成了分片的備份，提供可用性

ES預設在建立索引的時候，會建立5個分片，1個備份。這個預設的數量是可以修改的。

​ number_of_shards： 每個索引的主分片數，預設值是 5 。這個配置在索引建立後不能修改。

​ number_of_replicas：每個主分片的副本數，預設值是 1 。對於活動的索引庫，這個配置可以隨時修改。

==注意==：索引的分片只能在建立索引的時候指定，而不能再後期進行修改。備份是可以動態修改的。

四、ElasticSearch 基本用法

ES是以Restful API的風格來命名的。

  • API 的基本格式

    http://:/<索引>/<型別>/<文件id>

  • 常用HTTP動詞

    GET/PUT/POST/DELETE

4.1、索引的建立

問題：如何確定一個索引是非結構化還是結構的化的呢？

結合Head外掛，索引–>索引資訊，檢視JSON資料中mappings，如果資料為空，則說明是非結構化索引。

非結構化建立

使用Head外掛進行索引的建立，在tab標籤上，選擇索引，點 新建索引，輸入索引的名稱，注意名稱的命名規則。（我自己驗證，中文、有中劃線的索引名字都可以建立成功！但是字母必須是小寫！）

建立成功每個框框，都是Es索引的分片，粗線框是主分片 和 細線框 是分片的備份。

索引的建立-1

結構化建立

1）、使用Head外掛進行索引的建立，在tab標籤上，選擇複合查詢，進行如下配置：

建立結構化索引

2）、或者使用PostMan工具進行索引的建立

說明：

在Elasticsearch 6.0.0或更高版本中建立的索引只包含一個mapping type。 在5.x中使用multiple mapping types建立的索引將繼續像以前一樣在Elasticsearch 6.x中執行。 Mapping types將在Elasticsearch 7.0.0中完全刪除。

Indices created in Elasticsearch 6.0.0 or later may only contain a single mapping type. Indices created in 5.x with multiple mapping types will continue to function as before in Elasticsearch 6.x. Mapping types will be completely removed in Elasticsearch 7.0.0.

PUT 127.0.0.1:9500/people

請求引數：

{
    "settings":{
        "number_of_shards":3,
        "number_of_replicas":1
    },
    "mappings":{
        "man":{
            "properties":{
                "name":{
                    "type":"text"
                },
                "age":{
                    "type":"integer"
                },
                "birth":{
                    "type":"date",
                    "format":"yyyy-MM-dd HH:mm:ss||yyyy-MM-dd||epoch_millis"
                },
                "country":{
                    "type":"keyword"
                }
            }
        },
        "woman":{}

    }
}

結果：

{
    "acknowledged": true,
    "shards_acknowledged": true,
    "index": "people"
}

如果一個mappings中有兩個type的話，在提交的時候會報如下錯誤：

PUT 127.0.0.1:9500/people2

引數：

{
    "settings":{
        "number_of_shards":3,
        "number_of_replicas":1
    },
    "mappings":{
        "man":{
            "properties":{
                "name":{
                    "type":"text"
                },
                "age":{
                    "type":"integer"
                },
                "birth":{
                    "type":"date",
                    "format":"yyyy-MM-dd HH:mm:ss||yyyy-MM-dd||epoch_millis"
                },
                "country":{
                    "type":"keyword"
                }
            }
        },
        "woman":{}

    }
}

結果：

{
    "error": {
        "root_cause": [
            {
                "type": "illegal_argument_exception",
                "reason": "Rejecting mapping update to [people2] as the final mapping would have more than 1 type: [woman, man]"
            }
        ],
        "type": "illegal_argument_exception",
        "reason": "Rejecting mapping update to [people2] as the final mapping would have more than 1 type: [woman, man]"
    },
    "status": 400
}

4.2、插入

文件ID是一個唯一索引值，指向我們的文件資料。

#### 指定文件ID插入

PUT 127.0.0.1:9500/people/man/1

指定插入文件的ID為 1.

引數：

{
    "name":"dufy",
    "age":27,
    "birth":"1992-09-28",
    "country":"China"
}

請求結果：

{
    "_index": "people",
    "_type": "man",
    "_id": "1", # id 為1 
    "_version": 1,
    "result": "created", # 標識建立一個文件
    "_shards": {
        "total": 2,
        "successful": 2,
        "failed": 0
    },
    "_seq_no": 0,
    "_primary_term": 1
}

使用Head外掛檢視資料：

使用ID插入文件

自動產生文件ID插入

自動產生ID和上面指定ID插入不同的兩個地方是:

（1）、在請求地址上不需要指定 ID，讓ES自動幫我們建立ID!

（2）、請求方式為POST方式

POST 127.0.0.1:9500/people/man

請求引數：

{
    "name":"dufy_auto_id",
    "age":37,
    "birth":"1982-09-28",
    "country":"China"
}

請求結果：

{
    "_index": "people",
    "_type": "man",
    "_id": "zmLSUGUBWifqa4luPRp5", # 自動建立ID
    "_version": 1,
    "result": "created", # 標識建立一個文件
    "_shards": {
        "total": 2,
        "successful": 2,
        "failed": 0
    },
    "_seq_no": 1,
    "_primary_term": 1
}

使用Head外掛檢視資料：

自動生成文件ID

4.3 、修改

#### 直接修改文件

POST 127.0.0.1:9500/people/man/1/_update

注意：需要在請求的地址後面加上 _update,標識是一個修改操作。

請求引數：

{
    "doc":{
        "name":"dufy_update" 
    }
}

請求響應結果：

{
    "_index": "people",
    "_type": "man",
    "_id": "1", # 標識文件的ID為1
    "_version": 2,
    "result": "updated", # 標識修改一個文件
    "_shards": {
        "total": 2,
        "successful": 2,
        "failed": 0
    },
    "_seq_no": 2,
    "_primary_term": 1
}

通過Head外掛檢視，發現文件ID為1 name已經修改了。

指令碼修改文件

指令碼修改和直接修改的API是一樣的，只是引數有些區別。

POST 127.0.0.1:9500/people/man/1/_update

第一種方式請求引數：

{
    "script":{
        "lang":"painless" , # ES 指令碼語言
        "inline":"ctx._source.age += 10" #ctx：es上下文，_source:代表es當前的文件，age：欄位
    }
}

第二種方式請求引數：

{
    "script":{
        "lang":"painless" ,
        "inline":"ctx._source.age = params.age",
        "params":{  #使用params 指定資料值
            "age":80
        }
    }
}

4.4、刪除

刪除文件

DELETE 127.0.0.1:9500/people/man/1

使用delete請求，通過文件的ID進行刪除操作。

{
    "_index": "people",
    "_type": "man",
    "_id": "1",
    "_version": 5,
    "result": "deleted", # 標識刪除一個文件
    "_shards": {
        "total": 2,
        "successful": 2,
        "failed": 0
    },
    "_seq_no": 5,
    "_primary_term": 1
}

刪除索引

刪除操作是一個比較危險的操作，因為索引一旦刪除，對應的所有資料全部被刪除了。

  • 可以通過Head外掛刪除。確認輸入刪除，索引就刪除了。

  • 使用 PostMan進行刪除，使用 請求，只輸入請求的索引

    127.0.0.1:9500/people

4.5、查詢-重點

查詢功能是使用過操作比較頻繁的。

首先進行資料初始化，建立一個book 的索引，然後插入一些資料。具體的建立索引和插入資料，檢視之前內容。

PUT　127.0.0.1:9500/book

結構化建立：

{
    "mappings":{
        "novel":{
            "properties":{
                "author":{
                    "type":"text"
                },
                "word_count":{
                    "type":"integer"
                },
                "publish_date":{
                    "type":"date",
                    "format":"yyyy-MM-dd HH:mm:ss||yyyy-MM-dd||epoch_millis"
                },
                "title":{
                    "type":"keyword"
                }
            }
        }
    }
}

插入文件資料：

POST 127.0.0.1:9500/book/novel/1

{
    "title":"Nginx",
    "word_count":5000,
    "publish_date":"2992-09-28",
    "author":"zhangyc"
}

book索引初始化資料

簡單查詢

GET 127.0.0.1:9500/book/novel/4 

{
    "_index": "book",
    "_type": "novel",
    "_id": "4",
    "_version": 1,
    "found": true,
    "_source": {  # 查詢出來索引為book，型別是novel的ID=4 的文件資料
        "title": "Dubbo",
        "word_count": 8000,
        "publish_date": "1992-09-28",
        "author": "alibb"
    }
}

條件查詢

POST 127.0.0.1:9500/book/_search

  • 查詢全部資料
{
    "query":{ # 查詢是以query為關鍵詞的
        "match_all":{} # 查詢全部的資料
    }
}

返回結果：

{
    "took": 8, # 介面響應花費的時間/ms
    "timed_out": false,
    "_shards": {
        "total": 5,
        "successful": 5,
        "skipped": 0,
        "failed": 0
    },
    "hits": { 
        "total": 5,  # 總共資料5條
        "max_score": 1,
        "hits": [ # 擊中，也就是響應的全部資料，hits預設返回的資料為10條，可以修改！
            {
                "_index": "book",
                "_type": "novel",
                "_id": "5",
                "_score": 1,
                "_source": {
                    "title": "Nginx",
                    "word_count": 5000,
                    "publish_date": "2992-09-28",
                    "author": "zhangyc"
                }
            },
            {....} #其他的資料資訊 
            }
        ]
    }
}

修改 hits預設返回資料的總數。

{
    "query":{ # 查詢是以query為關鍵詞的
        "match_all":{} # 查詢全部的資料
    },
    "size":2 # 返回資料的總數
}

  • 關鍵詞查詢

    POST 127.0.0.1:9500/book/_search 

{
    "query":{ 
        "match":{
            "title": "Redis實戰"
        },
        # 預設 排序 使用 _score 
        "sort":[ # 如何查詢資料較多，可以進行排序操作
            {"publish_date":{"order":"desc"}}
        ]
    }
}
{
    "took": 7,
    "timed_out": false,
    "_shards": {
        "total": 5,
        "successful": 5,
        "skipped": 0,
        "failed": 0
    },
    "hits": {
        "total": 1,
        "max_score": 0.2876821,
        "hits": [
            {
                "_index": "book",
                "_type": "novel",
                "_id": "3",
                "_score": 0.2876821,
                "_source": {
                    "title": "Redis實戰",
                    "word_count": 2000,
                    "publish_date": "1582-09-28",
                    "author": "marry"
                }
            }
        ]
    }
}

聚合查詢

POST 127.0.0.1:9500/book/_search

  • 對書籍的字數進行聚合

查詢引數：

{
    "aggs":{
        "groud_word_count":{ # 自定義聚合名稱
            "terms":{
                "field":"word_count"
            }
        }
    }
}

返回結果：

{
    # 其他資料省略
    "aggregations": {
        "groud_word_count": {
            "doc_count_error_upper_bound": 0,
            "sum_other_doc_count": 0,
            "buckets": [
                {
                    "key": 5000,
                    "doc_count": 2 # 文件總數
                },
                {
                    "key": 2000,
                    "doc_count": 1
                },
                {
                    "key": 8000,
                    "doc_count": 1
                },
                {
                    "key": 10000,
                    "doc_count": 1
                }
            ]
        }
    }
}

上面這個是單個聚合，多個聚合同理：

{
    "aggs":{
        "groud_word_count":{ # 自定義聚合名稱
            "terms":{
                "field":"word_count"
            }
        },
        "groud_title":{ # 自定義聚合名稱
            "terms":{
                "field":"title"
            }
        }
    }
}
  • 進行函式計算
{
    "aggs":{
        "grades_word_count":{
            "stats":{  #統計資料 min 、max、avg、avg
                "field":"word_count"
            }
        }
    }
}

返回結果：

"aggregations": { # 聚合
        "grades_word_count": {
            "count": 5,
            "min": 2000,
            "max": 10000,
            "avg": 6000,
            "sum": 30000
        }
    }

五、ElasticSearch 高階查詢

子條件查詢

特定欄位查詢 所指特定值

1、Query Context

在查詢過程中，除了判斷文件是否滿足查詢條件外，ES還會計算一個_score來標識匹配的程度，旨在判斷目標文件和查詢條件匹配的有多好（匹配度）！

  • 全文字查詢 —— 針對文字型別資料
  • 欄位級別查詢——針對結構化資料，如數字、日期等
{
    "query":{
        "multi_match":{ # 多條件查詢
            "query":"Redis",
            "fields":["title","author"]
        }
    }

}

語法查詢：

{
    "query":{
        "query_string":{
            "query":"入門 OR Redis",
            "fields":["title","author"]
        }
    }

}

欄位級別的查詢：

{
    "query":{
        "term":{
            "word_count":5000
        }
    }

}

字數或者日期範圍：

{
    "query":{
        "range":{
            "word_count":{
                "gte":1000,
                "lte":5000
            }
        }
    }

}
2、Filter Context
{
    "query":{
        "bool":{
            "filter":{
                "term":{
                    "word_count":5000
                }
            }
        }
    }

}

複合條件查詢

以一定的邏輯組合子條件查詢,結合了Query和Filter Context

  • 固定分數查詢

  • 布林查詢

六、ElasticSearch 實戰演練

1、配置Spring boot ElasticSearch開發環境

1、建立Spring boot web專案，spring boot 使用2.0.4版本, elasticsearch為5.6.10

 <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.0.4.RELEASE</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>

 <!--引入ELasticSearch的依賴包，預設使用elasticsearch5.6.10版本-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-data-elasticsearch</artifactId>
        </dependency>
 <!--需要引入transport-netty3-client，否則會啟動報錯-->
        <dependency>
            <groupId>org.elasticsearch.plugin</groupId>
            <artifactId>transport-netty3-client</artifactId>
            <version>5.6.10</version>
        </dependency>

2、配置程式碼

/**
 * ES 配置類
 * @author:dufyun
 * @version:1.0.0
 * @date 2018/8/19
 * @update:[日期YYYY-MM-DD] [更改人姓名][變更描述]
 */
@Configuration
public class ElasticSearchConfig {

    private static final Logger logger = LoggerFactory.getLogger(ElasticSearchConfig.class);

    @Bean
    public TransportClient transportClient() {
        logger.info("初始化開始。。。。。");
        TransportClient client = null;
        try {
            TransportAddress transportAddress = new InetSocketTransportAddress(InetAddress.getByName("localhost"),
                    Integer.valueOf(9300));

            // 配置資訊
            Settings esSetting = Settings.builder()
                    .put("cluster.name","myEsCluster")
                    .build();

            //配置資訊Settings自定義,下面設定為EMPTY
            client = new PreBuiltTransportClient(esSetting);

            client.addTransportAddresses(transportAddress);


        } catch (Exception e) {
            logger.error("elasticsearch TransportClient create error!!!", e);
        }

        return client;
    }
}

也可以使用配置檔案！

es.hostName=localhost
es.transport=9300
es.cluster.name=myEsCluster
@Configuration
@PropertySource(value={"classpath:elasticsearch.properties"}) // 載入 指定的配置，只支援properti
public class ElasticSearchConfig {

    private static final Logger logger = LoggerFactory.getLogger(ElasticSearchConfig.class);

    @Value("${es.hostName}")
    private String hostName;

    @Value("${es.transport}")
    private Integer transport;

    @Value("${es.cluster.name}")
    private String clusterName;

    @Bean
    public TransportClient transportClient() {
        LOGGER.info("初始化開始。。。。。");
        TransportClient client = null;
        try {
            TransportAddress transportAddress = new InetSocketTransportAddress(InetAddress.getByName(hostName),
                    Integer.valueOf(transport));

            // 配置資訊
            Settings esSetting = Settings.builder()
                    .put("cluster.name",clusterName)
                    .build();

            //配置資訊Settings自定義,下面設定為EMPTY
            client = new PreBuiltTransportClient(esSetting);

            client.addTransportAddresses(transportAddress);


        } catch (Exception e) {
            logger.error("elasticsearch TransportClient create error!!!", e);
        }

        return client;
    }
}

3、使用單元測試進行驗證

@Autowired
    private TransportClient client;

    @Test
    public void contextLoads() {

        System.out.println(client);
       //[email protected]4bf
    }

2、介面開發

1、新增圖書資訊功能開發

2、修改圖書資訊功能開發

3、刪除功能開發

4、綜合查詢介面開發

程式碼如下：

/**
 * ES book索引 控制器
 * @author:dufyun
 * @version:1.0.0
 * @date 2018/8/19
 * @update:[日期YYYY-MM-DD] [更改人姓名][變更描述]
 */
@Controller
public class BookController {

    @Autowired
    private TransportClient client;

    /**
     * http://localhost

相關推薦

ElasticSearch 入門總結

ElasticSearch 入門 本篇為 ElasticSearch 入門學習總結筆記，課程視訊地址：ElasticSearch 入門 一、ElasticSearch 簡介 1.1、什麼是ElasticSearch ​ 簡稱 ES 基於Apa

Jenkins入門總結

安裝配置 perf 能夠 control 總結 sla 英文 play 5% 在網上貌似沒有找到Jenkins的中文的太多的文檔，有的都是關於Hudson的一些零零散散的，所以自己邊學習邊實踐總結了以下系列文章，希望有助於大家對於Jenkins的使用。 本系列文章是基於我3

AangularJS入門總結二

奇數 串匹配 參數 存儲 show 影響 pan 循環語句 mouseover 雙向數據綁定：在Mode(JS)中改變數據，而這些變動立刻就會自動出現在View上，反之亦然。一方面可以做到model變化驅動了DOM中元素變化，另一方面也可以做到DOM元素的變化也會影響到M

AangularJS入門總結三

align directive 使用方式 數據結構 指令 監聽 性能問題 資料 watch （參考的資料） 1. 數據綁定的原理： 　　　(1) $watch 隊列： 在DOM中每次綁定一些東西，就會往$watch隊列中插入一條$watch； 　　　　　　　　　　　　

Elasticsearch入門

concepts 更新 進行 索引 日誌 .cn item 允許 必須 Elasticsearch 是一個高伸縮的開源全文搜索和分析引擎。它可以快速地、近實時的存儲，搜索和分析大規模的數據。一般被用作底層引擎/技術，為具有復雜搜索功能和要求的應用提供強有力的支撐。 Ela

ElasticSearch入門常用命令

開源 基於 nod pan ear arc http localhost count 基於開源項目MyAlice智能客服學習ElasticSearch https://github.com/hpgary/MyAlice/wiki/%E7%AC%AC01%E7%AB%A0%

JAVA通信系列三：Netty入門總結

hand list code end @override ada 群發消息 -s object 一、Netty學習資料 書籍《Netty In Action中文版》 對於Netty的十一個疑問http://news.cnblogs.com/n/205413/ 深入淺出Net

ElasticSearch入門 —— 集群搭建

com tar 3.0 情況 port ase -i img oracl 一、環境介紹與安裝準備 1、環境說明 2臺虛擬機，OS為ubuntu13.04，ip分別為xxx.xxx.xxx.140和xxx.xxx.xxx.145。 2、安裝準備

Elasticsearch學習總結

web Lucene arc search 服務器 搜索服務 能力 全文搜索 log ElasticSearch是一個基於Lucene的搜索服務器。它提供了一個分布式多用戶能力的全文搜索引擎，基於RESTful web接口。 結構圖： Elasticsearch學習總結

Elasticsearch入門-安裝

one 從未有 http style 發送 文件 download lock 分析 Elasticsearch 是一個實時的分布式搜索分析引擎， 它能讓你以一個之前從未有過的速度和規模，去探索你的數據。 它被用作全文檢索、結構化搜索、分析以及這三個功能的組合。-- 權威指南

JavaWeb一小時急速入門總結反思

isp host size pre strong 但是 sys 後端 ppi 0.條件一個可以開發javaee的開發工具1.配置首先需要下載tomcat，用來跑javaweb的服務器，下載後自行百度配置。然後需要servlet.jar包，其實就是一個java網絡層api包2

Elasticsearch入門之從零開始安裝ik分詞器

gpo article terms n) rm -rf 從零開始 系列 pack 默認 起因 需要在ES中使用聚合進行統計分析，但是聚合字段值為中文，ES的默認分詞器對於中文支持非常不友好：會把完整的中文詞語拆分為一系列獨立的漢字進行聚合，顯然這並不是我的初衷。我們來看個

爬蟲入門總結

int abc html print 過濾 tle soup ali pan 1 #爬蟲 2 #自己寫給自己看的，排版不是很好，請不要介意 3 4 import requests 5 res = requests.get(‘http://...‘)#註意是ge

[Spring框架]Spring 事務管理基礎入門總結.

復制 tor junit4 dao img bubuko 說過 應該 pat 前言:在之前的博客中已經說過了數據庫的事務, 不過那裏面更多的是說明事務的一些鎖機制, 今天來說一下Spring管理事務的一些基礎知識. 之前的文章: [數據庫事務與鎖]詳解一: 徹底理解數據庫

[Spring框架]Spring AOP基礎入門總結二:Spring基於AspectJ的AOP的開發.

work 復制代碼 配置文件 exec dao tool ont pda nbsp 前言: 在上一篇中: [Spring框架]Spring AOP基礎入門總結一. 中 我們已經知道了一個Spring AOP程序是如何開發的, 在這裏呢我們將基於AspectJ來進行AOP

elasticsearch入門使用（五） kibana安裝使用

png elastic sha img 相關 復制 logstash per usr Kibana User Guide 一、UI安裝 https://www.elastic.co/downloads/kibana 下載rpm直接運行即可 二、參數配置 find / -

ElasticSearch入門一

elastics java環境 lin bat文件 log 技術 環境 配置環境變量 而且 ElasticSearch入門一 1 安裝ElasticSearch，配置環境變量，並且存在Java環境，而且是Java環境； 下圖是安裝的目錄： 進入bin目錄之後，請看bi

elasticsearch入門筆記

pack change class ref 執行 log words rds all 安裝 https://es.xiaoleilu.com/010_Intro/10_Installing_ES.html 下載elasticsearch https://www.elasti

簡單的入門總結

操作系統大概簡單了解 計算機與操作系統 ENIARC:CPU:運算器、控制器、寄存器、緩存；（CPU緩存越大；CPU價格越貴）儲存器：內存、RAM；Input：下指令，提供數據；Output:輸出數據加工的結果操作系統接口：OS兩類GUI：gra

perl語言入門總結-第2章

換行 col lin 函數 tex AD 變量 nbsp print $what =‘steak‘; print "fred ate $n ${what}s.\n"; 布爾值 如果是數字0為假， 如果是空字符串‘‘為假， 如果即不是數字也不是字符串，那就先轉成數字或字