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);
6. 实时排行榜特性
Redis 的 Sorted Set 能够以 O(log(N)) 的时间复杂度完成插入和删除操作，以 O(log(N) + M) 的时间复杂度完成范围操作（M 是范围内元素的数量）。这种特性使得它非常适合用于高并发环境下的排行榜应用。
7. 扩展功能
- 分页查询：使用
zRevRange结合起始和结束索引可以实现分页获取排行榜用户。 - 批量插入：如果有多个用户需要同时插入或更新分数，可以使用 Redis 的管道（pipeline）机制，提高操作效率。
- 持久化管理：定期将 Redis 中的数据同步回 MySQL，以防止数据丢失。
总结
通过 Redis 的 Sorted Set 实现实时排行榜，不仅操作简单、效率高，而且非常适合处理高并发的场景。将用户的分数与排名存储在 Redis 中，结合 MySQL 进行数据的持久化存储，可以在保证性能的同时确保数据的可靠性。