日本免费高清视频-国产福利视频导航-黄色在线播放国产-天天操天天操天天操天天操|www.shdianci.com

學無先后,達者為師

網站首頁 編程語言 正文

基于Redis?zSet實現滑動窗口對短信進行防刷限流的問題_Redis

作者:聽風是雨 ? 更新時間: 2022-04-15 編程語言

前言

  主要針對目前線上短信被腳本惡意盜刷的情況,用Redis實現滑動窗口限流

public void checkCurrentWindowValue(String telNum) {
        
        String windowKey = CommonConstant.getNnSmsWindowKey(telNum);
        //獲取當前時間戳
        long currentTime = System.currentTimeMillis();
        //1小時,默認只能發5次,參數smsWindowMax做成可配置項,配置到Nacos配置中心,可以動態調整
        if (RedisUtil.hasKey(windowKey)) {
            //參數smsWindowTime表示限制的窗口時間
            //這里獲取當前時間與限制窗口時間之間的短信發送次數
            Optional<Long> optional = Optional.ofNullable(RedisUtil.zCount(windowKey, currentTime - smsWindowTime, currentTime));
            if (optional.isPresent()) {
                long count = optional.get();
                if (count >= smsWindowMax) {
                    log.error("==========>當前號碼:{} 短信發送太頻繁,{}", telNum, count);
                    throw new ServiceException(MidRetCode.umid_10060);
                }
            }
        }
        StringBuilder sb =new StringBuilder();
        String windowEle = sb.append(telNum).append(":").append(currentTime).toString();
        //添加當前發送元素到zSet中(由于保證元素唯一,這里將元素加上了當前時間戳)
        RedisUtil.zAdd(windowKey, windowEle, currentTime);
        //設置2倍窗口Key:windowKey 的過期時間
        RedisUtil.expire(windowKey, smsWindowTime*2, TimeUnit.MILLISECONDS);
    }

補充:下面看下以php語言為例基于redis實現滑動窗口式的短信發送接口限流

滑動窗口短信發送限流算法

1.有兩條規則

基于IP的限制和基于手機號的限制

IP規則:

1分鐘限制5

10分鐘限制30

1小時限制50

手機號規則:

1分鐘限制1

10分鐘限制5

1小時限制10

2.滑動窗口就是隨著時間的流動 , 進行動態的刪減區間內的數據 , 限制時獲取區間內的數據

最主要的是用到了redis的zRemRangeByScore來進行刪除區間外的數據

<?php
/*滑動窗口短信發送限流算法
1.有兩條規則
 基于IP的限制和基于手機號的限制
 IP規則:

 1分鐘限制5
 10分鐘限制30
 1小時限制50

 手機號規則:
 1分鐘限制1
 10分鐘限制5
 1小時限制10
*/
//IP規則
$ipRules=array(
    60=>5,
    600=>30,
    3600=>50
);
//手機號規則
$phoneRules=array(
    60=>1,
    600=>5,
    3600=>10
);

$r = checkLimits($ipRules,$_SERVER["REMOTE_ADDR"],$_GET['tel']);
var_dump($r);

$r = checkLimits($phoneRules,$_GET['tel'],$_GET['tel']);
var_dump($r);

function checkLimits($rules,$key,$tel){
    $redis = new Redis();
    $redis->connect('115.159.28.111', 1991);
    foreach($rules as $ruleTime=>$rule) {
        $redisKey=$key."_".$ruleTime;
        $score=time();
        $member=$tel.'_'.$score;
        $redis->multi();
        $redis->zRemRangeByScore($redisKey, 0, $score - $ruleTime);//移除窗口以外的數據
        $redis->zAdd($redisKey, $score, $member);
        $redis->expire($redisKey, $ruleTime);
        $redis->zRange($redisKey, 0, -1, true);
        $members = $redis->exec();
        if (empty($members[3])) {
            break;
        }
        $nums=count($members[3]);
        var_dump($nums);

        if($nums>$rule){
            return false;
        }
    }
    return true;
}

原文鏈接:https://www.cnblogs.com/july-sunny/p/15874026.html

欄目分類
最近更新