Django生命周期 URL ----> CBV 源码解析-------------- 及rest_framework APIView 源码流程解析

一、一个请求来到Django 的生命周期
  • FBV 不讨论

  • CBV:

    请求被代理转发到uwsgi:

    开始Django的流程:

    首先经过中间件process_request (session等)

    然后:url --- > Xxx.as_view() 根据url映射到对应业务逻辑类 --->process_view (csrf等)

     

    业务逻辑类中:

    as_view() -- > view ---> dispatch() 通过映射调用请求的方法在业务逻辑中的对应处理函数

    (如post、put、delete等)

    Django生命周期  URL ----> CBV 源码解析-------------- 及rest_framework APIView 源码流程解析

 

1.2 CBV源码解析
  • 自己的业务逻辑类:MyView 继承View

  • 没有as_view() 方法,将会去父类View找as_view

class MyView(View):

    def get(self, request):
#处理业务逻辑,返回response
pass def post(self, request):
pass def put(self, request):
pass def delete(self, request):
pass

 

1.2.2 View源码中:as_view() 方法被调用
  • 查看as_view 方法源码:作者省略了部分,只留下了关键部分,并做了注释
class View:
...
@classonlymethod
def as_view(cls, **initkwargs):
... def view(request, *args, **kwargs):
...
return self.dispatch(request, *args, **kwargs) #调用父类的dispatch() 方法
... return view #返回内部定义的view 方法

这儿可以看见:

1.  as_view()方法被调用,

2.  内部回返回定义的view 方法,

3.  view方法中调用了 dispatch() 方法

4.  如果自己的类没有重写dispatch 方法的话,将会调用父类View类的 dispatche() 方法

 

1.2. 查看dispatch方法
  • dispatch方法中:作者省略了部分,只留下了关键部分,并做了注释
class View:
...
def dispatch(self, request, *args, **kwargs):
...
#request.method中保存了客户端解析出来的请求方法,如:GET/POST等
if 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
return handler(request, *args, **kwargs) #并调用该业务逻辑函数处理结果,将结果返回
  • 注意:request.method 保存着解析出来的请求行第一个数据(GET URL HTTP1.1)如:GET

可以看见:

1.  if判断客户端请求的方法是否是,http协议(Django)自己支持的

2.  handler = getattr(self, request.method.lower(), self.http_method_not_allowed)

    将请求方法小写,然后在自己的业务类中映射到对应处理函数,如果没有报错

3.  return handler(request, *args, **kwargs)

    并调用该业务逻辑函数处理结果,将结果返回

 

二、rest_framework APIView 流程解析

先看一个图:给出大致流程

Django生命周期  URL ----> CBV 源码解析-------------- 及rest_framework APIView 源码流程解析

 

2.2 APIView中请求流程
  • 同上:请求通过URL 匹配到继承APIView的自己的业务逻辑类。
class APIView(View):
...
parser_classes = api_settings.DEFAULT_PARSER_CLASSES #默认解析类
authentication_classes = api_settings.DEFAULT_AUTHENTICATION_CLASSES #默认认证类
throttle_classes = api_settings.DEFAULT_THROTTLE_CLASSES #默认限流类
permission_classes = api_settings.DEFAULT_PERMISSION_CLASSES #权限类
...
versioning_class = api_settings.DEFAULT_VERSIONING_CLASS #版本控制获取类 ... @classmethod
def as_view(cls, **initkwargs):
...
view = super(APIView, cls).as_view(**initkwargs) #继承父类as_view方法
view.cls = cls
view.initkwargs = initkwargs
...
return csrf_exempt(view) #返回父类view
...
def get_parsers(self):
"""
获取到上面4. 第一步initialize_request函数封装request过程中一并生成封装的解析器对象
"""
return [parser() for parser in self.parser_classes] def get_authenticators(self):
"""
同理身份认证对象
"""
return [auth() for auth in self.authentication_classes] def get_permissions(self):
"""
同理权限对象
"""
return [permission() for permission in self.permission_classes] def get_throttles(self):
"""
同理限流(访问频率控制对象)
"""
return [throttle() for throttle in self.throttle_classes] def perform_authentication(self, request):
... #这里面真正认证 def check_permissions(self, request):
... #这里面检查权限 def check_throttles(self, request):
... #这里面限流 def determine_version(self, request, *args, **kwargs):
... #这里面获取版本 def initialize_request(self, request, *args, **kwargs):
"""
被dispatch调用,封装request,并调用上述函数生成相应对象封装到request对象中
"""
parser_context = self.get_parser_context(request) return Request(
request,
parsers=self.get_parsers(),
authenticators=self.get_authenticators(),
negotiator=self.get_content_negotiator(),
parser_context=parser_context
) def initial(self, request, *args, **kwargs):
...
被dispatch调用,在里面初始化获取版本,认证、权限检查、访问控制等 # Determine the API version, if versioning is in use.
#处理版本问题,调用 determine_version方法
version, scheme = self.determine_version(request, *args, **kwargs)
request.version, request.versioning_scheme = version, scheme # Ensure that the incoming request is permitted
#3.在这儿实现认证
self.perform_authentication(request)
#4.权限检查
self.check_permissions(request)
#5.访问频率控制 ... def dispatch(self, request, *args, **kwargs):
...
self.args = args
self.kwargs = kwargs
##############################################################
# 1.封装request
request = self.initialize_request(request, *args, **kwargs)
##############################################################
self.request = request
self.headers = self.default_response_headers # deprecate? try:
##############################################################
#2.认证
self.initial(request, *args, **kwargs)
##############################################################
# Get the appropriate handler method
if 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 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. 找as_view()函数

第一步自己业务逻辑类中:没有,

第二步父类-APIView中:找到as_view方法,开始调用

2. APIView继承了View,APIView的as_view函数继承了父类as_view:如下为源码

view = super(APIView, cls).as_view(**initkwargs) #继承父类的as_view

view.cls = cls #把自身封装进去

view.initkwargs = initkwargs #将参数初始化

return csrf_exempt(view) #返回view

可以看见封装了一次as_view方法,将自身cls (APIView)一起封装到了view中

并返回

3. 通过上面1-2 知道:继承请求进入后会调用返回的view方法,然后在self中找dispatch方法,

第一步自己的业务逻辑类中:没有dispatch

第二步父类APIView中:找到dispatch方法,开始调用

4. APIView的dispatch 函数中:

第一步:request = self.initialize_request(request, *args, **kwargs) 封装了一次request

 

initialize_request函数内如下:

return Request(

request, #原生request

parsers=self.get_parsers(), #解析器

authenticators=self.get_authenticators(), #身份验证器

negotiator=self.get_content_negotiator(),

parser_context=parser_context

)

第二步:self.initial(request, *args, **kwargs) 开始初始化认证

 

initial函数内:

1)获取版本,版本处理类实例。并封装到request中

version, scheme = self.determine_version(request, *args, **kwargs)

request.version, request.versioning_scheme = version, scheme

 

2)身份(登录)认证啥的

self.perform_authentication(request)

 

3)权限管理

self.check_permissions(request)

 

4)限流控制(访问频率控制)

self.check_throttles(request)

 

2.2.3 上述总结
  1. 首先找dispatch 函数(APIView类中)

  2. dispatch中:

    调用了self.initialize_request 函数封装request

  3. 接着2的dispatch中initialize_request 函数

    查看APIView中的initialize_request 函数

    调用了:get_parsers()、get_authenticators() 等

    封装了一堆解析器类实例、认证类实例啥的

    可自己去看(这些类使用默认配置,APIView 一开头下面一堆配置就是)

    这些类也可以自己写,配置到自己的业务逻辑类中,或者settings.py中作为全局配置(下面在讲)

  4. 接着2的dispatch中initial函数

    版本获取:

    version, scheme = self.determine_version(request, *args, **kwargs)

    request.version, request.versioning_scheme = version, scheme

    实现认证

    self.perform_authentication(request)

    权限检查

    self.check_permissions(request)

    访问频率控制

    self.check_throttles(request)

 

三、常用的解析、认证、权限、访问频率控制源码及解析

from rest_framework.views import APIView #继承类路径

from rest_framework import request #dispatch中initialize_request封装的request对象

from rest_framework.parsers import JSONParser, FormParser, FileUploadParser #不同解析器

from rest_framework.versioning import QueryParameterVersioning,URLPathVersioning #两种版本获取器

from rest_framework.authentication import BaseAuthentication #登录验证

from rest_framework.permissions import BasePermission #权限

from rest_framework.throttling import SimpleRateThrottle #节流

from rest_framework import exceptions #错误

上一篇:Django 之 admin组件使用&源码解析


下一篇:Django的rest_framework的视图之Mixin类编写视图源码解析