【Elasticsearch篇】详解使用RestClient操作索引库的相关操作

迈不过友情╰ 2024-04-17 06:40 81阅读 0赞

#### 文章目录 ####

*  ?什么是Elasticsearch
 *  ?什么是RestClient
 *  ?代码操作
 *   *  ⭐初始化RestClient
     *  ⭐使用RestClient操作索引库
     *  ⭐使用RestClient删除索引库
     *  ⭐使用RestClient判断索引库是否存在

![在这里插入图片描述][99aab4edcb574447b73988e549e07060.png]

## ?什么是Elasticsearch ##

Elasticsearch是一个开源的分布式搜索和分析引擎，`用于实时搜索、分析和存储大规模数据`。它基于Apache Lucene库构建，提供了一个简单而强大的分布式搜索解决方案。

Elasticsearch具有以下特点：

*  分布式架构：Elasticsearch可以在多个节点上分布数据，并自动处理数据的复制、故障转移和负载均衡。
 *  实时性能：Elasticsearch可以快速地进行实时搜索和分析，支持高并发查询。
 *  多种数据类型支持：Elasticsearch支持各种类型的数据，包括结构化数据、无结构数据和地理位置数据等。
 *  强大的查询功能：Elasticsearch提供了丰富而灵活的查询语言，可以进行全文搜索、过滤、聚合等操作。
 *  可扩展性：Elasticsearch可以轻松地扩展到数百台甚至数千台服务器，以处理海量的数据和请求。
 *  插件生态系统：Elasticsearch有一个活跃的插件生态系统，可以通过插件来扩展其功能，满足各种不同的需求。

由于其强大的功能和易于使用的特点，Elasticsearch被广泛应用于各种场景，包括企业搜索、日志分析、安全分析、商业智能等。

## ?什么是RestClient ##

在Java中，RestClient是一种用于与RESTful API进行通信的客户端库或框架，可以用来操作ES，这些客户端的本质就是组装DSL语句，通过http请求发给ES

## ?代码操作 ##

相关代码我上传到网盘里面了

> 链接：https://pan.baidu.com/s/1b6kMtGWL7FAK0f6R-3kyqA  
> 提取码：lsyu

### ⭐初始化RestClient ###

引入依赖

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

统一版本  
在properties里面加上下面的代码

<elasticsearch.version>7.12.1</elasticsearch.version>

![在这里插入图片描述][bd826ef55dc94c7c8febb826bc9b1a9c.png]

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

下面我们新创建一个单元测试类HotelIndexTest

![在这里插入图片描述][adcdaf0b7f3a46679429cda61feaf9c0.png]  
写入下面的测试代码

package cn.itcast.hotel;
    
    import org.apache.http.HttpHost;
    import org.elasticsearch.client.RestClient;
    import org.elasticsearch.client.RestHighLevelClient;
    import org.junit.jupiter.api.AfterEach;
    import org.junit.jupiter.api.BeforeEach;
    import org.junit.jupiter.api.Test;
    
    public class HotelIndexTest {
        
        private RestHighLevelClient client;
    
        @Test
        void testInit(){
        
            System.out.println(client);
        }
    
        @BeforeEach
        void setUp() {
        
            this.client = new RestHighLevelClient(RestClient.builder(
                    HttpHost.create("http://192.168.125.131:9200")
                    ));
        }
    
        //用完后销毁
        @AfterEach
        void tearDown() throws Exception {
        
            this.client.close();
        }
    }

![在这里插入图片描述][0bc618db11d8479f977ac6840a2525cb.png]

至此，初始化完成

### ⭐使用RestClient操作索引库 ###

新建一个类，写入下面的代码，用来定义mapping映射的JSON字符串常量：  
![在这里插入图片描述][7aae97fbb44a4474bc487cc707286f74.png]

package cn.itcast.hotel.constants;
    
    public class HotelConstants {
        
        public static final String MAPPING_TEMPLATE = "{\n" +
                "  \"mappings\": {\n" +
                "    \"properties\": {\n" +
                "      \"id\": {\n" +
                "        \"type\": \"keyword\"\n" +
                "      },\n" +
                "      \"name\":{\n" +
                "        \"type\": \"text\",\n" +
                "        \"analyzer\": \"ik_max_word\",\n" +
                "        \"copy_to\": \"all\"\n" +
                "      },\n" +
                "      \"address\":{\n" +
                "        \"type\": \"keyword\",\n" +
                "        \"index\": false\n" +
                "      },\n" +
                "      \"price\":{\n" +
                "        \"type\": \"integer\"\n" +
                "      },\n" +
                "      \"score\":{\n" +
                "        \"type\": \"integer\"\n" +
                "      },\n" +
                "      \"brand\":{\n" +
                "        \"type\": \"keyword\",\n" +
                "        \"copy_to\": \"all\"\n" +
                "      },\n" +
                "      \"city\":{\n" +
                "        \"type\": \"keyword\",\n" +
                "        \"copy_to\": \"all\"\n" +
                "      },\n" +
                "      \"starName\":{\n" +
                "        \"type\": \"keyword\"\n" +
                "      },\n" +
                "      \"business\":{\n" +
                "        \"type\": \"keyword\"\n" +
                "      },\n" +
                "      \"location\":{\n" +
                "        \"type\": \"geo_point\"\n" +
                "      },\n" +
                "      \"pic\":{\n" +
                "        \"type\": \"keyword\",\n" +
                "        \"index\": false\n" +
                "      },\n" +
                "      \"all\":{\n" +
                "        \"type\": \"text\",\n" +
                "        \"analyzer\": \"ik_max_word\"\n" +
                "      }\n" +
                "    }\n" +
                "  }\n" +
                "}";
    }

我们继续使用上面的测试类，新建一个测试对象，代码如下

@Test
    void createHotelIndex() throws IOException {
        
        // 1.创建Request对象
        CreateIndexRequest request = new CreateIndexRequest("hotel");
        // 2.准备请求的参数：DSL语句
        request.source(MAPPING_TEMPLATE, XContentType.JSON);
        // 3.发送请求
        client.indices().create(request, RequestOptions.DEFAULT);
    }

![在这里插入图片描述][46c687f47e554b1db340c73345928f3e.png]代码分为三步：

*  1）创建Request对象。因为是创建索引库的操作，因此Request是CreateIndexRequest。
 *  2）添加请求参数，其实就是DSL的JSON参数部分。因为json字符串很长，这里是定义了静态字符串常量MAPPING\_TEMPLATE，让代码看起来更加优雅。
 *  3）发送请求，client.indices()方法的返回值是IndicesClient类型，封装了所有与索引库操作有关的方法。

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

我们运行一下上面的测试代码，然后去浏览器看一下效果

> 注意不要导错包了，我们测试类使用中的包是  
> import org.elasticsearch.client.indices.CreateIndexRequest;

![在这里插入图片描述][7398ffcfda924c9698c270775baca612.png]  
查询到了结果

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

### ⭐使用RestClient删除索引库 ###

我们继续使用上面的测试类，加入下面的代码

*  1）创建Request对象。这次是DeleteIndexRequest对象
 *  2）准备参数。这里是无参
 *  3）发送请求。改用delete方法

@Test
    void testDeleteHotelIndex() throws IOException {
        
        // 1.创建Request对象
        DeleteIndexRequest request = new DeleteIndexRequest("hotel");
        // 2.发送请求
        client.indices().delete(request, RequestOptions.DEFAULT);
    }

### ⭐使用RestClient判断索引库是否存在 ###

我们继续使用上面的测试类，加入下面的代码

*  1）创建Request对象。这次是GetIndexRequest对象
 *  2）准备参数。这里是无参
 *  3）发送请求。改用exists方法

@Test
    void testExistsHotelIndex() throws IOException {
        
        // 1.创建Request对象
        GetIndexRequest request = new GetIndexRequest("hotel");
        // 2.发送请求
        boolean exists = client.indices().exists(request, RequestOptions.DEFAULT);
        // 3.输出
        System.err.println(exists ? "索引库已经存在！" : "索引库不存在！");
    }

![在这里插入图片描述][d3c0a75abe66418c97f117bdaefb08a0.png]

> 在技术的道路上，我们不断探索、不断前行，不断面对挑战、不断突破自我。科技的发展改变着世界，而我们作为技术人员，也在这个过程中书写着自己的篇章。让我们携手并进，共同努力，开创美好的未来！愿我们在科技的征途上不断奋进，创造出更加美好、更加智能的明天！

![在这里插入图片描述][749a94fd0a89448787e60e7c819e0f83.png_pic_center]

[99aab4edcb574447b73988e549e07060.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/15/fd573a86a62c4ff7be7828006ba84f74.png
[bd826ef55dc94c7c8febb826bc9b1a9c.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/15/b53f0d456fee41d881e7e70aac56f25a.png
[adcdaf0b7f3a46679429cda61feaf9c0.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/15/98ba542c588a44eb98f3891ef8ff4d65.png
[0bc618db11d8479f977ac6840a2525cb.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/15/5763f1d62a8d4efc9e088c033e32e401.png
[7aae97fbb44a4474bc487cc707286f74.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/15/3c44e8ad5b3147109e12eef2645cab56.png
[46c687f47e554b1db340c73345928f3e.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/15/dcf58f57d4864521b8f6e59428a1970b.png
[7398ffcfda924c9698c270775baca612.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/15/bb7e9aaa2687409b95ef486c87efe1e6.png
[d3c0a75abe66418c97f117bdaefb08a0.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/15/823125c4827c44fc8aa374c2535fdfad.png
[749a94fd0a89448787e60e7c819e0f83.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/15/fec3cd00e07449e1b9b249d66b0e5d6d.png