ElasticSearch 7.6.1 集成SpringBoot（无废话版）--------------------------------------------（四）

小鱼儿 2022-12-08 04:58 179阅读 0赞

### 代码地址：（[https://github.com/heidaodageshiwo/ElasticSearch7.6.1.git][https_github.com_heidaodageshiwo_ElasticSearch7.6.1.git]） ###

## ##

### 找官方文档！ ###

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2h1bmhlaWRhb2Rl_size_16_color_FFFFFF_t_70][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2h1bmhlaWRhb2Rl_size_16_color_FFFFFF_t_70 1][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2h1bmhlaWRhb2Rl_size_16_color_FFFFFF_t_70 2][]

1、找到原生的依赖

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

2、找对象

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2h1bmhlaWRhb2Rl_size_16_color_FFFFFF_t_70 3][]

3、分析这个类中的方法即可！

问题：一定要保证 我们的导入的依赖和我们的es 版本一致

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2h1bmhlaWRhb2Rl_size_16_color_FFFFFF_t_70 4][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2h1bmhlaWRhb2Rl_size_16_color_FFFFFF_t_70 5][]

源码中提供对象！

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2h1bmhlaWRhb2Rl_size_16_color_FFFFFF_t_70 6][]

虽然这里导入3个类，静态内部类，核心类就一个！

/*
    * Copyright 2012-2019 the original author or authors.
    *
    * Licensed under the Apache License, Version 2.0 (the "License");
    * you may not use this file except in compliance with the License.
    * You may obtain a copy of the License at
    *
    *   https://www.apache.org/licenses/LICENSE-2.0
    *
    * Unless required by applicable law or agreed to in writing, software
    * distributed under the License is distributed on an "AS IS" BASIS,
    * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
    * See the License for the specific language governing permissions and
    * limitations under the License.
    */
    package org.springframework.boot.autoconfigure.elasticsearch.rest;
    import java.time.Duration;
    import org.apache.http.HttpHost;
    import org.apache.http.auth.AuthScope;
    import org.apache.http.auth.Credentials;
    import org.apache.http.auth.UsernamePasswordCredentials;
    import org.apache.http.client.CredentialsProvider;
    import org.apache.http.impl.client.BasicCredentialsProvider;
    import org.elasticsearch.client.RestClient;
    import org.elasticsearch.client.RestClientBuilder;
    import org.elasticsearch.client.RestHighLevelClient;
    import org.springframework.beans.factory.ObjectProvider;
    import org.springframework.boot.autoconfigure.condition.ConditionalOnClass;
    import
    org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
    import org.springframework.boot.context.properties.PropertyMapper;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    /**
    * Elasticsearch rest client infrastructure configurations.
    *
    * @author Brian Clozel
    * @author Stephane Nicoll
    */
    class RestClientConfigurations {
     @Configuration(proxyBeanMethods = false)
     static class RestClientBuilderConfiguration {
    // RestClientBuilder
       @Bean
       @ConditionalOnMissingBean
       RestClientBuilder elasticsearchRestClientBuilder(RestClientProperties
    properties,
          ObjectProvider<RestClientBuilderCustomizer> builderCustomizers) {
        HttpHost[] hosts =
    properties.getUris().stream().map(HttpHost::create).toArray(HttpHost[]::new);
        RestClientBuilder builder = RestClient.builder(hosts);
        PropertyMapper map = PropertyMapper.get();
        map.from(properties::getUsername).whenHasText().to((username) -> {
          CredentialsProvider credentialsProvider = new
    BasicCredentialsProvider();
          Credentials credentials = new
    UsernamePasswordCredentials(properties.getUsername(),
             properties.getPassword());
          credentialsProvider.setCredentials(AuthScope.ANY, credentials);
          builder.setHttpClientConfigCallback(
            (httpClientBuilder) ->
    httpClientBuilder.setDefaultCredentialsProvider(credentialsProvider));
        });
        builder.setRequestConfigCallback((requestConfigBuilder) -> {
        
     map.from(properties::getConnectionTimeout).whenNonNull().asInt(Duration::toMill
    is)
            .to(requestConfigBuilder::setConnectTimeout);
        
     map.from(properties::getReadTimeout).whenNonNull().asInt(Duration::toMillis)
            .to(requestConfigBuilder::setSocketTimeout);
    具体的Api测试！
    1、创建索引
    2、判断索引是否存在
    3、删除索引
    4、创建文档
    5、crud文档！
          return requestConfigBuilder;
        });
        builderCustomizers.orderedStream().forEach((customizer) ->
    customizer.customize(builder));
        return builder;
      }
     }
     @Configuration(proxyBeanMethods = false)
     @ConditionalOnClass(RestHighLevelClient.class)
     static class RestHighLevelClientConfiguration {
    // RestHighLevelClient 高级客户端，也是我们这里要讲，后面项目会用到的客户端
       @Bean
       @ConditionalOnMissingBean
       RestHighLevelClient elasticsearchRestHighLevelClient(RestClientBuilder
    restClientBuilder) {
        return new RestHighLevelClient(restClientBuilder);
      }
       @Bean
       @ConditionalOnMissingBean
       RestClient elasticsearchRestClient(RestClientBuilder builder,
          ObjectProvider<RestHighLevelClient> restHighLevelClient) {
        RestHighLevelClient client = restHighLevelClient.getIfUnique();
        if (client != null) {
          return client.getLowLevelClient();
        }
        return builder.build();
      }
     }
     @Configuration(proxyBeanMethods = false)
     static class RestClientFallbackConfiguration {
    // RestClient 普通的客户端！
       @Bean
       @ConditionalOnMissingBean
       RestClient elasticsearchRestClient(RestClientBuilder builder) {
        return builder.build();
      }
     }
    }

具体的Api测试！  
1、创建索引  
2、判断索引是否存在  
3、删除索引  
4、创建文档  
5、crud文档！

package com.kuang;
    import com.alibaba.fastjson.JSON;
    import com.kuang.pojo.User;
    import com.kuang.utils.ESconst;
    import com.sun.corba.se.spi.activation.ServerAlreadyRegistered;
    import lombok.SneakyThrows;
    import org.elasticsearch.action.admin.indices.delete.DeleteIndexRequest;
    import org.elasticsearch.action.bulk.BulkRequest;
    import org.elasticsearch.action.bulk.BulkResponse;
    import org.elasticsearch.action.delete.DeleteRequest;
    import org.elasticsearch.action.delete.DeleteResponse;
    import org.elasticsearch.action.get.GetRequest;
    import org.elasticsearch.action.get.GetResponse;
    import org.elasticsearch.action.index.IndexRequest;
    import org.elasticsearch.action.index.IndexResponse;
    import org.elasticsearch.action.search.SearchRequest;
    import org.elasticsearch.action.search.SearchResponse;
    import org.elasticsearch.action.support.master.AcknowledgedResponse;
    import org.elasticsearch.action.update.UpdateRequest;
    import org.elasticsearch.action.update.UpdateResponse;
    import org.elasticsearch.client.RequestOptions;
    import org.elasticsearch.client.RestHighLevelClient;
    import org.elasticsearch.client.indices.CreateIndexRequest;
    import org.elasticsearch.client.indices.CreateIndexResponse;
    import org.elasticsearch.client.indices.GetIndexRequest;
    import org.elasticsearch.common.unit.TimeValue;
    import org.elasticsearch.common.xcontent.XContentType;
    import org.elasticsearch.index.query.MatchAllQueryBuilder;
    import org.elasticsearch.index.query.QueryBuilder;
    import org.elasticsearch.index.query.QueryBuilders;
    import org.elasticsearch.index.query.TermQueryBuilder;
    import org.elasticsearch.search.SearchHit;
    import org.elasticsearch.search.SearchPhase;
    import org.elasticsearch.search.builder.SearchSourceBuilder;
    import org.elasticsearch.search.fetch.subphase.FetchSourceContext;
    import org.junit.jupiter.api.Test;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.beans.factory.annotation.Qualifier;
    import org.springframework.boot.test.context.SpringBootTest;
    import sun.reflect.ReflectionFactory;
    import java.io.IOException;
    import java.util.ArrayList;
    import java.util.concurrent.TimeUnit;
    import java.util.function.Predicate;
    /**
    * 狂神讲解 es7.6.x 高级客户端测试 API
    */
    @SpringBootTest
    class KuangshenEsApiApplicationTests {
      // 面向对象来操作
      @Autowired
      @Qualifier("restHighLevelClient")
      private RestHighLevelClient client;
      // 测试索引的创建 Request PUT kuang_index
      @Test
      void testCreateIndex() throws IOException {
        // 1、创建索引请求
        CreateIndexRequest request = new CreateIndexRequest("kuang_index");
        // 2、客户端执行请求 IndicesClient,请求后获得响应
        CreateIndexResponse createIndexResponse =
            client.indices().create(request, RequestOptions.DEFAULT);
        System.out.println(createIndexResponse);
     }
      // 测试获取索引,判断其是否存在
      @Test
      void testExistIndex() throws IOException {
        GetIndexRequest request = new GetIndexRequest("kuang_index2");
        boolean exists = client.indices().exists(request,
    RequestOptions.DEFAULT);
        System.out.println(exists);
     }
      // 测试删除索引
      @Test
      void testDeleteIndex() throws IOException {
        DeleteIndexRequest request = new DeleteIndexRequest("kuang_index");
        // 删除
        AcknowledgedResponse delete = client.indices().delete(request,
    RequestOptions.DEFAULT);
        System.out.println(delete.isAcknowledged());
     }
      // 测试添加文档
      @Test
      void testAddDocument() throws IOException {
        // 创建对象
        User user = new User("狂神说", 3);
        // 创建请求
        IndexRequest request = new IndexRequest("kuang_index");
        // 规则 put /kuang_index/_doc/1
        request.id("1");
        request.timeout(TimeValue.timeValueSeconds(1));
        request.timeout("1s");
        // 将我们的数据放入请求 json
        request.source(JSON.toJSONString(user), XContentType.JSON);
        // 客户端发送请求 , 获取响应的结果
        IndexResponse indexResponse = client.index(request,
    RequestOptions.DEFAULT);
        System.out.println(indexResponse.toString()); //
        System.out.println(indexResponse.status()); // 对应我们命令返回的状态
    CREATED
     }
      // 获取文档，判断是否存在 get /index/doc/1
      @Test
      void testIsExists() throws IOException {
        GetRequest getRequest = new GetRequest("kuang_index", "1");
        // 不获取返回的 _source 的上下文了
        getRequest.fetchSourceContext(new FetchSourceContext(false));
        getRequest.storedFields("_none_");
        boolean exists = client.exists(getRequest, RequestOptions.DEFAULT);
        System.out.println(exists);
     }
      // 获得文档的信息
      @Test
      void testGetDocument() throws IOException {
        GetRequest getRequest = new GetRequest("kuang_index", "1");
        GetResponse getResponse = client.get(getRequest,
    RequestOptions.DEFAULT);
        System.out.println(getResponse.getSourceAsString()); // 打印文档的内容
        System.out.println(getResponse); // 返回的全部内容和命令式一样的
     }
      // 更新文档的信息
      @Test
      void testUpdateRequest() throws IOException {
        UpdateRequest updateRequest = new UpdateRequest("kuang_index","1");
        updateRequest.timeout("1s");
        User user = new User("狂神说Java", 18);
        updateRequest.doc(JSON.toJSONString(user),XContentType.JSON);
        UpdateResponse updateResponse = client.update(updateRequest,
    RequestOptions.DEFAULT);
        System.out.println(updateResponse.status());
     }
      // 删除文档记录
      @Test
      void testDeleteRequest() throws IOException {
        DeleteRequest request = new DeleteRequest("kuang_index","1");
        request.timeout("1s");
        DeleteResponse deleteResponse = client.delete(request,
    RequestOptions.DEFAULT);
        System.out.println(deleteResponse.status());
     }
      // 特殊的，真的项目一般都会批量插入数据！
      @Test
      void testBulkRequest() throws IOException {
        BulkRequest bulkRequest = new BulkRequest();
        bulkRequest.timeout("10s");
        ArrayList<User> userList = new ArrayList<>();
        userList.add(new User("kuangshen1",3));
        userList.add(new User("kuangshen2",3));
        userList.add(new User("kuangshen3",3));
        userList.add(new User("qinjiang1",3));
        userList.add(new User("qinjiang1",3));
        userList.add(new User("qinjiang1",3));
        // 批处理请求
        for (int i = 0; i < userList.size() ; i++) {
          // 批量更新和批量删除，就在这里修改对应的请求就可以了
          bulkRequest.add(
              new IndexRequest("kuang_index")
             .id(""+(i+1))
            
    .source(JSON.toJSONString(userList.get(i)),XContentType.JSON));
       }
        BulkResponse bulkResponse = client.bulk(bulkRequest,
    RequestOptions.DEFAULT);
        System.out.println(bulkResponse.hasFailures()); // 是否失败，返回 false 代表
    成功！
     }
      // 查询
      // SearchRequest 搜索请求
      // SearchSourceBuilder 条件构造
      // HighlightBuilder 构建高亮
      // TermQueryBuilder 精确查询
      // MatchAllQueryBuilder
      // xxx QueryBuilder 对应我们刚才看到的命令！
     
      @Test
      void testSearch() throws IOException {
        SearchRequest searchRequest = new SearchRequest("kuang_index");
        // 构建搜索条件
        SearchSourceBuilder sourceBuilder = new SearchSourceBuilder();
        sourceBuilder.highlighter()
        // 查询条件，我们可以使用 QueryBuilders 工具来实现
        // QueryBuilders.termQuery 精确
        // QueryBuilders.matchAllQuery() 匹配所有
        TermQueryBuilder termQueryBuilder = QueryBuilders.termQuery("name",
    "qinjiang1");
    //    MatchAllQueryBuilder matchAllQueryBuilder =
    QueryBuilders.matchAllQuery();
        sourceBuilder.query(termQueryBuilder);
        sourceBuilder.timeout(new TimeValue(60,TimeUnit.SECONDS));
        searchRequest.source(sourceBuilder);
        SearchResponse searchResponse = client.search(searchRequest,
    RequestOptions.DEFAULT);
        System.out.println(JSON.toJSONString(searchResponse.getHits()));
        System.out.println("=================================");
        for (SearchHit documentFields : searchResponse.getHits().getHits()) {
          System.out.println(documentFields.getSourceAsMap());
       }
     }
     
    }

### 1.创建项目（[https://github.com/heidaodageshiwo/ElasticSearch7.6.1.git][https_github.com_heidaodageshiwo_ElasticSearch7.6.1.git]） ###

### ![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2h1bmhlaWRhb2Rl_size_16_color_FFFFFF_t_70 7][] ###

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2h1bmhlaWRhb2Rl_size_16_color_FFFFFF_t_70 8][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2h1bmhlaWRhb2Rl_size_16_color_FFFFFF_t_70 9][]

[https_github.com_heidaodageshiwo_ElasticSearch7.6.1.git]: https://github.com/heidaodageshiwo/ElasticSearch7.6.1.git
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2h1bmhlaWRhb2Rl_size_16_color_FFFFFF_t_70]: /images/20221123/368d287a75e0459f9fc0983291b96c86.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2h1bmhlaWRhb2Rl_size_16_color_FFFFFF_t_70 1]: /images/20221123/7e8361d78fc743b2b354e53092e12a16.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2h1bmhlaWRhb2Rl_size_16_color_FFFFFF_t_70 2]: /images/20221123/4177d25783f94993971fc29af612e521.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2h1bmhlaWRhb2Rl_size_16_color_FFFFFF_t_70 3]: /images/20221123/0f714c0fec8b4a9eab1dae2578cb9746.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2h1bmhlaWRhb2Rl_size_16_color_FFFFFF_t_70 4]: /images/20221123/ddb5c696fd48469c846161406e67d7b4.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2h1bmhlaWRhb2Rl_size_16_color_FFFFFF_t_70 5]: /images/20221123/f55949603e3c4a1698102578b4707222.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2h1bmhlaWRhb2Rl_size_16_color_FFFFFF_t_70 6]: /images/20221123/38d7ef328b174a7794d256d8ca805d97.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2h1bmhlaWRhb2Rl_size_16_color_FFFFFF_t_70 7]: /images/20221123/9149d939a30d4096805a29ac7621264d.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2h1bmhlaWRhb2Rl_size_16_color_FFFFFF_t_70 8]: /images/20221123/3826e38fb1dd442e90e90620cae404fa.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2h1bmhlaWRhb2Rl_size_16_color_FFFFFF_t_70 9]: /images/20221123/e9ec6bc0ccfb4b788208e8b72cb8420a.png

ElasticSearch 7.6.1 集成SpringBoot（无废话版）--------------------------------------------（四）

发表评论取消回复

还没有评论，来说两句吧...

相关阅读

相关 SpringBoot整合RocketMq之===RocketMq安装（无废话版）--------------------------------------------（一）

相关 SpringBoot整合Rabbitmq之===Springboot整合Rabbitmq（无废话版）--------------------------------------------（七）

相关 SpringBoot整合Rabbitmq之===RabbitMQ的 Fanout模型（无废话版）--------------------------------------------（四）

相关 SpringBoot整合Rabbitmq之===RabbitMQ的安装（无废话版）--------------------------------------------（一）

相关 ElasticSearch 7.6.1 集成SpringBoot（无废话版）--------------------------------------------（四）

相关 ElasticSearch 7.6.1 Rest风格说明（无废话版）--------------------------------------------（三）

相关 ElasticSearch 7.6.1（无废话版）--------------------------------------------（一）

相关 ElasticSearch 7.6.1 集成SpringBoot Search所有操作（无废话版）--------------------------------------------（七）

相关 ElasticSearch 7.6.1 集成SpringBoot Document所有操作（无废话版）--------------------------------------------（六）

相关 ElasticSearch 7.6.1 集成SpringBoot Index所有操作（无废话版）--------------------------------------------（五）