SpringBoot+ElasticSearch 實作模糊查詢，批量CRUD 排序分頁高亮！

原文：blog.csdn.net/qq_52355487/article/details/123805713

一、導入elasticsearch依賴

在pom.xml裡加入如下依賴

xml複制代碼<dependency>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-starter-data-elasticsearch</artifactId>
</dependency>

非常重要：檢查依賴版本是否與你目前所用的版本是否一緻，如果不一緻，會連接配接失敗！

二、建立進階用戶端

java複制代碼import org.apache.http.HttpHost;
import org.elasticsearch.client.RestClient;
import org.elasticsearch.client.RestHighLevelClient;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class ElasticSearchClientConfig {
    @Bean
    public RestHighLevelClient restHighLevelClient(){
        RestHighLevelClient client = new RestHighLevelClient(
                RestClient.builder(
                        new HttpHost("伺服器IP", 9200, "http")));
        return client;
    }
}

三、基本用法

1.建立、判斷存在、删除索引

java複制代碼import org.elasticsearch.action.admin.indices.delete.DeleteIndexRequest;
import org.elasticsearch.action.support.master.AcknowledgedResponse;
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.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;

import java.io.IOException;

@SpringBootTest
class ElasticsearchApplicationTests {

 @Autowired
 private RestHighLevelClient restHighLevelClient;

 @Test
 void testCreateIndex() throws IOException {
  //1.建立索引請求
  CreateIndexRequest request = new CreateIndexRequest("ljx666");
  //2.用戶端執行請求IndicesClient，執行create方法建立索引，請求後獲得響應
  CreateIndexResponse response=
    restHighLevelClient.indices().create(request, RequestOptions.DEFAULT);
  System.out.println(response);
 }

 @Test
 void testExistIndex() throws IOException {
        //1.查詢索引請求
  GetIndexRequest request=new GetIndexRequest("ljx666");
        //2.執行exists方法判斷是否存在
  boolean exists=restHighLevelClient.indices().exists(request,RequestOptions.DEFAULT);
  System.out.println(exists);
 }

 @Test
 void testDeleteIndex() throws IOException {
        //1.删除索引請求
  DeleteIndexRequest request=new DeleteIndexRequest("ljx666");
        //執行delete方法删除指定索引
  AcknowledgedResponse delete = restHighLevelClient.indices().delete(request, RequestOptions.DEFAULT);
  System.out.println(delete.isAcknowledged());
 }

}

2.對文檔的CRUD

建立文檔：

注意：如果添加時不指定文檔ID，他就會随機生成一個ID，ID唯一。

建立文檔時若該ID已存在，發送建立文檔請求後會更新文檔中的資料。

csharp複制代碼@Test
void testAddUser() throws IOException {
 //1.建立對象
 User user=new User("Go",21,new String[]{"内卷","吃飯"});
 //2.建立請求
 IndexRequest request=new IndexRequest("ljx666");
 //3.設定規則 PUT /ljx666/_doc/1
 //設定文檔id=6，設定逾時=1s等，不設定會使用預設的
 //同時支援鍊式程式設計如 request.id("6").timeout("1s");
 request.id("6");
 request.timeout("1s");

 //4.将資料放入請求，要将對象轉化為json格式
    //XContentType.JSON，告訴它傳的資料是JSON類型
 request.source(JSONValue.toJSONString(user), XContentType.JSON);
    
 //5.用戶端發送請求，擷取響應結果
 IndexResponse indexResponse=restHighLevelClient.index(request,RequestOptions.DEFAULT);
 System.out.println(indexResponse.toString());
 System.out.println(indexResponse.status());
}

擷取文檔中的資料：

csharp複制代碼@Test
void testGetUser() throws IOException {
 //1.建立請求,指定索引、文檔id
 GetRequest request=new GetRequest("ljx666","1");
 GetResponse getResponse=restHighLevelClient.get(request,RequestOptions.DEFAULT);
  
 System.out.println(getResponse);//擷取響應結果
 //getResponse.getSource() 傳回的是Map集合
 System.out.println(getResponse.getSourceAsString());//擷取響應結果source中内容，轉化為字元串
  
}

更新文檔資料:

注意：需要将User對象中的屬性全部指定值，不然會被設定為空，如User隻設定了名稱，那麼隻有名稱會被修改成功，其他會被修改為null。

ini複制代碼@Test
void testUpdateUser() throws IOException {
 //1.建立請求,指定索引、文檔id
 UpdateRequest request=new UpdateRequest("ljx666","6");

 User user =new User("GoGo",21,new String[]{"内卷","吃飯"});
 //将建立的對象放入文檔中
 request.doc(JSONValue.toJSONString(user),XContentType.JSON);

 UpdateResponse updateResponse=restHighLevelClient.update(request,RequestOptions.DEFAULT);
 System.out.println(updateResponse.status());//更新成功傳回OK
}

删除文檔:

csharp複制代碼@Test
void testDeleteUser() throws IOException {
 //建立删除請求，指定要删除的索引與文檔ID
 DeleteRequest request=new DeleteRequest("ljx666","6");

 DeleteResponse updateResponse=restHighLevelClient.delete(request,RequestOptions.DEFAULT);
 System.out.println(updateResponse.status());//删除成功傳回OK，沒有找到傳回NOT_FOUND
}

3.批量CRUD資料

這裡隻列出了批量插入資料，其他與此類似

注意：hasFailures()方法是傳回是否失敗，即它的值為false時說明上傳成功

csharp複制代碼@Test
void testBulkAddUser() throws IOException {
 BulkRequest bulkRequest=new BulkRequest();
 //設定逾時
 bulkRequest.timeout("10s");

 ArrayList<User> list=new ArrayList<>();
 list.add(new User("Java",25,new String[]{"内卷"}));
 list.add(new User("Go",18,new String[]{"内卷"}));
 list.add(new User("C",30,new String[]{"内卷"}));
 list.add(new User("C++",26,new String[]{"内卷"}));
 list.add(new User("Python",20,new String[]{"内卷"}));

 int id=1;
 //批量處理請求
 for (User u :list){
  //不設定id會生成随機id
  bulkRequest.add(new IndexRequest("ljx666")
    .id(""+(id++))
    .source(JSONValue.toJSONString(u),XContentType.JSON));
 }

 BulkResponse bulkResponse=restHighLevelClient.bulk(bulkRequest,RequestOptions.DEFAULT);
 System.out.println(bulkResponse.hasFailures());//是否執行失敗,false為執行成功
}

4.查詢所有、模糊查詢、分頁查詢、排序、高亮顯示

scss複制代碼@Test
void testSearch() throws IOException {
 SearchRequest searchRequest=new SearchRequest("ljx666");//裡面可以放多個索引
 SearchSourceBuilder sourceBuilder=new SearchSourceBuilder();//構造搜尋條件

 //此處可以使用QueryBuilders工具類中的方法
 //1.查詢所有
 sourceBuilder.query(QueryBuilders.matchAllQuery());
 //2.查詢name中含有Java的
 sourceBuilder.query(QueryBuilders.multiMatchQuery("java","name"));
 //3.分頁查詢
 sourceBuilder.from(0).size(5);
    
 //4.按照score正序排列
 //sourceBuilder.sort(SortBuilders.scoreSort().order(SortOrder.ASC));
 //5.按照id倒序排列（score會失效傳回NaN）
 //sourceBuilder.sort(SortBuilders.fieldSort("_id").order(SortOrder.DESC));

 //6.給指定字段加上指定高亮樣式
 HighlightBuilder highlightBuilder=new HighlightBuilder();
 highlightBuilder.field("name").preTags("<span style='color:red;'>").postTags("</span>");
 sourceBuilder.highlighter(highlightBuilder);
  
 searchRequest.source(sourceBuilder);
 SearchResponse searchResponse=restHighLevelClient.search(searchRequest,RequestOptions.DEFAULT);

 //擷取總條數
 System.out.println(searchResponse.getHits().getTotalHits().value);
 //輸出結果資料（如果不設定傳回條數，大于10條預設隻傳回10條）
 SearchHit[] hits=searchResponse.getHits().getHits();
 for(SearchHit hit :hits){
  System.out.println("分數:"+hit.getScore());
  Map<String,Object> source=hit.getSourceAsMap();
  System.out.println("index->"+hit.getIndex());
  System.out.println("id->"+hit.getId());
  for(Map.Entry<String,Object> s:source.entrySet()){
   System.out.println(s.getKey()+"--"+s.getValue());
  }
 }
}

四、總結

1.大緻流程

建立對應的請求 --> 設定請求（添加規則，添加資料等） --> 執行對應的方法（傳入請求，預設請求選項）–> 接收響應結果（執行方法傳回值）–> 輸出響應結果中需要的資料（source，status等）

2.注意事項

如果不指定id，會自動生成一個随機id
正常情況下，不應該這樣使用new IndexRequest(“ljx777”)，如果索引發生改變了，那麼代碼都需要修改，可以定義一個枚舉類或者一個專門存放常量的類，将變量用final static等進行修飾，并指定索引值。其他地方引用該常量即可，需要修改也隻需修改該類即可。
elasticsearch相關的東西，版本都必須一緻，不然會報錯
elasticsearch很消耗記憶體，建議在記憶體較大的伺服器上運作elasticsearch，否則會因為記憶體不足導緻elasticsearch自動killed

SpringBoot+ElasticSearch 實作模糊查詢，批量CRUD 排序分頁高亮！

一、導入elasticsearch依賴

二、建立進階用戶端

三、基本用法

1.建立、判斷存在、删除索引

2.對文檔的CRUD

3.批量CRUD資料

4.查詢所有、模糊查詢、分頁查詢、排序、高亮顯示

四、總結

1.大緻流程

2.注意事項

繼續閱讀

MyBatis-Plus 之AR模式

馴服爛代碼_馴服Tomcat：Tomcat 5的過濾技巧

基于Springboot+VUE+Mysql的大學生校園疫情防控管理系統

Using MessageConverter

馴服爛代碼_C＃中的馴服配置

Spring Cloud整合Sleuth，當請求完成後，Zipkin沒有鍊路資訊

JAVA自學之路——馬士兵

Rabbitmq指令行手動建立隊列

整合 Spring 開發架構及服務端技術

SSM整合02---Spring-SpringMVC層一、添加web架構支援二、web.xml三、spring-mvc.xml

SSM架構（二）------------表現層的SpringMVC

Intellij idea基于Maven 的SSM 架構整合

Spring資料和Redis

SpringMVC的啟動過程源碼分析1 SpringMVC 配置XML的方式啟動2 SpringMVC純注解模式啟動

Java Spring 架構

SpringCloud微服務（四）之ribbon筆記ribbon是什麼？入門案例自定義均衡負載算法

SpringBoot+ElasticSearch 實作模糊查詢，批量CRUD 排序 分頁 高亮！

一、導入elasticsearch依賴

二、建立進階用戶端

三、基本用法

1.建立、判斷存在、删除索引

2.對文檔的CRUD

3.批量CRUD資料

4.查詢所有、模糊查詢、分頁查詢、排序、高亮顯示

四、總結

1.大緻流程

2.注意事項

繼續閱讀

SpringBoot+ElasticSearch 實作模糊查詢，批量CRUD 排序分頁高亮！