springboot集成elasticsearch7.6.1，常用api调用,创建,查找，删除索引，crud，高亮。。。--转载

转载地址 https://blog.csdn.net/qq_42231437/article/details/108012824?utm_medium=distribute.pc_relevant.none-task-blog-title-10&spm=1001.2101.3001.4242

最近因为需求，然后自学了es，下面把学习成果分享一下，希望可以帮助es才入门的小伙伴，话不多说，下面开始。

在开始之前，需要有es，官网下载比较慢，下面是我下载的es7.6.1，拿走不谢
es-7.6.1百度网盘
提取码：syfk

spring-boot集成es 7.6.1

1）创建一个springboot项目，项目创建比较简单，下面截图是创建项目需要引入的依赖

2）因为spring-boot自带的es版本还是6.xx，所以需要更改一下版本，在pom.xml文件中，添加

    <properties>
        <java.version>1.8</java.version>
        <elasticsearch.version>7.6.1</elasticsearch.version>
    </properties>

3）引入es高级客户端依赖

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

关于es客户端介绍，最好在官网查看

es官网-rest高级客户端

4）配置，新建一个配置类，下面是我的配置类

package com.study.es_study.config;

import org.apache.http.HttpHost;
import org.elasticsearch.client.RestClient;
import org.elasticsearch.client.RestClientBuilder;
import org.elasticsearch.client.RestHighLevelClient;
import org.springframework.boot.SpringBootConfiguration;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@SpringBootConfiguration
public class ElasticSearchConfig {
    //在spring容器中放入RestHighLevelClient，使用的时候直接注入就可以了
    @Bean
    public RestHighLevelClient restHighLevelClient(){
        RestHighLevelClient restHighLevelClient = new RestHighLevelClient(RestClient.builder(
                new HttpHost("127.0.0.1",9200,"http")));
        return restHighLevelClient;
    }
}

常见API使用

在springboot的test里面测常用的api，在开始之前，在测试类中注入RestHighLevelClient

@Autowired
@Qualifier("restHighLevelClient")
private RestHighLevelClient client;

关于索引的操作

1.创建索引

    @Test
    public void contextLoadTest() throws IOException {
        //创建索引请求
        CreateIndexRequest request = new CreateIndexRequest("dome_one");
        System.out.println(client);
        //这里是通过客户端，然后传递请求， RequestOptions.DEFAULT（这个是默认的，是es里面的，可以查看源码）
        CreateIndexResponse response = client.indices().create(request, RequestOptions.DEFAULT);
        System.out.println(response);
    }

2.查询索引是否存在

    @Test
    public void existRequest() throws IOException {
        //创建请求
        GetIndexRequest re = new GetIndexRequest("dome_one");
        boolean exists = client.indices().exists(re,RequestOptions.DEFAULT);
        System.out.println(exists);
    }

3.删除索引

    @Test
    public void deleteRequest() throws IOException {
        //创建删除索引请求
        DeleteIndexRequest request = new DeleteIndexRequest("dome_one");
        //通过客户端把请求提交
        AcknowledgedResponse delete = client.indices().delete(request, RequestOptions.DEFAULT);
        System.out.println(delete);
    }

总结：
①关于索引相关的操作，比较好理解，对索引进行什么操作，则建立相应的请求
②通过es的客户端api，client.indices()：获取关于indexClient，来得到对index操作的权力
③在②的基础上，indexClient.(相应操作)

文档crud

1.添加

    @Test
    public void addDocumentTest() throws IOException {
        //创建请求连接
        IndexRequest request = new IndexRequest("dome_one");
        //创建要添加的信息
        User user = new User("大鹏鸟",6);
        
        //通过rest高级客户端添加信息 
        request.id("1");        //自定义id，不自定义则随机生成
        request.timeout("10s");    //请求超时不执行

        //把要添加的信息放入请求中，XContentType.JSON（指定信息的类型）
        request.source(JSON.toJSONString(user), XContentType.JSON);

        //通过客户端传递求情
        IndexResponse responseResult = client.index(request, RequestOptions.DEFAULT);
        System.out.println(responseResult.toString());
        System.out.println(responseResult.status());
    }

2.修改

    @Test
    public void updateDocument() throws IOException {
        //创建修改请求，请求中指定索引，修改id
        UpdateRequest request = new UpdateRequest("dome_one","1");
        request.timeout("5s");
        User user = new User("大鹏鸟学java", 10);

        //es原生api中有_doc,这里在修改的时候调用doc(),把要修改的信息放入请求中
        request.doc(JSON.toJSONString(user),XContentType.JSON);

        request.fetchSource(true);//修改之后获取结果

        UpdateResponse update = client.update(request, RequestOptions.DEFAULT);
        
        System.out.println(update.toString());
        System.out.println(update.getIndex());
        System.out.println(update.getGetResult());
        System.out.println(update.status());


    }

3.删除

    public void deleteDocument() throws IOException {
        //创建删除请求，指定索引和删除的id
        DeleteRequest request = new DeleteRequest("dome_one","1");

        DeleteResponse delete = client.delete(request, RequestOptions.DEFAULT);
        
        System.out.println(delete.status());
        System.out.println(delete.toString());
    }

4.查询

    @Test
    public void queryDocument() throws IOException {
        //查询请求
        GetRequest request = new GetRequest("dome_one","wqFN7XMBSotzIjY682h-");

        GetResponse response = client.get(request, RequestOptions.DEFAULT);
        System.out.println(response.getSource());

    }

批量添加，搜索，高亮查询

1.批量添加（删除修改类型）

    @Test
    public void bulkDocument() throws IOException {
        //执行批量操作的请求
        BulkRequest request = new BulkRequest("dome_one");
        request.timeout("10s");
        request.estimatedSizeInBytes();

        List<User> userList = new ArrayList<User>();
        User u1 = new User("张三", 1);
        User u2 = new User("张21", 221);
        User u3 = new User("张1", 21);
        User u4 = new User("张21三", 21);
        User u5 = new User("13张21三", 31);
        User u6 = new User("32张21三", 21);
        User u7 = new User("31张三", 1);
        userList.add(u1);
        userList.add(u2);
        userList.add(u3);
        userList.add(u4);
        userList.add(u4);
        userList.add(u5);
        userList.add(u6);
        userList.add(u7);

        for (int i =0 ; i < 7 ; i++){
            //通过批量请求，依次放入单个请求，类似入数据库的批量操作
            request.add(new IndexRequest()
                    .source(JSON.toJSONString(userList.get(i)),XContentType.JSON));
        }
        
        //客户端执行批量操作
        BulkResponse response = client.bulk(request, RequestOptions.DEFAULT);
        System.out.println(response.status());
    }

2.搜索

    @Test
    public void searchDocument() throws IOException {
        //搜索请求
        SearchRequest request = new SearchRequest("dome_one");
        
        //请求条件构建器,这里和mybatis中的自定义查询有点类型
        SearchSourceBuilder builder = new SearchSourceBuilder();
        
        //匹配所有
//        MatchAllQueryBuilder allQuery = QueryBuilders.matchAllQuery();

        /*
        *精确查询
        *QueryBuilders：查询工具，用它查询比较方便
        */
        TermQueryBuilder termQuery = QueryBuilders.termQuery("name", "张三");
        
        //把查询添加放入查询构造器中
        builder.query(termQuery);
        
        //把查询添加放入请求中
        request.source(builder);
        SearchResponse response = client.search(request, RequestOptions.DEFAULT);
        
        //打印查询的信息
        for (SearchHit hit : response.getHits().getHits()) {
            System.out.println(hit.getSourceAsMap());
        }
    }

3.高亮查询

@Test
    public void highSearch() throws IOException {
        //创建查询请求
        SearchRequest request = new SearchRequest("dome_one");
        
        //
        SearchSourceBuilder builder = new SearchSourceBuilder();

        MatchQueryBuilder matchQueryBuilder = QueryBuilders.matchQuery("name", "张三");
        builder.query(matchQueryBuilder);

        HighlightBuilder highlighter = new HighlightBuilder();
        highlighter.field("name",1);
        highlighter.preTags("<em style='color:red>'");
        highlighter.postTags("</em>");
        builder.highlighter(highlighter);

        request.source(builder);
        SearchResponse response = client.search(request, RequestOptions.DEFAULT);

        System.out.println(response.getHits().getCollapseValues());

        System.out.println(response.getAggregations());

        System.out.println(response.getHits().getSortFields());

        System.out.println(response.getHits().getHits().length);
        SearchHit[] hits = response.getHits().getHits();

        for (SearchHit hit:hits) {
            System.out.println(hit.toString());
        }

        System.out.println();

        System.out.println(response.getHits().getAt(0));

        System.out.println(response.toString());

        System.out.println(response.getTook().toString());

        System.out.println(response.status());

    }

至此es的常用操作就没问题了，能满足一般需求，深入学习还是需要查看官网文档。
原创不易，转发请标明文章出处，谢谢