java通过redis实现排行榜功能

本文涉及的产品
容器镜像服务 ACR,镜像仓库100个 不限时长
应用实时监控服务-可观测链路OpenTelemetry版,每月50GB免费额度
云原生网关 MSE Higress,422元/月
简介: java通过redis实现排行榜功能
  1. 数据存储规划
    在排行榜中,每个用户都会有一个唯一的标识(ID),同时需要记录该用户的积分(Score)。因此,我们可以将每个用户的ID作为有序集合中的一个元素,将用户的积分作为该元素的分数。

ZADD rank 1000 user1
ZADD rank 2000 user2
ZADD rank 3000 user3
上面的命令向名为rank的有序集合中添加了3个成员,分别是user1、user2和user3,他们的积分分别是1000、2000和3000。

  1. 排行查询操作
    使用Redis的ZREVRANGE命令,可以按照分数从高到低的顺序返回指定数量的元素,也就是排行榜中前N名的用户。

ZREVRANGE rank 0 2 WITHSCORES
上面的命令表示返回有序集合rank中排名前3的用户,同时返回他们对应的积分。执行该命令后,会返回以下结果:

1) "user3"
2) "3000"
3) "user2"
4) "2000"
5) "user1"
6) "1000"
其中,每个元素的前一个返回值是用户的ID,后一个返回值是用户的积分。

如果需要查询某个用户的排行信息,可以使用Redis的ZREVRANK命令,通过用户ID获取该用户的排名。注意,由于排行榜是从1开始计算的,而有序集合是从0开始计算的,因此需要将计算结果加1才能得到正确的排名。

ZREVRANK rank user2
上面的命令表示查询用户user2在排行榜中的排名。执行该命令后,会返回以下结果:

(integer) 1

  1. 排行更新操作
    使用Redis的ZINCRBY命令,可以增加指定用户的积分。如果用户不存在,该命令会自动创建一个新成员并设置初始积分为0,然后再增加积分。

ZINCRBY rank 1000 user1
上面的命令表示将用户user1的积分增加1000。执行该命令后,用户user1的积分变成了2000。

  1. 删减排行榜
    使用Redis的ZREMRANGEBYRANK命令,可以删除有序集合中指定排名范围的成员。例如,可以删除排行榜中前1000名之外的所有用户。

ZREMRANGEBYRANK rank 0 -1001
上面的命令表示删除有序集合rank中除了前1000名之外的所有成员。执行该命令后,排行榜中只剩下前1000名用户。

  1. 排行榜过期时间设置
    如果需要自动清除某个时间段内的排行榜,可以使用Redis的EXPIRE命令为有序集合设置过期时间。

EXPIRE rank 3600
上面的命令表示为有序集合rank设置一个过期时间为3600秒(即1小时)

Java 实现:

import redis.clients.jedis.Jedis;
import java.util.Map;
import java.util.LinkedHashMap;
import java.util.List;

public class RankList {
private static final String REDIS_HOST = "localhost";
private static final int REDIS_PORT = 6379;
private static final String RANK_KEY = "rank";

public static void main(String[] args) {
    // 初始化Jedis客户端
    Jedis jedis = new Jedis(REDIS_HOST, REDIS_PORT);

    // 添加用户信息
    addUser(jedis, "user1", 1000);
    addUser(jedis, "user2", 2000);
    addUser(jedis, "user3", 3000);

    // 查询排行榜前3名
    List<Map.Entry<String, Double>> topUsers = getTopUsers(jedis, 3);
    System.out.println("Rank\tUser ID\tScore");
    for (int i = 0; i < topUsers.size(); i++) {
        Map.Entry<String, Double> entry = topUsers.get(i);
        System.out.printf("%d\t%s\t%.0f\n", i + 1, entry.getKey(), entry.getValue());
    }

    // 更新用户积分
    incrementScore(jedis, "user1", 1000);

    // 查询指定用户的排名信息
    long rank = getUserRank(jedis, "user1");
    System.out.printf("User1's rank: %d\n", rank);

    // 删除排行榜前1000名之外的用户
    removeExtraUsers(jedis, 1000);

    // 关闭Jedis客户端
    jedis.close();
}

// 添加用户信息
public static void addUser(Jedis jedis, String userId, double score) {
    jedis.zadd(RANK_KEY, score, userId);
}

// 查询排行榜前N名用户
public static List<Map.Entry<String, Double>> getTopUsers(Jedis jedis, int limit) {
    return new LinkedHashMap<>(jedis.zrevrangeWithScores(RANK_KEY, 0, limit - 1)).entrySet().stream()
            .sorted(Map.Entry.<String, Double>comparingByValue().reversed())
            .toList();
}

// 更新用户积分
public static void incrementScore(Jedis jedis, String userId, double increment) {
    jedis.zincrby(RANK_KEY, increment, userId);
}

// 查询指定用户的排名
public static long getUserRank(Jedis jedis, String userId) {
    return jedis.zrevrank(RANK_KEY, userId);
}

// 删除排行榜前N名之外的用户
public static void removeExtraUsers(Jedis jedis, int limit) {
    long rank = jedis.zcard(RANK_KEY) - limit;
    if (rank > 0) {
        jedis.zremrangeByRank(RANK_KEY, 0, rank - 1);
    }
}

}

上面的代码中,首先定义了Redis服务器的地址和端口号等常量。然后通过Jedis客户端连接到Redis服务器,在Redis中添加用户信息、查询排行榜等操作。其中,addUser()方法用于添加用户信息,getTopUsers()方法用于查询排行榜前N名用户,incrementScore()方法用于更新用户积分,getUserRank()方法用于查询指定用户的排名,removeExtraUsers()方法用于删除排行榜中前N名之外的用户。

请注意,在上面的代码示例中,为了保证排行榜中元素的有序性,使用了LinkedHashMap来保存排行榜前N名用户的信息,并使用Java 16中的toList()方法将元素转换为列表形式输出。如果使用的是较早版本的Java,可以自行实现一个按照值排序的Comparator类,或者使用其他第三方库(如Guava等)来进行列表操作。

相关实践学习
基于Redis实现在线游戏积分排行榜
本场景将介绍如何基于Redis数据库实现在线游戏中的游戏玩家积分排行榜功能。
云数据库 Redis 版使用教程
云数据库Redis版是兼容Redis协议标准的、提供持久化的内存数据库服务,基于高可靠双机热备架构及可无缝扩展的集群架构,满足高读写性能场景及容量需弹性变配的业务需求。 产品详情:https://www.aliyun.com/product/kvstore &nbsp; &nbsp; ------------------------------------------------------------------------- 阿里云数据库体验:数据库上云实战 开发者云会免费提供一台带自建MySQL的源数据库&nbsp;ECS 实例和一台目标数据库&nbsp;RDS实例。跟着指引,您可以一步步实现将ECS自建数据库迁移到目标数据库RDS。 点击下方链接,领取免费ECS&amp;RDS资源,30分钟完成数据库上云实战!https://developer.aliyun.com/adc/scenario/51eefbd1894e42f6bb9acacadd3f9121?spm=a2c6h.13788135.J_3257954370.9.4ba85f24utseFl
目录
相关文章
|
29天前
|
安全 Java 测试技术
🎉Java零基础:全面解析枚举的强大功能
【10月更文挑战第19天】本文收录于「滚雪球学Java」专栏,专业攻坚指数级提升,希望能够助你一臂之力,帮你早日登顶实现财富自由🚀;同时,欢迎大家关注&&收藏&&订阅!持续更新中,up!up!up!!
104 60
|
17天前
|
Java
Java 8 引入的 Streams 功能强大,提供了一种简洁高效的处理数据集合的方式
Java 8 引入的 Streams 功能强大,提供了一种简洁高效的处理数据集合的方式。本文介绍了 Streams 的基本概念和使用方法,包括创建 Streams、中间操作和终端操作,并通过多个案例详细解析了过滤、映射、归并、排序、分组和并行处理等操作,帮助读者更好地理解和掌握这一重要特性。
25 2
|
18天前
|
存储 消息中间件 NoSQL
使用Java操作Redis数据类型的详解指南
通过使用Jedis库,可以在Java中方便地操作Redis的各种数据类型。本文详细介绍了字符串、哈希、列表、集合和有序集合的基本操作及其对应的Java实现。这些示例展示了如何使用Java与Redis进行交互,为开发高效的Redis客户端应用程序提供了基础。希望本文的指南能帮助您更好地理解和使用Redis,提升应用程序的性能和可靠性。
32 1
|
20天前
|
存储 NoSQL PHP
如何用Redis高效实现点赞功能?用Set?还是Bitmap?
在众多软件应用中,点赞功能几乎成为标配。本文从实际需求出发,探讨如何利用 Redis 的 `Set` 和 `Bitmap` 数据结构设计高效点赞系统,分析其优缺点,并提供 PHP 实现示例。通过对比两种方案,帮助开发者选择最适合的存储方式。
28 3
|
2月前
|
Java 程序员
在Java编程中,关键字不仅是简单的词汇,更是赋予代码强大功能的“魔法咒语”。
【10月更文挑战第13天】在Java编程中,关键字不仅是简单的词汇,更是赋予代码强大功能的“魔法咒语”。本文介绍了Java关键字的基本概念及其重要性,并通过定义类和对象、控制流程、访问修饰符等示例,展示了关键字的实际应用。掌握这些关键字,是成为优秀Java程序员的基础。
25 3
|
2月前
|
Java 数据安全/隐私保护
Java ffmpeg 实现视频加文字/图片水印功能
【10月更文挑战第22天】在 Java 中使用 FFmpeg 实现视频加文字或图片水印功能,需先安装 FFmpeg 并添加依赖(如 JavaCV)。通过构建 FFmpeg 命令行参数,使用 `drawtext` 滤镜添加文字水印,或使用 `overlay` 滤镜添加图片水印。示例代码展示了如何使用 JavaCV 实现文字水印。
|
2月前
|
Java
让星星⭐月亮告诉你,jdk1.8 Java函数式编程示例:Lambda函数/方法引用/4种内建函数式接口(功能性-/消费型/供给型/断言型)
本示例展示了Java中函数式接口的使用,包括自定义和内置的函数式接口。通过方法引用,实现对字符串操作如转换大写、数值转换等,并演示了Function、Consumer、Supplier及Predicate四种主要内置函数式接口的应用。
27 1
|
2月前
|
缓存 NoSQL Java
Java中redis面试题
Java中redis面试题
42 1
|
1月前
|
存储 NoSQL Java
Java 使用 Redis
10月更文挑战第22天
32 0