数据库
首页 > 数据库> > 基于Redis的Zset实现用户n分钟内的广告奖励总数——滑动窗口问题

基于Redis的Zset实现用户n分钟内的广告奖励总数——滑动窗口问题

作者:互联网

1、场景

  最近在做用户拉灰策略,需要统计用户在n分钟之内获得的广告奖励总数,如果超过阈值则拉灰,其中n和阈值都支持配置。

2、方案分析

  获得用户任意时间段内的奖励值是一个典型的滑动窗口问题,这里我们要明确几点:

    (1)广告行为是非高频行为,因为一个广告的市场一般在15-30之间

    (2)因为作弊用户都是在短时间内获得高额奖励来实现刷钱行为,所以针对这种情况,我们只判断用户在最近一个小时内的数据

  基于以上两点考虑,我们考虑使用Redis的zset,以奖励gold作为zset的member,时间作为score,这样就能以时间为range进行查找,但是因为member如果重复会覆盖,所以针对menmber做一下处理:

    member = "gold-random",random取0-1000000之间的随机值,这样冲突的概率为百万分之一。

    另外还要考虑性能问题,尽量在一次Redis请求内完成设置值,设置有效时间,根据范围查询区间奖励,所以使用lua。

private  int miniteGoldLimitGray(long userId,EcpmEvent ecpmEvent,String ocpcPam,String osPam,JSONObject object){
        if (object.getBooleanValue("switch")) {
            List<String> keyList = new ArrayList<>();
            keyList.add(RedisConstants.getMiniteGold(userId));
            List<String> valueList = new ArrayList<>();
            long now = System.currentTimeMillis(); //score
            valueList.add(now+"");
            String gold = ecpmEvent.getGold()+"-"+new Random().nextInt(1000000);  //member
            valueList.add(gold);
            valueList.add(RedisConstants.EXPIRE_ONE_HOUR+""); //过期时间
            long start = now - object.getIntValue("startTime") * 60 * 1000;
            valueList.add(start+"");
            valueList.add((now + 1000)+""); //查询时间范围

            Object result = jedisClusterClient.eval(ShuaConstants.LUA_ECPM,keyList,valueList);
            String reStr = result.toString();
            String[] arr = reStr.substring(1,reStr.length()-1).replaceAll(" ","").split(",");
            int total = 0;
            for (String item : arr){
                String[] itemArr = item.split("-");
                total += Integer.parseInt(itemArr[0]);
            }

            if (total >= object.getJSONObject(ocpcPam).getIntValue(osPam)) {
                log.error("minite gold gray,user:{},total:{}", userId, total);
                return 3;
            }
        }
        return 0;
    }

  lua脚本:

public static final String LUA_ECPM = "redis.call('zadd',KEYS[1],ARGV[1],ARGV[2]);redis.call('expire',KEYS[1],ARGV[3]);return redis.call('zrangeByScore',KEYS[1],ARGV[4],ARGV[5])";

 

标签:String,Zset,Redis,ARGV,add,valueList,滑动,gold,total
来源: https://www.cnblogs.com/jing-yi/p/15758615.html