游戏玩家积分排行榜 - 云数据库 Redis

云数据库Redis兼容开源Redis，本文通过简单的示例，为您演示通过云数据库Redis实现在线游戏中的积分排行榜功能。

环境说明


云产品	说明
ECS实例	操作系统为Ubuntu 16.04.6。网络类型为专有网络，且与Redis实例属于同一专有网络。
Redis实例	网络类型为专有网络，且与ECS实例属于同一专有网络。

说明如果Redis实例与ECS的专有网络不同，您可以更换Redis实例的专有网络，具体操作，请参见更换专有网络VPC或交换机；如果网络类型不同，解决方法请参见ECS实例与Redis实例的网络类型不同时如何连接。

操作步骤

设置Redis实例的白名单，保障ECS实例和Redis实例可以互通。
1. 获取ECS实例的内网IP地址。具体操作，请参见查询ECS实例的IP地址。
2. 将获取到的ECS内网IP地址添加至Redis实例的白名单中。具体操作，请参见设置IP白名单。
登录ECS实例。具体操作，请参见连接方式概述。

在ECS实例中，执行下述命令安装环境。

sudo apt-get update
sudo apt-get install openjdk-8-jdk
apt install maven

执行下述命令，下载并解压示例代码。

wget https://docs-aliyun.cn-hangzhou.oss.aliyun-inc.com/assets/attach/120287/cn_zh/1615470698355/source.tar.gz
tar xvf source.tar.gz && cd source

执行vim src/main/java/test/GameRankSample.java命令，按照要求修改示例代码中各参数的值。

说明执行命令后，系统将进入编辑界面，输入a可进入编辑模式。


参数	说明
String host	分别填入Redis实例的专有网络连接地址与端口号，关于如何获取连接地址和端口号，请参见查看连接地址。
port	分别填入Redis实例的专有网络连接地址与端口号，关于如何获取连接地址和端口号，请参见查看连接地址。
String authString	账号的密码（该账号需具备读写权限），根据选取账号的不同，密码的填写格式有一定区别。关于如何创建账号，请参见创建与管理账号。说明默认账号（即以实例ID命名的账号）：直接填写密码即可。新创建的账号：密码格式为`<user>:<password>`。例如自定义账号为testaccount，密码为Rp829dlwa，密码需填写为testaccount:Rp829dlwa。

按下Esc键退出编辑模式，输入:wq并按回车键保存配置并退出编辑界面。

执行下述命令，运行示例代码。

mvn clean package assembly:single -DskipTests
java -classpath target/demo-0.0.1-SNAPSHOT.jar test.GameRankSample

执行结果

示例代码注释

package test;

import java.util.ArrayList;
import java.util.List;
import java.util.Set;
import java.util.UUID;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.Tuple;

public class GameRankSample {

  static int TOTAL_SIZE = 20;

  public static void main(String[] args) {
    //连接地址，可通过Redis控制台获取
    String host = "r-gs50a75e1968****.redis.hangzhou.rds.aliyuncs.com";

    int port = 6379;
    Jedis jedis = new Jedis(host, port);
    try {
      //实例密码
      String authString = jedis.auth("Pass!123"); //password
      if (!authString.equals("OK")) {
        System.err.println("AUTH Failed: " + authString);
        return;
      }
      //Key（键）
      String key = "Game name: Keep Running, Alibaba Cloud!";
      //清除可能的已有数据
      jedis.del(key);
      //模拟生成若干个游戏玩家
      List<String> playerList = new ArrayList<String>();
      for (int i = 0; i < TOTAL_SIZE; ++i) {
        //为每个玩家随机生成一个ID
        playerList.add(UUID.randomUUID().toString());
      }
      System.out.println("Inputs all players ");
      //记录每个玩家的得分
      for (int i = 0; i < playerList.size(); i++) {
        //随机生成数字，模拟玩家的游戏得分
        int score = (int) (Math.random() * 5000);
        String member = playerList.get(i);
        System.out.println("Player ID:" + member + ", Player Score: " + score);
        //将玩家ID和分数添加到相应键的SortedSet中。
        jedis.zadd(key, score, member);
      }
      //输出打印全部玩家排行榜
      System.out.println();
      System.out.println("       " + key);
      System.out.println(" Ranking list of all players");
      //从对应key的SortedSet中获取已经排好序的玩家列表
      Set<Tuple> scoreList = jedis.zrevrangeWithScores(key, 0, -1);
      for (Tuple item : scoreList) {
        System.out.println(
          "Player ID:" +
          item.getElement() +
          ", Player Score:" +
          Double.valueOf(item.getScore()).intValue()
        );
      }
      //输出打印前五名玩家的信息
      System.out.println();
      System.out.println("       " + key);
      System.out.println("       Top players");
      scoreList = jedis.zrevrangeWithScores(key, 0, 4);
      for (Tuple item : scoreList) {
        System.out.println(
          "Player ID:" +
          item.getElement() +
          ", Player Score:" +
          Double.valueOf(item.getScore()).intValue()
        );
      }
      //输出打印特定玩家列表
      System.out.println();
      System.out.println("         " + key);
      System.out.println(" Players with scores from 1,000 to 2,000");
      //从对应key的SortedSet中获取已经积分在1000至2000的玩家列表
      scoreList = jedis.zrangeByScoreWithScores(key, 1000, 2000);
      for (Tuple item : scoreList) {
        System.out.println(
          "Player ID:" +
          item.getElement() +
          ", Player Score:" +
          Double.valueOf(item.getScore()).intValue()
        );
      }
    } catch (Exception e) {
      e.printStackTrace();
    } finally {
      jedis.quit();
      jedis.close();
    }
  }
}