基于redis实现【最热搜索】和【最近搜索】功能

目录

  • 一、前言
  • 二、分析问题
  • 三、针对两个问题，使用redis怎么解决问题？
    • 1、字符串String
    • 2、列表List
    • 3、字典Hash
    • 4、集合Set
    • 5、有序集合ZSet
    • 6、需要解决的五大问题
  • 四、编写代码
    • 1.pom依赖
    • 2.application.yml配置
    • 3.Product商品实体
    • 4.用户最近搜索信息
    • 5.redis辅助类SearchRedisHelper
    • 6.业务service
    • 7.controller控制层
  • 五、postman测试
    • 1.第一次搜索
    • 2.热点搜索
    • 3.最近搜索
    • 4.第二次第三次搜索
    • 5.再看热点搜索
    • 6.再看最近搜索变化
    • 7.第四次搜索
    • 8.热搜变化
    • 9.最近搜索变化
  • 六、总结

一、前言

大家在浏览各种网站，比如淘宝，京东，微博等网站，都会看到一些热门搜索和最近搜索的功能，大家有木有好奇，技术背后是如何实现的呢？今天我们一起来用redis解决这两个问题，并已在项目中实战！！！
热搜如下图：

在这里插入图片描述
最近搜索如下图:

在这里插入图片描述

二、分析问题

1、热门搜索：是指一定时间内、一定范围内，公众较为关心的热点问题，被搜索的次数越多，热搜榜越靠前。

2、最近搜索：只显示当前用户最近一段时间内的搜索记录，按照时间进行排序，如果有重复搜索，覆盖到重复的数据，并且要排到最前面。

3、针对于热门的搜索属于高并发的场景，还需要高性能显示给用户，用MySQL存储显然不太合适，流量过多会把MySQL撑爆，最近搜索和最热搜索也不需要持久化，最好的解决方案之一就是redis做缓存，单机redis可以承受10万QPS。

三、针对两个问题，使用redis怎么解决问题？

我们复习一下redis的五大数据类型，redis数据类型可以参考Redis中5种基本数据类型结构详解

1、字符串String

特性：
（1）最基本的数据类型，二进制安全的字符串，最大512M。
（2）支持字符串操作:strlen或取value的长度，返回的是字节的数量。
（3）数据交互有个二进制安全的概念，给我数据的时候你自己编码，字节数组到达我这里整理，帮你存，客户端之间商量好。
（4）支持数值计算操作:incr,decr
应用场景：做简单得键值对缓存，比如`Session，token，统计，限流，轻量级（kb级别）的FS内存级的文件系统—任何东西都可以变成字节数组（二进制），一些复杂的计数功能的缓存

2、列表List

特性：
按照添加顺序保持顺序的字符串列表，也就是存储一些列表型得数据结构，类似粉丝列表、文字得评论列表之类得数据。
应用场景：
可以做简单的消息队列的功能。另外还有一个就是，可以利用lrange命令，做基于redis的分页功能，性能极佳，用户体验好。

3、字典Hash

特性：
（1）key-value对的一种集合，存储结构化得数据，比如一个对象。
（2）这里value存放的是结构化的对象，比较方便的就是操作其中的某个字段。
应用场景：
经常会用来做用户数据的管理，存储用户的信息。比如做单点登录的时候，就是用这种数据结构存储用户信息，以cookieId作为key，设置30分钟为缓存过期时间，能很好的模拟出类似session的效果。

4、集合Set

特性:
无序的字符串集合，不存在重复的元素.
应用场景：
去重，还可以利用交集、并集、差集等操作，可以计算共同喜好，全部的喜好，自己独有的喜好等功能。

5、有序集合ZSet

特性：
已排序的字符串集合。去重并排序，如获取排名前几名。
应用场景：
sorted set多了一个权重参数score,集合中的元素能够按score进行排列。可以做排行榜应用，取TOP N操作。

6、需要解决的五大问题

问题一：很显然根据咱们的以上分析，热门搜索和最近搜索的功能需要去重并且排序，热门搜索点击率最高的在前面，最近搜索最新的数据搜索在最前面，所以使用ZSet集合实现最合适。针对于最近搜索的功能使用List也可以实现，但是删除的效率要比ZSet慢，还需要自己去重，所以还是Zset最合适。

问题二：用户可能无限制浏览商品，最近搜索的功能需要确保zSet 不能无限制插入，需要控制zSet 的大小，也就是指保存最近N条浏览记录。

问题三：最近搜索的功能需要在插入第N+1 条后移除最开始浏览的第一条。

问题四：热门搜索key值需要过期时间的。

问题五：热门搜索针对的是所有用户，而最近搜索针对的是当前用户。

以上五大问题均在代码中详细解决，仔细看注释。

四、编写代码

1.pom依赖

<!-- redis -->
<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>

2.application.yml配置

server:port: 8889spring:redis:host: 127.0.0.1port: 6379password: database: 2timeout: 5000

3.Product商品实体

@Data
public class Product implements Serializable {//商品idprivate Long id;//商品名称private String productName;//.....等属性
}

4.用户最近搜索信息

@Data
public class UserRecentSearch implements Serializable {/*** 搜索信息*/private String searchInfo;/*** 用户id*/private Long unionId;
}

5.redis辅助类SearchRedisHelper

@Component
public class SearchRedisHelper {@Resourceprivate RedisTemplate redisTemplate;/*** 热搜的KEY*/public static final String HOT_SEARCH = "product_hot_search";/*** 最近搜索的KEY*/public static final String RECENT_SEARCH = "product_recent_search";/*** 最近搜索的大小*/public static final Integer CURRENT_SEARCH_SIZE = 3;/*** 最热搜索KEY过期时间*/public static final Integer HOT_SEARCH_EXPIRE_TIME = 3;/*** 设置redis的过期时间* expire其实是懒加载，不设置key的时候是不会执行的*/@PostConstructpublic void setHotSearchExpireTime() {redisTemplate.expire(HOT_SEARCH, HOT_SEARCH_EXPIRE_TIME, TimeUnit.SECONDS);}/*** redis添加最近搜索** @param query*/public void addRedisRecentSearch(String query) {UserRecentSearch userRecentSearch = new UserRecentSearch();// 用户id，当前用户iduserRecentSearch.setUnionId(100434L);// 搜索信息userRecentSearch.setSearchInfo(query);// score为一个分值，需要把最近浏览的商品id的分值设为最大值，// 此处我们可以设置为当前时间Instant.now().getEpochSecond()// 这样最近浏览的商品id的分值一定最大，排在Zset集合最前面ZSetOperations<String, UserRecentSearch> zSet = redisTemplate.opsForZSet();// 由于zSet的集合特性当插入已经存在的V值（商品id）时只会更新score值，zSet.add(RECENT_SEARCH, userRecentSearch, Instant.now().getEpochSecond());// 获取到全部用户的最近搜索记录，用reverseRangeWithScores方法，可以获取到根据score排序之后的集合Set<ZSetOperations.TypedTuple<UserRecentSearch>> typedTuples = zSet.reverseRangeWithScores(RECENT_SEARCH, 0, -1);//只得到当前用户的最近搜索记录,注意这里必须保证set集合的顺序Set<UserRecentSearch> userRecentSearches = listRecentSearch();if (userRecentSearches.size() > CURRENT_SEARCH_SIZE) {//获取到最开始浏览的第一条UserRecentSearch userRecentSearchLast = userRecentSearches.stream().reduce((first, second) -> second).orElse(null);//删除最开始浏览的第一条zSet.remove(RECENT_SEARCH, userRecentSearchLast);}}/*** 热搜列表* @return*/public Set<Product> listHotSearch() {//0 5 表示0-5下标对应的元素return redisTemplate.opsForZSet().reverseRangeWithScores(HOT_SEARCH, 0, 5);}/*** redis添加热搜* @param productList*/public void addRedisHotSearch(List<Product> productList) {//1：表示每调用一次，当前product的分数+1productList.forEach(product -> redisTemplate.opsForZSet().incrementScore(HOT_SEARCH, product, 1D));}/*** 最近搜索列表* @return*/public Set<UserRecentSearch> listRecentSearch() {Set<ZSetOperations.TypedTuple<UserRecentSearch>> typedTuples = redisTemplate.opsForZSet().reverseRangeWithScores(RECENT_SEARCH, 0, -1);return Optional.ofNullable(typedTuples).map(tuples -> tuples.stream().map(ZSetOperations.TypedTuple::getValue).filter(Objects::nonNull)
//                        .filter(userRecentSearch -> Objects.equals(userRecentSearch.getUnionId(), ContextHolder.getUser().getId())).filter(userRecentSearch -> Objects.equals(userRecentSearch.getUnionId(), 100434L)).collect(Collectors.collectingAndThen(Collectors.toCollection(LinkedHashSet::new), LinkedHashSet::new))).orElseGet(LinkedHashSet::new);}}

6.业务service

@Service
public class ProductService {@Resourceprivate SearchRedisHelper searchRedisHelper;/*** 搜索* @param query* @return*/public List<Product> search(String query) {//业务代码可用es.....此处略过....模拟数据库数据List<Product> productList = new ArrayList();Product product = new Product();product.setId(1L);product.setProductName("iphone15");productList.add(product);searchRedisHelper.addRedisRecentSearch(query);searchRedisHelper.addRedisHotSearch(productList);return productList;}/*** 热搜列表* @return*/public Set<Product> listHotSearch() {return searchRedisHelper.listHotSearch();}/*** 最近搜索列表* @return*/public Set<UserRecentSearch> listRecentSearch() {return searchRedisHelper.listRecentSearch();}
}

7.controller控制层

@RequestMapping("/redis/test")
@RestController
public class RedisController {@Resourceprivate RedisTemplate redisTemplate;@Resourceprivate ProductService productService;/*** 删除redis* @param key* @return*/@GetMapping("/w/remove/redis")public Result removeRedis(String key){redisTemplate.delete(key);return Result.success();}/*** 搜索* @param query* @return*/@GetMapping("/r/search/product")public Result listProduct(String query) {return Result.success(productService.search(query));}/*** 热搜列表* @return*/@ResponseBody@GetMapping("/r/list/hot/search")public Result listHotSearch() {return Result.success(productService.listHotSearch());}/*** 最近搜索列表* @return*/@ResponseBody@GetMapping("/r/list/recent/search")public Result recentHotSearch() {return Result.success(productService.listRecentSearch());}}

五、postman测试

1.第一次搜索

在这里插入图片描述

2.热点搜索

在这里插入图片描述

3.最近搜索

在这里插入图片描述

4.第二次第三次搜索

在这里插入图片描述

在这里插入图片描述

5.再看热点搜索

在这里插入图片描述

6.再看最近搜索变化

在这里插入图片描述

7.第四次搜索

再搜索两次
在这里插入图片描述

8.热搜变化

在这里插入图片描述

9.最近搜索变化

在这里插入图片描述

六、总结

本文针对于网站热点搜索和最近搜索的问题，对redis的五大数据类型进行了解读，并且采用高并发利器redis的ZSet有序集合完美解决本文一开始引入的问题，保证了系统的高并发和高性能，提高用户体验。

项目代码：Github

推荐好文：
Redis实现分布式锁详细方法

如果看到这里，说明你喜欢这篇文章，请转发，点赞

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

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

相关文章

软件分层(数据结构/软件逻辑上分层+举例),相连节点的概念+如何相连,为什么是层状结构(软件分层,网络协议分层+梳理协议顺序),协议分层(打电话例子)

软件分层(数据结构/软件逻辑上分层+举例),相连节点的概念+如何相连,为什么是层状结构(软件分层,网络协议分层+梳理协议顺序),协议分层(打电话例子)

目录 软件分层 介绍 举例 类的继承 虚拟文件系统 线程接口封装 虚拟地址空间 总结 为什么是层状的 软件分层 网络协议 原因 梳理协议顺序 相连节点 协议分层 引入 示例 实际上 逻辑上 制定出协议 软件分层 介绍 通过将软件系统划分为不同的层次,每一层都有…
阅读更多...
中电金信精选好文，全篇划重点~

中电金信精选好文，全篇划重点~

从硅谷银行件看中美金融监管差异 2023年3月&#xff0c;硅谷银行事件引发全球金融市场震荡&#xff0c;该事件除了给美联储从暴力降息到暴力升息的极限操作敲响一记警钟之外&#xff0c;更是暴露出美国金融监管漏洞重重的现状。相较之下&#xff0c;近年来我国不断深化金融监管…
阅读更多...
【架构之路】糟糕程序员的20个坏习惯,切记要改掉

【架构之路】糟糕程序员的20个坏习惯,切记要改掉

文章目录 强烈推荐前言&#xff1a;坏习惯:总结&#xff1a;强烈推荐专栏集锦写在最后 强烈推荐 前些天发现了一个巨牛的人工智能学习网站&#xff0c;通俗易懂&#xff0c;风趣幽默&#xff0c;忍不住分享一下给大家。点击跳转到网站:人工智能 前言&#xff1a; 优秀的程序员…
阅读更多...
【MATLAB】ICEEMDAN_ MFE_SVM_LSTM 神经网络时序预测算法

【MATLAB】ICEEMDAN_ MFE_SVM_LSTM 神经网络时序预测算法

有意向获取代码&#xff0c;请转文末观看代码获取方式~也可转原文链接获取~ 1 基本定义 ICEEMDAN是指“改进的完全扩展经验模态分解与自适应噪声”&#xff08;Improved Complete Ensemble Empirical Mode Decomposition with Adaptive Noise&#xff09;&#xff0c;它是CEEM…
阅读更多...
【力扣hot100】刷题笔记Day15

【力扣hot100】刷题笔记Day15

前言 今天要刷的是图论&#xff0c;还没学过&#xff0c;先看看《代码随想录》这部分的基础 深搜DFS理论基础 深搜三部曲 确认递归函数、参数确认终止条件处理目前搜索节点出发的路径 代码框架 void dfs(参数) {if (终止条件) {存放结果;return;}for (选择&#xff1a;本节点…
阅读更多...
unity 场景烘焙中植物叶片（单面网络）出现的白面

unity 场景烘焙中植物叶片（单面网络）出现的白面

Unity版本 2021.3.3 平台 Windows 在场景烘焙中烘焙植物的模型的时候发现植物的叶面一面是合理的&#xff0c;背面是全白的&#xff0c;在材质球上勾选了双面烘焙&#xff0c;情况如下 这个问题可能是由于植物叶片的单面网格导致的。在场景烘焙中&#xff0c;单面网格只会在一…
阅读更多...
CSS_实现三角形和聊天气泡框

CSS_实现三角形和聊天气泡框

如何用css画出一个三角形 1、第一步 写一个正常的盒子模型&#xff0c;先给个正方形的div&#xff0c;便于观察&#xff0c;给div设置宽高和背景颜色 <body><div class"box"></div> </body> <style>.box {width: 100px;height: 100px…
阅读更多...
GDB之(8)GDB-Server远程调试

GDB之(8)GDB-Server远程调试

GDB之(8)GDB-Server远程调试 Author&#xff1a;Once Day Date&#xff1a;2024年2月27日 漫漫长路&#xff0c;有人对你微笑过嘛… 全系列文章请查看专栏: Linux实践记录_Once-Day的博客-CSDN博客 参考文档: 用GDB调试程序 _CSDN博客 _陈皓GDB: The GNU Project Debugger…
阅读更多...
【大数据】Flink SQL 语法篇（八）：集合、Order By、Limit、TopN

【大数据】Flink SQL 语法篇（八）：集合、Order By、Limit、TopN

Flink SQL 语法篇&#xff08;八&#xff09;&#xff1a;集合、Order By、Limit、TopN 1.集合操作2.Order By、Limit 子句2.1 Order By 子句2.2 Limit 子句 3.TopN 子句 1.集合操作 集合操作支持 Batch / Streaming 任务。 UNION&#xff1a;将集合合并并且去重。UNION ALL&a…
阅读更多...
云尚办公-0.0.3

云尚办公-0.0.3

5. controller层 import pers.beiluo.yunshangoffice.model.system.SysRole; import pers.beiluo.yunshangoffice.service.SysRoleService;import java.util.List;//RestController&#xff1a;1.该类是控制器&#xff1b;2.方法返回值会被写进响应报文的报文体&#xff0c;而…
阅读更多...
Apache SeaTunnel 及 Web 功能部署指南(小白版)

Apache SeaTunnel 及 Web 功能部署指南(小白版)

在大数据处理领域&#xff0c;Apache SeaTunnel 已成为一款备受青睐的开源数据集成平台&#xff0c;它不仅可以基于Apache Spark和Flink&#xff0c;而且还有社区单独开发专属数据集成的Zeta引擎&#xff0c;提供了强大的数据处理能力。随着SeaTunnel Web的推出&#xff0c;用户…
阅读更多...
如何开发一个mybatis扩展框架

如何开发一个mybatis扩展框架

如何开发一个mybatis扩展框架 都说官网是最好的入门。当你参考mybatis官网执行查询发现这样&#xff1a; // try 执行完后会关闭 session try (SqlSession session sqlSessionFactory.openSession()) {BlogMapper mapper session.getMapper(BlogMapper.class);Blog blog …
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023