SpringBoot進階教程(七十三)整合elasticsearch-有解無憂

Elasticsearch 是一個分布式、高擴展、高實時的搜索與資料分析引擎，它能很方便的使大量資料具有搜索、分析和探索的能力，充分利用Elasticsearch的水平伸縮性，能使資料在生產環境變得更有價值，Elasticsearch 的實作原理主要分為以下幾個步驟，首先用戶將資料提交到Elasticsearch 資料庫中，再通過分詞控制器去將對應的陳述句分詞，將其權重和分詞結果一并存入資料，當用戶搜索資料時候，再根據權重將結果排名，打分，再將回傳結果呈現給用戶，

在上一篇文章linux安裝elasticsearch中，已經介紹了在linux安裝elasticsearch，這篇文章主要介紹介紹es的一些基礎的入門教程、docker安裝elasticsearch以及在springboot中整合elasticsearch，

v基礎概念

1.0 Node與Cluster

Node:單個Elastic實體稱為一個節點（node）

Cluster:一組節點構成一個集群（cluster）

當然，這也正是集群和節點最通俗的解釋，這個解釋適用于絕大部分，類似elasticsearch這種分布式架構，如之前講過的《詳解Redis Cluster集群》，你可以可以說node就是單個redis實體，這樣的實體我們稱為一個節點，多個這樣的節點組成的集群，正因為如此，我們在設計架構的時候，需要考慮不同環境的不同節點的節點名注意不要重復，避免配置集群遇到尷尬，

1.1 Index

由一個和多個分片組成，通過索引的名字在集群內進行唯一標識，索引是具有某種相似特征的檔案的集合，Elastic資料管理的頂層設計就叫做 Index（索引），類似mysql中的database，

索引也分為名次索引和動詞索引，

索引（名詞）：如前所述，一個索引類似于傳統關系資料庫中的一個資料庫，是一個存盤關系型檔案的地方，索引 (index) 的復數詞為 indices 或 indexes ，
索引（動詞）：索引一個檔案就是存盤一個檔案到一個索引（名詞）中以便被檢索和查詢，這非常類似于 SQL 陳述句中的 INSERT 關鍵詞，除了檔案已存在時，新檔案會替換舊檔案情況之外，

這個也好理解，類似詞組"表演"，看她的表演，表演的很精彩，這是兩個意思，

1.2 Document

Elasticsearch是面向檔案的，意味著它存盤整個物件或檔案，檔案是可以被索引的基本資訊單元，檔案用JSON表示，

例如：存盤員工資訊，那就是一個員工資訊代表一個檔案，多個檔案組成一個index，類似于關系型資料庫中的一條資料通過id在Type內進行唯一標識，

1.3 Type

類別，指索引內部的邏輯磁區，通過type的名字在索引內進行唯一標識，在查詢時如果沒有該值，則表示在整個索引中查詢，

例如：在員工表里，可以按照員工籍貫分組(北上、上海、廣州)，也可以按照員工工種分組（職能、產品、運營），這種分組可以理解為type，

在7.x版會移除Type，Elasticsearch為何要在7.X版本中去除type

1.4 與關系型資料庫對比

Relational DB	Elasticsearch
資料庫(database)	索引 index
表(tables)	型別 types
行(rows)	檔案 documents
欄位(columns)	?elds

1.5 Mapping

定義檔案及其包含的欄位是如何存盤和索引的程序，類似于資料庫中的表結構定義，主要作用如下：

定義index下的欄位名
定義欄位型別，比如數值型、浮點型、布爾型等
定義倒排索引相關的設定，比如是否索引、記錄position等

vdocker安裝Elasticsearch

在上一篇文章中，已經詳細介紹了linux安裝elasticsearch，這篇文章講解的elasticsearch主要圍繞docker展開，

2.0 拉取鏡像

docker pull docker.io/elasticsearch:版本號

版本號是可選的，默認使用latest

2.1 創建&運行容器

docker run -d --name=es7 \
-p 9200:9200 -p 9300:9300 \
-e "discovery.type=single-node" elasticsearch:7.5.1

注意：若創建es持久化目錄，則按下面的命令執行，

mkdir -p /data/elasticsearch
docker cp es7:/usr/share/elasticsearch/data /data/elasticsearch/
docker cp es7:/usr/share/elasticsearch/logs /data/elasticsearch/
docker rm -f es7
docker run -d --name=es7 \
  --restart=always \
  -p 9200:9200 -p 9300:9300 \
  -e "discovery.type=single-node" \
  -v /data/elasticsearch/data:/usr/share/elasticsearch/data \
  -v /data/elasticsearch/logs:/usr/share/elasticsearch/logs \
elasticsearch:7.5.1

注意：若es起不來，可能是容器沒有宿主機掛載的目錄的讀寫權限，那就需要賦予它讀寫權限： chmod 777 /data/elasticsearch

2.2 驗證效果

輸入ip + 埠號(9200)驗證，

2.3 安裝elasticsearch-head

docker pull mobz/elasticsearch-head:5

2.4 創建&運行head容器

docker run -d --name elasticsearch-head -p 9100:9100 mobz/elasticsearch-head:5

2.5 跨域問題

url訪問http://toutou.com:9100之后發現無法連接http://toutou.com:9200，需要在es服務端做CORS的配置，

修改docker中es7的elasticsearch.yml檔案

[root@localhost data]# docker exec -it es7 /bin/bash
[root@f1358d18c9be elasticsearch]# vi config/elasticsearch.yml

在elasticsearch.yml底部追加如下配置：

http.cors.enabled: true 
http.cors.allow-origin: "*"

保存以后退出docker并重啟docker實體，

[root@f1358d18c9be elasticsearch]# exit
exit
[root@localhost data]# docker restart es7
es7

2.6 驗證elasticsearch-head

SpringBoot進階教程(七十三)整合elasticsearch

2.7 安裝中文分詞器ik

注意：ik分詞器的版本需要和es的版本一致，

docker exec -it es7 /bin/bash
./bin/elasticsearch-plugin install https://github.com/medcl/elasticsearch-analysis-ik/releases/download/v7.5.1/elasticsearch-analysis-ik-7.5.1.zip
-> Downloading https://github.com/medcl/elasticsearch-analysis-ik/releases/download/v7.5.1/elasticsearch-analysis-ik-7.5.1.zip

進入plugins可以看到IK分詞器已經安裝成功，重啟docker實體即可，

SpringBoot進階教程(七十三)整合elasticsearch

vRESTful API

任何語言都可以使用RESTful API通過9200埠(默認埠號)和Elasticsearch進行通信，也可以用web客戶端(瀏覽器Sense插件、postman)訪問 Elasticsearch ，甚至直接使用curl命令就可以和Elasticsearch互動，

Elasticsearch為很多語言（Groovy、JavaScript、.NET、 PHP、 Perl、 Python 和 Ruby）提供了官方客戶端，詳情：Elasticsearch Clients，

3.0 Elasticsearch請求格式：

Elasticsearch請求和我們認識的其它HTTP請求一樣，由多個部件組成，具體格式如下：

curl -X<VERB> '<PROTOCOL>://<HOST>:<PORT>/<PATH>?<QUERY_STRING>' -d '<BODY>'

被 < > 標記的部件釋義：

VERB：HTTP請求方法: GET、POST、PUT、DELETE、HEAD... SpringBoot進階教程(七十三)整合elasticsearch

GET:標識該操作是用于獲取服務端的資源，可以理解為select操作
POST:用于向服務端新增資料，常用于提交表單，可以理解為insert操作
PUT:用于向服務端更新資料，與post的使用很相似，可以理解為update操作
DELETE:標識該操作是：用于洗掉服務端的資源，可以理解為delete操作
HEAD:只請求頁面首部，回應報文中沒有物體的主體部分(沒有body體)

點擊查看幾種http方法的區別...

PROTOCOL：http 或者 https SpringBoot進階教程(七十三)整合elasticsearch

概念：
HTTP：是互聯網上應用最為廣泛的一種網路協議，是一個客戶端和服務器端請求和應答的標準（TCP），用于從WWW服務器傳輸超文本到本地瀏覽器的傳輸協議，它可以使瀏覽器更加高效，使網路傳輸減少，
HTTPS：是以安全為目標的HTTP通道，簡單講是HTTP的安全版，即HTTP下加入SSL層，HTTPS的安全基礎是SSL，因此加密的詳細內容就需要SSL，
區別：
1.https協議需要到ca申請證書，一般免費證書很少，需要交費，
2.http是超文本傳輸協議，資訊是明文傳輸，https 則是具有安全性的ssl加密傳輸協議，
3.http和https使用的是完全不同的連接方式，用的埠也不一樣，前者是80，后者是443，
4.http的連接很簡單，是無狀態的；HTTPS協議是由SSL+HTTP協議構建的可進行加密傳輸、身份認證的網路協議，比http協議安全，

點擊查看http和https的區別

HOST：Elasticsearch 集群中任意節點的主機名，或者用 localhost 代表本地機器上的節點，
PORT：服務的埠號，默認是9200，
PATH：API 的終端路徑（例如 _count 將回傳集群中檔案數量），Path可能包含多個組件，例如： _cluster/stats 和 _nodes/stats/jvm ，
QUERY_STRING：任意可選的查詢字串引數 (例如 ?pretty 將格式化地輸出JSON回傳值，使其更容易閱讀)
BODY：一個 JSON格式的請求體(如果請求需要的話)

3.1 計算集群中檔案的數量

命令列格式： curl -XGET http://test.com:9200/_count?pretty

SpringBoot進階教程(七十三)整合elasticsearch

當然，也可以考慮使用其他工具，例如postman，

SpringBoot進階教程(七十三)整合elasticsearch

3.2 集群健康

Elasticsearch的集群監控資訊中包含了許多的統計資料，其中最為重要的一項就是集群健康，它在 status 欄位中展示為green、yellow或者red，

curl http://test.com:9200/_cluster/health

postman請求回傳結果如下：

SpringBoot進階教程(七十三)整合elasticsearch

{
    "cluster_name": "my-application",
    "status": "green",
    "timed_out": false,
    "number_of_nodes": 1,//集群節點數
    "number_of_data_nodes": 1,//資料節點數量
    "active_primary_shards": 0,//主分片數量
    "active_shards": 0,//可用的分片數量
    "relocating_shards": 0,//正在重新分配的分片數量，在新加或者減少節點的時候會發生
    "initializing_shards": 0,//正在初始化的分片數量，新建索引或者剛啟動會存在，時間很短
    "unassigned_shards": 0,//沒有分配的分片，一般就是那些名存實不存的副本分片
    "delayed_unassigned_shards": 0,
    "number_of_pending_tasks": 0,
    "number_of_in_flight_fetch": 0,
    "task_max_waiting_in_queue_millis": 0,
    "active_shards_percent_as_number": 100
}

3.3 status三種狀態值：

green:所有的主分片和副本分片都正常運行，
yellow:所有的主分片都正常運行，但不是所有的副本分片都正常運行，
red:有主分片沒能正常運行，

更多引數介紹：

索引級別集群狀態，可以細致查看到底是哪個索引引起集群的故障的

curl http://test.com:9200/_cluster/health?level=indices

分片級別集群狀態，可以細致查看到底是哪個分片引起的集群故障

curl http://test.com:9200/_cluster/health?level=shards

阻塞查看集群狀態，適用于自動化腳本，當狀態變為指定狀態或者更好就回傳繼續執行，

curl http://test.com:9200/_cluster/health?wait_for_status=yellow

v操作Elasticsearch

4.1 索引操作

4.1.1 查看索引是否存在

curl -i -XHEAD 'http://toutou.com:9200/city'

若索引存在：


HTTP/1.1 200 OK
content-type: application/json; charset=UTF-8
content-length: 239

若索引不存在：


HTTP/1.1 404 Not Found
content-type: application/json; charset=UTF-8
content-length: 395

4.1.2 創建Index

創建一個非結構化的索引，需要使用PUT請求，例如創建一個名為city的索引，

curl -X PUT '127.0.0.1:9200/city'

回傳結果：

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

acknowledged=true表示操作成功，

創建一個結構化的索引：

SpringBoot進階教程(七十三)整合elasticsearch

{
    "settings":{
        "number_of_shards":3,
        "number_of_replicas":1
    },
    "mappings":{
        "properties":{
            "name":{
                "type":"text",
                "analyzer":"ik_max_word",
                "search_analyzer":"ik_max_word"
            },
            "level":{
                "type":"integer"
            },
            "address":{
                "type":"text",
                "analyzer":"ik_smart",
                "search_analyzer":"ik_smart"
            },
            "createTime":{
                "type":"date",
                "format":"yyyy-MM-dd HH:mm:ss || yyyy-MM-dd || epoch_millis"
            }
        }
    }
}

View Code

number_of_shards表示分片個數，number_of_replicas表示備份個數，

注意：在上文中已經介紹了，在在7.x版會移除Type，所以這里不需要再指定type, 相反若指定type了的話會報錯， Root mapping definition has unsupported parameters

建議使用elasticsearch最新版本，若安裝的是低于elasticsearch7版本的elasticsearch,可以使用下面的方式創建索引，

{
    "settings":{
        "number_of_shards":3,
        "number_of_replicas":1
    },
    "mappings":{
        "hotel":{
            "properties":{
                "level":{
                    "type":"integer"
                },
                "address":{
                    "type":"text",
                    "analyzer":"ik_max_word"
                },
                "createTime":{
                    "type":"date",
                    "format":"yyyy-MM-dd HH:mm:ss || yyyy-MM-dd || epoch_millis"
                }
            }
        },
        "restaurant":{
            "properties":{
                "type":{
                    "type":"text",
                    "analyzer":"ik_smart"
                },
                "price":{
                    "type":"integer"
                }
            }
        }
    }
}

View Code

4.1.3 洗掉Index

$ curl -X DELETE '127.0.0.1:9200/city'

回傳結果：

{"acknowledged":true}

4.2 插入資料

4.2.1 插入指定id的資料

在 es 中，插入資料分為指定檔案id插入和自動產生檔案id插入

指定檔案id插入，其中我們指定資料ID為1，

SpringBoot進階教程(七十三)整合elasticsearch

生成id=1的資料，

注意，在在7.x版會移除Type，所以插入資料的url需要加上 _doc ,即： http://toutou.com:9200/city/_doc/1 ，具體規則可以看看這里

自動產生檔案id插入，

SpringBoot進階教程(七十三)整合elasticsearch

4.3 修改資料

SpringBoot進階教程(七十三)整合elasticsearch

4.4 查詢資料

4.4.1 ID查詢GET

SpringBoot進階教程(七十三)整合elasticsearch

4.4.2 條件查詢POST

查詢5星級酒店，

SpringBoot進階教程(七十三)整合elasticsearch

4.5 洗掉資料

curl -X DELETE 'toutou.com:9200/city/_doc/2'

vSpringBoot整合Elasticsearch

spring-boot-starter-data-elasticsearch除錯了很久，嘗試的很多方法，始終報錯： NoNodeAvailableException[None of the configured nodes are available: [{#transport#-1}{wlOJEdIeQqKrmiBiUuJVzQ}{toutou.com}{192.168.118.137:9300}]] ，看了一些相關介紹和博客，Spring Data Elasticsearch和Elasticsearch還有Spring Boot的版本需要全部一一對應上，才能使用，感覺太麻煩，新專案還好說，線上專案誰有功夫去跟你協調這些版本統一啊，費老勁了，果斷棄用了，如果有大佬這塊有好上手的兼容辦法，還請多多指點，

5.1 添加pom參考

        <dependency>
            <groupId>org.elasticsearch.client</groupId>
            <artifactId>elasticsearch-rest-high-level-client</artifactId>
            <!--<version>7.5.1</version>-->
        </dependency>

注意：如果是springboot程式的話， org.elasticsearch.client 參考的版本號 7.5.1 最好注釋掉，不然會報下面這個錯：

org.springframework.beans.factory.UnsatisfiedDependencyException: Error creating bean with name 'indexController': Unsatisfied dependency expressed through field 'cityEsService'; nested exception is org.springframework.beans.factory.UnsatisfiedDependencyException: Error creating bean with name 'cityEsServiceImpl': Unsatisfied dependency expressed through field 'client'; nested exception is org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'client' defined in class path resource [learn/service/impl/EsConfig.class]: Post-processing of merged bean definition failed; nested exception is java.lang.IllegalStateException: Failed to introspect Class [org.elasticsearch.client.RestHighLevelClient] from ClassLoader [sun.misc.Launcher$AppClassLoader@18b4aac2]
    at org.springframework.beans.factory.annotation.AutowiredAnnotationBeanPostProcessor$AutowiredFieldElement.inject(AutowiredAnnotationBeanPostProcessor.java:596)
    at org.springframework.beans.factory.annotation.InjectionMetadata.inject(InjectionMetadata.java:90)
    at org.springframework.beans.factory.annotation.AutowiredAnnotationBeanPostProcessor.postProcessProperties(AutowiredAnnotationBeanPostProcessor.java:374)
    at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.populateBean(AbstractAutowireCapableBeanFactory.java:1411)
    at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.doCreateBean(AbstractAutowireCapableBeanFactory.java:592)
    at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBean(AbstractAutowireCapableBeanFactory.java:515)
    at org.springframework.beans.factory.support.AbstractBeanFactory.lambda$doGetBean$0(AbstractBeanFactory.java:320)
    at org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.getSingleton(DefaultSingletonBeanRegistry.java:222)
    at org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:318)
    at org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:199)
    at org.springframework.beans.factory.support.DefaultListableBeanFactory.preInstantiateSingletons(DefaultListableBeanFactory.java:845)
    at org.springframework.context.support.AbstractApplicationContext.finishBeanFactoryInitialization(AbstractApplicationContext.java:877)
    at org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:549)
    at org.springframework.boot.web.servlet.context.ServletWebServerApplicationContext.refresh(ServletWebServerApplicationContext.java:140)
    at org.springframework.boot.SpringApplication.refresh(SpringApplication.java:742)
    at org.springframework.boot.SpringApplication.refreshContext(SpringApplication.java:389)
    at org.springframework.boot.SpringApplication.run(SpringApplication.java:311)
    at org.springframework.boot.SpringApplication.run(SpringApplication.java:1213)
    at org.springframework.boot.SpringApplication.run(SpringApplication.java:1202)
    at learn.web.Application.main(Application.java:18)
Caused by: org.springframework.beans.factory.UnsatisfiedDependencyException: Error creating bean with name 'cityEsServiceImpl': Unsatisfied dependency expressed through field 'client'; nested exception is org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'client' defined in class path resource [learn/service/impl/EsConfig.class]: Post-processing of merged bean definition failed; nested exception is java.lang.IllegalStateException: Failed to introspect Class [org.elasticsearch.client.RestHighLevelClient] from ClassLoader [sun.misc.Launcher$AppClassLoader@18b4aac2]
    at org.springframework.beans.factory.annotation.AutowiredAnnotationBeanPostProcessor$AutowiredFieldElement.inject(AutowiredAnnotationBeanPostProcessor.java:596)
    at org.springframework.beans.factory.annotation.InjectionMetadata.inject(InjectionMetadata.java:90)
    at org.springframework.beans.factory.annotation.AutowiredAnnotationBeanPostProcessor.postProcessProperties(AutowiredAnnotationBeanPostProcessor.java:374)
    at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.populateBean(AbstractAutowireCapableBeanFactory.java:1411)
    at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.doCreateBean(AbstractAutowireCapableBeanFactory.java:592)
    at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBean(AbstractAutowireCapableBeanFactory.java:515)
    at org.springframework.beans.factory.support.AbstractBeanFactory.lambda$doGetBean$0(AbstractBeanFactory.java:320)
    at org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.getSingleton(DefaultSingletonBeanRegistry.java:222)
    at org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:318)
    at org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:199)
    at org.springframework.beans.factory.config.DependencyDescriptor.resolveCandidate(DependencyDescriptor.java:277)
    at org.springframework.beans.factory.support.DefaultListableBeanFactory.doResolveDependency(DefaultListableBeanFactory.java:1251)
    at org.springframework.beans.factory.support.DefaultListableBeanFactory.resolveDependency(DefaultListableBeanFactory.java:1171)
    at org.springframework.beans.factory.annotation.AutowiredAnnotationBeanPostProcessor$AutowiredFieldElement.inject(AutowiredAnnotationBeanPostProcessor.java:593)
    ... 19 common frames omitted
Caused by: org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'client' defined in class path resource [learn/service/impl/EsConfig.class]: Post-processing of merged bean definition failed; nested exception is java.lang.IllegalStateException: Failed to introspect Class [org.elasticsearch.client.RestHighLevelClient] from ClassLoader [sun.misc.Launcher$AppClassLoader@18b4aac2]
    at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.doCreateBean(AbstractAutowireCapableBeanFactory.java:570)
    at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBean(AbstractAutowireCapableBeanFactory.java:515)
    at org.springframework.beans.factory.support.AbstractBeanFactory.lambda$doGetBean$0(AbstractBeanFactory.java:320)
    at org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.getSingleton(DefaultSingletonBeanRegistry.java:222)
    at org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:318)
    at org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:199)
    at org.springframework.beans.factory.config.DependencyDescriptor.resolveCandidate(DependencyDescriptor.java:277)
    at org.springframework.beans.factory.support.DefaultListableBeanFactory.doResolveDependency(DefaultListableBeanFactory.java:1251)
    at org.springframework.beans.factory.support.DefaultListableBeanFactory.resolveDependency(DefaultListableBeanFactory.java:1171)
    at org.springframework.beans.factory.annotation.AutowiredAnnotationBeanPostProcessor$AutowiredFieldElement.inject(AutowiredAnnotationBeanPostProcessor.java:593)
    ... 32 common frames omitted
Caused by: java.lang.IllegalStateException: Failed to introspect Class [org.elasticsearch.client.RestHighLevelClient] from ClassLoader [sun.misc.Launcher$AppClassLoader@18b4aac2]
    at org.springframework.util.ReflectionUtils.getDeclaredMethods(ReflectionUtils.java:507)
    at org.springframework.util.ReflectionUtils.doWithLocalMethods(ReflectionUtils.java:367)
    at org.springframework.beans.factory.annotation.InitDestroyAnnotationBeanPostProcessor.buildLifecycleMetadata(InitDestroyAnnotationBeanPostProcessor.java:207)
    at org.springframework.beans.factory.annotation.InitDestroyAnnotationBeanPostProcessor.findLifecycleMetadata(InitDestroyAnnotationBeanPostProcessor.java:189)
    at org.springframework.beans.factory.annotation.InitDestroyAnnotationBeanPostProcessor.postProcessMergedBeanDefinition(InitDestroyAnnotationBeanPostProcessor.java:128)
    at org.springframework.context.annotation.CommonAnnotationBeanPostProcessor.postProcessMergedBeanDefinition(CommonAnnotationBeanPostProcessor.java:297)
    at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.applyMergedBeanDefinitionPostProcessors(AbstractAutowireCapableBeanFactory.java:1077)
    at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.doCreateBean(AbstractAutowireCapableBeanFactory.java:567)
    ... 41 common frames omitted
Caused by: java.lang.NoClassDefFoundError: org/elasticsearch/client/Cancellable
    at java.lang.Class.getDeclaredMethods0(Native Method)
    at java.lang.Class.privateGetDeclaredMethods(Class.java:2701)
    at java.lang.Class.getDeclaredMethods(Class.java:1975)
    at org.springframework.util.ReflectionUtils.getDeclaredMethods(ReflectionUtils.java:489)
    ... 48 common frames omitted
Caused by: java.lang.ClassNotFoundException: org.elasticsearch.client.Cancellable
    at java.net.URLClassLoader.findClass(URLClassLoader.java:381)
    at java.lang.ClassLoader.loadClass(ClassLoader.java:424)
    at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:335)
    at java.lang.ClassLoader.loadClass(ClassLoader.java:357)
    ... 52 common frames omitted

View Code

因為就像上文提到的data與es version沖突似的， org.elasticsearch.client 也有版本之間的兼容性問題，把 org.elasticsearch.client 的版本號去掉由SpringBoot來管理依賴的版本即可，

5.2 添加EsConfig

import com.google.gson.Gson;
import org.apache.http.HttpHost;
import org.elasticsearch.client.RestClient;
import org.elasticsearch.client.RestHighLevelClient;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

/**
 * @author toutou
 * @date by 2021/02
 * @des
 */
@Configuration
public class EsConfig {

    public Gson gson(){
        return new Gson();
    }

    @Bean
    public RestHighLevelClient client(){
        RestHighLevelClient client=new RestHighLevelClient(
                RestClient.builder(
                        // 本地demo快速實作效果，host等資訊直接寫成固定值了，
                        new HttpHost("toutou.com",9200,"http")
                )
        );
        return client;
    }
}

5.3 根據id查詢城市酒店資訊

5.3.1 添加Service

CityEsService：

import java.util.Map;

/**
 * @author toutou
 * @date by 2021/02
 * @des
 */
public interface  CityEsService {
    Map<String,Object> getCityById(String id);
}

iceCityEsService

CityEsServiceImpl：

package learn.service.impl;

import learn.service.CityEsService;
import org.elasticsearch.action.get.GetRequest;
import org.elasticsearch.action.get.GetResponse;
import org.elasticsearch.client.RequestOptions;
import org.elasticsearch.client.RestHighLevelClient;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.io.IOException;
import java.util.HashMap;
import java.util.Map;

/**
 * @author toutou
 * @date by 2021/02
 * @des
 */
@Service
public class CityEsServiceImpl implements CityEsService{
    @Autowired
    private RestHighLevelClient client;

    @Override
    public Map<String,Object> getCityById(String id){
        GetRequest getRequest=new GetRequest("city","_doc",id);
        Map map=new HashMap();
        GetResponse response=null;
        try{
            response= client.get(getRequest, RequestOptions.DEFAULT);
        } catch (IOException e) {
            e.printStackTrace();
        }
        if(response.isExists()){
            // 本初為了方便演示，將id回傳
            map.put("id", response.getId());

            // 默認不回傳id資訊，若不需要id資訊直接回傳getSource結果即可，
            map.putAll(response.getSource());
            return map;
        }else{
            throw new RuntimeException("Is not exists.");
        }
    }
}

5.3.2 添加Controller

/**
 * @author toutou
 * @date by 2021/2
 * @des   https://www.cnblogs.com/toutou
 */
@Slf4j
@RestController
public class IndexController {

    @Autowired
    private CityEsService cityEsService;


    @GetMapping("es/search")
    public Result esSearch(@RequestParam("id") String id) {
        return Result.setSuccessResult(cityEsService.getCityById(id));
    }
}

5.3.3 效果驗證

由于service層和Controller大部分代碼都是重復的，下面就只貼service層代碼實作了，感興趣的可以在文章底部的原始碼中查看更多細節，

5.4 根據id洗掉城市酒店資訊

5.4.1 洗掉方法實作代碼

    @Override
    public String delCityById(String id){
        try {
            DeleteRequest request=new DeleteRequest("city","_doc",id);
            DeleteResponse response= client.delete(request,RequestOptions.DEFAULT);
            return response.status().name();
        } catch (IOException e) {
            throw new RuntimeException("洗掉失敗.");
        }
    }

5.4.2 效果驗證

5.5 添加資料

    @Override
    public String addCityByInfo(String id, String name, Integer level, String address, String createTime){
        Map<String, Object> jsonMap = new HashMap<>();
        jsonMap.put("name", name);
        jsonMap.put("level", level);
        jsonMap.put("address", address);
        jsonMap.put("createTime", createTime);

        // 若不需要創建指定id的資料，則不需要再IndexRequest的建構式中傳入id
        // IndexRequest indexRequest = new IndexRequest("city", "_doc");
        IndexRequest indexRequest = new IndexRequest("city", "_doc", id);
        indexRequest.source(jsonMap);
        try {
            IndexResponse rp = client.index(indexRequest);
            return rp.status().name();
        } catch (IOException e) {
            throw new RuntimeException("添加失敗.");
        }
    }

5.6 修改資料

    @Override
    public String updateCityByInfo(String id, String name){
        UpdateRequest request=new UpdateRequest("city","_doc", id);
        Map<String, Object> jsonMap = new HashMap<>();
        jsonMap.put("name", name);
        request.doc(jsonMap);
        try {
            return client.update(request,RequestOptions.DEFAULT).status().name();
        } catch (IOException e) {
            throw new RuntimeException("修改失敗.");
        }
    }

5.7 復合查詢

    public List<Map<String, Object>> query(String name, Integer level, Integer index, Integer size){
        SearchRequest request = new SearchRequest("city");
        BoolQueryBuilder boolQueryBuilder = QueryBuilders.boolQuery();
        boolQueryBuilder.must(QueryBuilders.matchQuery("name", name));
        boolQueryBuilder.must(QueryBuilders.matchQuery("level", level));
        SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
        //排序
        searchSourceBuilder.sort(SortBuilders.fieldSort("createTime").order(SortOrder.DESC));
        //分頁
        searchSourceBuilder.from(index).size(size).query(boolQueryBuilder);
        request.searchType(SearchType.DEFAULT).source(searchSourceBuilder);
        List<Map<String, Object>> list = new ArrayList<>();
        try {
            SearchResponse rp = client.search(request, RequestOptions.DEFAULT);
            for (SearchHit item : rp.getHits().getHits()) {
                list.add(item.getSourceAsMap());
            }
        } catch (IOException e) {
            throw new RuntimeException("查詢失敗.");
        }

        return list;
    }

其他參考資料：

Elasticsearch: 權威指南
elasticsearch - Docker Hub
Java High Level REST Client

v原始碼地址

https://github.com/toutouge/javademosecond/tree/master/hellospringboot

作　　者：請叫我頭頭哥
出　　處：http://www.cnblogs.com/toutou/
關于作者：專注于基礎平臺的專案開發，如有問題或建議，請多多賜教！
著作權宣告：本文著作權歸作者和博客園共有，歡迎轉載，但未經作者同意必須保留此段宣告，且在文章頁面明顯位置給出原文鏈接，
特此宣告：所有評論和私信都會在第一時間回復，也歡迎園子的大大們指正錯誤，共同進步，或者直接私信我
聲援博主：如果您覺得文章對您有幫助，可以點擊文章右下角【推薦】一下，您的鼓勵是作者堅持原創和持續寫作的最大動力！

轉載請註明出處，本文鏈接：https://www.uj5u.com/houduan/438610.html

標籤：Java

上一篇：C語言程式設計100例之（75）：Vigenère 密碼

下一篇：反射、靜態代理、動態代理（jdk、cglib）