脚本之家 服务器常用软件
快捷导航
您的位置：首页 → 数据库 → Redis → redis实现排行榜功能

手把手教你使用redis实现排行榜功能

 更新时间：2023年04月14日 10:58:53   作者：Java是最nb的语言  
使用Redis中有序集合的特性来实现排行榜是又好又快的选择,一般排行榜都是有实效性的,比如“用户积分榜”,下面这篇文章主要给大家介绍了关于使用redis实现排行榜功能的相关资料,需要的朋友可以参考下

一、需求背景

最近项目需要做排行榜功能，实现员工邀请用户注册排行榜，要求是实时更新，查询要快。员工所属支行、二级行、省行，界面要根据条件显示排名数据。效果如下图所示：

原型图展示比较随意，用excel随便写了一下，凑合着看。

二、实现思路  

1、利用数据库

建一张统计表，字段包括：邀请人、邀请人所属支行、邀请人所属二级行、被邀请人、注册时间等关键信息，用于sql统计排名，根据条件使用group by相关字段，比较简单，这个大家应该清楚。

数据量小，统计效率还可以。但是支行下有十几万员工，一个员工邀请10个就百万数据，如果更多，数据就更大了，统计效率不高。下面重点讨论用第二种方式实现。

2、利用redis

我们都知道redis基于内存实现的，查询效率极高，且支持多种数据类型，其中zset是本次实现功能的关键。

  • ZSet也是String类型元素的集合，且不允许重复的成员；
  • 不同的是每个元素都会关联一个double类型的分数，刚好也是我们需要的邀请用户数；
  • 通过分数来为集合中的成员进行排序。ZSet的成员是唯一的，但分数（score）却可以重复；

基于上面的特性，满足我们本次的需求。好了，说了一大堆废话，下面将进入正题。

首先，捋一下查询条件，根据前面的效果图，可以看出有以下几种情况：

  1. 二级行的全部排名以及日周月榜排名
  2. 支行在省行的全部排名以及日周月榜排名
  3. 支行在二级行的全部排名以及日周月榜排名
  4. 员工在省行的全部排名以及日周月榜排名
  5. 员工在二级行的全部排名以及日周月榜排名
  6. 员工在支行的全部排名以及日周月榜排名

基于redis的Zset函数incrementScore，我们很快就能发现，其实实现各个排名，只要把key规定好即可，例如：

  • 员工在省行的全部排名key，可以设置为 rank:employee:省行
  • 员工在省行的日排行榜key，可以设置为 rank:emploee:省行:当天日期

下面我们来实现其中的上面的两个排行：

String key = "rank:employee:广东省";
redisTemplate.opsForZSet().incrementScore(key, "张三", 10);
redisTemplate.opsForZSet().incrementScore(key, "李四", 8);
redisTemplate.opsForZSet().incrementScore(key, "王五", 5);

执行完后，redis会保存为如下数据：

 这样的话，有了上面的数据，可以用redis的提供的函数把排行榜查出来，代码如下：

String key = "rank:employee:广东省";
Set<ZSetOperations.TypedTuple<String>> set = redisTemplate.opsForZSet().reverseRangeWithScores(key, 0, -1);
JSONArray jsonArray = JSONObject.parseArray(JSONObject.toJSONString(set));
for(int i = 0, size = jsonArray.size(); i < size; i++) {
    JSONObject o = JSONObject.parseObject(jsonArray.get(i).toString());
    System.out.println("员工：" + o.getString("value") + ", 邀请人数：" + o.getLongValue("score"));
}

reverseRangeWithScores方法接收三个参数，第一个是key，后面两个是分页查询，起始是从0开始，-1表示全部，如果设置为0，4，那么就是查询前5条记录，查出结果如下：

以上就实现了员工在省行的排名。类似的，员工要实现在省行的日榜，代码如下：

String key = "rank:employee:广东省:2022-09-01";
redisTemplate.opsForZSet().incrementScore(key, "张三", 10);
redisTemplate.opsForZSet().incrementScore(key, "李四", 8);
redisTemplate.opsForZSet().incrementScore(key, "王五", 5);

 执行完后，redis会保存为如下数据（这里我多设置了前一天的数据）：

一样的，用 reverseRangeWithScores方法可以把上面的结果查出来。

至于周榜、月榜，可以把每一天的数据累加起来，再做个排名，redis已经帮我们实现了这个功能，代码如下：

Date date = DateUtil.date();
//获取本周的第一天
DateTime beginOfWeek = DateUtil.beginOfWeek(date);
//到今天一共有几天
long diffDay = DateUtil.between(date, beginOfWeek, DateUnit.DAY) + 1;
 
List<String> keys = new ArrayList<>();
for(int i = 0; i < diffDay; i++) {
    //把需要查询的天数放一起
    keys.add("rank:employee:广东省:" + DateUtil.formatDate(DateUtil.offsetDay(beginOfWeek, i)));
}
 
//redis使用unionAndStore做合并，将结果集放在另一个的key，也就是第三个参数
redisTemplate.opsForZSet().unionAndStore("weekRank", keys, "employeeRankWeek");
 
//查询结果集用employeeRankWeek这个key
Set<ZSetOperations.TypedTuple<String>> set = redisTemplate.opsForZSet().reverseRangeWithScores("employeeRankWeek", 0, -1);
JSONArray jsonArray = JSONObject.parseArray(JSONObject.toJSONString(set));
for(int i = 0, size = jsonArray.size(); i < size; i++) {
    JSONObject o = JSONObject.parseObject(jsonArray.get(i).toString());
    System.out.println("员工：" + o.getString("value") + ", 本周邀请人数：" + o.getLongValue("score"));
}

注意代码里面说的，redis会把结果合并到另一个key，在redis上也可以看到，如下图：

查出来的结果如下图：

其实我们会发现，本周榜、本月榜无需保存每一天的数据，只要把key设置为本周或本月的第一天就可以，因为添加数据的那一刻就知道是哪一周或哪月了。

例如：key = rank:employee:广东省:2022-08-29，8月29日是本周的第一天，无论你在接下来一周内邀请多少人，都是在本周内完成的，在这个基础上累加邀请数量即可。本月榜的逻辑也是一样。

查询的时候，获取当前时间本周或本月的第一天，就可以实现本周、本月排行了。

String key = "rank:employee:广东省";
Date date = DateUtil.date();
 
String week = DateUtil.formatDate(DateUtil.beginOfWeek(date));
String month = DateUtil.formatDate(DateUtil.beginOfMonth(date));
 
//周榜
redisTemplate.opsForZSet().incrementScore(key+":week:"+week, "张三", 17);
//月榜
redisTemplate.opsForZSet().incrementScore(key+":month:"+month, "张三", 17);

当然了，如果要查询历史的排行，这种设计就满足不了了，还是要保存每天的数据才行。

总结

到此这篇关于使用redis实现排行榜功能的文章就介绍到这了,更多相关redis实现排行榜功能内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！

您可能感兴趣的文章:

相关文章

  • Redis实现限流器的三种方法(小结)

    Redis实现限流器的三种方法(小结)

    本文主要介绍了Redis实现限流器的三种方法，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
    2022-05-05
  • Redis生成分布式系统全局唯一ID的实现

    Redis生成分布式系统全局唯一ID的实现

    在互联网系统中，并发越大的系统，数据就越大，数据越大就越需要分布式，本文主要介绍了Redis生成分布式系统全局唯一ID的实现，感兴趣的可以了解一下
    2021-10-10
  • Redis读写分离搭建的完整步骤

    Redis读写分离搭建的完整步骤

    为满足读多写少的业务场景.最大化节约用户成本.云数据库Redis版推出了读写分离规格,为用户提供透明、高可用、高性能、高灵活的读写分离服务,这篇文章主要给大家介绍了关于Redis读写分离搭建的相关资料,需要的朋友可以参考下
    2021-09-09
  • Redis全文搜索教程之创建索引并关联源数据的教程

    Redis全文搜索教程之创建索引并关联源数据的教程

    RediSearch提供了一种简单快速的方法对 hash 或者 json 类型数据的任何字段建立二级索引，然后就可以对被索引的 hash 或者 json 类型数据字段进行搜索和聚合操作，这篇文章主要介绍了Redis全文搜索教程之创建索引并关联源数据,需要的朋友可以参考下
    2023-12-12
  • Redis中一些最常见的面试问题总结

    Redis中一些最常见的面试问题总结

    Redis在互联网技术存储方面使用如此广泛，几乎所有的后端技术面试官都要在Redis的使用和原理方面对小伙伴们进行各种刁难。下面这篇文章主要给大家总结介绍了关于Redis中一些最常见的面试问题，需要的朋友可以参考下
    2018-09-09
  • Redis RDB技术底层原理详解

    Redis RDB技术底层原理详解

    为了使Redis在重启之后仍能保证数据不丢失，需要将数据从内存中以某种形式同步到硬盘中，这一过程就是持久化，本文重点给大家介绍Redis RDB技术底层原理实现方法，一起看看吧
    2021-09-09
  • 详解redis desktop manager安装及连接方式

    详解redis desktop manager安装及连接方式

    这篇文章主要介绍了redis desktop manager安装及连接方式，本文图文并茂给大家介绍的非常详细，具有一定的参考借鉴价值,需要的朋友可以参考下
    2019-09-09
  • redis不能访问本机真实ip地址的解决方案

    redis不能访问本机真实ip地址的解决方案

    这篇文章主要介绍了redis不能访问本机真实ip地址的解决方案，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教
    2021-07-07
  • 如何使用Redis实现电商系统的库存扣减

    如何使用Redis实现电商系统的库存扣减

    在日常开发中有很多地方都有类似扣减库存的操作，本文主要介绍了如何使用Redis实现电商系统的库存扣减，具有一定的参考价值，感兴趣的可以了解一下
    2022-01-01
  • Redis如何一键部署脚本

    Redis如何一键部署脚本

    这篇文章主要介绍了Redis如何一键部署脚本，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
    2021-04-04

最新评论