資訊專欄INFORMATION COLUMN
摘要：時間年月日星期四說明本文部分內(nèi)容均來自慕課網(wǎng)。那么里面的數(shù)據(jù)就可以分為各種各樣的索引，比如汽車索引圖書索引家具索引等等。圖書索引又可以細(xì)分為各種類型，比如科普類小說類技術(shù)類等等。具體到每一本書籍，就是文檔，就是整個圖書里面最小的存儲單位。
時間：2017年09月14日星期四
說明：本文部分內(nèi)容均來自慕課網(wǎng)。@慕課網(wǎng)：http://www.imooc.com
教學(xué)源碼：無
學(xué)習(xí)源碼：https://github.com/zccodere/s...
什么是ElasticSearch
基于Apache Lucene構(gòu)建的開源搜索引擎 采用Java編寫，提供簡單易用的RESTful API 輕松的橫向擴(kuò)展，可支持PB級的結(jié)構(gòu)化和非結(jié)構(gòu)化數(shù)據(jù)處理
可用應(yīng)用場景
海量數(shù)據(jù)分析引擎 站內(nèi)搜索引擎 數(shù)據(jù)倉庫
一線公司實(shí)際應(yīng)用場景
英國衛(wèi)報-實(shí)時分析公眾對文章的回應(yīng) 維基百科、GitHub-站內(nèi)實(shí)時搜索 百度-實(shí)時日志監(jiān)控平臺 阿里巴巴、谷歌、京東、騰訊、小米等等
前置知識
熟悉用Maven構(gòu)建項目 了解Spring Boot的基本使用
環(huán)境要求
IDE工具：IntelliJ IDEA、Eclipse等常用IDE即可 Java版本：JDK1.8 其他依賴：Maven、NodeJs（6.0以上）
課程安排
如何安裝單節(jié)點(diǎn)的ElasticSearch 如何安裝插件及插件的主要作用 如何安裝分布式的ElasticSearch 了解ElasticSearch的基礎(chǔ)概念 了解ElasticSearch的基本用法 了解ElasticSearch的高級查詢 使用Spring Boot集合ElasticSearch實(shí)戰(zhàn)開發(fā)第二章：軟件安裝 2-1 版本選擇
ES版本問題
版本歷史：1.x -> 2.x -> 5.x 版本選擇：擁抱新的版本2-2 單機(jī)安裝
學(xué)習(xí)筆記
單機(jī)安裝ElasticSearch 安裝前，請確保已經(jīng)安裝JDK1.8 安裝前，請確保已經(jīng)安裝nodejs6.0以上 官網(wǎng)：https://www.elastic.co/products/elasticsearch 下載安裝包：https://artifacts.elastic.co/downloads/elasticsearch/elasticsearch-5.6.0.tar.gz 解壓安裝包：tar -vxf elasticsearch-5.6.0.tar.gz cd elasticsearch-5.6.0.tar.gz 啟動前，檢查JDK環(huán)境 java -v 請確保已經(jīng)安裝JDK1.8 啟動elasticsearch sh ./bin/elasticsearch 當(dāng)日志輸出started時，表示啟動成功 驗(yàn)證服務(wù) 127.0.0.1:9200 elasticsearch服務(wù)默認(rèn)監(jiān)聽9200端口 訪問：http://127.0.0.1:9200 如果出現(xiàn)版本信息，則安裝成功2-3 插件安裝
學(xué)習(xí)筆記
實(shí)用插件Head安裝 打開github：https://github.com/mobz/elasticsearch-head 下載插件包：https://codeload.github.com/mobz/elasticsearch-head/zip/master unzip elasticsearch-head-master.zip cd elasticsearch-head-master 檢查Node環(huán)境 node -v 請確保已經(jīng)安裝nodejs6.0以上 安裝插件 npm install 啟動插件 npm run start 輸出日志表示啟動成功 Started connect web server on http://localhost:9100 訪問 http://localhost:9100 ElasticSearch整合elasticsearch-head插件 cd elasticsearch-5.6.0 vim config/elasticsearch.yml 在配置文件的最后面加上 允許head插件跨域訪問rest接口 http.cors.allowed: true http.cors.allow-origin: "*" :wq 后臺啟動 ./bin/elasticsearch -d 再次重新啟動elasticsearch-head插件 cd elasticsearch-head-master 啟動插件 npm run start 訪問 http://localhost:91002-4 集群安裝
學(xué)習(xí)筆記
集群安裝 1個master、2個slave master節(jié)點(diǎn)配置 配置當(dāng)前節(jié)點(diǎn)為主節(jié)點(diǎn) cd elasticsearch-5.6.0 修改配置 vim config/elasticsearch.yml 在配置文件的最后面加上 # 指定集群的名字 cluster.name: myes # 指定當(dāng)前節(jié)點(diǎn)的名字 node.name: master # 指定當(dāng)前節(jié)點(diǎn)為master node.master: true # 指定綁定的IP network.host: 127.0.0.1 # 使用默認(rèn)端口：9200 :wq ps -ef | grep "pwd" kill pid 重新啟動 ./bin/elasticsearch -d 檢查服務(wù)是否正常啟動 http://localhost:9200 slave節(jié)點(diǎn)配置 mkdir es_slave cp elasticsearch-5.6.0.tar.gz es_slave/ cd es_slave tar -vxf elasticsearch-5.6.0.tar.gz cp -r elasticsearch-5.6.0 es_slave1 cp -r elasticsearch-5.6.0 es_slave2 修改es_slave1配置 cd es_slave1 vim config/elasticsearch.yml 在配置文件的最后面加上 # 指定集群的名字：需要和master節(jié)點(diǎn)一致 cluster.name: myes # 指定當(dāng)前節(jié)點(diǎn)的名字 node.name: slave1 # 指定綁定的IP network.host: 127.0.0.1 # 指定當(dāng)前節(jié)點(diǎn)綁定端口號8200 http.port: 8200 # 該配置主要是為了找到master節(jié)點(diǎn) discovery.zen.ping.unicast.hosts: ["127.0.0.1"] :wq 啟動服務(wù) ./bin/elasticsearch -d 檢查服務(wù)是否正常啟動 http://localhost:9100 安裝之前的步驟配置slave2 cd es_slave2 vim config/elasticsearch.yml 在配置文件的最后面加上 # 指定集群的名字：需要和master節(jié)點(diǎn)一致 cluster.name: myes # 指定當(dāng)前節(jié)點(diǎn)的名字 node.name: slave2 # 指定綁定的IP network.host: 127.0.0.1 # 指定當(dāng)前節(jié)點(diǎn)綁定端口號8000 http.port: 8000 # 該配置主要是為了找到master節(jié)點(diǎn) discovery.zen.ping.unicast.hosts: ["127.0.0.1"] :wq 啟動服務(wù) ./bin/elasticsearch -d 檢查服務(wù)是否正常啟動 http://localhost:9100第三章：基礎(chǔ)概念 3-1 基礎(chǔ)概念
集群和節(jié)點(diǎn)
一個集群是由一個或多個ES組成的集合 每一個集群都有一個唯一的名字 每一個節(jié)點(diǎn)都是通過集群的名字來加入集群的 每一個節(jié)點(diǎn)都有自己的名字 節(jié)點(diǎn)能夠存儲數(shù)據(jù)，參與集群索引數(shù)據(jù)以及搜索數(shù)據(jù)的獨(dú)立服務(wù)
基礎(chǔ)概念
索引：含有相同屬性的文檔集合 類型：索引可以定義一個或多個類型，文檔必須屬于一個類型 （通常會定義有相同字段的文檔作為一個類型） 文檔：文檔是可以被索引的基本數(shù)據(jù)單位
三者之間的關(guān)系
索引相當(dāng)于SQL里的DataBase，也就是數(shù)據(jù)庫 類型相當(dāng)于SQL里的Table，也就是表 文檔相當(dāng)于SQL里的一行記錄，也就是一行數(shù)據(jù)
舉個例子
假設(shè)有一個信息查詢系統(tǒng)，使用ES做存儲。那么里面的數(shù)據(jù)就可以分為各種各樣的索引，比如：汽車索引、圖書索引、家具索引等等。圖書索引又可以細(xì)分為各種類型，比如：科普類、小說類、技術(shù)類等等。具體到每一本書籍，就是文檔，就是整個圖書里面最小的存儲單位。
和索引相關(guān)的兩個高級概念
分片：每個索引都有多個分片，每個分片是一個Lucene索引 備份：拷貝一份分片就完成了分片的備份 ES默認(rèn)在創(chuàng)建索引時，會創(chuàng)建5個分片、1個備份 分片的數(shù)量只能在創(chuàng)建索引時設(shè)置，而不能在后期進(jìn)行修改 備份是可以動態(tài)修改的第四章：基本用法 4-1 創(chuàng)建索引
ES的API組成結(jié)構(gòu)：使用RESTful API風(fēng)格來命名API
API基本格式：http://: /<索引>/<類型>/<文檔id> 常用HTTP動詞：GET/PUT/POST/DELETE
使用Head插件創(chuàng)建非結(jié)構(gòu)化索引
訪問：localhost:9100 路徑：索引->新建索引->索引名稱：book->點(diǎn)擊OK 索引名稱：必須小寫，不能有中劃線
如何區(qū)分索引是結(jié)構(gòu)化的還是非結(jié)構(gòu)化的
結(jié)合Head插件查看 點(diǎn)擊索引信息->索引信息->mappings節(jié)點(diǎn) 當(dāng)mappings節(jié)點(diǎn)后的內(nèi)容為空時：非結(jié)構(gòu)化索引
使用Head插件創(chuàng)建結(jié)構(gòu)化索引
路徑：復(fù)合查詢->查詢->book/novel/_mappings
指定映射：使用JSON結(jié)構(gòu)體
{
"novel":{
"propertise":{
"title":{"type":"test"}
}
}
}
然后勾選易讀->點(diǎn)擊驗(yàn)證JSON->提交請求
再次查看mappings節(jié)點(diǎn)時，已經(jīng)不是空的了
使用PostMan創(chuàng)建索引
PUT：127.0.0.1:9200/people Body->raw->JSON(application/json) 編寫JSON體 點(diǎn)擊Send，然后到Head插件中查看people索引信息
編寫JSON體如下
{
"settings":{
"number_of_shards":3,
"number_of_replicas":1
},
"mappings":{
"man":{
"properties":{
"name":{
"type": "text"
},
"country":{
"type": "keyword"
},
"age":{
"type": "integer"
},
"date":{
"type": "date",
"format":"yyyy-MM-dd HH:mm:ss||yyyy-MM-dd||epoch_millis"
}
}
},
"woman":{
}
}
}
4-2 新增文檔
新增文檔
指定文檔id新增 自動產(chǎn)生文檔id新增 文檔id：唯一索引值指向文檔數(shù)據(jù)
使用PostMan工具新增數(shù)據(jù)-指定文檔id新增
PUT：127.0.0.1::9200/people/man/1
Body->raw->JSON(application/json)
{
"name":"zc",
"country":"china",
"age":22,
"date":"1995-01-01"
}
點(diǎn)擊Send，可以看到ES響應(yīng)的信息
使用Head插件查看索引下的數(shù)據(jù)，docs字段代表索引下所有文檔的數(shù)量值
點(diǎn)擊數(shù)據(jù)瀏覽，可以看見剛剛新增的數(shù)據(jù)
使用PostMan工具新增數(shù)據(jù)-自動產(chǎn)生文檔id新增
POST：127.0.0.1::9200/people/man/
Body->raw->JSON(application/json)
{
"name":"myzc",
"country":"china",
"age":22,
"date":"1995-02-01"
}
點(diǎn)擊Send，可以看到ES響應(yīng)的信息
使用Head插件，點(diǎn)擊數(shù)據(jù)瀏覽，可以看見剛剛新增的數(shù)據(jù)
4-3 修改文檔
修改文檔
直接修改文檔 腳本修改文檔
使用PostMan工具修改文檔-指定文檔ID修改
POST：127.0.0.1:9200/people/man/1/_update
Body->raw->JSON(application/json)
{
"doc":{
"name":"who is zc"
}
}
點(diǎn)擊Send，可以看到ES響應(yīng)的信息
使用Head插件，點(diǎn)擊數(shù)據(jù)瀏覽，可以看見剛剛修改的數(shù)據(jù)
使用PostMan工具修改文檔-指定文檔ID使用腳本修改
POST：127.0.0.1:9200/people/man/1/_update
Body->raw->JSON(application/json)
{
"script":{
"lang":"painless",
"inline":"ctx._sources.age+=10"
}
}
或使用以下格式
{
"script":{
"lang":"painless",
"inline":"ctx._sources.age = params.age",
"params":{
"age":100
}
}
}
點(diǎn)擊Send，可以看到ES響應(yīng)的信息
使用Head插件，點(diǎn)擊數(shù)據(jù)瀏覽，可以看見剛剛修改的數(shù)據(jù)
4-4 刪除文檔
刪除
刪除文檔 刪除索引
使用PostMan刪除文檔-指定文檔ID
DELETE：127.0.0.1:9200/people/man/1 點(diǎn)擊Send，可以看到ES響應(yīng)的信息 使用Head插件，點(diǎn)擊數(shù)據(jù)瀏覽，可以看見數(shù)據(jù)已經(jīng)刪除
使用Head插件刪除索引
路徑：概覽->book->動作->刪除->輸入刪除->確定 注意：刪除操作本身很危險，刪除索引時會刪除它所有的文檔數(shù)據(jù)
使用PostMan刪除索引
DELETE：127.0.0.1:9200/people 點(diǎn)擊Send，可以看到ES響應(yīng)的信息 使用Head插件，點(diǎn)擊數(shù)據(jù)瀏覽，可以看見索引已經(jīng)刪除4-5 查詢語法
ES查詢分類
簡單查詢 條件查詢 聚合查詢
前置條件，創(chuàng)建book索引，并預(yù)先新增一些數(shù)據(jù)
使用PostMan簡單查詢-指定文檔ID
GET：127.0.0.1:9200/book/novel/1 點(diǎn)擊Send，可以看到ES響應(yīng)的信息
使用PostMan條件查詢
POST：127.0.0.1:9200/book/_search Body->raw->JSON(application/json) 編寫查詢JSON體 點(diǎn)擊Send，可以看到ES響應(yīng)的信息
編寫查詢JSON體如下
查詢所有數(shù)據(jù)
{
"query":{
"match_all":{}
}
}
用from指定從哪里返回，用size指定返回的數(shù)據(jù)大小
{
"query":{
"match_all":{}
},
"from":1,
"size":1
}
使用關(guān)鍵字查詢，查詢標(biāo)題含有ElasticSearch的數(shù)據(jù)
{
"query":{
"match":{
"title":"ElasticSearch"
}
}
}
使用sort指定結(jié)果集排序-按照出版日期倒序
{
"query":{
"match":{
"title":"ElasticSearch"
}
},
"sort":[
{
"publish_date":{
"order":"desc"
}
}
]
}
按照書籍的字?jǐn)?shù)進(jìn)行單個聚合查詢
{
"aggs":{
"group_by_word_count":{
"terms":{
"field":"word_count"
}
}
}
}
按照書籍的字?jǐn)?shù)及出版日期進(jìn)行多個聚合查詢
{
"aggs":{
"group_by_word_count":{
"terms":{
"field":"word_count"
}
},
"group_by_publish_date":{
"terms":{
"field":"publish_date"
}
}
}
}
對書籍字?jǐn)?shù)進(jìn)行統(tǒng)計計算
{
"aggs":{
"grades_word_count":{
"stats":{
"field":"word_count"
}
}
}
}
第五章：高級查詢
5-1 query語法
高級查詢
子條件查詢：特定字段查詢所指特定值 query context filter context 復(fù)合條件查詢：以一定的邏輯組合子條件查詢 固定分?jǐn)?shù)查詢 布爾查詢
query context介紹
在查詢過程中，除了判斷是否滿足查詢條件外 ES還會計算一個_score來標(biāo)識匹配的程度 旨在判斷目標(biāo)文檔和查詢條件匹配的有多好
query context查詢
全文本查詢：針對文本類型數(shù)據(jù) 字段級別查詢：針對結(jié)構(gòu)化數(shù)據(jù)，如數(shù)字、日期等
使用PostMan進(jìn)行query context文本查詢
POST：127.0.0.1:9200/book/_search Body->raw->JSON(application/json) 編寫查詢JSON體 點(diǎn)擊Send，可以看到ES響應(yīng)的信息
編寫查詢JSON體如下
使用match關(guān)鍵字模糊匹配
{
"query":{
"match":{
"author":"wali"
}
}
}
使用match_phrase關(guān)鍵字習(xí)語匹配
{
"query":{
"match_phrase":{
"author":"ElasticSearch入門"
}
}
}
使用multi_match查詢作者和標(biāo)題包含wali的數(shù)據(jù)
{
"query":{
"multi_match":{
"query":"wali",
"fields":["author","title"]
}
}
}
使用query_string進(jìn)行語法查詢
{
"query":{
"query_string":{
"query":"(ElasticSearch AND 大法) OR Python"
}
}
}
使用query_string查詢多個字段
{
"query":{
"query_string":{
"query":"wali OR ElasticSearch",
"field":["title","author"]
}
}
}
使用PostMan進(jìn)行query context字段查詢
POST：127.0.0.1:9200/book/_search Body->raw->JSON(application/json) 編寫查詢JSON體 點(diǎn)擊Send，可以看到ES響應(yīng)的信息
編寫查詢JSON體如下
查詢字?jǐn)?shù)在某個特定集（1000）的書籍
{
"query":{
"term":{
"word_count":1000
}
}
}
查詢字符在某個范圍（大于等于1000-小于等于2000）的書籍
{
"query":{
"range":{
"word_count":{
"gte":1000,
"lte":2000
}
}
}
}
查詢出版日期在某個范圍（2017-01-01至2017-12-31）的書籍
{
"query":{
"range":{
"publish_date":{
"gte":"2017-01-01",
"lte":"2017-12-31"http://或 "lte":"now"
}
}
}
}
使用關(guān)鍵now，代指當(dāng)前日志（即現(xiàn)在）
5-2 filter語法filter context介紹
在查詢過程中，只判斷該文檔是否滿足條件 只有Yes或No
使用PostMan進(jìn)行filter context查詢
POST：127.0.0.1:9200/book/_search Body->raw->JSON(application/json) 點(diǎn)擊Send，可以看到ES響應(yīng)的信息
查詢字?jǐn)?shù)1000的書籍
{
"query":{
"bool":{
"filter":{
"term":{
"word_count":1000
}
}
}
}
}
5-3 復(fù)合查詢
常用復(fù)合條件查詢
固定分?jǐn)?shù)查詢 布爾查詢
使用PostMan進(jìn)行復(fù)合查詢
127.0.0.1:9200 /_search Body->raw->JSON(application/json) 點(diǎn)擊Send，可以看到ES響應(yīng)的信息
全文搜索-標(biāo)題含有ElasticSearch的書籍
{
"query":{
"constant_score":{
"filter":{
"match":{
"title": "ElasticSearch"
}
},
"boost":2
}
}
}
布爾查詢- should滿足任意條件
{
"query":{
"bool":{
"should":[
{
"match":{
"author":"wali"
}
},
{
"match":{
"title":"ElasticSearch"
}
}
]
}
}
}
布爾查詢- must滿足全部條件
{
"query":{
"bool":{
"must":[
{
"match":{
"author":"wali"
}
},
{
"match":{
"title":"ElasticSearch"
}
}
]
}
}
}
使用must和filter復(fù)合查詢
{
"query":{
"bool":{
"must":[
{
"match":{
"author":"wali"
}
},
{
"match":{
"title":"ElasticSearch"
}
}
],
"filter":[
{
"term":{
"word_count":1000
}
}
]
}
}
}
布爾查詢- must_not一定不能滿足的條件
{
"query":{
"bool":{
"must_not":{
"term":{
"author":"wali"
}
}
}
}
}
第六章：實(shí)戰(zhàn)開發(fā)
6-1 環(huán)境搭建
實(shí)戰(zhàn)演練
SpringBoot集成ES 圖書信息管理接口開發(fā)
創(chuàng)建名為springbootes的gradle項目build.gradle如下
buildscript {
ext {
springBootVersion = "1.5.6.RELEASE"
}
repositories {
mavenCentral()
}
dependencies {
classpath("org.springframework.boot:spring-boot-gradle-plugin:${springBootVersion}")
}
}
apply plugin: "java"
apply plugin: "eclipse"
apply plugin: "org.springframework.boot"
group = "com.myimooc"
version = "0.0.1-SNAPSHOT"
sourceCompatibility = 1.8
repositories {
maven{url:"http://maven.aliyun.com/nexus/content/groups/public/"}
mavenCentral()
}
dependencies {
compile("org.springframework.boot:spring-boot-starter-web")
//compile("org.springframework.boot:spring-boot-starter-data-elasticsearch")
compile("org.elasticsearch.client:transport:5.5.2")
compile("org.apache.logging.log4j:log4j-core:2.7.0")
testCompile("org.springframework.boot:spring-boot-starter-test")
}
6-2 接口開發(fā)
接口列表
新增圖書信息 修改圖書信息 刪除圖書信息 綜合查詢功能
代碼編寫
1.編寫EsConfig類
package com.myimooc.springbootes.config;
import java.net.InetAddress;
import java.net.UnknownHostException;
import org.elasticsearch.client.transport.TransportClient;
import org.elasticsearch.common.settings.Settings;
import org.elasticsearch.common.transport.InetSocketTransportAddress;
import org.elasticsearch.transport.client.PreBuiltTransportClient;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
/**
* @title ElasticSearch配置類
* @describe ElasticSearch配置
* @author zc
* @version 1.0 2017-09-15
*/
@Configuration
public class EsConfig {
@Bean
public TransportClient client() throws UnknownHostException{
InetSocketTransportAddress node = new InetSocketTransportAddress(InetAddress.getByName("localhost"),9300);
Settings settings = Settings.builder()
// es集群名稱
.put("cluster.name", "myes")
.build();
TransportClient client = new PreBuiltTransportClient(settings);
client.addTransportAddress(node);
return client;
}
}
2.編寫B(tài)ookRest類
package com.myimooc.springbootes.rest;
import java.io.IOException;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
import java.util.Map;
import org.elasticsearch.action.delete.DeleteResponse;
import org.elasticsearch.action.get.GetResponse;
import org.elasticsearch.action.index.IndexResponse;
import org.elasticsearch.action.search.SearchRequestBuilder;
import org.elasticsearch.action.search.SearchResponse;
import org.elasticsearch.action.search.SearchType;
import org.elasticsearch.action.update.UpdateRequest;
import org.elasticsearch.action.update.UpdateResponse;
import org.elasticsearch.client.transport.TransportClient;
import org.elasticsearch.common.xcontent.XContentBuilder;
import org.elasticsearch.common.xcontent.XContentFactory;
import org.elasticsearch.index.query.BoolQueryBuilder;
import org.elasticsearch.index.query.QueryBuilders;
import org.elasticsearch.index.query.RangeQueryBuilder;
import org.elasticsearch.search.SearchHit;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.format.annotation.DateTimeFormat;
import org.springframework.http.HttpStatus;
import org.springframework.http.ResponseEntity;
import org.springframework.util.StringUtils;
import org.springframework.web.bind.annotation.DeleteMapping;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;
/**
* @title 圖書REST接口類
* @describe 調(diào)ES接口
* @author zc
* @version 1.0 2017-09-15
*/
@RestController
public class BookRest {
@Autowired
private TransportClient client;
@GetMapping("/")
public String index(){
return "index";
}
/**
* @describe 查詢接口
* @author zc
* @version 1.0 2017-09-15
*/
@GetMapping("/get/book/novel")
public ResponseEntity get(@RequestParam(name="id",defaultValue="")String id){
if(id.isEmpty()){
return new ResponseEntity<>(HttpStatus.NOT_FOUND);
}
GetResponse result = this.client.prepareGet("book","novel",id).get();
if(!result.isExists()){
return new ResponseEntity<>(HttpStatus.NOT_FOUND);
}
return new ResponseEntity<>(result.getSource(), HttpStatus.OK);
}
/**
* @describe 增加接口
* @author zc
* @version 1.0 2017-09-15
*/
@PostMapping("/add/book/novel")
public ResponseEntity add(
@RequestParam(name="title")String title,
@RequestParam(name="author")String author,
@RequestParam(name="word_count")int wordCount,
@RequestParam(name="publish_date") @DateTimeFormat(pattern="yyyy-MM-dd HH:mm:ss") Date publishDate){
try {
XContentBuilder content = XContentFactory.jsonBuilder()
.startObject()
.field("title",title)
.field("author", author)
.field("word_count", wordCount)
.field("publish_date", publishDate.getTime())
.endObject();
IndexResponse result = this.client.prepareIndex("book","novel").setSource(content).get();
return new ResponseEntity<>(result.getId(),HttpStatus.OK);
} catch (IOException e) {
e.printStackTrace();
return new ResponseEntity<>(HttpStatus.INTERNAL_SERVER_ERROR);
}
}
/**
* @describe 刪除接口
* @author zc
* @version 1.0 2017-09-15
*/
@DeleteMapping("/delete/book/novel")
public ResponseEntity delete(@RequestParam(name="id",defaultValue="")String id){
DeleteResponse result = this.client.prepareDelete("book", "novel", id).get();
return new ResponseEntity<>(result.toString(),HttpStatus.OK);
}
/**
* @describe 修改接口
* @author zc
* @version 1.0 2017-09-15
*/
@DeleteMapping("/update/book/novel")
public ResponseEntity update(
@RequestParam(name="id",defaultValue="")String id,
@RequestParam(name="title",required=false)String title,
@RequestParam(name="author",required=false)String author){
UpdateRequest update = new UpdateRequest("book","novel",id);
try {
XContentBuilder builder = XContentFactory.jsonBuilder()
.startObject();
if(!StringUtils.isEmpty(title)){
builder.field("title",title);
}
if(!StringUtils.isEmpty(author)){
builder.field("author", author);
}
builder.endObject();
update.doc(builder);
UpdateResponse result = this.client.update(update).get();
return new ResponseEntity<>(result.toString(),HttpStatus.OK);
} catch (Exception e) {
e.printStackTrace();
return new ResponseEntity<>(HttpStatus.INTERNAL_SERVER_ERROR);
}
}
/**
* @describe 復(fù)合查詢
* @author zc
* @version 1.0 2017-09-15
*/
@DeleteMapping("/query/book/novel")
public ResponseEntity query(
@RequestParam(name="author",required=false)String author,
@RequestParam(name="title",required=false)String title,
@RequestParam(name="gt_word_count",defaultValue="0") int gtWordCount,
@RequestParam(name="lt_word_count",required=false) Integer ltWordCount){
// 構(gòu)建布爾查詢
BoolQueryBuilder boolQuery = QueryBuilders.boolQuery();
if(!StringUtils.isEmpty(author)){
boolQuery.must(QueryBuilders.matchQuery("author", author));
}
if(!StringUtils.isEmpty(title)){
boolQuery.must(QueryBuilders.matchQuery("title", title));
}
// 構(gòu)建范圍查詢
RangeQueryBuilder rangeQuery = QueryBuilders.rangeQuery("word_count")
.from(gtWordCount);
if(ltWordCount != null && ltWordCount > 0){
rangeQuery.to(ltWordCount);
}
// 使用filter構(gòu)建
boolQuery.filter(rangeQuery);
SearchRequestBuilder builder = this.client.prepareSearch("book")
.setTypes("novel")
.setSearchType(SearchType.DFS_QUERY_THEN_FETCH)
.setQuery(boolQuery)
.setFrom(0)
.setSize(10);
System.out.println("[ES查詢請求參數(shù)]："+builder);
SearchResponse response = builder.get();
List> result = new ArrayList>();
for(SearchHit hit:response.getHits()){
result.add(hit.getSource());
}
return new ResponseEntity<>(result,HttpStatus.OK);
}
}
3.編寫SpringbootesApplication類
package com.myimooc.springbootes;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
/**
* @title SpringBoot集成ElasticSearch
* @describe 啟動類
* @author zc
* @version 1.0 2017-09-15
*/
@SpringBootApplication
public class SpringbootesApplication {
public static void main(String[] args) {
SpringApplication.run(SpringbootesApplication.class, args);
}
}
第七章：課程總結(jié)
7-1 課程總結(jié)
課程總結(jié)
ES簡介：使用場景例子、ES的重要性 ES安裝：單機(jī)安裝、集群安裝、Head插件安裝 ES基礎(chǔ)：核心基礎(chǔ)概念：索引、類型、文檔 ES用法：基本用法：增刪改查 ES高級：高級查詢語法 ES實(shí)戰(zhàn)：SpringBoot集成ES開發(fā)增刪改查接口
文章版權(quán)歸作者所有，未經(jīng)允許請勿轉(zhuǎn)載,若此文章存在違規(guī)行為，您可以聯(lián)系管理員刪除。
轉(zhuǎn)載請注明本文地址：http://specialneedsforspecialkids.com/yun/70474.html
時間：2017年10月16日星期一說明：本文部分內(nèi)容均來自慕課網(wǎng)。@慕課網(wǎng)：http://www.imooc.com教學(xué)源碼：無學(xué)習(xí)源碼：https://github.com/zccodere/s... 第一章：課程簡介 1-1 課程介紹 本門課程的主要內(nèi)容 RxJava是什么 RxAndroid是什么 RxJava常用操作符（重點(diǎn)、難點(diǎn)） 怎樣在項目中使用RxJava和RxAndroid 如何學(xué)...
摘要：數(shù)據(jù)綁定入門學(xué)習(xí)總結(jié)時間年月日星期日說明本文部分內(nèi)容均來自慕課網(wǎng)。慕課網(wǎng)教學(xué)示例源碼個人學(xué)習(xí)源碼第一章課程介紹數(shù)據(jù)綁定入門概述數(shù)據(jù)綁定概念來自百度百科簡單綁定是將一個用戶界面元素控件的屬性綁定到一個類型對象實(shí)例上的某個屬性的方法。 《SpringMVC數(shù)據(jù)綁定入門》學(xué)習(xí)總結(jié) 時間：2017年2月19日星期日說明：本文部分內(nèi)容均來自慕課網(wǎng)。@慕課網(wǎng)：http://www.imooc.co...
摘要：入門篇學(xué)習(xí)總結(jié)時間年月日星期三說明本文部分內(nèi)容均來自慕課網(wǎng)。主要的功能是日志記錄，性能統(tǒng)計，安全控制，事務(wù)處理，異常處理等等。 《Spring入門篇》學(xué)習(xí)總結(jié) 時間：2017年1月18日星期三說明：本文部分內(nèi)容均來自慕課網(wǎng)。@慕課網(wǎng)：http://www.imooc.com教學(xué)示例源碼：https://github.com/zccodere/s...個人學(xué)習(xí)源碼：https://git...
閱讀 3685·2021-09-07 10:19
閱讀 3626·2021-09-03 10:42
閱讀 3583·2021-09-03 10:28
閱讀 2548·2019-08-29 14:11
閱讀 808·2019-08-29 13:54
閱讀 1593·2019-08-29 12:14
閱讀 416·2019-08-26 12:12
閱讀 3613·2019-08-26 10:45
