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

阿新 • • 發佈：2022-03-06

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

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例項即可。

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...

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

點選檢視幾種http方法的區別...

PROTOCOL：http 或者 https

概念：
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

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

3.2 叢集健康

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

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

postman請求返回結果如下：

{
    "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表示操作成功。

建立一個結構化的索引：

{
    "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。

生成id=1的資料。

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

自動產生文件id插入。

4.3 修改資料

4.4 查詢資料

4.4.1 ID查詢GET

4.4.2 條件查詢POST

查詢5星級酒店。

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;
    }

其他參考資料：

v原始碼地址

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

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

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

v基礎概念

vdocker安裝Elasticsearch

vRESTful API

v操作Elasticsearch

4.1 索引操作

4.2 插入資料

4.3 修改資料

4.4 查詢資料

4.5 刪除資料

vSpringBoot整合Elasticsearch

v原始碼地址

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

SpringBoot進階教程(六十三)Jasypt配置檔案加密

SpringBoot進階教程(六十七)RateLimiter限流

SpringBoot進階教程(六十四)註解大全

SpringBoot進階教程(六十五)自定義註解

SpringBoot進階教程(六十八)Sentinel實現限流降級

SpringBoot進階之道-@Enable模組驅動

SpringBoot進階之道-@SpringBootApplication

大型Java進階專題(七) 設計模式之委派模式與策略模式

FastAPI 進階知識(七) 高階定製的Response

angular的學習進階(十七)

JavaScript進階筆記(七):非同步任務和事件迴圈

《MSSQL2008進階教程》之四“SQL常用函式（二）”

《MSSQL2008進階教程》之一“SQL分組查詢”

《MSSQL2008進階教程》之五“SQL觸發器”

四天Mysql進階教程之Day01

PHP進階教程-PHP的協程怎麼玩？這一篇帶你搞定swoole協程

springboot使用rest-high-level-client整合elasticsearch 7.5.1

python基礎-面向物件（十九）面向物件進階（七）描述符get()、set()和delete()

【MySQL】MySQL進階教程學習筆記1

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

v基礎概念

vdocker安裝Elasticsearch

vRESTful API

v操作Elasticsearch

4.1 索引操作

4.2 插入資料

4.3 修改資料

4.4 查詢資料

4.5 刪除資料

vSpringBoot整合Elasticsearch

v原始碼地址

相關推薦