基于exZset实现分布式架构排行榜

代码示例

本方案需使用TairJedis（Tair自研）客户端。

1. 添加pom.xml配置。

           <dependency>
               <groupId>com.aliyun.tair</groupId>
               <artifactId>alibabacloud-tairjedis-sdk</artifactId>
               <version>5.3.1</version>
           </dependency>

2. 示例代码。

   import io.valkey.JedisPool;
   import io.valkey.JedisPoolConfig;
   import com.aliyun.tair.tairzset.*;
   
   public class DistributedLeaderBoardExample {
       // 配置实例连接地址、端口号、账号密码等信息。
       private static final int DEFAULT_CONNECTION_TIMEOUT = 5000;
       private static final int DEFAULT_SO_TIMEOUT = 2000;
       private static final String HOST = "<r-bp1mx0ydsivrbp****.redis.rds.aliyuncs.com>";
       private static final int PORT = 6379;
       private static final String PASSWORD = "<Pass****word>";
       private static final JedisPoolConfig config = new JedisPoolConfig();
   
       // 配置分布式排行榜信息。
       private static final int shardKeySize = 10;  // 底层子排行榜的数量。
       private static final int pageSize = 10;      // 排行榜每页包含的个数。
       private static final boolean reverse = true; // 本示例为从大到小排序。
       private static final boolean useZeroIndexForRank = false; // 本示例以1作为排名起点。
   
       public static void main(String[] args) {
           JedisPool jedisPool = new JedisPool(config, HOST, PORT, DEFAULT_CONNECTION_TIMEOUT,
                   DEFAULT_SO_TIMEOUT, PASSWORD, 0, null);
                   
           // 创建分布式架构排行榜，此次以Key名称distributed_leaderboard为例。
           DistributedLeaderBoard dlb = new DistributedLeaderBoard("distributed_leaderboard", jedisPool,
               shardKeySize, pageSize, reverse, useZeroIndexForRank);
   
           // 如果金牌数相同，按照银牌数排序，否则继续按照铜牌排序。
           //                    金牌 银牌 铜牌
           dlb.addMember("A",     32,  21, 16);
           dlb.addMember("D",     14,  4,  16);
           dlb.addMember("C",     20,  7,  12);
           dlb.addMember("B",     25,  29, 21);
           dlb.addMember("E",     13,  21, 18);
           dlb.addMember("F",     13,  17,  14);
   
           // 获取A的排名。
           dlb.rankFor("A"); // 1
           System.out.println(dlb.rankFor("A"));
   
           // 获取top3
           dlb.top(3);
           System.out.println(dlb.top(3));
           // [{"member":"A","score":"32#21#16","rank":1},
           // {"member":"B","score":"25#29#21","rank":2},
           // {"member":"C","score":"20#7#12","rank":3}]
       }
   }

   参数说明：

   参数	类型	说明
   shardKeySize	int	底层子排行榜的数量，默认为10，无法动态扩容，需要在业务初期做好规划。
   pageSize	int	排行榜每页包含的个数，默认为10。
   reverse	boolean	取值说明： false（默认）：按从小到大排序。 true：按从大到小排序。
   useZeroIndexForRank	boolean	取值说明： true（默认）：以0作为排名起点。 false：以1作为排名起点。

   更多操作请参见alibabacloud-tairjedis-sdk中的com.aliyun.tair.tairzset.DistributedLeaderBoard介绍。

附录：常规排行榜和分布式架构排行榜对比

在实现同一基本功能时，常规排行榜和分布式架构排行榜的实现方案如下：