关于后端:SpringBootElasticSearch-实现模糊查询批量CRUD排序分页高亮

一、导入elasticsearch依赖
在pom.xml里退出如下依赖
<dependency>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-starter-data-elasticsearch</artifactId>
</dependency>
复制代码
十分重要：查看依赖版本是否与你以后所用的版本是否统一，如果不统一，会连贯失败！

二、创立高级客户端
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.创立、判断存在、删除索引
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已存在，发送创立文档申请后会更新文档中的数据。
@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());
}
复制代码
获取文档中的数据：
@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。

@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
}
复制代码
删除文档:
@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时阐明上传胜利

@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.查问所有、含糊查问、分页查问、排序、高亮显示
@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。