Java 操作 Redis ZSet：实现排行榜功能的完整代码示例

在现代应用中，排行榜功能是常见需求，如游戏得分排名、用户积分榜等。Redis的有序集合（ZSet）是理想选择，因为它支持基于分数的自动排序。本文将逐步指导你使用Java操作Redis ZSet，实现一个完整的排行榜系统。文章基于Jedis客户端库（一个流行的Java Redis库），确保代码简洁、可运行。

1. 准备工作

在开始前，确保环境已配置：

• 安装Redis服务器（版本5.0+）。
• Java开发环境（JDK 11+）。
• 添加Jedis依赖到项目（Maven示例）：

<dependency>
    <groupId>redis.clients</groupId>
    <artifactId>jedis</artifactId>
    <version>4.3.0</version>
</dependency>

2. Redis ZSet核心概念

ZSet存储成员（member）和分数（score），成员唯一，分数用于排序。排序规则基于分数值，分数高的排名靠前。数学上，排序可表示为： $$ \text{rank}(i) < \text{rank}(j) \quad \text{当} \quad s_i > s_j $$ 其中 $s_i$ 是成员 $i$ 的分数，$\text{rank}(i)$ 是其排名。Redis支持ZADD添加成员、ZRANGE获取排名等命令。

3. 逐步实现排行榜功能

下面分步实现核心操作，包括添加分数、获取排行榜和更新排名。

步骤1: 连接Redis 使用Jedis建立连接：

import redis.clients.jedis.Jedis;

public class RedisLeaderboard {
    private Jedis jedis;

    public RedisLeaderboard(String host, int port) {
        jedis = new Jedis(host, port); // 连接Redis
        System.out.println("Connected to Redis");
    }
}

步骤2: 添加成员分数 向ZSet添加成员及其分数：

public void addScore(String member, double score) {
    jedis.zadd("leaderboard", score, member); // 使用ZADD命令
    System.out.println("Added " + member + " with score: " + score);
}

步骤3: 获取排行榜 获取前N名成员（降序排列，分数高者在前）：

import java.util.Set;

public Set<String> getTopPlayers(int n) {
    // ZREVRANGE获取降序排名，0到n-1
    return jedis.zrevrange("leaderboard", 0, n - 1);
}

步骤4: 更新分数和获取排名 支持增量更新分数和查询特定成员排名：

public void updateScore(String member, double increment) {
    jedis.zincrby("leaderboard", increment, member); // 增加分数
}

public Long getRank(String member) {
    // ZREVRANK获取降序排名（0为最高）
    return jedis.zrevrank("leaderboard", member);
}

4. 完整代码示例

以下是完整的Java类，包含所有功能，可直接运行：

import redis.clients.jedis.Jedis;
import java.util.Set;

public class RedisLeaderboard {
    private Jedis jedis;
    private static final String KEY = "leaderboard";

    public RedisLeaderboard(String host, int port) {
        jedis = new Jedis(host, port);
        System.out.println("Connected to Redis");
    }

    public void addScore(String member, double score) {
        jedis.zadd(KEY, score, member);
        System.out.println("Added: " + member + " (Score: " + score + ")");
    }

    public void updateScore(String member, double increment) {
        jedis.zincrby(KEY, increment, member);
        System.out.println("Updated: " + member + " (+" + increment + ")");
    }

    public Set<String> getTopPlayers(int n) {
        return jedis.zrevrange(KEY, 0, n - 1);
    }

    public Long getRank(String member) {
        return jedis.zrevrank(KEY, member);
    }

    public static void main(String[] args) {
        RedisLeaderboard leaderboard = new RedisLeaderboard("localhost", 6379);
        
        // 添加初始分数
        leaderboard.addScore("Player1", 100.0);
        leaderboard.addScore("Player2", 150.0);
        leaderboard.addScore("Player3", 80.0);
        
        // 更新分数
        leaderboard.updateScore("Player1", 30.0); // Player1新分数130.0
        
        // 获取前2名
        Set<String> topPlayers = leaderboard.getTopPlayers(2);
        System.out.println("Top 2 Players: " + topPlayers); // 输出: [Player2, Player1]
        
        // 获取特定成员排名
        Long rank = leaderboard.getRank("Player3");
        System.out.println("Player3 Rank: " + (rank != null ? rank + 1 : "N/A")); // 排名从1开始
    }
}

5. 运行与测试

• 编译运行：javac RedisLeaderboard.java && java RedisLeaderboard
• 预期输出：

  Connected to Redis
  Added: Player1 (Score: 100.0)
  Added: Player2 (Score: 150.0)
  Added: Player3 (Score: 80.0)
  Updated: Player1 (+30.0)
  Top 2 Players: [Player2, Player1]
  Player3 Rank: 3
  

• 验证：使用Redis CLI检查数据：ZREVRANGE leaderboard 0 -1 WITHSCORES

6. 总结

通过Redis ZSet实现排行榜，具有天然排序优势，避免了手动排序的开销。本文代码覆盖了核心场景：

• 优点：代码简洁（少于100行），支持动态更新和实时查询。
• 注意事项：确保Redis服务器运行；在高并发场景，使用Jedis连接池优化性能。
• 扩展：可添加功能如时间范围排行（使用ZRANGEBYSCORE）。

这个实现基于Java标准库，无外部依赖，适合任何Java项目。如需处理大规模数据，可结合Redis集群。