Redis(案例六：ZSet数据)

案例实战之SortedSet⽤户积分实时榜单最佳实践

背景

⽤户玩游戏-积分实时榜单
IT视频热销实时榜单
电商商品热销实时榜单
⼀般的排⾏榜读多写少，可以对 master 进⾏写⼊操作，然后多个 slave 进⾏读取操作。如果是对象记得重写HashCode与Equals⽅法

UserPointVO

package net.xdclass.xdclassredis.vo;import java.util.Objects;public class UserPointVO {public UserPointVO(String username, String phone) {this.username = username;this.phone = phone;}private String username;private String phone;public String getUsername() {return username;}public void setUsername(String username) {this.username = username;}public String getPhone() {return phone;}public void setPhone(String phone) {this.phone = phone;}@Overridepublic boolean equals(Object o) {if (this == o) return true;if (o == null || getClass() != o.getClass()) return false;UserPointVO that = (UserPointVO) o;return Objects.equals(phone, that.phone);}@Overridepublic int hashCode() {return Objects.hash(phone);}
}

加入测试数据

@SpringBootTest
class XdclassRedisApplicationTests {@Autowiredprivate RedisTemplate redisTemplate;@Testvoid testData() {UserPointVO p1 = new UserPointVO("老王","13113");UserPointVO p2 = new UserPointVO("老A","324");UserPointVO p3 = new UserPointVO("老B","242");UserPointVO p4 = new UserPointVO("老C","542345");UserPointVO p5 = new UserPointVO("老D","235");UserPointVO p6 = new UserPointVO("老E","1245");UserPointVO p7 = new UserPointVO("老F","2356432");UserPointVO p8 = new UserPointVO("老G","532332");BoundZSetOperations<String, UserPointVO> operations = redisTemplate.boundZSetOps("point:rank:real");operations.add(p1,324);operations.add(p2,542);operations.add(p3,52);operations.add(p4,434);operations.add(p5,1123);operations.add(p6,64);operations.add(p7,765);operations.add(p8,8);}
}

接⼝开发

返回榜单-从⼤到⼩排序
查看这个⼈的排名,从⼤到⼩，0就是第⼀
给某个⽤户加积分
查看某个⽤户的积分

import net.xdclass.xdclassredis.model.VideoDO;
import net.xdclass.xdclassredis.util.JsonData;
import net.xdclass.xdclassredis.vo.UserPointVO;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.BoundZSetOperations;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;import java.util.List;
import java.util.Set;@RestController
@RequestMapping("api/v1/rank")
public class RankController {@Autowiredprivate RedisTemplate redisTemplate;private static final String DAILY_RANK_KEY = "video:rank:daily";/*** 返回全部榜单，从大到小* @return*/@RequestMapping("real_rank1")public JsonData realRank1() {BoundZSetOperations<String, UserPointVO> operations = redisTemplate.boundZSetOps("point:rank:real");Set<UserPointVO> set = operations.reverseRange(0, -1);return JsonData.buildSuccess(set);}/*** 返回全部榜单，从小到大* @return*/@RequestMapping("real_rank2")public JsonData realRank2() {BoundZSetOperations<String, UserPointVO> operations = redisTemplate.boundZSetOps("point:rank:real");Set<UserPointVO> set = operations.range(0, -1);return JsonData.buildSuccess(set);}/*** 返回全部榜单，从大到小,指定长度* @return*/@RequestMapping("real_rank3")public JsonData realRank3() {BoundZSetOperations<String, UserPointVO> operations = redisTemplate.boundZSetOps("point:rank:real");Set<UserPointVO> set = operations.reverseRange(0, 3);return JsonData.buildSuccess(set);}/*** 查看某个用户的排名* @param phone* @param name* @return*/@RequestMapping("find_myrank")public JsonData realMyRank(String phone,String name) {BoundZSetOperations<String, UserPointVO> operations = redisTemplate.boundZSetOps("point:rank:real");UserPointVO userPointVO = new UserPointVO(name,phone);long rank = operations.reverseRank(userPointVO);return JsonData.buildSuccess(++rank);}/*** 加积分* @param phone* @param name* @return*/@RequestMapping("uprank")public JsonData uprank(String phone,String name,int point) {BoundZSetOperations<String, UserPointVO> operations = redisTemplate.boundZSetOps("point:rank:real");UserPointVO userPointVO = new UserPointVO(name,phone);operations.incrementScore(userPointVO,point);Set<UserPointVO> set = operations.range(0, -1);return JsonData.buildSuccess(set);}/*** 查看个人的积分* @param phone* @param name* @return*/@RequestMapping("mypoint")public JsonData mypoint(String phone,String name) {BoundZSetOperations<String, UserPointVO> operations = redisTemplate.boundZSetOps("point:rank:real");UserPointVO userPointVO = new UserPointVO(name,phone);double score = operations.score(userPointVO);return JsonData.buildSuccess(score);}}

Redis(案例六：ZSet数据)相关推荐

2021年大数据Spark（四十一）：SparkStreaming实战案例六自定义输出 foreachRDD
目录 SparkStreaming实战案例六自定义输出-foreachRDD 需求注意: 代码实现 SparkStreaming实战案例六自定义输出-foreachRDD 需求对上述案例的结果 ...
19.2、Javaweb案例_Servlet代码抽取优化分页数据redis缓存优化分页数据展示
优化Servlet 目的减少Servlet的数量,现在是一个功能一个Servlet,将其优化为一个模块一个Servlet,相当于在数据库中一张表对应一个Servlet,在Servlet中提供不同的方 ...
Redis重点六：怎么保证redis挂掉之后重启数据可以恢复？
redis的持久化有哪几种方式?不同的持久化机制都有什么优缺点?持久化机制具体底层是如何实现的? redis如果仅仅只是将数据缓存在内存里面,如果redis宕机了,再重启,内存里的数据就全部都弄丢了啊 ...
redis的基本操作And数据持久化方式以及redis实现mybatis缓存
Redis 1.NoSql # NoSql(Not Only Sql),不仅仅是sql,泛指非关系型数据库 2.NoSql的诞生随着互联网web2.0网站的兴起,传统的关系型数据库在高并发和特大规模 ...
redis介绍命令性能数据及监控缓存穿透
上一章: linux安装部署redis&配置远程连接_傲娇的喵酱的博客-CSDN博客一.redis介绍 Redis是C语言写的,官方提供的数据为100000+的QPS(每秒查询率) Redi ...
springboot整合redis案例——点赞取消点赞
目录 springboot与缓存 JSR-107 Spring缓存抽象重要概念和缓存注解 springboot整合redis 案例一:Redis是实现点赞.取消点赞一.Redis 缓存设计及实现 ...
Redis-学习笔记06【Redis案例】
Java后端学习路线笔记汇总表[黑马程序员] Redis-学习笔记01[Redis环境搭建] Redis-学习笔记02[Redis命令操作] Redis-学习笔记03[Redis持久化] Redi ...
redis基础命令和数据操作命令学习笔记
redis基础命令和数据操作命令学习笔记基础命令安装成功后,redis的启动命令:先修改配置文件.将服务改成默认运行.然后以配置文件启动服务 redis-server config/redis-c ...
redis常用的五大数据类型和redis新增类型以及对应的命令
常用五大数据数据类型 1.1 String 类型 String类型是一个key对应一个value. String类型是二进制安全的,也就是Redis的string可以包含任务数据.比如jpg图片或者序 ...

Redis(案例六：ZSet数据)

案例实战之SortedSet⽤户积分实时榜单最佳实践

Redis(案例六：ZSet数据)相关推荐

最新文章

热门文章