springboot simple （13） springboot Elasticsearch（Elasticsearch8.5.1）

爱被打了一巴掌 2024-03-26 09:55 129阅读 0赞

这里首先简单的介绍了Elasticsearch，然后实现了springboot集成Elasticsearch。

版本：  
Elasticsearch：**v8.5.1**  
Kibana：**v8.5.1**

springboot集成elasticsearch有两种方式。  
1）rest客户端RestHingLevelClient；  
2）接口ElasticSearchRepository。  
这里采用第1种方式。

## 1 Elasticsearch简介 ##

ElasticSearch是一个基于Apache Lucene的开源搜索引擎。  
Kibana 是一个开源分析和可视化平台，旨在可视化操作 Elasticsearch。

**也就是说**：  
ElasticSearch 只是后台程序，没有界面；  
Kibana是ElasticSearch对应的前端。

主要术语：

*  索引（Index）  
    索引是具有某种相似特征的文档的集合。例如，客户数据索引，产品目录索引，以及订单数据索引。
 *  文档（document）  
    文档是可以被索引的基本单位。文档使用JSON表示。

## 2 springboot 集成Elasticsearch ##

Elasticsearch已支持Index（索引）、Document（文档）、Graph（图）、Machine learning（机器学习）等。  
![在这里插入图片描述][075498a3284f48a19b3d516a195dff0f.png]  
这里介绍了Index（索引）、Document（文档）的简单使用。

第1步：pom中引入依赖的包：

<dependency>
    			<groupId>org.springframework.boot</groupId>
    			<artifactId>spring-boot-starter-data-elasticsearch</artifactId>
    			<version>3.0.2</version>
    		</dependency>

第2步：application.properties设置相关参数：

server.port =8081
    
    spring.data.elasticsearch.repositories.enabled = true
    spring.data.elasticsearch.cluster-nodes = localhost:9300
    
    spring.elasticsearch.rest.username=elastic
    spring.elasticsearch.rest.password=123456
    spring.elasticsearch.rest.uris=localhost:9200

第3步：对应的配置类ElasticSearchConfig.java：

@Component
    @Configuration
    public class ElasticSearchConfig extends AbstractElasticsearchConfiguration {
        
        @Value("${spring.elasticsearch.rest.uris}")
        private String uris ;
        @Value("${spring.elasticsearch.rest.username}")
        private String username;
        @Value("${spring.elasticsearch.rest.password}")
        private String password ;
    
        @Override
        @Bean(destroyMethod = "close")
        public RestHighLevelClient elasticsearchClient() {
        
            final ClientConfiguration clientConfiguration = ClientConfiguration.builder()
                    .connectedTo(uris)
                    .withBasicAuth(username, password)
                    .build();
            return RestClients.create(clientConfiguration).rest();
        }
    }

第4步：实现index的工具类IndexUtil.java：

@Component
    public class IndexUtil {
        
        @Autowired
        private RestHighLevelClient restHighLevelClient;
    
        /**
         * 创建索引index
         * @param index
         * @return
         * @throws IOException
         */
        public boolean createIndex(String index){
        
            if (!isIndexExist(index)) {
        
                return false;
            }
            boolean isAcknowledged = false;
            CreateIndexRequest createIndexRequest = new CreateIndexRequest(index);
            try {
        
                AcknowledgedResponse acknowledgedResponse = restHighLevelClient.indices().create(createIndexRequest, RequestOptions.DEFAULT);
                isAcknowledged = acknowledgedResponse.isAcknowledged();
            } catch (IOException e) {
        
                e.printStackTrace();
            } finally {
        
                return isAcknowledged;
            }
        }
    
        /**
         * 删除索引
         * @param index
         * @return
         * @throws IOException
         */
        public boolean deleteIndex(String index){
        
            if (!isIndexExist(index)) {
        
                return false;
            }
            boolean isAcknowledged = false;
            DeleteIndexRequest deleteIndexRequest = new DeleteIndexRequest(index);
            try {
        
                AcknowledgedResponse acknowledgedResponse = restHighLevelClient.indices().delete(deleteIndexRequest,RequestOptions.DEFAULT);
                isAcknowledged = acknowledgedResponse.isAcknowledged();
            } catch (IOException e) {
        
                e.printStackTrace();
            } finally {
        
                return isAcknowledged;
            }
        }
    
        /**
         * 判断索引是否存在
         * @param index
         * @return
         * @throws IOException
         */
        public boolean isIndexExist(String index) {
        
            boolean isExist = false;
            try {
        
                GetIndexRequest getIndexRequest = new GetIndexRequest(index);
                isExist = restHighLevelClient.indices().exists(getIndexRequest, RequestOptions.DEFAULT);
            } catch (IOException e) {
        
                e.printStackTrace();
            } finally {
        
                return isExist;
            }
        }
    }

第5步：实现document的工具类DocumentUtil.java：

@Component
    public class DocumentUtil {
        
        @Autowired
        private RestHighLevelClient restHighLevelClient;
    
        /**
         * 添加document
         * @param object
         * @param index
         * @param id
         * @return
         */
        public void addDocument(Object object, String index,String id){
        
            //1 create IndexRequest
            IndexRequest indexRequest = new IndexRequest(index);
            indexRequest.id(id);
            indexRequest.timeout(TimeValue.timeValueSeconds(1));
            String content = JSON.toJSONString(object);
            indexRequest.source(content, XContentType.JSON);
            try {
        
                //2 send IndexRequest
                IndexResponse indexResponse =restHighLevelClient.index(indexRequest,RequestOptions.DEFAULT);
            } catch (IOException e) {
        
                e.printStackTrace();
            }
        }
    
        /**
         * 添加document,随机id
         * @param object
         * @param index
         * @return
         */
        public void addDocument(Object object, String index){
        
            String id= "";
            id = UUID.randomUUID().toString().replaceAll("-","").toUpperCase();
            addDocument(object, index, id);
        }
    
        /**
         * get Document
         * @param index
         * @param id
         * @return
         */
        public GetResponse getDocumnet(String index,String id){
        
            GetResponse getResponse = null;
            GetRequest getRequest = new GetRequest(index, id);
            try {
        
                getResponse = restHighLevelClient.get(getRequest, RequestOptions.DEFAULT);
            }catch (IOException e){
        
                e.printStackTrace();
            } finally {
        
                return  getResponse;
            }
        }
    
        /**
         * update document
         * @param object
         * @param index
         * @param id
         */
        public void updateDocument(Object object, String index,String id){
        
            //1 create UpdateRequest
            UpdateRequest updateRequest = new UpdateRequest(index,id);
            updateRequest.timeout(TimeValue.timeValueSeconds(1));
            String content = JSON.toJSONString(object);
            updateRequest.doc(content, XContentType.JSON);
            try {
        
                //2 send UpdateRequest
                UpdateResponse updateResponse =restHighLevelClient.update(updateRequest,RequestOptions.DEFAULT);
            } catch (IOException e) {
        
                e.printStackTrace();
            }
        }
    
        /**
         * 删除Document
         * @param index
         * @param id
         */
        public void deleteDocument(String index,String id){
        
            //1 create DeleteRequest
            DeleteRequest deleteRequest = new DeleteRequest(index, id);
            try {
        
                //2 send DeleteRequest
                DeleteResponse deleteResponse =  restHighLevelClient.delete(deleteRequest,RequestOptions.DEFAULT);
            } catch (IOException e) {
        
                e.printStackTrace();
            }
        }
    
        public SearchResponse search(String index, TermQueryBuilder termQueryBuilder){
        
            //1 create SearchRequest
            SearchRequest searchRequest = new SearchRequest(index);
    
            //2 create SearchSourceBuilder
            SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
            searchSourceBuilder.query(termQueryBuilder);
            searchSourceBuilder.timeout(TimeValue.timeValueSeconds(60));
    
            //3 查询条件放入SearchRequest
            searchRequest.source(searchSourceBuilder);
    
            //4 send SearchRequest
            SearchResponse searchResponse = null;
            try {
        
                searchResponse = restHighLevelClient.search(searchRequest,RequestOptions.DEFAULT);
            } catch (IOException e) {
        
                e.printStackTrace();
            } finally {
        
                return searchResponse;
            }
        }
    
        public SearchResponse searchHighLight(String index, TermQueryBuilder termQueryBuilder){
        
            //1 create SearchRequest
            SearchRequest searchRequest = new SearchRequest(index);
    
            //2 create SearchSourceBuilder
            SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
            searchSourceBuilder.highlighter();
            searchSourceBuilder.query(termQueryBuilder);
            searchSourceBuilder.timeout(TimeValue.timeValueSeconds(60));
    
            //3 查询条件放入SearchRequest
            searchRequest.source(searchSourceBuilder);
    
            //4 send SearchRequest
            SearchResponse searchResponse = null;
            try {
        
                searchResponse = restHighLevelClient.search(searchRequest,RequestOptions.DEFAULT);
            } catch (IOException e) {
        
                e.printStackTrace();
            } finally {
        
                return searchResponse;
            }
        }
    }

## 3 测试验证 ##

前提：安装运行ElasticSearch和Kibana。

第1步：创建index，postman发送请求：  
![在这里插入图片描述][b4969b65774746bfa8af8e1ed9ddbe66.png]

然后，Kibana中输入：  
`GET /_cat/indices?v`  
查询到index创建成功。![在这里插入图片描述][176c2f7da4ad44d59023c414809a316f.png]  
第2步：创建Document，postman发送请求：  
![在这里插入图片描述][5b128ba00b734e7e83f01447ef2f7e1a.png]  
然后，Kibana中输入：  
`GET heroic/_doc/1`  
查询到Document创建成功。![在这里插入图片描述][741b7073f836495bab8a51bf6f89b9e6.png]  
第3步：查询Document，postman发送请求：  
![在这里插入图片描述][b6f767a7a4574952ae44eae128265cd0.png]

第4步：修改Document，将name“关羽”改为“刘备”；  
postman发送请求：  
![在这里插入图片描述][ccb9551be1c14a13a3e1ba15fcc47ec6.png]  
然后，Kibana中输入：  
`GET heroic/_doc/1`  
查询到Document修改成功。  
![在这里插入图片描述][6a25260a9e794a36aed81963b0657dfa.png]  
第5步：删除Document，postman发送请求：  
![在这里插入图片描述][e7b580e7984041d2baee654065915789.png]  
然后，Kibana中输入：  
`GET heroic/_doc/1`  
查询到Document删除成功。  
![在这里插入图片描述][e8aa86cd5da040e49216ce62f76bb42c.png]  
代码详见：  
[https://gitee.com/linghufeixia/springboot-simple][https_gitee.com_linghufeixia_springboot-simple]  
chapter9-1

--------------------

**教程列表**：  
[springboot simple（0） springboot简介][springboot simple_0_ springboot]  
[springboot simple（1） springboot Helloworld][springboot simple_1_ springboot Helloworld]  
[springboot simple（2） springboot Starter][springboot simple_2_ springboot Starter]  
[springboot simple（3 ）springboot Web开发][springboot simple_3 _springboot Web]  
[springboot simple（4）springboot 数据持久化][springboot simple_4_springboot]  
[springboot simple （5） springboot Nosql][springboot simple _5_ springboot Nosql]  
[springboot simple （6） springboot mqtt][springboot simple _6_ springboot mqtt]  
[springboot simple （7） springboot thrift][springboot simple _7_ springboot thrift]  
[springboot simple （8） springboot kafka][springboot simple _8_ springboot kafka]  
[springboot simple （9） springboot jpa（Hibernate）][springboot simple _9_ springboot jpa_Hibernate]  
[springboot simple （10） springboot protobuf][springboot simple _10_ springboot protobuf]  
[springboot simple （11） springboot protostuff][springboot simple _11_ springboot protostuff]  
[springboot simple （12） springboot RabbitMQ][springboot simple _12_ springboot RabbitMQ]  
[springboot simple （13） springboot Elasticsearch][springboot simple _13_ springboot Elasticsearch]

[075498a3284f48a19b3d516a195dff0f.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/26/3b7c68d43f854d6087d519a257b4f0d2.png
[b4969b65774746bfa8af8e1ed9ddbe66.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/26/cf3ff6fae7374799bbbb55f3aefe2cb9.png
[176c2f7da4ad44d59023c414809a316f.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/26/e054a093115548d7bb0fe2cfc0598265.png
[5b128ba00b734e7e83f01447ef2f7e1a.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/26/e4b513ff55f64df7afd9c4fdcbe9f217.png
[741b7073f836495bab8a51bf6f89b9e6.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/26/1e2b1ca3b5854bf7a9c7fc217a21b9f8.png
[b6f767a7a4574952ae44eae128265cd0.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/26/9256b0ae9f19437789a5de398a21bb16.png
[ccb9551be1c14a13a3e1ba15fcc47ec6.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/26/cb58a1dadf464f3389aee127dc1e308a.png
[6a25260a9e794a36aed81963b0657dfa.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/26/647394509d6e475faa37098e4b8f7c6f.png
[e7b580e7984041d2baee654065915789.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/26/c289e9ac8ef642a8b9656e57cc314b9f.png
[e8aa86cd5da040e49216ce62f76bb42c.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/26/d1155afa2dd04247bc1e07ad89c1ed4c.png
[https_gitee.com_linghufeixia_springboot-simple]: https://gitee.com/linghufeixia/springboot-simple
[springboot simple_0_ springboot]: https://blog.csdn.net/afei8080/article/details/101297868
[springboot simple_1_ springboot Helloworld]: https://blog.csdn.net/afei8080/article/details/101345712
[springboot simple_2_ springboot Starter]: https://blog.csdn.net/afei8080/article/details/101346285
[springboot simple_3 _springboot Web]: https://blog.csdn.net/afei8080/article/details/101348597
[springboot simple_4_springboot]: https://blog.csdn.net/afei8080/article/details/101422030
[springboot simple _5_ springboot Nosql]: https://blog.csdn.net/afei8080/article/details/101422594
[springboot simple _6_ springboot mqtt]: https://blog.csdn.net/afei8080/article/details/121513387?spm=1001.2014.3001.5502
[springboot simple _7_ springboot thrift]: https://blog.csdn.net/afei8080/article/details/127687148
[springboot simple _8_ springboot kafka]: https://blog.csdn.net/afei8080/article/details/127749475
[springboot simple _9_ springboot jpa_Hibernate]: https://blog.csdn.net/afei8080/article/details/128001389
[springboot simple _10_ springboot protobuf]: https://blog.csdn.net/afei8080/article/details/128297408
[springboot simple _11_ springboot protostuff]: https://blog.csdn.net/afei8080/article/details/128342603
[springboot simple _12_ springboot RabbitMQ]: https://blog.csdn.net/afei8080/article/details/128493057
[springboot simple _13_ springboot Elasticsearch]: https://blog.csdn.net/afei8080/article/details/129081165