zoukankan      html  css  js  c++  java
  • 频率组件

    一、频率简介

    为了控制用户对某个url请求的频率,比如,一分钟以内,只能访问三次

    二、自定义频率类(了解):

    from rest_framework.throttling import BaseThrottle
    class MyThrottle(BaseThrottle):
        VISIT_RECORD = {}
        def __init__(self):
            self.history=None
        def allow_request(self,request,view):
            # 自定义控制每分钟访问多少次,运行访问返回true,不允许访问返回false
    1)取出访问者ip{ip1:[第二次访问时间,第一次访问时间],ip2:[]}
            (2)判断当前ip不在访问字典里,如果不在添加进去,并且直接返回True,表示第一次访问,在字典里,继续往下走
            (3)循环判断当前ip的列表,有值,并且当前时间减去列表的最后一个时间大于60s,把这种数据pop掉,这样列表中只有60s以内的访问时间,
            (4)判断,当列表小于3,说明一分钟以内访问不足三次,把当前时间插入到列表第一个位置,返回True,顺利通过
            (5)当大于等于3,说明一分钟内访问超过三次,返回False验证失败
    
            # (1)取出访问者ip
            ip = request.META.get('REMOTE_ADDR')
            import time
            #拿到当前时间
            ctime = time.time()
            # (2)判断当前ip不在访问字典里,添加进去,并且直接返回True,表示第一次访问
            if ip not in self.VISIT_RECORD:
                self.VISIT_RECORD[ip] = [ctime, ]
                return True
            #是个当前访问者ip对应的时间列表 [第一次访问的时间,]
            self.history = self.VISIT_RECORD.get(ip)
            # (3)循环判断当前ip的列表,有值,并且当前时间减去列表的最后一个时间大于60s,把这种数据pop掉,这样列表中只有60s以内的访问时间,
            while self.history and ctime - self.history[-1] > 60:
                self.history.pop()
            # (4)判断,当列表小于3,说明一分钟以内访问不足三次,把当前时间插入到列表第一个位置,返回True,顺利通过
            # (5)当大于等于3,说明一分钟内访问超过三次,返回False验证失败
            if len(self.history) < 3:
                self.history.insert(0, ctime)
                return True
            else:
                return False
    
        def wait(self):
            import time
            ctime = time.time()
            return 60 - (ctime - self.history[-1])
    
    class Books(APIView):
        throttle_classes=[MyThrottle,]
        def get(self,request):
            return Response('')
    View Code

    自定义频率类限制了访问次数,所以我们使用内置的频率类

    三、频率组件的使用

    1、第一步:新建py文件写一个频率类,继承SimpleRateThrottle,重写get_cache_key,返回self.get_ident(request),注意一定要记住在里面配置一个:scop='字符串'

    from rest_framework.throttling import SimpleRateThrottle
    
    # 频率类
    class Throttle(SimpleRateThrottle):
        scope = 'jerry'
    
        def get_cache_key(self, request, view):
            return self.get_ident(request)

    2、第二步:在setting中配置以下参数

    REST_FRAMEWORK = {
        'DEFAULT_THROTTLE_RATES': {'jerry': '3/minute'}  # 一分钟访问三次
    }

    3、视图函数中使用频率类

    from rest_framework.views import APIView
    from rest_framework.response import Response
    from app01.myth import Throttle
    
    class Books(APIView):
        throttle_classes = [Throttle, ]
    
        def get(self, request):
            return Response()

    urls.py

    url(r'^books/', views.Books.as_view()),

    效果演示

    局部使用

    全局使用

    在settings里配置:

    REST_FRAMEWORK = {'DEFAULT_AUTHENTICATION_CLASSES': ['自己定义的频率类',]}

    REST_FRAMEWORK = {
        'DEFAULT_AUTHENTICATION_CLASSES': ['app01.myth.Throttle', ]
    }

    局部禁用

    源码分析:

    执行的是APIView中的dispatch里面的方法

    去列表里拿数据找allow_request, 而且传了一个参数,如果不符合,执行self.throttled(request, throttle.wait())
    如果符合直接返回,所以我们应该自己写一个类,实现allow_request方法,成功返回True,不成功返回False,这就是需要我们自定义频率类,上面有介绍

    SimpleRateThrottle源码分析:

    点进去看一下它的allow_request

    self.key是访问者的ip,放在了缓存中

    从缓存中通过key也就是ip拿到了访问者的时间列表,self.history是当前访问者ip对应的时间列表[第一次访问的时间,],self.now是当前时间

    继续下翻,到了操作次数

    self.history是一个列表,里面是一个个访问时间,利用len统计次数,如果访问次数大于固定次数,执行failure,否则执行success,那么我们分别点开看一下它们是什么

    可以看到:执行failure返回的是False,

    执行success,也就是访问次数小于固定次数,返回的是True,注意succcess返回Ture之前,把当前时间插进去,然后再把数据存到缓存中

    有了这个方法之后,所以就不需要我们自定义频率类重写allow_request方法了,只需要重写获取ip方法get_cache_key(self, request, view),返回当前访问者的ip。

    完了之后还需要分析:scope为什么要定义在频率类中?

    点进源码再分析一下

    然后点进rate看一下里面执行了什么

    用反射getattr去获取rate的值,没有值就执行self.get_rate(),点进去看一下

    这里通过反射到类里面判断scope存不存在,没有直接抛出异常,有就返回self.THROTTLE_RATES[self.scope]

    self.scope是频率类定义scope的值

    然后再点进THROTTLE_RATES中,这个就是我们在settings里设置的

    key值jerry赋给了self.scope,3/minute赋给了self.rate

    再点进parse_rate中

    parse_rate中执行了哪些操作呢?首先通过字符串的切分把3赋给了num,把minute赋给了period,然后把num的字符串3转成数字3赋给num_requests,然后将period索引取值取第一个字母m作为key取出所对应的的value值为60,这里面不仅可以识别分钟,还可以识别秒,时,天,所以在settings里可以设置s/h/d(单词首字母也可以全称)

    最后返回了num_requests的值为3,duration的值为60,那么让我们看一下这两个值被谁接收了

    到了这里我们已经清楚了为什么访问三次以后就必须等60秒过了之后才能再次一分钟访问三次

  • 相关阅读:
    linux 学习随笔-shell基础知识
    linux 学习随笔-压缩和解压缩
    解析xml的4种方法详解
    集合工具类
    Map概述
    List集合概述
    Java集合框架
    Spring JdbcTemplate详解
    关于c3p0数据库连接池的简单使用
    Java通过JDBC封装通用DAO层
  • 原文地址:https://www.cnblogs.com/zhangguosheng1121/p/11134617.html
Copyright © 2011-2022 走看看