devbox
代码探险家
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

SpringBoot整合ES_springboot 集成es

作者：代码探险家 | 2024-07-04 05:23:24

赞

踩

springboot 集成es

1.引入依赖

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

2.config配置文件

  1. @Configuration
  2. public class RestClientConfig extends AbstractElasticsearchConfiguration {
  3.  
  4.     @Override
  5.     @Bean
  6.     public RestHighLevelClient elasticsearchClient() {
  7.         final ClientConfiguration clientConfiguration =ClientConfiguration.builder()
  8.                 .connectedTo("xx.xxx.xxx.xx:9200") //地址
  9.                 .build();
  10.         return RestClients.create(clientConfiguration).rest();
  11.     }
  12. }

         会返回两个客户端对象，分别是ElasticsearchOperations和RestHighLevelClient(更推荐使用)。前者是通过面向对象的形式来操作的，后者是通过客户端的方式操作的。

3.索引相关操作

  1. /*
  2.     索引相关操作
  3.  */
  4. public class Test1 {
  5.  
  6.     RestHighLevelClient restHighLevelClient;
  7.  
  8.     @Before
  9.     public void init(){
  10.         final ClientConfiguration clientConfiguration =ClientConfiguration.builder()
  11.                 .connectedTo("xx.xxxx.xxx.xx:xxxx")
  12.                 .build();
  13.         this.restHighLevelClient = RestClients.create(clientConfiguration).rest();
  14.     }
  15.  
  16.     @Test//创建索引
  17.     public void createIndex() throws IOException {
  18.         CreateIndexRequest createIndexRequest = new CreateIndexRequest("products");
  19.         //指定映射 参数1：指定映射json结构 参数2：指定数据类型
  20.         createIndexRequest.mapping("{\n" +
  21.                 "    \"properties\": {\n" +
  22.                 "        \"id\":{\n" +
  23.                 "          \"type\":\"integer\"\n" +
  24.                 "        },\n" +
  25.                 "        \"title\":{\n" +
  26.                 "          \"type\":\"keyword\"\n" +
  27.                 "        },\n" +
  28.                 "        \"price\":{\n" +
  29.                 "          \"type\":\"double\"\n" +
  30.                 "        },\n" +
  31.                 "        \"created_at\":{\n" +
  32.                 "          \"type\":\"date\"\n" +
  33.                 "        },\n" +
  34.                 "        \"description\":{\n" +
  35.                 "          \"type\":\"text\",\n" +
  36.                 "          \"analyzer\": \"ik_max_word\"\n" +
  37.                 "        }\n" +
  38.                 "    }\n" +
  39.                 "  }", XContentType.JSON);
  40.         //参数1：创建索引请求对象  参数2：请求配置对象
  41.         CreateIndexResponse createIndexResponse = restHighLevelClient.indices().create(createIndexRequest, RequestOptions.DEFAULT);
  42.         System.out.println("创建状态："+createIndexResponse.isAcknowledged()); //打印返回信息
  43.         restHighLevelClient.close(); //关闭资源
  44.     }
  45.  
  46.     @Test//删除索引
  47.     public void deleteIndex() throws IOException {
  48.         AcknowledgedResponse acknowledgedResponse = restHighLevelClient.indices().delete(new DeleteIndexRequest("products"), RequestOptions.DEFAULT);
  49.         System.out.println("删除状态："+acknowledgedResponse.isAcknowledged()); //打印返回信息
  50.         restHighLevelClient.close(); //关闭资源
  51.     }
  52. }

4.文档相关操作

  1. /*
  2.     文档相关操作(document)
  3.  */
  4. public class Test2 {
  5.     RestHighLevelClient restHighLevelClient;
  6.  
  7.     @Before
  8.     public void init(){
  9.         final ClientConfiguration clientConfiguration =ClientConfiguration.builder()
  10.                 .connectedTo("xx.xxx.xxx.xx:9200")
  11.                 .build();
  12.         this.restHighLevelClient = RestClients.create(clientConfiguration).rest();
  13.     }
  14.  
  15.     @Test  //创建文档
  16.     public void createDoc() throws IOException {
  17.         IndexRequest indexRequest = new IndexRequest("products");
  18.         indexRequest.id("2") //手动指定文档的id，如果不指定则会用uuid
  19.                     .source("{\n" +
  20.                             "  \"title\":\"瑞星咖啡\",\n" +
  21.                             "  \"price\": 9.8,\n" +
  22.                             "  \"created_at\":\"2023-11-18\",\n" +
  23.                             "  \"description\":\"瑞星咖啡我最爱了，好喝\"\n" +
  24.                             "}", XContentType.JSON);
  25.         //参数1：索引请求对象，参数2：请求配置对象
  26.         IndexResponse indexResponse = restHighLevelClient.index(indexRequest, RequestOptions.DEFAULT);
  27.         System.out.println(indexResponse.status());
  28.         restHighLevelClient.close();
  29.     }
  30.  
  31.     @Test  //修改文档
  32.     public void updateDoc() throws IOException {
  33.         UpdateRequest updateRequest = new UpdateRequest("products","1");
  34.         updateRequest.doc("{\n" +
  35.                 "    \"title\":\"库迪咖啡非\"\n" +
  36.                 "  }",XContentType.JSON);
  37.         //参数1：索引请求对象，参数2：请求配置对象
  38.         UpdateResponse updateResponse = restHighLevelClient.update(updateRequest, RequestOptions.DEFAULT);
  39.         System.out.println(updateResponse.status());
  40.         restHighLevelClient.close();
  41.     }
  42.  
  43.     @Test  //删除文档
  44.     public void deleteDoc() throws IOException {
  45.         DeleteRequest deleteRequest = new DeleteRequest("products","2");
  46.         //参数1：索引请求对象，参数2：请求配置对象
  47.         DeleteResponse deleteResponse = restHighLevelClient.delete(deleteRequest, RequestOptions.DEFAULT);
  48.         System.out.println(deleteResponse.status());
  49.         restHighLevelClient.close();
  50.     }
  51.  
  52.     @Test  //基于id查询文档
  53.     public void searchDocById() throws IOException {
  54.         GetRequest getRequest = new GetRequest("products", "1");
  55.         GetResponse getResponse = restHighLevelClient.get(getRequest, RequestOptions.DEFAULT);
  56.         System.out.println(getResponse.getId());
  57.         System.out.println(getResponse.getSourceAsString());
  58.     }
  59.  
  60. }

5.高级查询

  1. public class Test3 {
  2.     RestHighLevelClient restHighLevelClient;
  3.  
  4.     @Before
  5.     public void init(){
  6.         final ClientConfiguration clientConfiguration =ClientConfiguration.builder()
  7.                 .connectedTo("xx.xxx.xxx.xx:9200")
  8.                 .build();
  9.         this.restHighLevelClient = RestClients.create(clientConfiguration).rest();
  10.     }
  11.  
  12.     @Test //查询一个索引中的所有文档
  13.     public void searchAll() throws IOException {
  14.         SearchRequest searchRequest = new SearchRequest("products");
  15.         searchRequest.source(new SearchSourceBuilder().query(QueryBuilders.matchAllQuery()));//查询所有
  16.         //参数1：搜索请求对象 参数2：请求配置对象
  17.         SearchResponse searchResponse = restHighLevelClient.search(searchRequest, RequestOptions.DEFAULT);
  18.         System.out.println("查询出来的总条数："+searchResponse.getHits().getTotalHits().value);
  19.         System.out.println("查询出来的最大得分"+searchResponse.getHits().getMaxScore());
  20.         //拿到数据结果
  21.         SearchHit[] hits = searchResponse.getHits().getHits();
  22.         for(SearchHit hit:hits){
  23.             String id = hit.getId();
  24.             System.out.println("id: "+id+" source: "+hit.getSourceAsString());
  25.         }
  26.     }
  27.  
  28.  
  29.     @Test //基于关键词查询
  30.     public void search() throws IOException {
  31.         SearchRequest searchRequest = new SearchRequest("products");
  32.         searchRequest.source(new SearchSourceBuilder().query(QueryBuilders.termQuery("description","好喝")));//查询所有
  33.         //参数1：搜索请求对象 参数2：请求配置对象
  34.         SearchResponse searchResponse = restHighLevelClient.search(searchRequest, RequestOptions.DEFAULT);
  35.         System.out.println("查询出来的总条数："+searchResponse.getHits().getTotalHits().value);
  36.         System.out.println("查询出来的最大得分"+searchResponse.getHits().getMaxScore());
  37.         //拿到数据结果
  38.         SearchHit[] hits = searchResponse.getHits().getHits();
  39.         for(SearchHit hit:hits){
  40.             String id = hit.getId();
  41.             System.out.println("id: "+id+" source: "+hit.getSourceAsString());
  42.         }
  43.     }
  44.  
  45.     /*
  46.      * 分页查询
  47.      * 排序
  48.      * 字段
  49.      */
  50.     @Test //分页查询 与排序
  51.     public void search2() throws IOException {
  52.         SearchRequest searchRequest = new SearchRequest("products");
  53.         SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
  54.         searchSourceBuilder.query(QueryBuilders.matchAllQuery())
  55.                             .from(1) //起始位置 start=(page-1)*size
  56.                             .size(1) //每页显示条数
  57.                             .sort("price", SortOrder.ASC) //字段排序
  58.                             .fetchSource(new String[]{},new String[]{"created_at"}); //参数1：包含字段数组  参数2：排除字段数组
  59.         searchRequest.source(searchSourceBuilder);//查询所有
  60.         //参数1：搜索请求对象 参数2：请求配置对象
  61.         SearchResponse searchResponse = restHighLevelClient.search(searchRequest, RequestOptions.DEFAULT);
  62.         System.out.println("查询出来的总条数："+searchResponse.getHits().getTotalHits().value);
  63.         System.out.println("查询出来的最大得分"+searchResponse.getHits().getMaxScore());
  64.         //拿到数据结果
  65.         SearchHit[] hits = searchResponse.getHits().getHits();
  66.         for(SearchHit hit:hits){
  67.             String id = hit.getId();
  68.             System.out.println("id: "+id+" source: "+hit.getSourceAsString());
  69.         }
  70.     }
  71.  
  72.     @Test //高亮
  73.     public void search3() throws IOException {
  74.         SearchRequest searchRequest = new SearchRequest("products");
  75.         SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
  76.         HighlightBuilder highlightBuilder = new HighlightBuilder();
  77.         highlightBuilder.requireFieldMatch(false).field("description").field("title").preTags("<span style='color:red;'>").postTags("</span>");
  78.         searchSourceBuilder.query(QueryBuilders.termQuery("description","好喝"))
  79.                             .highlighter(highlightBuilder);
  80.         searchRequest.source(searchSourceBuilder);//查询所有
  81.         //参数1：搜索请求对象 参数2：请求配置对象
  82.         SearchResponse searchResponse = restHighLevelClient.search(searchRequest, RequestOptions.DEFAULT);
  83.         System.out.println("查询出来的总条数："+searchResponse.getHits().getTotalHits().value);
  84.         System.out.println("查询出来的最大得分"+searchResponse.getHits().getMaxScore());
  85.         //拿到数据结果
  86.         SearchHit[] hits = searchResponse.getHits().getHits();
  87.         for(SearchHit hit:hits){
  88.             System.out.println("id: "+hit.getId()+" source: "+hit.getSourceAsString());
  89.             //获取高亮字段
  90.             Map<String, HighlightField> highlightFields = hit.getHighlightFields();
  91.             if(highlightFields.containsKey("description")){
  92.                 System.out.println("description高亮结果： "+highlightFields.get("description").fragments()[0]);
  93.             }
  94.             if(highlightFields.containsKey("title")){
  95.                 System.out.println("title高亮结果： "+highlightFields.get("title").fragments()[0]);
  96.             }
  97.         }
  98.     }
  99.  
  100.  
  101.     @Test //过滤查询
  102.     public void search4() throws IOException {
  103.         SearchRequest searchRequest = new SearchRequest("products");
  104.         SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
  105.         searchSourceBuilder.query(QueryBuilders.matchAllQuery())
  106.                            .postFilter(QueryBuilders.idsQuery().addIds("1")); //指定过滤条件
  107.         searchRequest.source(searchSourceBuilder);//查询所有
  108.         //参数1：搜索请求对象 参数2：请求配置对象
  109.         SearchResponse searchResponse = restHighLevelClient.search(searchRequest, RequestOptions.DEFAULT);
  110.         System.out.println("查询出来的总条数："+searchResponse.getHits().getTotalHits().value);
  111.         System.out.println("查询出来的最大得分"+searchResponse.getHits().getMaxScore());
  112.         //拿到数据结果
  113.         SearchHit[] hits = searchResponse.getHits().getHits();
  114.         for(SearchHit hit:hits){
  115.             String id = hit.getId();
  116.             System.out.println("id: "+id+" source: "+hit.getSourceAsString());
  117.         }
  118.     }
  119. }

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/代码探险家/article/detail/785774
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

  

闽ICP备14008679号