关键字搜索

1.1.1 需求分析

在首页或搜索页输入关键字，点击搜索显示列表搜索结果：

1.1.2实现思路

（1）后端使用匹配查询和布尔查询
（2）前端向后端传递map（因为提交的不仅仅是关键字，还有品牌、规格、分类等信息）
（3）后端向前端返回map（因为返回的不仅仅是列表，还有商品分类、品牌和规格列表等数据）

1.1.3 代码实现

(1)changgou_service_search工程接口 SearchService 新增方法定义

/*** 全文检索* @param paramMap  查询参数* @return*/public Map search(Map<String, String> paramMap) throws Exception;

(2)SearchServiceImpl 实现此方法，实现关键字查询

package com.changgou.service;import com.netflix.discovery.converters.Auto;
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.index.query.MatchQueryBuilder;
import org.elasticsearch.index.query.QueryBuilder;
import org.elasticsearch.index.query.QueryBuilders;
import org.elasticsearch.search.SearchHit;
import org.elasticsearch.search.SearchHits;
import org.elasticsearch.search.builder.SearchSourceBuilder;
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;@Overridepublic Map search(Map<String, String> paramMap) throws Exception {Map<String,Object> resultMap=new HashMap<>();/*** 1.获取查询参数*/String keywords = paramMap.get("keywords");/*** 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);/*** 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();rows.add(sourceAsMap);}}resultMap.put("rows",rows);return resultMap;}
}

(3)changgou_service_search新增SearchController类

package com.changgou.controller;import com.changgou.entity.Result;
import com.changgou.entity.StatusCode;
import com.changgou.service.EsManagerService;import com.changgou.service.SearchService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;import java.util.Map;/*** @author ：lijunxuan* @date ：Created in 2019/7/14  21:41* @description ：* @version: 1.0*/
@RestController
@RequestMapping("/search")
public class SearchController {@Autowiredprivate SearchService searchService;/*** 全文检索* @return*/@GetMappingpublic Result search(@RequestParam Map<String, String> paramMap) throws Exception {Map resultMap = searchService.search(paramMap);return new Result(true, StatusCode.OK, "查询成功", resultMap);}
}