使用Redis实现实时排行榜的示例
更新时间：2025年04月21日 08:33:45 作者：库库林_沙琪马
为了实现一个实时排行榜系统,我们可以使用Redis的有序集合,本文主要介绍了使用Redis实现实时排行榜的示例,具有一定的参考价值,感兴趣的可以了解一下
为了实现一个实时排行榜系统，我们可以使用Redis的有序集合（ZSet），其底层通常是使用跳跃表实现的。有序集合允许我们按照分数（score）对成员（member）进行排序，因此非常适合用来实现排行榜。本文首先介绍有序集合及其底层数据结构——跳表，然后使用Python和Redis结合，展示一个简单的排行榜系统。
一、ZSet 概述
1.1 ZSet 介绍
实现一个排行榜，很多人可能首先想到的是使用MySQL的order by来排序。然而，当数据量达到百万级别时，使用数据库排序的代价是很大的。因此，Redis的有序集合（ZSet）成为了一个更好的选择。
ZSet（Sorted Set）的特点如下：
- 唯一性：集合内的元素（成员）是唯一的。
- 有序性：与普通Set的无序性不同，ZSet的成员是“有序的”，这种有序性是基于成员所关联的“分数”（score）进行排序的，分数是浮点类型。
1.2 Zset 底层原理
ZSet 是Redis中的一种复杂数据结构，它在Set的基础上增加了一个权重参数score，使得集合中的元素能按score进行有序排列。
ZSet的底层实现通常有两种数据结构：
- 当元素数量较少或元素长度较短时，采用压缩列表（ziplist）。
- 当元素数量达到一定量或者元素长度超过一定限制时，采用跳跃表（skiplist）。
跳表（skiplist）具有多层链表结构，查询、插入和删除操作的平均时间复杂度均为O(log n)。
1.3 ZSet 主要操作命令
ZADD key score member：将元素及其分数添加到有序集合中。ZINCRBY key increment member：为有序集合中的元素增加或减少分数。ZRANGE key start stop [WITHSCORES]：获取有序集合中分数从小到大的排名在指定范围内的成员。ZREVRANGE key start stop [WITHSCORES]：获取有序集合中分数从大到小的排名在指定范围内的成员。ZRANK key member：获取成员在有序集合中的排名（从小到大的排名，排名从0开始）。ZREVRANK key member：获取成员在有序集合中的排名（从大到小的排名，排名从0开始）。ZSCORE key member：获取成员在有序集合中的分数。ZCARD key：获取有序集合的基数，即成员数量。
二、使用 Redis 和 Python 实现实时排行榜
下面是一个使用Python的redis库来操作ZSet并实现实时排行榜的示例。
2.1 安装所需的库
首先确保已经安装redis库：
pip install redis
2.2 初始化RedisLeaderboard类
接下来，我们实现一个RedisLeaderboard类来管理排行榜：
import redis
from flask import Flask, render_template
import sys
app = Flask(__name__)
# Initialize Redis connection with error handling
try:
r = redis.Redis(
host='192.168.88.139',
password='123456',
port=6379,
db=0,
socket_connect_timeout=3, # 3 seconds timeout
decode_responses=True # Automatically decode responses to UTF-8
)
# Test the connection
r.ping()
print("成功连接Redis", file=sys.stderr)
except redis.ConnectionError as e:
print(f"连接Redis失败: {e}", file=sys.stderr)
r = None # Set to None so we can check later
@app.route('/')
def leaderboard():
if r is None:
return render_template('error.html',
message="Redis server is not available"), 503
try:
top_10 = get_top_n(10)
return render_template('leaderboard.html', leaderboard=top_10)
except redis.RedisError as e:
return render_template('error.html',
message=f"Redis error: {str(e)}"), 500
def get_top_n(n):
try:
top_n = r.zrevrange("game_leaderboard", 0, n - 1, withscores=True)
leaderboard = []
for rank, (user_id, score) in enumerate(top_n, start=1):
leaderboard.append({
"rank": rank,
"user_id": user_id, # No need to decode with decode_responses=True
"score": float(score)
})
return leaderboard
except redis.RedisError as e:
print(f"Redis operation failed: {e}", file=sys.stderr)
raise # Re-raise the exception to be handled by the route
if __name__ == '__main__':
app.run(debug=True)
2.3 案例数据
import redis
r = redis.Redis(host='192.168.88.139', password='123456', port=6379, db=0)
def add_score(user_id, score):
r.zadd("game_leaderboard", {user_id: score})
def update_score(user_id, score):
r.zincrby("game_leaderboard", score, user_id)
def get_top_n(n):
top_n = r.zrevrange("game_leaderboard", 0, n - 1, withscores=True)
leaderboard = []
for rank, (user_id, score) in enumerate(top_n, start=1):
leaderboard.append({
"rank": rank,
"user_id": user_id.decode("utf-8"),
"score": score
})
return leaderboard
def get_user_rank_and_score(user_id):
rank = r.zrevrank("game_leaderboard", user_id)
if rank is not None:
rank += 1
score = r.zscore("game_leaderboard", user_id)
return rank, score
if __name__ == '__main__':
# 添加初始得分
add_score('user1', 100)
add_score('user2', 150)
add_score('user3', 50)
# 更新得分（加分操作），如果用户不存在，会将其得分初始化为该值
update_score('user1', 30)
update_score('user2', 20)
update_score('user3', -10)
# 获取前2名的用户
top_2 = get_top_n(2)
for entry in top_2:
print(f"Rank {entry['rank']}: UserID: {entry['user_id']} with score {entry['score']}")
# 获取特定用户的排名和得分
rank, score = get_user_rank_and_score('user1')
if rank is not None and score is not None:
print(f"User user1 is ranked {rank} with a score of {score}.")
else:
print("User user1 is not found in the leaderboard.")
2.4 前端
需要创建一个templates文件夹，并在其中存放leaderboard.html文件：
<!DOCTYPE html>
<html lang="en">
<head>
<meta charset="UTF-8">
<meta name="viewport" content="width=device-width, initial-scale=1.0">
<title>Leaderboard</title>
<style>
table {
width: 100%;
border-collapse: collapse;
}
th, td {
border: 1px solid black;
padding: 8px;
text-align: left;
}
</style>
</head>
<body>
<h1>Leaderboard</h1>
<table>
<thead>
<tr>
<th>Rank</th>
<th>User ID</th>
<th>Score</th>
</tr>
</thead>
<tbody>
{% for entry in leaderboard %}
<tr>
<td>{{ entry.rank }}</td>
<td>{{ entry.user_id }}</td>
<td>{{ entry.score }}</td>
</tr>
{% endfor %}
</tbody>
</table>
</body>
</html>
三、结论
Redis的有序集合(ZSet)由于其高效的插入、删除、查询及排序操作，是实现实时排行榜的理想选择。跳表作为ZSet的底层数据结构之一，保证了这些操作的时间复杂度为O(log n)。结合Python的redis库，可以快速实现一个功能强大、高效的实时排行榜系统。
这种排行榜实现方案非常适合用于在线游戏、社交平台等各种应用场景。
到此这篇关于使用Redis实现实时排行榜的示例的文章就介绍到这了,更多相关Redis 实时排行榜内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！
相关文章
本文主要介绍了浅谈Redis内存回收策略，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧2023-06-06
这篇文章主要介绍了Redis 实现队列原理的实例详解的相关资料,希望通过本文能帮助到大家，需要的朋友可以参考下2017-09-09
这篇文章主要介绍了Redis实现分布式锁全解析之从原理到实践过程,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教2025-05-05
Redis 是完全开源免费的,遵守BSD协议,是一个高性能(NOSQL)的key-value数据库,Redis是一个开源的使用ANSI C语言编写、支持网络、可基于内存亦可持久化的日志型、Key-Value数据库,并提供多种语言的API,本文给大家介绍Redis介绍及6.2.x版本安装,感兴趣的朋友一起看看吧2025-06-06
Redis缓存预热与缓存穿透是Redis缓存使用中的两个重要概念,文章首先介绍了Redis缓存预热和缓存穿透的基本概念,然后详细阐述了它们的产生原因和解决方案,感兴趣的可以了解一下2023-12-12
Redis序列化设置以及jetcache连接Redis序列化的设置过程
这篇文章主要介绍了Redis序列化设置以及jetcache连接Redis序列化的设置过程,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教2023-12-12
这篇文章主要介绍了Redis 哈希Hash底层数据结构详解的相关资料,需要的朋友可以参考下2022-08-08
使用Redis中有序集合的特性来实现排行榜是又好又快的选择,一般排行榜都是有实效性的,比如“用户积分榜”,下面这篇文章主要给大家介绍了关于使用redis实现排行榜功能的相关资料,需要的朋友可以参考下2023-04-04
这篇文章主要介绍了排查Redis大key的方法,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面跟着小编来一起学习学习吧2024-08-08
Redis修改密码需注意：命令行设置为临时,配置文件需正确重启,先修改redis.windows.conf中的requirepass,再用redis-server.exe redis.windows.conf启动服务,避免密码失效2025-07-07
最新评论