如何使用 Redis实现排行榜？

发表于 更新于 分类于 阅读次数： 本文字数： 5.2k 阅读时长 ≈ 5 分钟

你好，我是猿java。

排行榜是实际生活中很常见的一个概念，比如在某些平台上，我们可以根据一些指标，如关注量、点赞量、评论量等进行排行，以便了解平台中的热门内容和活跃用户。这篇文章，我们来分析如何用 Redis实现排行榜。

1. 为什么选择 Redis 的有序集合

首先要声明的是：我们将使用 Redis 的 有序集合（Sorted Sets） 数据结构来实现排行榜。那么，为什么要选择 Sorted Sets呢？

这是因为，Redis 的有序集合（ZSET）是一种结合了集合和排序的强大数据结构，每个成员都有一个分数（score），成员会根据分数进行自动排序。适用于排行榜场景。

  • 自动排序：根据分数自动排序，方便获取排名。
  • 快速操作：提供高效的添加、更新和查询操作，适合高并发场景。
  • 丰富的命令：支持多种排序和查询方式，如获取排名范围、分数范围等。

2. 基本操作

2.1 添加或更新用户分数 (ZADD)

使用 ZADD 命令可以添加新成员或更新已有成员的分数。

1
2
3
ZADD leaderboard 1000 "user1"
ZADD leaderboard 1500 "user2"
ZADD leaderboard 1200 "user3"

如果 user1 已存在，ZADD 会更新其分数为 1000。

2.2 获取排行榜前 N 名 (ZREVRANGE)

由于排行榜通常是按照分数从高到低排序，可以使用 ZREVRANGE 获取排名。

1
ZREVRANGE leaderboard 0 9 WITHSCORES

上面的命令获取分数最高的前 10 名用户及其分数。

2.3 获取指定用户的排名 (ZREVRANK)

获取某个用户在排行榜中的排名（排名从 0 开始）。

1
ZREVRANK leaderboard "user1"

如果 user1 的分数最高，返回 0。

2.4 获取用户的分数 (ZSCORE)

获取某个用户的当前分数。

1
ZSCORE leaderboard "user1"

2.5 获取分数在某个范围内的用户 (ZREVRANGEBYSCORE)

获取分数介于某个范围的用户列表。

1
ZREVRANGEBYSCORE leaderboard 1000 800 WITHSCORES

2.6 增加用户的分数 (ZINCRBY)

增加或减少某个用户的分数。

1
2
ZINCRBY leaderboard 200 "user1"  # 增加200分
ZINCRBY leaderboard -100 "user2"  # 减少100分

3. 举例说明

假设我们要创建一个游戏的积分排行榜，步骤如下：

3.1 添加用户分数

1
2
3
4
ZADD game_leaderboard 500 "alice"
ZADD game_leaderboard 750 "bob"
ZADD game_leaderboard 600 "carol"
ZADD game_leaderboard 800 "dave"

3.2 更新用户分数

用户 alice 玩得好，增加了300分：

1
ZINCRBY game_leaderboard 300 "alice"  # alice 的新分数为 800

3.3 获取前 3 名

1
ZREVRANGE game_leaderboard 0 2 WITHSCORES

返回：

1
2
3
4
5
6
1) "alice"
2) "800"
3) "dave"
4) "800"
5) "bob"
6) "750"

（注意：alice 和 dave 分数相同，可以根据具体需求决定如何处理同分情况）

3.4 获取 carol 的排名和分数

1
2
ZREVRANK game_leaderboard "carol"  # 返回 3 （排名从 0 开始）
ZSCORE game_leaderboard "carol"  # 返回 600

4. 高级用法

4.1 使用事务确保数据一致性

当需要同时更新多个数据时，可以使用 Redis 事务（MULTI / EXEC）或 Lua 脚本来确保操作的原子性。

4.2 过期时间管理

如果排行榜需要有时间限制（如每日排行榜），可以为对应的键设置过期时间：

1
EXPIRE game_leaderboard 86400  # 24小时后过期

4.3 分页获取排行榜

使用 ZREVRANGE 的偏移量和数量参数来实现分页。

获取第 11 到第 20 名：

1
ZREVRANGE game_leaderboard 10 19 WITHSCORES

4.4 多维排行榜

如果需要多个维度的排行榜（如每日、每周、总榜），可以使用不同的键或者使用 HASH 结构来管理。

1
2
3
ZADD leaderboard_daily:20240427 500 "alice"
ZADD leaderboard_weekly:20240421 3500 "alice"
ZADD leaderboard_total 3500 "alice"

5. 性能优化

  • 合理设置内存：根据预期的用户量和排行榜长度，合理配置 Redis 的内存。
  • 使用集群：对于大规模排行榜，可以使用 Redis 集群分片，提高并发处理能力。
  • 持久化策略：根据业务需求选择合适的持久化方式（RDB、AOF 或混合），确保数据安全。

6. 示例代码

为了更好地理解排行榜的实现，下面以 Java为了示例，展示如何使用 Redis实现排行榜功能。代码如下：

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
import redis.clients.jedis.Jedis;
import redis.clients.jedis.Tuple;

import java.util.Set;

public class RedisLeaderboard {

    private Jedis jedis;
    private String leaderboardKey;

    // 构造函数，初始化 Redis 连接和排行榜键
    public RedisLeaderboard(String host, int port, int db, String leaderboardKey) {
        this.jedis = new Jedis(host, port);
        this.jedis.select(db);
        this.leaderboardKey = leaderboardKey;
    }

    // 添加或更新用户分数
    public void addScore(String user, double score) {
        jedis.zadd(leaderboardKey, score, user);
    }

    // 获取排行榜前 N 名
    public Set<Tuple> getTopN(int n) {
        // ZREVRANGE 获取分数从高到低的排序
        return jedis.zrevrangeWithScores(leaderboardKey, 0, n - 1);
    }

    // 获取用户排名（排名从1开始）
    public Long getRank(String user) {
        Long rank = jedis.zrevrank(leaderboardKey, user);
        if (rank != null) {
            return rank + 1;
        }
        return null; // 用户不存在于排行榜中
    }

    // 获取用户分数
    public Double getScore(String user) {
        return jedis.zscore(leaderboardKey, user);
    }

    // 增加或减少用户分数
    public void incrementScore(String user, double increment) {
        jedis.zincrby(leaderboardKey, increment, user);
    }

    // 关闭 Redis 连接
    public void close() {
        if (jedis != null) {
            jedis.close();
        }
    }

    // 主方法示例使用
    public static void main(String[] args) {
        // 初始化排行榜
        RedisLeaderboard leaderboard = new RedisLeaderboard("localhost", 6379, 0, "game_leaderboard");

        try {
            // 添加用户分数
            leaderboard.addScore("alice", 500);
            leaderboard.addScore("bob", 750);
            leaderboard.addScore("carol", 600);
            leaderboard.addScore("dave", 800);

            // 更新分数，alice 增加300分
            leaderboard.incrementScore("alice", 300); // alice 的新分数为 800

            // 获取前3名
            Set<Tuple> top3 = leaderboard.getTopN(3);
            System.out.println("Top 3 用户及分数：");
            for (Tuple tuple : top3) {
                System.out.println("用户: " + tuple.getElement() + ", 分数: " + tuple.getScore());
            }

            // 获取某个用户的排名和分数
            String user = "carol";
            Long rank = leaderboard.getRank(user);
            Double score = leaderboard.getScore(user);
            if (rank != null && score != null) {
                System.out.println(user + " 的排名: " + rank + ", 分数: " + score);
            } else {
                System.out.println(user + " 不存在于排行榜中。");
            }

        } finally {
            // 关闭连接
            leaderboard.close();
        }
    }
}

代码说明

类 RedisLeaderboard 封装了与 Redis 交互的所有方法：

  • 构造函数：初始化 Redis 连接，选择数据库 (db) 并设置排行榜的键 (leaderboardKey)。
  • addScore ：使用 ZADD 命令添加或更新用户的分数。
  • getTopN ：使用 ZREVRANGE 命令获取分数最高的前 N 名用户及其分数。
  • getRank ：使用 ZREVRANK 命令获取用户的排名，排名从 1 开始。
  • getScore ：使用 ZSCORE 命令获取用户的当前分数。
  • incrementScore ：使用 ZINCRBY 命令增加或减少用户的分数。
  • close ：关闭 Redis 连接，释放资源。

运行结果

1
2
3
4
5
Top 3 用户及分数：
用户: alice, 分数: 800.0
用户: dave, 分数: 800.0
用户: bob, 分数: 750.0
carol 的排名: 4, 分数: 600.0

7. 注意事项

  • 分数类型：Redis 的 ZSET 支持浮点数分数，可以根据需要选择合适的精度。
  • 唯一性：ZSET 中成员是唯一的，重复添加会更新分数。
  • 内存消耗：随着成员数量的增加，ZSET 会占用更多内存，需监控 Redis 的内存使用情况。

通过以上步骤和示例，你可以快速利用 Redis 有序集合实现高效的排行榜系统，适用于游戏积分、社交平台排名、销售数据排行等多种场景。

8. 总结

本文，我们通过使用 Redis的有序集合，实现了一个简单的排行榜系统，另外，我们还延伸了有序集合更多的高级用法以及需要注意的事项。

可以说，Redis 的有序集合在实际工作中是一个被高频使用的数据结构，因此我们需要对它有一定的了解和掌握。

9. 学习交流

如果你觉得文章有帮助，请帮忙转发给更多的好友，或关注公众号：猿java，持续输出硬核文章。

drawing