基于SpringBoot+Redis实现点赞/排行榜功能,可同理实现收藏/关注功能,可拓展实现共同好友/共同关注/关注推送功能

本文涉及的产品
云数据库 Tair(兼容Redis),内存型 2GB
Redis 开源版,标准版 2GB
推荐场景:
搭建游戏排行榜
简介: 在SpringBoot项目中使用Redis的Set和ZSet集合实现点赞和排行榜功能,并通过示例代码展示了如何使用`stringRedisTemplate`操作Redis来完成这些功能。

前言

简单记录一下在SpringBoot项目中,使用Redis实现点赞/排行榜功能,可同理实现收藏/关注功能,可拓展实现共同好友/共同关注/关注推送功。主要用到了Redis中的Set集合和ZSet集合。

一、指定使用某个索引的数据库

在Redis中,可以使用SELECT命令来选择要使用的数据库索引。默认情况下,Redis有16个数据库索引,编号从0到15。

SELECT 15

二、Redis集合(Set)数据类型的SADD、SREM、SMEMBERS命令

1.SADD 命令

(1)用法:SADD key val_1 或 SADD key val_1, val_2 ...
(2)作用:将一个或多个成员元素加入到集合中,已经存在于集合的成员元素将被忽略。
(3)返回值:被添加到集合中的新元素的数量,不包括被忽略的元素。
(4)示例

redis > SADD myset "hello"
(integer) 1
redis > SADD myset "foo"
(integer) 1
redis > SADD myset "hello"
(integer) 0
redis > SMEMBERS myset
1) "hello"
2) "foo"

2.SREM 命令

(1)用法:SREM key val_1 或 SREM key val_1, val_2 ...
(2)作用:移除集合中一个或多个成员
(3)返回值:被成功移除的元素的数量,不包括被忽略的元素。
(4)示例

redis > SADD myset1 "hello"
(integer) 1
redis > SADD myset1 "world"
(integer) 1
redis > SADD myset1 "bar"
(integer) 1
redis > SREM myset1 "hello"
(integer) 1
redis > SREM myset1 "foo"
(integer) 0
redis > SMEMBERS myset1
1) "bar"
2) "world"

3.SMEMBERS 命令

(1)用法:SMEMBERS key
(2)作用:返回集合中的所有的成员。
(3)返回值:集合中的所有成员。

4.SISMEMBER 命令

(1)用法:SISMEMBER key member
(2)作用:判断成员元素是否是集合的成员。
(3)返回值:如果成员元素是集合的成员,返回 1 。 如果成员元素不是集合的成员,或 key 不存在,返回 0 。
(4)示例

redis > SADD myset1 "hello"
(integer) 1
redis > SISMEMBER myset1 "hello"
(integer) 1
redis > SISMEMBER myset1 "world"
(integer) 0

5.SINTERSTORE 命令

(1)用法:SINTERSTORE DESTINATION_KEY KEY1 KEY2 ...
(2)作用:将给定集合之间的交集存储在指定的集合中。
(3)返回值:返回存储交集的集合的元素数量。
(4)示例

redis > SADD myset1 "hello"
(integer) 1
redis > SADD myset1 "foo"
(integer) 1
redis > SADD myset1 "bar"
(integer) 1
redis > SADD myset2 "hello"
(integer) 1
redis > SADD myset2 "world"
(integer) 1
redis > SINTERSTORE myset myset1 myset2
(integer) 1
redis > SMEMBERS myset
1) "hello"

(5)场景:实现共同好友、共同关注、关注推送等功能。

三、Redis集合(ZSet)数据类型的ZINCRBY、ZRANGE、ZREVRANGE、ZSCORE命令

1.ZINCRBY 命令

(1)用法:ZINCRBY key increment member
(2)作用:对有序集合中指定成员的分数加上增量increment,
· 可以通过传递一个负数值increment,让分数减去相应的值;
· 当key不存在,或分数不是key的成员时,ZINCRBY key increment member 等同于 ZADD key increment member;
· 当key不是有序集类型时,返回一个错误;
(3)返回值:member成员的新分数值。
(4)示例

redis > ZADD myzset 1 "one"
(integer) 1
redis > ZADD myzset 2 "two"
(integer) 1
redis > ZINCRBY myzset 2 "one"
"3"
redis > ZRANGE myzset 0 -1 WITHSCORES
1) "two"
2) "2"
3) "one"
4) "3"

2.ZRANGE 命令

(1)用法:ZRANGE key start stop [WITHSCORES]
(2)作用:返回有序集中,指定区间内的成员,其中成员的位置按分数值递增(从小到大)来排序。下标参数 start 和 stop 都以 0 为底,也就是说,以 0 表示有序集第一个成员,以 1 表示有序集第二个成员,以此类推。你也可以使用负数下标,以 -1 表示最后一个成员, -2 表示倒数第二个成员,以此类推。
(3)返回值:指定区间内,带有分数值(可选)的有序集成员的列表。
(4)示例

redis > ZRANGE Blog-Rank 0 -1 WITHSCORES
1) "Blog-10"
2) "1"
3) "Blog-1"
4) "2"
5) "Blog-5"
6) "3"

3.ZREVRANGE 命令

(1)用法:ZREVRANGE key start stop [WITHSCORES]
(2)作用:返回有序集中,指定区间内的成员,其中成员的位置按分数值递减(从大到小)来排列。
(3)返回值:指定区间内,带有分数值(可选)的有序集成员的列表。
(4)示例

redis > ZREVRANGE Blog-Rank 0 -1 WITHSCORES
1) "Blog-5"
2) "3"
3) "Blog-1"
4) "2"
5) "Blog-10"
6) "1"

4.ZSCORE 命令

(1)用法:ZSCORE key member
(2)作用:返回有序集中,成员的分数值。 如果成员元素不是有序集 key 的成员,或 key 不存在,返回 nil 。
(3)返回值:成员的分数值,以字符串形式表示。
(4)示例

redis > ZRANGE salary 0 -1 WITHSCORES
1) "tom"
2) "2000"
3) "peter"
4) "3500"
5) "jack"
6) "5000"

redis > ZSCORE salary peter
"3500"

四、示例代码

1.控制层

(1)UserController.java

/**
 * 点赞
 * 同一个用户只能点赞一次,再次点击则取消点赞,若当前用户已经点赞,则点赞按钮高亮显示
 */
@PutMapping(value = "like/{blogId}")
@ResponseBody
@CrossOrigin
public <T> T like (@PathVariable("blogId") Long blogId) {
   
    return userService.like(blogId);
}

/**
 * 排行榜
 * 查询点赞量最多的3篇博文
 */
@GetMapping(value = "blogTop")
@ResponseBody
@CrossOrigin
public <T> T blogTop () {
   
    return userService.blogTop();
}

2.接口层

(1)IUserService.java

<T> T like(Long blogId);

<T> T blogTop();

3.实现层

(1)UserServiceImpl.java

private static final String BLOG_LIKED_KEY = "Blog-Liked-";
private static final String BLOG_RANK_KEY = "Blog-Rank";
private static final String BLOG_KEY = "Blog-";

@Autowired
private StringRedisTemplate stringRedisTemplate;

@Override
public <T> T like(Long blogId) {
   
    HashMap<String, Object> responseObj = new HashMap<>();
    // 获取登录用户
    UserDTO userDTO = RequestHolder.getUser();
    // 是否已点赞
    String key = BLOG_LIKED_KEY + blogId; // Blog-Liked-10
    String val = userDTO.getPhone(); // 13800138000
    Boolean isMember = stringRedisTemplate.opsForSet().isMember(key, val); // SISMEMBER Blog-Liked-10 "13800138000"
    if (BooleanUtil.isFalse(isMember)) {
   
        // 未点赞
        boolean isSuccess = true; // 在数据库点赞表中,新增/修改关于此博文的点赞状态为1
        if (isSuccess) {
   
            stringRedisTemplate.opsForSet().add(key, val); // SADD Blog-Liked-10 "13800138000"
            stringRedisTemplate.opsForZSet().incrementScore(BLOG_RANK_KEY, BLOG_KEY + blogId, 1); // ZINCRBY BLOG_RANK_KEY 1 Blog-10
        }
    } else {
   
        // 已点赞
        boolean isSuccess = true; // 在数据库点赞表中,修改关于此博文的点赞状态为0
        if (isSuccess) {
   
            stringRedisTemplate.opsForSet().remove(key, val); // SREM Blog-Liked-10 "13800138000"
            stringRedisTemplate.opsForZSet().incrementScore(BLOG_RANK_KEY, BLOG_KEY + blogId, -1); // ZINCRBY BLOG_RANK_KEY -1 Blog-10
        }
    }
    responseObj.put("code", 200);
    responseObj.put("success", true);
    return (T) responseObj;
}

@Override
public <T> T blogTop() {
   
    HashMap<String, Object> responseObj = new HashMap<>();
    // Set<ZSetOperations.TypedTuple<String>> set = stringRedisTemplate.opsForZSet().rangeWithScores(BLOG_RANK_KEY, 0, -1); // ZRANGE Blog-Rank 0 -1 WITHSCORES
    Set<ZSetOperations.TypedTuple<String>> set = stringRedisTemplate.opsForZSet().reverseRangeWithScores(BLOG_RANK_KEY, 0, 2); // ZREVRANGE Blog-Rank 0 2 WITHSCORES
    System.out.println("blogTop :: set -> " + set);

    List<HashMap> list = new ArrayList<>();
    for (ZSetOperations.TypedTuple<String> tuple : set) {
   
        HashMap<String, Long> map = new HashMap();
        String key = tuple.getValue();
        double score = tuple.getScore();
        long val = (long) score;
        map.put(key, val);
        list.add(map);
    }

    responseObj.put("code", 200);
    responseObj.put("success", true);
    responseObj.put("data", list);
    return (T) responseObj;
}

五、其它相关知识点

1.stringRedisTemplate.keys(pattern)方法说明

(1)参数说明
- 匹配所有键:*
- 匹配以特定前缀开头的键:prefix*
- 匹配以特定后缀结尾的键:*suffix
- 匹配包含特定字符串的键:*substring*
- 匹配特定模式的键:pattern?
(2)示例

// 查询所有key列表
Set<String> keys = stringRedisTemplate.keys("*");
System.out.println("blogTop :: keys -> " + keys);

// 查询点赞博文的key列表
Set<String> blogKeys = stringRedisTemplate.keys(BLOG_LIKED_KEY + "*");
System.out.println("blogTop :: blogKeys -> " + blogKeys);
目录
相关文章
|
27天前
|
NoSQL Java 调度
分布式锁与分布式锁使用 Redis 和 Spring Boot 进行调度锁(不带 ShedLock)
分布式锁是分布式系统中用于同步多节点访问共享资源的机制,防止并发操作带来的冲突。本文介绍了基于Spring Boot和Redis实现分布式锁的技术方案,涵盖锁的获取与释放、Redis配置、服务调度及多实例运行等内容,通过Docker Compose搭建环境,验证了锁的有效性与互斥特性。
分布式锁与分布式锁使用 Redis 和 Spring Boot 进行调度锁(不带 ShedLock)
|
7月前
|
NoSQL Java 关系型数据库
微服务——SpringBoot使用归纳——Spring Boot 中集成Redis——Redis 介绍
本文介绍在 Spring Boot 中集成 Redis 的方法。Redis 是一种支持多种数据结构的非关系型数据库(NoSQL),具备高并发、高性能和灵活扩展的特点,适用于缓存、实时数据分析等场景。其数据以键值对形式存储,支持字符串、哈希、列表、集合等类型。通过将 Redis 与 Mysql 集群结合使用,可实现数据同步,提升系统稳定性。例如,在网站架构中优先从 Redis 获取数据,故障时回退至 Mysql,确保服务不中断。
282 0
微服务——SpringBoot使用归纳——Spring Boot 中集成Redis——Redis 介绍
|
6月前
|
XML 前端开发 Java
SpringBoot实现文件上传下载功能
本文介绍了如何使用SpringBoot实现文件上传与下载功能,涵盖配置和代码实现。包括Maven依赖配置(如`spring-boot-starter-web`和`spring-boot-starter-thymeleaf`)、前端HTML页面设计、WebConfig路径映射配置、YAML文件路径设置,以及核心的文件上传(通过`MultipartFile`处理)和下载(利用`ResponseEntity`返回文件流)功能的Java代码实现。文章由Colorful_WP撰写,内容详实,适合开发者学习参考。
548 0
|
2月前
|
存储 NoSQL Redis
采用Redis的Bitmaps实现类似Github连续提交状态的功能。
在现实世界的应用开发中,实现类似于Github提交跟踪系统时,还可能需要考虑用户时区、闰年等日期相关的边界条件,以及辅助数据的存储和查询优化,例如对活跃用户的即时查询和统计等。不过这些都可以在Bitmaps的基础功能之上通过额外的代码逻辑来实现。
71 0
|
5月前
|
消息中间件 缓存 NoSQL
基于Spring Data Redis与RabbitMQ实现字符串缓存和计数功能(数据同步)
总的来说,借助Spring Data Redis和RabbitMQ,我们可以轻松实现字符串缓存和计数的功能。而关键的部分不过是一些"厨房的套路",一旦你掌握了这些套路,那么你就像厨师一样可以准备出一道道饕餮美食了。通过这种方式促进数据处理效率无疑将大大提高我们的生产力。
195 32
|
7月前
|
缓存 NoSQL Java
基于SpringBoot的Redis开发实战教程
Redis在Spring Boot中的应用非常广泛,其高性能和灵活性使其成为构建高效分布式系统的理想选择。通过深入理解本文的内容,您可以更好地利用Redis的特性,为应用程序提供高效的缓存和消息处理能力。
552 79
|
5月前
|
存储 监控 NoSQL
使用Redis实现延迟消息发送功能
使用 Redis 的密码认证功能,为实例设置密码以防止未授权访问。为消息提供适当加密,确保消息内容在网络传输过程中不被窃取或篡改。
191 16
|
5月前
|
安全 Java API
Spring Boot 功能模块全解析:构建现代Java应用的技术图谱
Spring Boot不是一个单一的工具,而是一个由众多功能模块组成的生态系统。这些模块可以根据应用需求灵活组合,构建从简单的REST API到复杂的微服务系统,再到现代的AI驱动应用。
|
4月前
|
机器学习/深度学习 数据采集 人机交互
springboot+redis互联网医院智能导诊系统源码,基于医疗大模型、知识图谱、人机交互方式实现
智能导诊系统基于医疗大模型、知识图谱与人机交互技术,解决患者“知症不知病”“挂错号”等问题。通过多模态交互(语音、文字、图片等)收集病情信息,结合医学知识图谱和深度推理,实现精准的科室推荐和分级诊疗引导。系统支持基于规则模板和数据模型两种开发原理:前者依赖人工设定症状-科室规则,后者通过机器学习或深度学习分析问诊数据。其特点包括快速病情收集、智能病症关联推理、最佳就医推荐、分级导流以及与院内平台联动,提升患者就诊效率和服务体验。技术架构采用 SpringBoot+Redis+MyBatis Plus+MySQL+RocketMQ,确保高效稳定运行。
281 0
|
6月前
|
SQL 前端开发 Java
深入理解 Spring Boot 项目中的分页与排序功能
本文深入讲解了在Spring Boot项目中实现分页与排序功能的完整流程。通过实际案例,从Service层接口设计到Mapper层SQL动态生成,再到Controller层参数传递及前端页面交互,逐一剖析每个环节的核心逻辑与实现细节。重点包括分页计算、排序参数校验、动态SQL处理以及前后端联动,确保数据展示高效且安全。适合希望掌握分页排序实现原理的开发者参考学习。
355 4