游戏设计之-排行榜处理

前言

我相信大部分人，乃至公司和团队在设计排行榜都考虑的是redis，zadd操作，不需要排序，维护获取，操作都极其简单；

无一例外我也是；

 

 在项目中运营了大量的模板，来处理各个木块的排行榜信息；

统一的会在晚上又一些结算处理；就牵涉一次性拉取，过滤，发放奖励，甚至还有删除操作；

同时为了节约运营陈本，定期还需要对redis里面无效数据进行删除，收缩操作；

 

 

目前redis已经达到6.55g，这只是其中一个平台运营部署；

运营过项目的都知道云redis的费用是非常高昂的；所以就需要定期做一些无用数据的删除操作； 

可是问题来了，随着运营时间的推移，每天早上总能看到如此的异常推送；

就问你揪心不？仔细一查才发现还是数据库相关的操作导致的卡主了；

于是下定决心对排行榜等相关功能进行调整；

削峰

1. 首先就是对数据库的一些删除操作，集中早上5-6点去处理他；这个时候在线玩家最少；处理一些垃圾数据最为合理；基本卡了也不会对玩家的感觉特别强烈反馈；

于是把原来处理的数据移除的代码调整为定时器创建异步任务在凌晨5-6点去处理；

2. 第二步就是为了避免玩家集体拉取数据，并对数据进行操作；考虑重构排行榜代码需求，

排行榜自定义实现

为了模拟排行榜实现的，

首先应该考虑，排行榜数据，既方便查找修改，又方便排序；

那么肯定需要考虑的是

一个map，用于存取和玩家相关积分数据；

一个list，用于排序积分；

首先我们来实现一个积分类

package org.wxd.lang.rank;

import lombok.Getter;
import lombok.Setter;
import lombok.experimental.Accessors;
import org.wxd.io.ObjectFactory;
import org.wxd.timer.TimeUtil;

import java.util.Comparator;
import java.util.Objects;

/**
 * 排行
 *
 * @author: Troy.Chen(無心道, 15388152619)
 * @version: 2022-12-08 21:27
 **/
@Getter
@Setter
@Accessors(chain = true)
public class RankScore implements Comparable<RankScore> {

    /** 正序 */
    public static final Comparator<RankScore> Sort = (o1, o2) -> {
        if (o1.score != o2.score) {
            return Double.compare(o1.score, o2.score);
        }

        if (o1.scoreTime != o2.scoreTime) {
            /**时间取值要倒叙*/
            return Long.compare(o2.scoreTime, o1.scoreTime);
        }

        return Long.compare(o1.uid, o2.uid);
    };

    /** 倒叙 */
    public static final Comparator<RankScore> BreSort = (o1, o2) -> {
        if (o1.score != o2.score) {
            return Double.compare(o1.score, o2.score);
        }

        if (o1.scoreTime != o2.scoreTime) {
            /**时间取值要倒叙*/
            return Long.compare(o2.scoreTime, o1.scoreTime);
        }

        return Long.compare(o1.uid, o2.uid);
    };

    private long uid;
    private double score;
    private long scoreTime;

    public RankScore setScore(double score) {
        this.score = score;
        this.scoreTime = TimeUtil.currentTimeMillis();
        return this;
    }

    @Override public int compareTo(RankScore o2) {
        return Sort.compare(this, o2);
    }

    public int scoreIntValue() {
        return (int) score;
    }

    public long scoreLongValue() {
        return (long) score;
    }

    @Override public boolean equals(Object o) {
        if (this == o) return true;
        if (o == null || getClass() != o.getClass()) return false;
        RankScore rankScore = (RankScore) o;
        return uid == rankScore.uid;
    }

    @Override public int hashCode() {
        return Objects.hash(uid);
    }

    @Override public String toString() {
        return ObjectFactory.stringBuilder(sb -> {
            sb.append(this.getClass().getSimpleName()).append("{");
            sb.append("u>).append(uid);
            sb.append(", score=").append(score);
            sb.append('}');
        });
    }
}