SpringBoot封装Elasticsearch搜索引擎实现全文检索

一、前言

注：本文实现了Java对Elasticseach的分页检索/不分页检索的封装

ES就不用过多介绍了，直接上代码：

二、实现步骤：

创建Store类（与ES字段对应，用于接收ES数据）

import com.alibaba.fastjson2.annotation.JSONField;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
import org.springframework.data.elasticsearch.annotations.Document;
import org.springframework.data.elasticsearch.annotations.Field;/*** indexName               索引名称 理解为数据库名 限定小写* type                    理解为数据库的表名称* shards                  默认分区数* replicas                每个分区默认的备份数* refreshInterval         刷新间隔* indexStoreType          索引文件存储类型**/
@Data
@Builder
@NoArgsConstructor
@AllArgsConstructor
@Document(indexName = yourIndex, shards = n, replicas = n, refreshInterval = n)
public class Store implements Serializable {/*** 属性，与ES字段对应* 注：@Field注解：* 若Java属性名与ES字段名不同，则根据@Field的name属性匹配ES字段* 若Java属性名与ES字段名完全相同，则不用加该注解或name属性*/@Field(name = "yourESfield")private String yourAttribute;
}

Elasticsearch全文检索接口：不分页检索

import com.alibaba.fastjson2.JSON;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.elasticsearch.action.search.SearchRequest;
import org.elasticsearch.action.search.SearchResponse;
import org.elasticsearch.client.RequestOptions;
import org.elasticsearch.client.RestHighLevelClient;
import org.elasticsearch.index.query.BoolQueryBuilder;
import org.elasticsearch.search.builder.SearchSourceBuilder;
import org.elasticsearch.search.sort.SortOrder;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;import java.util.Arrays;
import java.util.Collections;
import java.util.List;
import java.util.stream.Collectors;@Slf4j
@Component
public class Elasticsearch{@Autowiredprivate RestHighLevelClient restHighLevelClient;/*** 不分页检索** @param yourIndex 索引* @param builder   搜索条件* @param sortField 排序属性* @param sortOrder 排序方式* @param clazz     返回类* @param <T>       泛型* @return 分页表格*/@SuppressWarnings("checkstyle:ParameterNumber")public <T> List<T> searchListByCond(String yourIndex, BoolQueryBuilder builder, String sortField, SortOrder sortOrder, Class<T> clazz) {SearchSourceBuilder sourceBuilder = new SearchSourceBuilder();sourceBuilder.query(builder);if (StringUtils.isNotBlank(sortField)) {sourceBuilder.sort(sortField, sortOrder);}SearchRequest request = new SearchRequest(yourIndex);request.source(sourceBuilder);SearchResponse response = null;try {response = restHighLevelClient.search(request, RequestOptions.DEFAULT);} catch (Exception e) {log.error("Search Elasticsearch Error!", e);}if (response == null) {return Collections.emptyList();}return Arrays.stream(response.getHits().getHits()).map(v -> JSON.parseObject(v.getSourceAsString(), clazz)).collect(Collectors.toList());}
}

Elasticsearch全文检索接口：分页检索

/*** 分页检索** @param yourIndex 索引* @param builder   搜索条件* @param page      分页参数（自己封装一个分页类，网上很多，easy）* @param sortField 排序属性* @param sortOrder 排序方式* @param clazz     返回类* @param <T>       泛型* @return 分页表格*/@SuppressWarnings("checkstyle:ParameterNumber")public <T> Page<T> searchPageByCond(String yourIndex, BoolQueryBuilder builder, Page<T> page, String sortField, SortOrder sortOrder, Class<T> clazz) {SearchSourceBuilder sourceBuilder = new SearchSourceBuilder();sourceBuilder.query(builder);sourceBuilder.from(Math.max(page.getOffset(), 0));sourceBuilder.size(page.getLimit());if (StringUtils.isNotBlank(sortField)) {sourceBuilder.sort(sortField, sortOrder);}SearchRequest request = new SearchRequest(yourIndex);request.source(sourceBuilder);SearchResponse response = null;try {response = restHighLevelClient.search(request, RequestOptions.DEFAULT);} catch (Exception e) {log.error("Search Elasticsearch Error!", e);}if (response == null) {page.setRows(Collections.emptyList());page.setTotal(0);return page;}page.setRows(Arrays.stream(response.getHits().getHits()).map(v -> JSON.parseObject(v.getSourceAsString(), clazz)).collect(Collectors.toList()));page.setTotal((int) response.getHits().getTotalHits().value);return page;}