DRF请求的生命周期：三年程序员的实战感悟

核动力

前言：作为工作一个3年左右的码农，在各种框架的摸爬滚打中，我也接触了不少前端后端的技术栈，其中 Django REST Framework（DRF）算是我后端日常工作中的用得最多的框架。今天就简单聊聊DRF请求的生命周期。从请求的发起，到数据的处理，再到最终的响应返回，每一步都有着很多的细节和挑战，由于篇幅原因，我在此篇文章中只是稍作解析，点到为止。
drf中请求的生命周期：

1、django接收请求后，先进行中间件的process_request方法，进行路由匹配后再进行中间件的process_view方法；

1. class MiddlewareMixin:
2.         # 中间件源码，当有请求进来时，会自动执行中间件的call方法；
3.         # 一般我们自定义中间件都是重写process_request和process_view方法
4.         # 从源码中可看出执行顺序：
5.     def __call__(self, request):
6.         # Exit out to async mode, if needed
7.         if asyncio.iscoroutinefunction(self.get_response):
8.             return self.__acall__(request)
9.         response = None
10.         if hasattr(self, 'process_request'):
11.             response = self.process_request(request)   
12.         response = response or self.get_response(request)
13.         if hasattr(self, 'process_response'):
14.             response = self.process_response(request, response)
15.         return response

复制代码

2、再执行APIView类中的as_view方法获取view函数，并同时免除了csrf认证（闭包原理）

1. class APIView(View):
2.     # 简略版源码：
3.     @classmethod
4.     def as_view(cls, **initkwargs):
5.         view = super().as_view(**initkwargs) # 调用原Django框架的as_view方法获取view函数
6.         view.cls = cls
7.         view.initkwargs = initkwargs
8.         return csrf_exempt(view)
10. # 原Django框架的as_view方法：
11. class View:
12.     @classonlymethod
13.     def as_view(cls, **initkwargs):
14.         def view(request, *args, **kwargs):
15.             self = cls(**initkwargs)
16.             self.setup(request, *args, **kwargs)
17.             return self.dispatch(request, *args, **kwargs) # 调用dispatch函数
18.         view.view_class = cls
19.         view.view_initkwargs = initkwargs
20.         return view

复制代码

3、通过路由匹配执行view函数，并在view中调用dispatch函数。

1. class APIView(View):
2.     def dispatch(self, request, *args, **kwargs):
3.         self.args = args
4.         self.kwargs = kwargs
5.         # request封装
6.         request = self.initialize_request(request, *args, **kwargs)
7.         self.request = request
8.         self.headers = self.default_response_headers  # deprecate?
10.         try:  # 捕获异常
11.             self.initial(request, *args, **kwargs)  # 版本管理、认证。权限、限流组件执行
13.             if request.method.lower() in self.http_method_names:  # 执行视图函数
14.                 handler = getattr(self, request.method.lower(),
15.                                   self.http_method_not_allowed)
16.             else:
17.                 handler = self.http_method_not_allowed
19.             response = handler(request, *args, **kwargs)
21.         except Exception as exc:
22.             response = self.handle_exception(exc)
24.         self.response = self.finalize_response(request, response, *args, **kwargs)
25.         return self.response

复制代码

4、在dispatch中进行版本管理、request封装、认证、权限、限流处理

1. # 版本管理
2.     def initial(self, request, *args, **kwargs):
4.         self.format_kwarg = self.get_format_suffix(**kwargs)
6.         version, scheme = self.determine_version(request, *args, **kwargs)  # 执行versioning_class中的determine_version方法，获取version和scheme
7.         request.version, request.versioning_scheme = version, scheme  # 封装参数到request中
9.         # Ensure that the incoming request is permitted
10.         self.perform_authentication(request)
11.         self.check_permissions(request)
12.         self.check_throttles(request)
15. # request封装
16.     def initialize_request(self, request, *args, **kwargs):
17.         parser_context = self.get_parser_context(request)
18.         return Request(
19.             request,
20.             parsers=self.get_parsers(),
21.             authenticators=self.get_authenticators(),
22.             negotiator=self.get_content_negotiator(),
23.             parser_context=parser_context
24.         )
26. #认证
27.     def _authenticate(self):
28.         for authenticator in self.authenticators:
29.             try:
30.                 user_auth_tuple = authenticator.authenticate(self) # 执行authenticate方法进行具体的认证流程
31.             except exceptions.APIException:
32.                 self._not_authenticated()
33.                 raise
35.             if user_auth_tuple is not None:
36.                 self._authenticator = authenticator
37.                 self.user, self.auth = user_auth_tuple  # 将返回值进行封装
38.                 return
40.         self._not_authenticated()
43. # 权限
44.     def check_permissions(self, request):
45.         for permission in self.get_permissions():
46.             if not permission.has_permission(request, self):  # 多个权限类中有一个方法为False则报错并抛出异常
47.                 self.permission_denied(
48.                     request,
49.                     message=getattr(permission, 'message', None),
50.                     code=getattr(permission, 'code', None)
51.                 )
54. # 限流
55.     def check_throttles(self, request):
56.         throttle_durations = []
57.         for throttle in self.get_throttles(): # 循环执行各限流类中的方法
58.             if not throttle.allow_request(request, self):
59.                 throttle_durations.append(throttle.wait()) # 限流方法返回False则将等待时间加到列表中
61.         if throttle_durations:
62.             durations = [
63.                 duration for duration in throttle_durations
64.                 if duration is not None
65.             ]
67.             duration = max(durations, default=None) # 取列表中的最大等待时间
68.             self.throttled(request, duration)  # 抛出异常

复制代码

5、执行具体的视图函数并返回数据

6、执行中间件的process_response方法并返回数据到客户端

以上只是简单分析了一下执行流程，涉及到的源码都是为了方便理解而经过简化的，只供参考。每个组件源码的设计思路和执行流程其实都有一定的复杂度，对于各个组件的源码，我在接下来的日子中也会逐一进行详细剖析。

来源:https://www.cnblogs.com/harry6/p/18438720
免责声明：由于采集信息均来自互联网，如果侵犯了您的权益，请联系我们【E-Mail:cb@itdo.tech】 我们会及时删除侵权内容，谢谢合作！