一、请求到来后,都要先执行dispatch方法

dispatch根据请求方式的不同触发get/post/put/delete等方法

注意,APIView中的dispatch方法有很多的功能

    def dispatch(self, request, *args, **kwargs):"""`.dispatch()` is pretty much the same as Django's regular dispatch,but with extra hooks for startup, finalize, and exception handling."""self.args = argsself.kwargs = kwargs第一步:对request进行加工(添加数据)request = self.initialize_request(request, *args, **kwargs)self.request = requestself.headers = self.default_response_headers  # deprecate?try:#第二步:#处理版权信息#认证#权限#请求用户进行访问频率的限制self.initial(request, *args, **kwargs)# Get the appropriate handler methodif request.method.lower() in self.http_method_names:handler = getattr(self, request.method.lower(),self.http_method_not_allowed)else:handler = self.http_method_not_allowed# 第三步、执行:get/post/put/delete函数response = handler(request, *args, **kwargs)except Exception as exc:response = self.handle_exception(exc)#第四步、 对返回结果再次进行加工self.response = self.finalize_response(request, response, *args, **kwargs)return self.response

二、上面是大致步骤,下面我们来具体分析一下

1、对request进行加工(添加数据)

我们来看看request里面都添加了那些数据

a、首先  request = self.initialize_request(request, *args, **kwargs)点进去,会发现:在Request里面多加了四个,如下

    def initialize_request(self, request, *args, **kwargs):"""Returns the initial request object."""#把请求弄成一个字典返回了parser_context = self.get_parser_context(request)return Request(request,parsers=self.get_parsers(),  #解析数据,默认的有三种方式,可点进去看#self.get_authenticator优先找自己的,没有就找父类的authenticators=self.get_authenticators(), #获取认证相关的所有类并实例化,传入request对象供Request使用negotiator=self.get_content_negotiator(),parser_context=parser_context)

b、获取认证相关的类的具体   authenticators=self.get_authenticators(),

    def get_authenticators(self):"""Instantiates and returns the list of authenticators that this view can use."""#返回的是对象列表return [auth() for auth in self.authentication_classes]  #[SessionAuthentication,BaseAuthentication]

c、查看认证的类:self.authentication_classes

authentication_classes = api_settings.DEFAULT_AUTHENTICATION_CLASSES  #默认的,如果自定制了会优先执行自定制的

d、接着走进api_settings

api_settings = APISettings(None, DEFAULTS, IMPORT_STRINGS)  #点击继承的DEFAULTS类

DEFAULTS = {# Base API policies'DEFAULT_AUTHENTICATION_CLASSES': ('rest_framework.authentication.SessionAuthentication',   #这时候就找到了他默认认证的类了,可以导入看看'rest_framework.authentication.BasicAuthentication'),

e、导入了类看看类里面具体干了什么

from rest_framework.authentication import SessionAuthentication
from rest_framework.authentication import BaseAuthentication

f、看到里面有个authenticate方法和authenticate_header方法

class BaseAuthentication(object):"""All authentication classes should extend BaseAuthentication."""def authenticate(self, request):"""Authenticate the request and return a two-tuple of (user, token)."""raise NotImplementedError(".authenticate() must be overridden.")def authenticate_header(self, request):"""Return a string to be used as the value of the `WWW-Authenticate`header in a `401 Unauthenticated` response, or `None` if theauthentication scheme should return `403 Permission Denied` responses."""pass

 具体处理认证,从headers里面能获取用户名和密码

class BasicAuthentication(BaseAuthentication):"""HTTP Basic authentication against username/password."""www_authenticate_realm = 'api'def authenticate(self, request):"""Returns a `User` if a correct username and password have been suppliedusing HTTP Basic authentication.  Otherwise returns `None`."""auth = get_authorization_header(request).split()if not auth or auth[0].lower() != b'basic':return None   #返回none不处理。让下一个处理if len(auth) == 1:msg = _('Invalid basic header. No credentials provided.')raise exceptions.AuthenticationFailed(msg)elif len(auth) > 2:msg = _('Invalid basic header. Credentials string should not contain spaces.')raise exceptions.AuthenticationFailed(msg)try:auth_parts = base64.b64decode(auth[1]).decode(HTTP_HEADER_ENCODING).partition(':')   #用partition切割,保留了分割项冒号except (TypeError, UnicodeDecodeError, binascii.Error):msg = _('Invalid basic header. Credentials not correctly base64 encoded.')raise exceptions.AuthenticationFailed(msg)userid, password = auth_parts[0], auth_parts[2]  # 返回用户和密码return self.authenticate_credentials(userid, password, request)def authenticate_credentials(self, userid, password, request=None):"""Authenticate the userid and password against username and passwordwith optional request for context."""credentials = {get_user_model().USERNAME_FIELD: userid,'password': password}user = authenticate(request=request, **credentials)if user is None:raise exceptions.AuthenticationFailed(_('Invalid username/password.'))if not user.is_active:raise exceptions.AuthenticationFailed(_('User inactive or deleted.'))return (user, None)def authenticate_header(self, request):return 'Basic realm="%s"' % self.www_authenticate_realm

g、当然restfulframework默认定义了两个类。我们也可以自定制类,自己有就用自己的了,自己没有就去找父类的了,但是里面必须实现authenticate方法,不然会报错。

2、进行以下操作(处理版权信息,认证,权限,访问频率限制)

  • 处理版权信息
  • 认证
  • 权限
  • 请求用户进行访问频率的限制

我们主要来看一下认证流程

认证流程:

a、首先 self.initial(request, *args, **kwargs)可以看到做了以下操作

    def initial(self, request, *args, **kwargs):"""Runs anything that needs to occur prior to calling the method handler."""self.format_kwarg = self.get_format_suffix(**kwargs)# Perform content negotiation and store the accepted info on the requestneg = self.perform_content_negotiation(request)request.accepted_renderer, request.accepted_media_type = neg# Determine the API version, if versioning is in use.#2.1 处理版本信息version, scheme = self.determine_version(request, *args, **kwargs)request.version, request.versioning_scheme = version, scheme# Ensure that the incoming request is permitted#2.2 认证
        self.perform_authentication(request)# 2.3 权限
        self.check_permissions(request)# 2.4 请求用户进行访问频率的限制self.check_throttles(request)

 b、我们先来看认证,self.perform_authentication(request) 具体干了什么,按住ctrl点击进去

    def perform_authentication(self, request):"""Perform authentication on the incoming request.Note that if you override this and simply 'pass', then authenticationwill instead be performed lazily, the first time either`request.user` or `request.auth` is accessed."""request.user   #执行request的user,这是的request已经是加工后的request了

c、那么我们可以从视图里面导入一下Request,找到request对象的user方法

from rest_framework.views import Request

    @propertydef user(self):"""Returns the user associated with the current request, as authenticatedby the authentication classes provided to the request."""if not hasattr(self, '_user'):with wrap_attributeerrors():self._authenticate()  #return self._user  #返回user

d、执行self._authenticate() 开始用户认证,如果验证成功后返回元组: (用户,用户Token)

 def _authenticate(self):"""Attempt to authenticate the request using each authentication instancein turn."""#循环对象列表for authenticator in self.authenticators:try:#执行每一个对象的authenticate 方法user_auth_tuple = authenticator.authenticate(self)   except exceptions.APIException:self._not_authenticated()raiseif user_auth_tuple is not None:self._authenticator = authenticatorself.user, self.auth = user_auth_tuple  #返回一个元组,user,和auth,赋给了self,# 只要实例化Request,就会有一个request对象,就可以request.user,request.auth了returnself._not_authenticated()

e、在user_auth_tuple = authenticator.authenticate(self) 进行验证,如果验证成功,执行类里的authenticatie方法

f、如果用户没有认证成功:self._not_authenticated()

 def _not_authenticated(self):"""Set authenticator, user & authtoken representing an unauthenticated request.Defaults are None, AnonymousUser & None."""#如果跳过了所有认证,默认用户和Token和使用配置文件进行设置self._authenticator = None  #
if api_settings.UNAUTHENTICATED_USER:self.user = api_settings.UNAUTHENTICATED_USER() # 默认值为:匿名用户AnonymousUserelse:self.user = None  # None 表示跳过该认证if api_settings.UNAUTHENTICATED_TOKEN:self.auth = api_settings.UNAUTHENTICATED_TOKEN()  # 默认值为:Noneelse:self.auth = None# (user, token)# 表示验证通过并设置用户名和Token;# AuthenticationFailed异常

3、执行get/post/delete等方法

4、对返回结果在进行加工

三、完整过程

现在我们主要去分析rest_framework内部对这个url的具体实现过程。

  1. 首先我们访问http://127.0.0.1:8000/user/ 根据urls.py中的配置,执行views.TestView.as_view()函数
  2. as_view方法是被定义在rest_framework/views.py里面的一个静态方法,所以可以通过类名直接调用。

  3. 父类的as_view方法是定义在django/views/generic/base.py里面的View类中的方法。在这个方法中最终会执行cls.dispatch,在第一步中我们知道cls是<class 'app01.views.TestView'>

  4. dispatch是定义在TestView继承的父类APIView(rest_framework/views.py)里面的方法。在这个方法里面,首先通过 request = self.initialize_request(request, *args, **kwargs)这条语句重新封装了request对象

  5. initialize_request是APIView类里面的一个方法,重新封装了request对象,增加了一些属性信息

  6. 认证信息。主要通过APIView类中的get_authenticators(rest_framework/views.py)方法获取,这个方法会返回一个所有认证对象的列表
    在全局定义的authentication_classes = api_settings.DEFAULT_AUTHENTICATION_CLASSES

  7. 默认的认证配置信息是在rest_framework/settings.py文件中定义的

  8. 在rest_framework/authentication.py中定义了几种认证类型,一般情况我们需要自定义认证类,也可以使用django-oauth-toolkit组件进行认证。

  9. dispatch中的initialize_request方法执行完成之后,还有执行一个重要方法是self.initial(request, *args, **kwargs),这个方法也是APIView类里的。在这个方法里面初始化
    被重新封装的request对象
    实现功能:

    • 版本处理
    • 用户认证
    • 权限
    • 访问频率限制

  10. 执行APIView里面的perform_authentication方法,该方法返回request.user,则会调用<rest_framework.request.request object="" at="" 0x10e80deb8="">里面的user方法。在user方法里面最终调用了Request类里面的_authenticate方法


  11. 执行rest_framework.request.Request类中的_authenticate方法,这个方法会遍历认证类,并根据认证结果给self.user, self.auth赋值。由于user,和auth都有property属性,
    所以给赋值的时候先在先执行setter方法


  12. dispatch中的initial方法执行完之后,会继续判断request.method并执行method相应的method.

  13. 执行TestView中定义的get方法,返回数据

Django rest_framework 认证源码流程相关推荐

  1. Django admin组件源码流程

    admin 组件 Django 自带的用户后台组件 用于用户便携的操作 admin 组件核心 启动 注册 设计url 启动核心代码 每个app 通过 apps.py 扫描 admin.py 文件 并执 ...

  2. Django后端项目----restful framework 认证源码流程

    一.请求到来之后,都要先执行dispatch方法,dispatch方法方法根据请求方式的不同触发get/post/put/delete等方法 注意,APIView中的dispatch方法有很多的功能 ...

  3. Django Rest Framework源码剖析(二)-----权限

    一.简介 在上一篇博客中已经介绍了django rest framework 对于认证的源码流程,以及实现过程,当用户经过认证之后下一步就是涉及到权限的问题.比如订单的业务只能VIP才能查看,所以这时 ...

  4. REST framework 用户认证源码

    REST 用户认证源码 在Django中,从URL调度器中过来的HTTPRequest会传递给disatch(),使用REST后也一样 # REST的dispatch def dispatch(sel ...

  5. 【武sir】django rest framework源码和实战_day01(上)

    (0)摘要 # 课程链接 4天搞定django rest framework源码和实战_哔哩哔哩_bilibili # 课程内容 (1)内容概要_略 (2)内容回顾_略 (3)django 视图之 C ...

  6. django-admin的源码流程

    一.admin的源码流程 首先可以确定的是:路由关系一定对应一个视图函数 a.当点击运行的时候,会先找到每一个app中的admin.py文件,并执行 settings---->INSTALLED ...

  7. SpringSecurity详细介绍RememberMe源码流程

      本文我们来详细看看rememberMe的源码流程 rememberMe源码分析   首先我们要搞清楚rememberMe功能应该是在认证成功后才能具有的,所以我们应该从Usernamepasswo ...

  8. android 虚拟按键源码流程分析

    android 虚拟按键流程分析 今天来说说android 的虚拟按键的源码流程.大家都知道,android 系统的状态栏,虚拟按键,下拉菜单,以及通知显示,keyguard 锁屏都是在framewo ...

  9. MediaPlayer源码流程简要分析

    涉及文件目录: \frameworks\base\media\java\android\media\MediaPlayer.java \frameworks\base\media\jni\androi ...

最新文章

  1. BZOJ 1852 [MexicoOI06]最长不下降序列(贪心+DP+线段树+离散化)
  2. 白炽灯可控硅调光程序
  3. hdu 2686(多线程dp)
  4. 【Linux】一步一步学Linux——dmesg命令(74)
  5. Mac和Linux下测试端口是否存活一法[转载]
  6. POJ 1089 Intervals 区间覆盖+ 贪心
  7. 洛谷P5170 【模板】类欧几里得算法(数论)
  8. OCR-CTPN 文字检测
  9. 导致ERP企业管理系统实施失败的四点原因
  10. 解决PageHelper版本不匹配,结果可能全部返回问题
  11. 你必须要看的IT培训机构选择意见
  12. vue在微信里面的兼容问题_Vue在 iOS 微信浏览器下不能播放
  13. Github上开源项目readme里好看的高大上的有趣的徽章从何而来
  14. 实时行情难处理?睿凝资本选择DolphinDB解决流数据难题
  15. JS EventListener
  16. ssm+jsp计算机毕业设计游戏网站设计n8q96(程序+lw+源码+远程部署)
  17. 操作系统负责为方便用户管理计算机系统,操作系统负责为用户方便管理计算机系统的( )。...
  18. 【python作品分享】密码锁3.0
  19. 【Nginx】Nginx服务器之负载均衡策略(6种)
  20. java实现多重继承_Java 程序实现多重继承

热门文章

  1. 探寻《魔兽争霸3》中最不为人知的按键
  2. GroupingComparator分组
  3. Java复习二 基本数据类型与变量和常量
  4. 【题解】Luogu P1533 可怜的狗狗
  5. Java中谈尾递归--尾递归和垃圾回收的比较
  6. HttpWebRequest在GetResponse时总是超时
  7. 十、oracle 常用函数
  8. 使用Azure portal Create Virtual Machine
  9. [IOS] 'Double' is not convertible to 'CGFloat'
  10. [ C++ ] 理解const