tornado学习笔记18 _RequestDispatcher 请求分发器

根据Application的配置,主要负责将客户端的请求分发到具体的RequestHandler。这个类实现了HTTPMessageDelegate接口。

18.1 构造函数

定义:

def __init__(self, application, connection):

参数:

application:Application对象。

connection:请求连接,为HTTP1Connection实例。

实现分析:

就是对这个类的属性进行初始化赋值。比如chunks,handler_class(RequestHandler处理类)、handler_kwargs(处理类参数)、path_args、path_kwargs等。

18.2 HTTPMessageDelegate接口实现

1.2.1 header_received

定义

def headers_received(self, start_line, headers):

实现分析:

实例化HTTPServerRequest对象,调用set_request方法,set_request方法中去查找匹配的请求处理类(RequestHandler)。如果请求处理类实现了_stream_request_body方法,则直接调用execute方法。

1.2.2 data_received

定义

def data_received(self, data):

实现过程:

如果RequestHandler实现了_stream_request_body方法,则调用handler的data_received方法,如果没实现,则将数据块添加至chunks中。

1.2.3 finish

当消息数据块接收完毕后,调用此方法。此方法的实现就是将数据块连接起来,然后调用HTTPServerReuqest的_parse_body方法,实现对body体消息的解析。然后调用excute方法。

18.3 其他方法

1.3.1 _find_handler

这个方法很重要,也是核心方法之一。实现Application的配置属性以及请求路径的匹配,找到匹配的RequestHandler。

实现过程:

(1) 调用Application的_get_host_handlers方法,获得匹配的hanlders集合;

(2) 如果没有匹配到合适的handlers,将handler_class设置成RedirectHandler,并设置handler_kwargs,然后返回。

(3) 如果匹配到了合适的handlers,循环handlers中的每一元素URLSpec,判断其中的路径正则表达式是否与请求路径相匹配。

(4) 如果匹配合适的RequestHandler,设置handler_class以及handler_kwargs,而后设置path_kwargs

(5) 没有没有匹配到RequestHandler,判断Application是否设置了default_handler_class选项,并设置handler_class为其值。如果没有设置default_handler_class选项,则将handler_class属性设置成 ErrorHandler,状态码设置成404错误,也就是not found错误。

18.3.2 execute

这个方法很核心,也很重要。当请求信息处理完毕后(调用finish方法后),会执行execute方法。方法如下:

def execute(self):    # If template cache is disabled (usually in the debug mode),
    # re-compile templates and reload static files on every
    # request so you don't need to restart to see changes
    if not self.application.settings.get("compiled_template_cache", True):
        with RequestHandler._template_loader_lock:
            for loader in RequestHandler._template_loaders.values():
                loader.reset()
    if not self.application.settings.get('static_hash_cache', True):
        StaticFileHandler.reset()

    self.handler = self.handler_class(self.application, self.request,
                                      **self.handler_kwargs)
    transforms = [t(self.request) for t in self.application.transforms]

    if self.stream_request_body:
        self.handler._prepared_future = Future()
    # Note that if an exception escapes handler._execute it will be
    # trapped in the Future it returns (which we are ignoring here,
    # leaving it to be logged when the Future is GC'd).
    # However, that shouldn't happen because _execute has a blanket
    # except handler, and we cannot easily access the IOLoop here to
    # call add_future (because of the requirement to remain compatible
    # with WSGI)
    f = self.handler._execute(transforms, *self.path_args,
                              **self.path_kwargs)
    # If we are streaming the request body, then execute() is finished
    # when the handler has prepared to receive the body.  If not,
    # it doesn't matter when execute() finishes (so we return None)
    return self.handler._prepared_future

实现过程描述如下:

(1) 判断application是否对complied_template_cache是否设置成True.如果没有,则将模板加载器重置。相当于不对编译后模板缓存的话,就重置模板加载器。

(2) 判断applacation是否对static_hash_cache是否设置成True. 如果没有,则调用StaticFileHandler的reset方法。相当于不对网站的静态文件进行缓存的话,就调用重置的方法。

(3) 根据_find_handler方法设置的handler_class属性初始化自定义的RequestHanlder

(4) 调用requestHandler的_exucute方法,就是调用相应的方法,要门是get方法,要么是post,要么是其他支持的http方法,具体实现详情请查看RequestHandler类。

原文地址:https://www.cnblogs.com/liaofeifight/p/5099440.html