flask請求流程

時間  2019-11-08
標籤 flask 請求 流程 欄目 Python 简体版
原文   原文鏈接

啓動先執行manage.py 中的    app.run()django

class Flask(_PackageBoundObject):
　　 def run(self, host=None, port=None, debug=None, **options):
    　　from werkzeug.serving import run_simple
    　　try:
        　　#run_simple 是werkzeug 提供的方法，會執行第三個參數 self()
        　　run_simple(host, port, self, **options)

執行app()，對象()表示調用對象的__call__方法flask

class Flask(_PackageBoundObject):
　　 def __call__(self, environ, start_response):
        return self.wsgi_app(environ, start_response)

又調用了app.wsgi_app方法cookie

複製代碼
複製代碼 
class Flask(_PackageBoundObject):
　　 def wsgi_app(self, environ, start_response):
        #1.
　　　　　ctx = self.request_context(environ)
　　　　       #self.request_context
        #2.
        ctx.push()
　　 　　try:
            try:
　　　　　　　　　 #3.執行視圖函數
                response = self.full_dispatch_request()
            except Exception as e:
                error = e
　　　　　　　　　 #4.
                response = self.handle_exception(e)
            except:
                error = sys.exc_info()[1]
                raise
            return response(environ, start_response)
        finally:
　　　　　　　#5.
            ctx.auto_pop(error)
複製代碼
複製代碼

第1步：執行app.request_context方法，把請求的相關信息傳進去了session

class Flask(_PackageBoundObject):
　　 def request_context(self, environ):
        return RequestContext(self, environ)

返回了一個RequestContext類的實例對象app

複製代碼
複製代碼 
class RequestContext(object):
　　 def __init__(self, app, environ, request=None):
        self.app = app
        if request is None:
            request = app.request_class(environ) 
　　　　　　  #app.request_class = Request       
        self.request = request
        self.session = None
複製代碼
複製代碼

在init構造方法中注意app又調用了request_class方法，這時候咱們所實例化的app中默認參數request_class中有一個Request的類，dom

那麼第1步咱們知道：ide

ctx是一個RequestContext對象，這個對象裏面封裝了兩個主要的屬性，一個是self.request = Request實例的對象，Request對象裏面封裝了請求進來的全部數據；
另一個是self.session = None就能夠了

 

第2步：執行ctx.push()方法函數

由於ctx是RequestContext類的對象，那咱們就要去RequestContext類中找push方法url

複製代碼
複製代碼 
class RequestContext(object):
　　 def push(self):
　　　　 #2.1.
        app_ctx = _app_ctx_stack.top
        if app_ctx is None or app_ctx.app != self.app:
            app_ctx = self.app.app_context()
　　　　　　　　　　　　# self.app.app_context = app.app_context = AppContext(app)
            app_ctx.push()
　　　　　#2.2.
　　　　  _request_ctx_stack.push(self)
　　　　　　　　#_request_ctx_stack = LocalStack()
　　　　 #2.3.
        self.session = self.app.open_session(self.request)

        #判斷沒有 secret_key時：
        if self.session is None:
            self.session = self.app.make_null_session()
            #raise RuntimeError('The session is unavailable because no secret ''key was set.)
複製代碼
複製代碼

 

第2.1步：到_app_ctx_stack這個棧中取最後一個數據，若是未取到或者取到的不是當前的app，就調用app.app_context()方法，就是新實例一個上下文app_ctx對象，再執行app_ctx.push()方法     （在這再次強調，由於app_ctx是AppContext對象，就要先去AppContext類中找push方法），spa

class AppContext(object):
　　 def push(self):
        _app_ctx_stack.push(self)     #把新建立的app_ctx上下文app對象添加到了_app_ctx_stack這個棧中
        appcontext_pushed.send(self.app)   #在這裏遇到了第一個信號，請求app上下文push時執行

第2.2步：LocalStack類的對象調用push方法

複製代碼
複製代碼 
class LocalStack(object):
　　 def push(self, obj):
        rv = getattr(self._local, 'stack', None)       #self._local = Local()
　　　　      #第一次的時候rv確定是None
        if rv is None:
            self._local.stack = rv = []      #Local對象 .stack = rv = [] 就執行了對象的 __setattr__方法
        rv.append(obj)                       #把 ctx對象添加到Local類的列表中
        return rv
複製代碼
複製代碼
複製代碼
複製代碼 
try:
    from greenlet import getcurrent as get_ident
except ImportError:
    try:
        from thread import get_ident
    except ImportError:
        from _thread import get_ident

class Local(object):    
    def __init__(self):
        object.__setattr__(self, '__storage__', {})             #這裏爲何用object.__setattr__  而不是直接用self.__storage__={}
        object.__setattr__(self, '__ident_func__', get_ident)   #若是用self的方式設置屬性，就會觸發self的__setattr__方法，就會無限的循環
　　
    def __setattr__(self, name, value):
        ident = self.__ident_func__()
        storage = self.__storage__
        try:
            storage[ident][name] = value    # {"惟一標識1"：{"stack":[]}，"惟一標識2"：{"stack":[]}}   和本地線程相似
        except KeyError:
            storage[ident] = {name: value}
複製代碼
複製代碼

 第2.3步：給ctx.session賦值，執行app.open_session(ctx.request)

 

class Flask(_PackageBoundObject):
　　 def open_session(self, request):
        return self.session_interface.open_session(self, request)
　　　　　#return SecureCookieSessionInterface().open_session(app, request)
　　　　　#因此就要去SecureCookieSessionInterface類找open_session方法
複製代碼
複製代碼 
class SecureCookieSessionInterface(SessionInterface):
　　 def open_session(self, app, request):
        # 查看 是否有secret_key
        s = self.get_signing_serializer(app)
        if s is None:
            return None

        val = request.cookies.get(app.session_cookie_name)
        # 請求第一次來的時候取不到值
        if not val:
            return self.session_class()
            #返回了一個 相似字典
        max_age = total_seconds(app.permanent_session_lifetime)
        try:
            data = s.loads(val, max_age=max_age)  #loads 做用是： 反序列化+解析亂碼
            return self.session_class(data)       ##返回了一個 相似字典對象，對象裏面有data
        except BadSignature:
            return self.session_class()
複製代碼
複製代碼

那麼第2步咱們知道：

1.把app_ctx上下文對象添加到了_app_ctx_stack這個棧中
2.把 ctx請求對象添加到Local類的列表中
3.執行open_session方法，把session加載到內

 第3步：app.full_dispatch_request()   執行視圖函數 

複製代碼
複製代碼 
class Flask(_PackageBoundObject):
    def full_dispatch_request(self):
        #3.1 
        self.try_trigger_before_first_request_functions()
        try:
            request_started.send(self)     # 信號 - 請求到來前執行
            # 3.2 
            rv = self.preprocess_request()
            if rv is None:
                # 3.3 若是全部的中間件都經過了， 執行視圖函數
                rv = self.dispatch_request()
　　　　 #3.4 
        return self.finalize_request(rv)
複製代碼
複製代碼

第3.1步：找到全部的 執行一次的 僞中間件 執行

class Flask(_PackageBoundObject):
    def try_trigger_before_first_request_functions(self):

        with self._before_request_lock:
            for func in self.before_first_request_funcs:
                func()

第3.2步：找到全部的 僞中間件的執行

複製代碼
複製代碼 
class Flask(_PackageBoundObject):
    def preprocess_request(self):

        funcs = self.before_request_funcs.get(None, ())
        for func in funcs:
            rv = func()
            if rv is not None:
                return rv
複製代碼
複製代碼

第3.3步：

複製代碼
複製代碼 
class Flask(_PackageBoundObject):
    def dispatch_request(self):
        #獲取請求的ctx對象中的request數據
        req = _request_ctx_stack.top.request
        #獲取請求的url
        rule = req.url_rule
        #執行視圖函數
        return self.view_functions[rule.endpoint](**req.view_args)
複製代碼
複製代碼

第3.4步：

複製代碼
複製代碼 
class Flask(_PackageBoundObject):
    def finalize_request(self, rv, from_error_handler=False):
        response = self.make_response(rv)   #經過make_response方法後就能夠對返回值進行設置響應頭等數據了
        try:
　　　　　　　#3.4.1
            response = self.process_response(response)
            request_finished.send(self, response=response)  #信號 -  請求結束後執行
        return response
複製代碼
複製代碼

第3.4.1步：

複製代碼
複製代碼 
class Flask(_PackageBoundObject):
    def process_response(self, response):
        ctx = _request_ctx_stack.top
        #找到全部的 after_request 僞中間件執行
        funcs = ctx._after_request_functions
        for handler in funcs:
            response = handler(response)
        # 3.4.1.1 若是有session就執行self.save_session方法
        if not self.session_interface.is_null_session(ctx.session):
　　　　　# self.session_interface = SecureCookieSessionInterface() 
　　　　　　  #3.4.1.2
　　　　 　　 self.save_session(ctx.session, response) return response
複製代碼
複製代碼

第3.4.1.1步： 到SecureCookieSessionInterface類中找is_null_session方法，發現沒有，就去它基類SessionInterface中找

class SessionInterface(object):
    def is_null_session(self, obj):
        #判斷ctx.session 是否是 self.null_session_class = NullSession 類或者它派生類的對象
        return isinstance(obj, self.null_session_class)

第3.4.1.2步：執行了SecureCookieSessionInterface類的save_session方法

class Flask(_PackageBoundObject):
    def save_session(self, session, response):
        return self.session_interface.save_session(self, session, response)
        # return SecureCookieSessionInterface().save_session(self, session, response)
class SecureCookieSessionInterface(SessionInterface):
    def save_session(self, app, session, response):
        #給響應設置cookie
        response.set_cookie(app.session_cookie_name, val,
                            expires=expires, httponly=httponly,
                            domain=domain, path=path, secure=secure)

補充：自定義session

  自定義相似django的session

第4步：

class Flask(_PackageBoundObject):
    def handle_exception(self, e):
        got_request_exception.send(self, exception=e)    #信號 - 請求執行出現異常時執行

第5步： 執行了RequestContext 的 pop 方法

class RequestContext(object):
    def auto_pop(self, exc):
        else:
            self.pop(exc)
複製代碼
複製代碼 
class RequestContext(object):
    def pop(self, exc=_sentinel):
　　　　 try:
        　　if not self._implicit_app_ctx_stack:
　　　　　　　　  #5.1
            　　self.app.do_teardown_request(exc)
        finally:
　　　　　　  # 請求結束時  request上下文的棧中就把請求pop掉
            rv = _request_ctx_stack.pop()
        　　 if app_ctx is not None:
　　　　　　　　　　#5.2
        　　 　　 app_ctx.pop(exc)
複製代碼
複製代碼

第5.1步： 執行  app.do_teardown_request方法

class Flask(_PackageBoundObject):
    def do_teardown_request(self, exc=_sentinel):
　　　　 # 信號 - 請求執行完畢後自動執行（不管成功與否）
        request_tearing_down.send(self, exc=exc)

第5.2步：

複製代碼
複製代碼 
class AppContext(object):
    def pop(self, exc=_sentinel):
        try:
            if self._refcnt <= 0:
　　　　　　　　　 #5.2.1
                self.app.do_teardown_appcontext(exc)
　　　　 # 信號 - 請求上下文pop時執行
        appcontext_popped.send(self.app)
複製代碼
複製代碼

第5.2.1步：

class Flask(_PackageBoundObject):
    def do_teardown_appcontext(self, exc=_sentinel):
        # 信號 - 請求上下文執行完畢後自動執行（不管成功與否）
        appcontext_tearing_down.send(self, exc=exc)

 

 補充：

多app應用

複製代碼 
from werkzeug.wsgi import DispatcherMiddleware
from werkzeug.serving import run_simple
from flask import Flask, current_app

app1 = Flask('app01')

app2 = Flask('app02')



@app1.route('/index')
def index():
    return "app01"


@app2.route('/index2')
def index2():
    return "app2"


dm = DispatcherMiddleware(app1, {
    '/sec': app2,
})

if __name__ == "__main__":
    app2.__call__
    run_simple('localhost', 5000, dm)
複製代碼

 

 調用__call__方法的時候，若是有‘/’的話分割，mounts以前傳過的url，若是在的話，就break，不在的話分割完拼接路徑

複製代碼 
    def __call__(self, environ, start_response):
        script = environ.get('PATH_INFO', '')
        path_info = ''
        while '/' in script:
            if script in self.mounts:
                app = self.mounts[script]
                break
            script, last_item = script.rsplit('/', 1)
            path_info = '/%s%s' % (last_item, path_info)
        else:
            app = self.mounts.get(script, self.app)
        original_script_name = environ.get('SCRIPT_NAME', '')
        environ['SCRIPT_NAME'] = original_script_name + script
        environ['PATH_INFO'] = path_info
        return app(environ, start_response)
相關文章
相關標籤/搜索
每日一句
    每一个你不满意的现在，都有一个你没有努力的曾经。
本站公眾號
   歡迎關注本站公眾號,獲取更多信息
聯繫我們 最近搜索 最新文章 沪ICP备13005482号-10 MyBatis教程 SQL 教程 MySQL教程 Java 教程 Thymeleaf 教程 Hibernate教程 Spring教程 Redis教程