电商项目-基于ElasticSearch实现商品搜索功能(三)

本系列文章主要介绍基于 Spring Data Elasticsearch 实现商品搜索的后端代码，介绍代码逻辑和代码实现。
主要实现功能：根据搜索关键字查询、条件筛选、规格过滤、价格区间搜索、搜索查询分页、搜索查询排序、高亮查询。

主要应用技术:canal，Eureka，微服务架构（Microservices Architecture），Spring Data Elasticsearch

一、 搜索分页

1 分页分析

基于spring data ElasticSearch 对于查询结果进行分页操作。
页面需要实现分页搜索，所以我们后台每次查询的时候，需要实现分页。用户页面每次会传入当前页和每页查询多少条数据，当然如果不传入每页显示多少条数据，设置默认查询条即可。

2 分页实现

分页使用PageRequest.of( pageNo- 1, pageSize);实现，第1个参数表示第N页，从0开始，第2个参数表示每页显示多少条，实现代码如下：
代码如下：

@Overridepublic Map search(Map<String, String> searchMap) throws Exception {Map<String, Object> resultMap = new HashMap<>();
​//有条件才查询Esif (null != searchMap) {//组合条件对象BoolQueryBuilder boolQuery = QueryBuilders.boolQuery();//0:关键词if (!StringUtils.isEmpty(searchMap.get("keywords"))) {boolQuery.must(QueryBuilders.matchQuery("name", searchMap.get("keywords")).operator(Operator.AND));}//1:条件 品牌if (!StringUtils.isEmpty(searchMap.get("brand"))) {boolQuery.filter(QueryBuilders.termQuery("brandName", searchMap.get("brand")));}
​//2:条件 规格for (String key : searchMap.keySet()) {if (key.startsWith("spec_")) {String value = searchMap.get(key).replace("%2B", "+");boolQuery.filter(QueryBuilders.termQuery("specMap." + key.substring(5) + ".keyword",value));}}//3:条件 价格if (!StringUtils.isEmpty(searchMap.get("price"))) {String[] p = searchMap.get("price").split("-");boolQuery.filter(QueryBuilders.rangeQuery("price").gte(p[0]));if (p.length == 2) {boolQuery.filter(QueryBuilders.rangeQuery("price").lte(p[1]));}}
​//4. 原生搜索实现类NativeSearchQueryBuilder nativeSearchQueryBuilder = new NativeSearchQueryBuilder();nativeSearchQueryBuilder.withQuery(boolQuery);
​//6. 品牌聚合(分组)查询String skuBrand = "skuBrand";nativeSearchQueryBuilder.addAggregation(AggregationBuilders.terms(skuBrand).field("brandName"));
​//7. 规格聚合(分组)查询String skuSpec = "skuSpec";nativeSearchQueryBuilder.addAggregation(AggregationBuilders.terms(skuSpec).field("spec.keyword"));
​
​String pageNum = searchMap.get("pageNum");if (null == pageNum) {pageNum = "1";}//9: 分页nativeSearchQueryBuilder.withPageable(PageRequest.of(Integer.parseInt(pageNum) - 1, Page.pageSize));
​//10: 执行查询, 返回结果对象AggregatedPage<SkuInfo> aggregatedPage = esTemplate.queryForPage(nativeSearchQueryBuilder.build(), SkuInfo.class, new SearchResultMapper() {@Overridepublic <T> AggregatedPage<T> mapResults(SearchResponse searchResponse, Class<T> aClass, Pageable pageable) {
​List<T> list = new ArrayList<>();
​SearchHits hits = searchResponse.getHits();if (null != hits) {for (SearchHit hit : hits) {SkuInfo skuInfo = JSON.parseObject(hit.getSourceAsString(), SkuInfo.class);
​list.add((T) skuInfo);}}return new AggregatedPageImpl<T>(list, pageable, hits.getTotalHits(), searchResponse.getAggregations());}});
​//11. 总条数resultMap.put("total", aggregatedPage.getTotalElements());//12. 总页数resultMap.put("totalPages", aggregatedPage.getTotalPages());//13. 查询结果集合resultMap.put("rows", aggregatedPage.getContent());
​//14. 获取品牌聚合结果StringTerms brandTerms = (StringTerms) aggregatedPage.getAggregation(skuBrand);List<String> brandList = brandTerms.getBuckets().stream().map(bucket -> bucket.getKeyAsString()).collect(Collectors.toList());resultMap.put("brandList", brandList);
​//15. 获取规格聚合结果StringTerms specTerms = (StringTerms) aggregatedPage.getAggregation(skuSpec);List<String> specList = specTerms.getBuckets().stream().map(bucket -> bucket.getKeyAsString()).collect(Collectors.toList());resultMap.put("specList", specList(specList));
​//16. 返回当前页resultMap.put("pageNum", pageNum);
​return resultMap;}
​return null;}

3测试

使用postman测试分页：

二、 搜索排序

1 排序分析

排序这里总共有根据价格排序、根据评价排序、根据新品排序、根据销量排序，排序要想实现只需要告知排序的域以及排序方式即可实现。

价格排序：只需要根据价格高低排序即可，降序价格高->低，升序价格低->高

评价排序：评价分为好评、中评、差评，可以在数据库中设计3个列，用来记录好评、中评、差评的量，每次排序的时候，好评的比例来排序，当然还要有条数限制，评价条数需要超过N条。

新品排序：直接根据商品的发布时间或者更新时间排序。

销量排序：销量排序除了销售数量外，还应该要有时间段限制。

2 排序代码实现

这里我们不单独针对某个功能实现排序，我们只需要在后台接收2个参数，分别是排序域名字和排序方式，代码如下：

   @Overridepublic Map search(Map<String, String> searchMap) throws Exception {Map<String, Object> resultMap = new HashMap<>();
​//有条件才查询Esif (null != searchMap) {//组合条件对象BoolQueryBuilder boolQuery = QueryBuilders.boolQuery();//0:关键词if (!StringUtils.isEmpty(searchMap.get("keywords"))) {boolQuery.must(QueryBuilders.matchQuery("name", searchMap.get("keywords")).operator(Operator.AND));}//1:条件 品牌if (!StringUtils.isEmpty(searchMap.get("brand"))) {boolQuery.filter(QueryBuilders.termQuery("brandName", searchMap.get("brand")));}
​//2:条件 规格for (String key : searchMap.keySet()) {if (key.startsWith("spec_")) {String value = searchMap.get(key).replace("%2B", "+");boolQuery.filter(QueryBuilders.termQuery("specMap." + key.substring(5) + ".keyword",value));}}//3:条件 价格if (!StringUtils.isEmpty(searchMap.get("price"))) {String[] p = searchMap.get("price").split("-");boolQuery.filter(QueryBuilders.rangeQuery("price").gte(p[0]));if (p.length == 2) {boolQuery.filter(QueryBuilders.rangeQuery("price").lte(p[1]));}}
​//4. 原生搜索实现类NativeSearchQueryBuilder nativeSearchQueryBuilder = new NativeSearchQueryBuilder();nativeSearchQueryBuilder.withQuery(boolQuery);
​//6. 品牌聚合(分组)查询String skuBrand = "skuBrand";nativeSearchQueryBuilder.addAggregation(AggregationBuilders.terms(skuBrand).field("brandName"));
​//7. 规格聚合(分组)查询String skuSpec = "skuSpec";nativeSearchQueryBuilder.addAggregation(AggregationBuilders.terms(skuSpec).field("spec.keyword"));
​//8: 排序if (!StringUtils.isEmpty(searchMap.get("sortField"))) {if ("ASC".equals(searchMap.get("sortRule"))) {nativeSearchQueryBuilder.withSort(SortBuilders.fieldSort(searchMap.get("sortField")).order(SortOrder.ASC));} else {
​nativeSearchQueryBuilder.withSort(SortBuilders.fieldSort(searchMap.get("sortField")).order(SortOrder.DESC));}
​}
​String pageNum = searchMap.get("pageNum");if (null == pageNum) {pageNum = "1";}//9: 分页nativeSearchQueryBuilder.withPageable(PageRequest.of(Integer.parseInt(pageNum) - 1, Page.pageSize));
​//10: 执行查询, 返回结果对象AggregatedPage<SkuInfo> aggregatedPage = esTemplate.queryForPage(nativeSearchQueryBuilder.build(), SkuInfo.class, new SearchResultMapper() {@Overridepublic <T> AggregatedPage<T> mapResults(SearchResponse searchResponse, Class<T> aClass, Pageable pageable) {
​List<T> list = new ArrayList<>();
​SearchHits hits = searchResponse.getHits();if (null != hits) {for (SearchHit hit : hits) {SkuInfo skuInfo = JSON.parseObject(hit.getSourceAsString(), SkuInfo.class);list.add((T) skuInfo);}}return new AggregatedPageImpl<T>(list, pageable, hits.getTotalHits(), searchResponse.getAggregations());}});
​//11. 总条数resultMap.put("total", aggregatedPage.getTotalElements());//12. 总页数resultMap.put("totalPages", aggregatedPage.getTotalPages());//13. 查询结果集合resultMap.put("rows", aggregatedPage.getContent());
​//14. 获取品牌聚合结果StringTerms brandTerms = (StringTerms) aggregatedPage.getAggregation(skuBrand);List<String> brandList = brandTerms.getBuckets().stream().map(bucket -> bucket.getKeyAsString()).collect(Collectors.toList());resultMap.put("brandList", brandList);
​//15. 获取规格聚合结果StringTerms specTerms = (StringTerms) aggregatedPage.getAggregation(skuSpec);List<String> specList = specTerms.getBuckets().stream().map(bucket -> bucket.getKeyAsString()).collect(Collectors.toList());resultMap.put("specList", specList(specList));
​//16. 返回当前页resultMap.put("pageNum", pageNum);
​return resultMap;}
​return null;}

3测试

使用postman测试
根据价格降序：

{"keywords":"手机","pageNum":"1","sortRule":"DESC","sortField":"price"}

根据价格升序：

{"keywords":"手机","pageNum":"1","sortRule":"ASC","sortField":"price"}

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/bicheng/68184.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

C++ using(八股总结)

C++ using(八股总结)

using作用&#xff1a; 类型别名using声明using指示 类型别名 using 可以用来创建类型别名&#xff0c;替代传统的 typedef。这在定义复杂类型时尤其有用&#xff0c;例如模板类型。 // 使用 typedef 创建类型别名 typedef long long ll;// 使用 using 创建类型别名 using …
阅读更多...
linux mysql 备份

linux mysql 备份

直接上代码 一&#xff0c;安装cron 1 安装cron sudo yum install cronie2 启动cron sudo systemctl start crond3 设置开机启动 sudo systemctl enable crond4 查看任务 crontab -l 没有任务则显示&#xff1a;no crontab for root二&#xff0c;备份脚本 #!/bin/bash # 备份…
阅读更多...
【0x005B】HCI_Write_Default_Erroneous_Data_Reporting命令详解

【0x005B】HCI_Write_Default_Erroneous_Data_Reporting命令详解

目录 一、命令概述 二、命令格式及参数 2.1. HCI_Write_Default_Erroneous_Data_Reporting命令格式 2.2. Erroneous_Data_Reporting 三、生成事件及参数 3.1. HCI_Command_Complete事件 3.2. 状态码（Status） 四、命令执行流程 4.1. 命令发起阶段（主机端） 4.2. 命…
阅读更多...
uniapp 小程序 textarea 层级穿透，聚焦光标位置错误怎么办？

uniapp 小程序 textarea 层级穿透，聚焦光标位置错误怎么办？

前言 在开发微信小程序时&#xff0c;使用 textarea 组件可能会遇到一些棘手的问题。最近我在使用 uniapp 开发微信小程序时&#xff0c;就遇到了两个非常令人头疼的问题&#xff1a; 层级穿透&#xff1a;由于 textarea 是原生组件&#xff0c;任何元素都无法遮盖住它。当其…
阅读更多...
FLASK创建下载

FLASK创建下载

html用a标签 <!-- Button to download the image --> <a href"{{ url_for(download_file, filenameimage.png) }}"><button>Download Image</button> </a> 后端&#xff1a;url_for双大括号即是用来插入变量到模板中的语法。也就是绑…
阅读更多...
Kotlin 快速上手指南：从安装 IntelliJ IDEA 到编写第一个程序

Kotlin 快速上手指南：从安装 IntelliJ IDEA 到编写第一个程序

文章目录 什么是kotlinIntelliJ IDEA安装 IntelliJ IDEA创建 Kotlin 项目运行 Kotlin 程序更改进入后默认打开上一次项目的设置打开 IntelliJ IDEA进入设置：重新启动 IntelliJ IDEA：快速学习Kotlin变量声明类型推断条件表达式定义函数单表达式函数when 表达式when 语句的基本…
阅读更多...
Docker 部署 Typecho

Docker 部署 Typecho

1. 官网 https://typecho.org/插件 & 主题 https://github.com/typecho-fans/plugins https://typechx.com/ https://typecho.work/2. 通过 compose 文件安装 github官网&#xff1a; https://github.com/typecho/Dockerfile 新建一个目录&#xff0c;存放 typecho 的相…
阅读更多...
2025/1/12 复习JS

2025/1/12 复习JS

我乞求你别再虚度光阴 ▶ 空心 --------------------------------------------------------------------------------------------------------------------------------- 摘自哔哩哔哩听课笔记。 01 上篇&#xff1a;核心语法 1.基于页面效果的操作 <!DOCTYPE html>…
阅读更多...
【机器学习】主动学习-增加标签的操作方法-样本池采样（Pool-Based Sampling）

【机器学习】主动学习-增加标签的操作方法-样本池采样（Pool-Based Sampling）

Pool-Based Sampling Pool-based sampling 是一种主动学习&#xff08;Active Learning&#xff09;方法&#xff0c;与流式选择性采样不同&#xff0c;它假设有一个预先定义的未标注样本池&#xff0c;算法从中选择最有价值的样本进行标注&#xff0c;以提升模型的性能。这种…
阅读更多...
【初识扫盲】厚尾分布

【初识扫盲】厚尾分布

厚尾分布&#xff08;Fat-tailed distribution&#xff09;是一种概率分布&#xff0c;其尾部比正态分布更“厚”&#xff0c;即尾部的概率密度更大&#xff0c;极端值出现的概率更高。 一、厚尾分布的特征 尾部概率大 在正态分布中&#xff0c;极端值&#xff08;如距离均值很…
阅读更多...
机组存储系统

机组存储系统

局部性 理论 程序执行&#xff0c;会不均匀访问主存&#xff0c;有些被频繁访问&#xff0c;有些很少被访问 时间局部性 被用到指令&#xff0c;不久可能又被用到 产生原因是大量循环操作 空间局部性 某个数据和指令被使用&#xff0c;附近数据也可能使用 主要原因是顺序存…
阅读更多...
Transformer创新模型！Transformer+BO-SVR多变量回归预测，添加气泡图、散点密度图（Matlab）

Transformer创新模型！Transformer+BO-SVR多变量回归预测，添加气泡图、散点密度图（Matlab）

Transformer创新模型&#xff01;TransformerBO-SVR多变量回归预测&#xff0c;添加气泡图、散点密度图&#xff08;Matlab&#xff09; 目录 Transformer创新模型&#xff01;TransformerBO-SVR多变量回归预测&#xff0c;添加气泡图、散点密度图&#xff08;Matlab&#xff0…
阅读更多...
31_搭建Redis分片集群

31_搭建Redis分片集群

Redis的主从复制模式和哨兵模式可以解决高可用、高并发读的问题。但是依然有两个问题没有解决：海量数据存储问题、高并发写的问题。由于数据量过大，单个master复制集难以承担，因此需要对多个复制集进行集群，形成水平扩展每个复制集只负责存储整个数据集的一部分，这就是Red…
阅读更多...
OpenGL —— 基于Qt的视频播放器 - ffmpeg硬解码，QOpenGL渲染yuv420p或nv12视频（附源码）

OpenGL —— 基于Qt的视频播放器 - ffmpeg硬解码，QOpenGL渲染yuv420p或nv12视频（附源码）

运行效果 工程说明 源码 vertex.glsl
阅读更多...
c++ 中的容器 vector、deque 和 list 的区别

c++ 中的容器 vector、deque 和 list 的区别

表格汇总&#xff1a; 容器存储结构随机访问性能中间插入/删除性能两端插入/删除性能内存管理特点迭代器类型适用场景vector连续存储的动态数组 O ( 1 ) O(1) O(1) O ( n ) O(n) O(n)&#xff08;需要移动元素&#xff09;末尾&#xff1a; O ( 1 ) O(1) O(1)&#xff0c;头部…
阅读更多...
ASP.NET Core - 日志记录系统(二)

ASP.NET Core - 日志记录系统(二)

ASP.NET Core - 日志记录系统&#xff08;二&#xff09; 2.4 日志提供程序2.4.1 内置日志提供程序2.4.2 源码解析 本篇接着上一篇 ASP.NET Core - 日志记录系统(一) 往下讲&#xff0c;所以目录不是从 1 开始的。 2.4 日志提供程序 2.4.1 内置日志提供程序 ASP.NET Core 包括…
阅读更多...
nginx的可视化配置工具nginxWebUI的使用

nginx的可视化配置工具nginxWebUI的使用

文章目录 1、nginx简介2、nginxWebUI2.1、技术解读2.2、开源版和专业版之间的区别2.3、功能解读 3、安装与使用3.1、下载镜像3.2、查看镜像3.3、启动容器3.4、使用 4、总结 1、nginx简介 Nginx 是一个高效的 HTTP 服务器和反向代理&#xff0c;它擅长处理静态资源、负载均衡和…
阅读更多...
【C++】IO 流

【C++】IO 流

文章目录 &#x1f449;C 语言的输入与输出&#x1f448;&#x1f449;流是什么&#x1f448;&#x1f449;C IO 流&#x1f448;C 标准 IO 流C 和 C 语言的输入格式问题C 的多次输入内置类型和自定义类型的转换日期的多次输入C 文件 IO 流文本文件和二进制文件的读写 &#x1…
阅读更多...
JavaScript系列（25）--性能优化技术详解

JavaScript系列（25）--性能优化技术详解

JavaScript性能优化技术详解 ⚡ 今天&#xff0c;让我们深入探讨JavaScript的性能优化技术。掌握这些技术对于构建高性能的JavaScript应用至关重要。 性能优化基础 &#x1f31f; &#x1f4a1; 小知识&#xff1a;JavaScript性能优化涉及多个方面&#xff0c;包括代码执行效…
阅读更多...
kotlin中的flow使用，Flow跟生命周期结合

kotlin中的flow使用，Flow跟生命周期结合

kotlin的Flow可以连续异步发出多个数据。 1. 普通flow,冷流类似于一个函数&#xff0c;当开始收集时才开始运行 val coldStream flow {for (i in 1..5) {delay(100L)emit(i)}} val collect1 buildString {coldStream.collect { append(it).append(", ") } }.remo…
阅读更多...
最新文章

Copyright @ 2022~2023