实现搜索分页功能

1.1 需求分析

实现搜索分页功能，每页显示30条记录。实现商品列表下方分页栏。

1.2 实现思路

前端向后端传递参数 pageNo （页码）

1.3 代码实现

修改SearchServiceImpl的search方法，在第1段代码中添加代码

package com.changgou.service;import org.apache.commons.lang.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.common.text.Text;
import org.elasticsearch.index.query.BoolQueryBuilder;
import org.elasticsearch.index.query.MatchQueryBuilder;import org.elasticsearch.index.query.QueryBuilders;
import org.elasticsearch.search.SearchHit;
import org.elasticsearch.search.SearchHits;
import org.elasticsearch.search.builder.SearchSourceBuilder;
import org.elasticsearch.search.fetch.subphase.highlight.HighlightBuilder;
import org.elasticsearch.search.fetch.subphase.highlight.HighlightField;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;/*** @author ：lijunxuan* @date ：Created in 2019/7/17  19:00* @description ：* @version: 1.0*/
@Service
public class SearchServiceImpl implements SearchService {@Autowiredprivate RestHighLevelClient restHighLevelClient;//设置每页查询条数据public final static Integer PAGE_SIZE = 4;@Overridepublic Map search(Map<String, String> paramMap) throws Exception {Map<String,Object> resultMap=new HashMap<>();/*** 1.获取查询参数*///查询关键字String keywords = paramMap.get("keywords");//当前页数String pageNo = paramMap.get("pageNo");/*** 2.获取查询需要的对象*///创建查询对象，指定索引库名称，_indexSearchRequest searchRequest = new SearchRequest("sku");//指定查询索引库中的类型searchRequest.types("doc");//创建查询构造对象SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();//创建布尔查询（组合查询对象）BoolQueryBuilder boolQueryBuilder = QueryBuilders.boolQuery();/*** 3.设置根据关键字查询（关键字需要中文分词）*/MatchQueryBuilder nameQueryBuilder = QueryBuilders.matchQuery("name", keywords);//根据名称查询条件放入组合查询对象中boolQueryBuilder.must(nameQueryBuilder);/*** 4. 设置高亮查询*/HighlightBuilder highlightBuilder = new HighlightBuilder();//设置在哪个域中高亮显示highlightBuilder.field("name");//设置高亮前缀highlightBuilder.preTags("<em style=\"color:red\">");//设置高亮后缀highlightBuilder.postTags("</em>");searchSourceBuilder.highlighter(highlightBuilder);/*** 5. 设置分页查询*/if (StringUtils.isEmpty(pageNo)) {paramMap.put("pageNo", "1");resultMap.put("pageNo", "1");}Integer pageNoTemp = Integer.parseInt(pageNo);if (pageNoTemp < 1) {paramMap.put("pageNo", "1");resultMap.put("pageNo", "1");pageNoTemp = 1;}//从第几条开始查询Integer start = (pageNoTemp - 1) * PAGE_SIZE;//从第几条开始查询searchSourceBuilder.from(start);//每页查询多少条数据searchSourceBuilder.size(PAGE_SIZE);/*** 12.查询并返回的结果*///将组合查询条件放入查询构造对象中searchSourceBuilder.query(boolQueryBuilder);//将组合查询条件放入查询请求中searchRequest.source(searchSourceBuilder);SearchResponse searchResponse = restHighLevelClient.search(searchRequest, RequestOptions.DEFAULT);/*** 13. 获取查询到的结果集, 封装后返回*/SearchHits searchHits = searchResponse.getHits();//获取查询到的总条数long totalHits = searchHits.getTotalHits();resultMap.put("total",totalHits);//获取查询结果集SearchHit[] hits = searchHits.getHits();List rows = new ArrayList<>();if (hits!=null){for (SearchHit hit : hits) {//获取普通的查询出来的一条数据(不带高亮名称)Map<String, Object> sourceAsMap = hit.getSourceAsMap();//获取高亮结果Map<String, HighlightField> highlightFields = hit.getHighlightFields();if (highlightFields != null) {HighlightField highlightField = highlightFields.get("name");Text[] fragments = highlightField.fragments();if (fragments != null && fragments.length > 0) {//将高亮名称放入查询出来的数据中, 覆盖原来不带高亮的名称sourceAsMap.put("name", fragments[0].toString());}}rows.add(sourceAsMap);}}resultMap.put("rows",rows);return resultMap;}
}