关键字搜索

左手的ㄟ右手 2021-12-05 05:04 288阅读 0赞

# 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 {
        @Autowired
        private RestHighLevelClient restHighLevelClient;
        @Override
        public Map search(Map<String, String> paramMap) throws Exception {
            Map<String,Object> resultMap=new HashMap<>();
            /**
             * 1.获取查询参数
             */
            String keywords = paramMap.get("keywords");
            /**
             * 2.获取查询需要的对象
             */
            //创建查询对象，指定索引库名称，_index
            SearchRequest 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 {
        @Autowired
        private SearchService searchService;
        /**
         * 全文检索
         * @return
         */
        @GetMapping
        public Result search(@RequestParam Map<String, String> paramMap) throws Exception {
            Map resultMap = searchService.search(paramMap);
            return new Result(true, StatusCode.OK, "查询成功", resultMap);
        }
    }

# 1.1.4测试结果 #

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3NpbmF0XzM5MTc5OTkz_size_16_color_FFFFFF_t_70]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3NpbmF0XzM5MTc5OTkz_size_16_color_FFFFFF_t_70]: /images/20211205/5a4a4d6a73894184bbfc1ef1e27050e1.png