Redis 有序集合【实现排行榜】

使用 Redis 的 Sorted Set 数据结构可以非常高效地实现实时排行榜功能。Sorted Set 允许将元素按分数进行排序，同时支持插入、删除和查询操作，且这些操作的时间复杂度较低，非常适合处理高并发的场景。

实现思路

插入操作：当用户产生分数时，将用户 ID 和分数插入到 Redis 的 Sorted Set 中。
查询操作：根据用户分数在排行榜中的位置，获取某个用户的排名或获取前 N 名的用户列表。

1. 创建排行榜表结构

首先，在 MySQL 中创建一个存储用户和分数的表，以便持久化保存数据

CREATE TABLE user_scores (user_id INT PRIMARY KEY,score INT NOT NULL
);

2. 插入分数到排行榜

当用户获得分数时，将用户 ID 和分数插入到 Redis 的 Sorted Set 中。

<?php
function addScoreToLeaderboard($userId, $score) {$redis = new Redis();$redis->connect('127.0.0.1', 6379);// 将用户ID和分数插入到Sorted Set中$redis->zAdd('leaderboard', $score, $userId);// 更新MySQL中的持久化数据$db = new mysqli('localhost', 'username', 'password', 'database');$stmt = $db->prepare("INSERT INTO user_scores (user_id, score) VALUES (?, ?) ON DUPLICATE KEY UPDATE score = ?");$stmt->bind_param("iii", $userId, $score, $score);$stmt->execute();
}// 示例：将用户123的分数更新为500
addScoreToLeaderboard(123, 500);

3. 查询用户的排名

根据用户的分数，查询其在排行榜中的排名。Redis 的 zRevRank 命令返回的是从高到低的排名。

<?php
function getUserRank($userId) {$redis = new Redis();$redis->connect('127.0.0.1', 6379);// 获取用户的排名（Redis 的排名从0开始，所以加1）$rank = $redis->zRevRank('leaderboard', $userId);return $rank !== false ? $rank + 1 : null;
}// 示例：获取用户123的排名
$rank = getUserRank(123);
echo "User 123's rank: " . $rank . "\n";

4. 获取排行榜前 N 名

通过 Redis 的 zRevRange 命令获取排行榜前 N 名的用户。

<?php
function getTopNUsers($n) {$redis = new Redis();$redis->connect('127.0.0.1', 6379);// 获取前N名用户ID及其分数$topUsers = $redis->zRevRange('leaderboard', 0, $n - 1, true);return $topUsers;
}// 示例：获取排行榜前10名
$topUsers = getTopNUsers(10);
print_r($topUsers);

5. 更新分数和排名

如果用户的分数需要更新，可以直接通过 zAdd 命令更新 Redis 中的分数，排行榜会自动调整顺序。

<?php
function updateScore($userId, $newScore) {$redis = new Redis();$redis->connect('127.0.0.1', 6379);// 更新用户的分数$redis->zAdd('leaderboard', $newScore, $userId);// 更新MySQL中的持久化数据$db = new mysqli('localhost', 'username', 'password', 'database');$stmt = $db->prepare("UPDATE user_scores SET score = ? WHERE user_id = ?");$stmt->bind_param("ii", $newScore, $userId);$stmt->execute();
}// 示例：更新用户123的分数为600
updateScore(123, 600);