简单记录一下在SpringBoot项目中,使用Redis实现点赞/排行榜功能,可同理实现收藏/关注功能,可拓展实现共同好友/共同关注/关注推送功。主要用到了Redis中的Set集合和ZSet集合。
在Redis中,可以使用SELECT命令来选择要使用的数据库索引。默认情况下,Redis有16个数据库索引,编号从0到15。
SELECT 15
(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"
(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"
(1)用法:SMEMBERS key
(2)作用:返回集合中的所有的成员。
(3)返回值:集合中的所有成员。
(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
(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)场景:实现共同好友、共同关注、关注推送等功能。
(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"
(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"
(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"
(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)UserController.java
/** * 点赞 * 同一个用户只能点赞一次,再次点击则取消点赞,若当前用户已经点赞,则点赞按钮高亮显示 */ @PutMapping(value = "like/{blogId}") @ResponseBody @CrossOrigin publicT like (@PathVariable("blogId") Long blogId) { return userService.like(blogId); } /** * 排行榜 * 查询点赞量最多的3篇博文 */ @GetMapping(value = "blogTop") @ResponseBody @CrossOrigin public T blogTop () { return userService.blogTop(); }
(1)IUserService.java
T like(Long blogId); T blogTop();
(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 publicT like(Long blogId) { HashMap 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 blogTop() { HashMap responseObj = new HashMap<>(); // Set > set = stringRedisTemplate.opsForZSet().rangeWithScores(BLOG_RANK_KEY, 0, -1); // ZRANGE Blog-Rank 0 -1 WITHSCORES Set > set = stringRedisTemplate.opsForZSet().reverseRangeWithScores(BLOG_RANK_KEY, 0, 2); // ZREVRANGE Blog-Rank 0 2 WITHSCORES System.out.println("blogTop :: set -> " + set); List list = new ArrayList<>(); for (ZSetOperations.TypedTuple tuple : set) { HashMap 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)参数说明
- 匹配所有键:*
- 匹配以特定前缀开头的键:prefix*
- 匹配以特定后缀结尾的键:*suffix
- 匹配包含特定字符串的键:*substring*
- 匹配特定模式的键:pattern?
(2)示例
// 查询所有key列表 Setkeys = stringRedisTemplate.keys("*"); System.out.println("blogTop :: keys -> " + keys); // 查询点赞博文的key列表 Set blogKeys = stringRedisTemplate.keys(BLOG_LIKED_KEY + "*"); System.out.println("blogTop :: blogKeys -> " + blogKeys);