ToB企服应用市场:ToB评测及商务社交产业平台

标题: 04-HighLevelAPI入门 [打印本页]

---

作者: 灌篮少年    时间: 2022-9-16 17:15
标题: 04-HighLevelAPI入门
八、HighLevelAPI

8.1、RestAPI介绍&项目导入

8.1.1、RestAPI介绍

• ES官方提供了各种不同语言的客户端，用来操作ES。这些客户端的本质就是组装DSL语句，通过http请求发送给ES
  
• 官方文档地址
  
  
  
  • https://www.elastic.co/guide/en/elasticsearch/client/index.html
    
  
  
• 其中的Java Rest Client又包括两种
  
  
  
  • Java Low Level Rest Client
    
  • Java High Level Rest Client
    
  • 
    
  
  

本次学习的是HighLevel版本

8.1.2、项目导入

有需要的可以直接联系本人

①、数据库数据导入

• 导入自定义的数据即可；
  

②、创建初始工程

• 初始工程创建成功后，目录结构如下所示
  
  
  
  • 
    
  • 其中HotelDoc后续会说到
    
  
  
• 配置application.yml
  
  
  
  • 在spring层级下添加es的服务端路径配置
    
  • 1.   elasticsearch:
    2.     rest:
    3.       uris:
    4.         - http://192.168.222.135:9200

    复制代码
  
  
• 导入相关依赖
  
  
  
  • 1. <?xml version="1.0" encoding="UTF-8"?>
    2. <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    3.          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
    4.     <modelVersion>4.0.0</modelVersion>
    5.     <parent>
    6.         <groupId>org.springframework.boot</groupId>
    7.         <artifactId>spring-boot-starter-parent</artifactId>
    8.         <version>2.3.8.RELEASE</version>
    9.         <relativePath/>
    10.     </parent>
    11.     <groupId>com.coolman.hotel</groupId>
    12.     <artifactId>hotel-demo</artifactId>
    13.     <name>hotel-demo</name>
    14.     <description>Demo project for Spring Boot</description>
    15.     <properties>
    16.         <java.version>1.8</java.version>
    17.     </properties>
    18.     <dependencies>
    19.         <dependency>
    20.             <groupId>org.springframework.boot</groupId>
    21.             <artifactId>spring-boot-starter-web</artifactId>
    22.         </dependency>
    23.         <dependency>
    24.             <groupId>com.baomidou</groupId>
    25.             <artifactId>mybatis-plus-boot-starter</artifactId>
    26.             <version>3.1.1</version>
    27.         </dependency>
    28.         <dependency>
    29.             <groupId>mysql</groupId>
    30.             <artifactId>mysql-connector-java</artifactId>
    31.             <version>8.0.27</version>
    32.             <scope>runtime</scope>
    33.         </dependency>
    34.         <dependency>
    35.             <groupId>org.projectlombok</groupId>
    36.             <artifactId>lombok</artifactId>
    37.             <optional>true</optional>
    38.         </dependency>
    39.         <dependency>
    40.             <groupId>org.springframework.boot</groupId>
    41.             <artifactId>spring-boot-starter-test</artifactId>
    42.             <scope>test</scope>
    43.         </dependency>
    44.                 <dependency>
    45.             <groupId>org.apache.commons</groupId>
    46.             <artifactId>commons-lang3</artifactId>
    47.         </dependency>
    49.         
    50.         <dependency>
    51.             <groupId>org.elasticsearch.client</groupId>
    52.             <artifactId>elasticsearch-rest-high-level-client</artifactId>
    53.         </dependency>
    54.     </dependencies>
    56.     <build>
    57.         <plugins>
    58.             <plugin>
    59.                 <groupId>org.springframework.boot</groupId>
    60.                 <artifactId>spring-boot-maven-plugin</artifactId>
    61.                 <configuration>
    62.                     <excludes>
    63.                         <exclude>
    64.                             <groupId>org.projectlombok</groupId>
    65.                             <artifactId>lombok</artifactId>
    66.                         </exclude>
    67.                     </excludes>
    68.                 </configuration>
    69.             </plugin>
    70.         </plugins>
    71.     </build>
    73. </project>

    复制代码
  
  
• 编写测试类，验证是否可以正常连接
  
  
  
  • 1. package com.coolman.hotel.test;
    3. import lombok.extern.slf4j.Slf4j;
    4. import org.elasticsearch.client.RestHighLevelClient;
    5. import org.junit.jupiter.api.Test;
    6. import org.springframework.beans.factory.annotation.Autowired;
    7. import org.springframework.boot.test.context.SpringBootTest;
    9. @SpringBootTest
    10. @Slf4j
    11. public class TestConnectES {
    13.     @Autowired
    14.     private RestHighLevelClient restHighLevelClient;
    16.     @Test
    17.     public void testConnect() {
    18.       log.info(restHighLevelClient + "");
    19.     }
    20. }

    复制代码
  • 
    
  
  

8.2、创建索引

• 代码如下所示
  
  
  
  • 1.     /**
    2.      * 创建索引测试
    3.      */
    4.     @Test
    5.     public void testCreateIndex() throws IOException {
    6.         // 1. 获取索引操作对象
    7.         IndicesClient indicesClient = restHighLevelClient.indices();
    9.         // 2. 创建索引对象
    10.         CreateIndexRequest request = new CreateIndexRequest("hotel");// 相当于DSL语句的 PUT hotel 请求，但是还没执行
    12.         // 3. 执行操作
    13.         CreateIndexResponse response = indicesClient.create(request, RequestOptions.DEFAULT);
    15.         // 4. 获取结果
    16.         log.info(response.isAcknowledged() + "");
    18.     }

    复制代码
  
  
• 运行结果如下所示
  
  
  
  • 
    
  
  
• Kibana验证
  
  
  
  • 
    
  
  

8.3、添加映射

• 代码如下所示
  
  
  
  • 因为创建映射需要DSL语句，所以先在kibana编写如下语句
    
    
    
    • 1. DELETE hotel
      3. GET hotel/_mapping
      5. # 分析hotel索引库的映射结构
      6. # index属性：是否建立索引，默认值true，如果该字段不用查询，则设置false
      7. # copy_to: 把指定字段的值拷贝到另一个字段上
      8. PUT hotel
      9. {
      10.   "mappings": {
      11.     "properties": {
      12.       "id": {
      13.         "type": "keyword"
      14.       },
      15.       "name": {
      16.         "type": "text",
      17.         "analyzer": "ik_smart",
      18.         "copy_to": "all"
      19.       },
      20.       "address": {
      21.         "type": "text",
      22.         "analyzer": "ik_smart"
      23.       },
      24.       "price": {
      25.         "type": "integer"
      26.       },
      27.       "score": {
      28.         "type": "integer"
      29.       },
      30.       "brand": {
      31.         "type": "keyword",
      32.         "copy_to": "all"
      33.       },
      34.       "city": {
      35.         "type": "keyword"
      36.       },
      37.       "starName": {
      38.         "type": "keyword"
      39.       },
      40.       "business": {
      41.         "type": "keyword",
      42.         "copy_to": "all"
      43.       },
      44.       "location": {
      45.         "type": "geo_point"
      46.       },
      47.       "pic": {
      48.         "type": "keyword",
      49.         "index": false
      50.       },
      51.       "isAD": {
      52.         "type": "boolean"
      53.       },
      54.       "all": {
      55.         "type": "text",
      56.         "analyzer": "ik_smart"
      57.       }
      58.     }
      59.   }
      60. }

      复制代码
    
    
  • 创建成功后，再删除，将mappings中的字段复制到Java代码中
    
  • 1.     /**
    2.      * 添加映射测试
    3.      */
    4.     @Test
    5.     public void testAddMapping() throws IOException {
    6.         // 1. 创建索引操作对象
    7.         IndicesClient indicesClient = restHighLevelClient.indices();
    9.         // 2. 创建索引
    10.         CreateIndexRequest request = new CreateIndexRequest("hotel");
    12.         // 3. 定义mapping语句
    13.         String mapping = "{\n" +
    14.                 "    "properties": {\n" +
    15.                 "      "id": {\n" +
    16.                 "        "type": "keyword"\n" +
    17.                 "      },\n" +
    18.                 "      "name": {\n" +
    19.                 "        "type": "text",\n" +
    20.                 "        "analyzer": "ik_smart",\n" +
    21.                 "        "copy_to": "all"\n" +
    22.                 "      },\n" +
    23.                 "      "address": {\n" +
    24.                 "        "type": "text",\n" +
    25.                 "        "analyzer": "ik_smart"\n" +
    26.                 "      },\n" +
    27.                 "      "price": {\n" +
    28.                 "        "type": "integer"\n" +
    29.                 "      },\n" +
    30.                 "      "score": {\n" +
    31.                 "        "type": "integer"\n" +
    32.                 "      },\n" +
    33.                 "      "brand": {\n" +
    34.                 "        "type": "keyword",\n" +
    35.                 "        "copy_to": "all"\n" +
    36.                 "      },\n" +
    37.                 "      "city": {\n" +
    38.                 "        "type": "keyword"\n" +
    39.                 "      },\n" +
    40.                 "      "starName": {\n" +
    41.                 "        "type": "keyword"\n" +
    42.                 "      },\n" +
    43.                 "      "business": {\n" +
    44.                 "        "type": "keyword",\n" +
    45.                 "        "copy_to": "all"\n" +
    46.                 "      },\n" +
    47.                 "      "location": {\n" +
    48.                 "        "type": "geo_point"\n" +
    49.                 "      },\n" +
    50.                 "      "pic": {\n" +
    51.                 "        "type": "keyword",\n" +
    52.                 "        "index": false\n" +
    53.                 "      },\n" +
    54.                 "      "isAD": {\n" +
    55.                 "        "type": "boolean"\n" +
    56.                 "      },\n" +
    57.                 "      "all": {\n" +
    58.                 "        "type": "text",\n" +
    59.                 "        "analyzer": "ik_smart"\n" +
    60.                 "      }\n" +
    61.                 "    }\n" +
    62.                 "  }";
    64.         request.mapping(mapping, XContentType.JSON);    // 设置mappings字段，并指定其内容为json格式
    66.         // 4. 执行操作
    67.         CreateIndexResponse response = indicesClient.create(request, RequestOptions.DEFAULT);
    69.         // 5. 获取结果
    70.         log.info(response.isAcknowledged() + "");
    72.     }

    复制代码
  • ​
    
  
  
• 运行结果如下所示
  
  
  
  • 
    
  
  
• Kibana验证
  
  
  
  • 
    
  
  

8.4、删除索引

• 代码如下所示
  
  
  
  • 1.     /**
    2.      * 删除索引测试
    3.      */
    4.     @Test
    5.     public void testDeleteIndex() throws IOException {
    6.         // 1. 获取索引操作对象
    7.         IndicesClient indicesClient = restHighLevelClient.indices();
    8.         
    9.         // 2. 获取索引对象
    10.         DeleteIndexRequest request = new DeleteIndexRequest("hotel");   // DELETE hotel
    12.         // 3. 执行操作
    13.         AcknowledgedResponse response = indicesClient.delete(request, RequestOptions.DEFAULT);
    15.         // 4. 获取结果
    16.         log.info("" + response.isAcknowledged());
    17.     }

    复制代码
  
  
• 比较简单，自行验证即可
  

8.5、添加文档

• 代码如下所示
  
  
  
  • 1.     /**
    2.      * 添加文档测试
    3.      */
    4. // Jackson
    5.     private ObjectMapper objectMapper = new ObjectMapper();
    6.     @Test
    7.     public void testAddDocument() throws IOException {
    8.         // 先获取 指定的 hotel数据
    9.         Hotel hotel = hotelMapper.selectById(36934);
    10.         HotelDoc hotelDoc = new HotelDoc(hotel);
    12.         // 1. 创建请求对象
    13.         IndexRequest request = new IndexRequest("hotel").id(hotelDoc.getId().toString());
    15.         // 2. 填充文档内容
    16.         String json = objectMapper.writeValueAsString(hotelDoc);
    17.         request.source(json, XContentType.JSON);
    19.         // 3. 执行请求体对象
    20.         IndexResponse response = restHighLevelClient.index(request, RequestOptions.DEFAULT);
    22.         // 4. 获取结果
    23.         log.info(response.getId() + "");
    24.     }

    复制代码
  
  
• Kibana验证
  
  
  
  • 
    
  
  

8.6、修改、查询、删除文档

8.6.1、修改文档

修改文档和添加文档操作一样，需要注意的是修改文档必须是已经存在的ID

• 代码如下所示
  
  
  
  • 1.     /**
    2.      * 修改文档
    3.      */
    4.     @Test
    5.     public void testUpdateDocument() throws IOException {
    6.         // 1. 先获取 指定的 hotel 数据
    7.         Hotel hotel = hotelMapper.selectById(36934L);
    8.         HotelDoc hotelDoc = new HotelDoc(hotel);
    10.         // 2. 修改数据，如价格
    11.         hotelDoc.setPrice(1999999999);
    13.         // 3. 将 hotelDoc 对象转换为 JSON格式的数据
    14.         String json = objectMapper.writeValueAsString(hotelDoc);
    16.         // 4. 创建请求对象
    17.         IndexRequest request = new IndexRequest("hotel").id(hotelDoc.getId().toString());
    18.         request.source(json, XContentType.JSON);
    20.         // 5. 执行操作
    21.         IndexResponse response = restHighLevelClient.index(request, RequestOptions.DEFAULT);
    23.         log.info(response.getId());
    24.     }

    复制代码
  
  
• Kibana验证
  
  
  
  • 
    
  
  

8.6.2、查询文档

• 代码如下所示
  
  
  
  • 1.     /**
    2.      * 查询文档
    3.      */
    4.     @Test
    5.     public void testSearchDocument() throws IOException {
    6.         Long id = 36934L;
    7.         // 1. 创建请求
    8.         GetRequest request = new GetRequest("hotel").id(id.toString());
    10.         // 2. 执行请求
    11.         GetResponse response = restHighLevelClient.get(request, RequestOptions.DEFAULT);
    13.         // 3. 取出结果
    14.         String hotelDocJson = response.getSourceAsString();
    16.         HotelDoc hotelDoc = objectMapper.readValue(hotelDocJson, HotelDoc.class);
    18.         log.info(hotelDoc.toString());
    19.     }

    复制代码
  
  
• 运行结果如下所示
  
  
  
  • 
    
  
  

8.6.3、删除文档

• 代码如下所示
  
  
  
  • 1.     /**
    2.      * 删除文档
    3.      */
    4.     @Test
    5.     public void testDeleteDocument() throws IOException {
    6.         Long id = 36934L;
    7.         // 1. 创建请求
    8.         DeleteRequest request = new DeleteRequest("hotel").id(id.toString());
    10.         // 2. 执行请求
    11.         DeleteResponse response = restHighLevelClient.delete(request, RequestOptions.DEFAULT);
    13.         log.info(response.getId());
    15.     }

    复制代码
  
  
• Kibana验证
  
  
  
  • 
    
  
  

8.7、批量添加

• Bulk批量操作是将文档的增删改查一些列操作，通过一次请求全都做完。减少网络传输次数
  
• 应用场景
  
  
  
  • ES索引库数据初始化的时候，可以将数据库的数据查询出来通过批量操作导入到索引库中
    
  
  
• 代码如下所示
  
  
  
  • 1.     /**
    2.      * 批量添加文档
    3.      */
    4.     @Test
    5.     public void testBatchAddDocument() throws IOException {
    6.         // 1. 获取需要导入的数据
    7.         List<Hotel> hotelList = hotelMapper.selectList(null);
    9.         if(CollectionUtils.isNotEmpty(hotelList)) {
    10.             // 2. 创建批量操作请求对象
    11.             BulkRequest bulkRequest = new BulkRequest();
    13.             // 4. 获取文档映射的对象数据
    14.             for (Hotel hotel : hotelList) {
    15.                 HotelDoc hotelDoc = new HotelDoc(hotel);
    17.                 // 5. 创建请求对象
    18.                 IndexRequest request = new IndexRequest("hotel").id(hotelDoc.getId().toString());;
    20.                 // 6. 填充内容
    21.                 String json = objectMapper.writeValueAsString(hotelDoc);
    22.                 request.source(json, XContentType.JSON);
    24.                 // 7. 将数据添加到批量操作对象中
    25.                 bulkRequest.add(request);
    26.             }
    27.             // 8. 一次性执行批量操作
    28.             BulkResponse response = restHighLevelClient.bulk(bulkRequest, RequestOptions.DEFAULT);
    29.             log.info(response.status().toString());
    30.         }
    31.     }

    复制代码
  
  
• 运行结果如下所示
  
  
  
  • 
    
  
  
• Kibana验证
  
  
  
  • 
    
  
  

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！

---

欢迎光临 ToB企服应用市场:ToB评测及商务社交产业平台 (https://dis.qidao123.com/)

Powered by Discuz! X3.4