Tornado源码浅探分析(一)基础篇

介绍

Tornado 是由 Facebook 开源的一个服务器“套装”,适合于做 python 的 web 或者使用其本身提供的可扩展的功能,完成了不完整的 wsgi 协议,可用于做快速的 web 开发,封装了 epoll 性能较好。文章主要以分析 tornado 的网络部分即异步事件处理与上层的 IOstream 类提供的异步IO,其他的模块如 web 的 tornado.web 以后慢慢留作分析。

在深入到模块进行分析之前,首先来看看Tornado的设计模型


Tornado框架设计模型

从上面的图可以看出,Tornado 不仅仅是一个WEB框架,它还完整地实现了HTTP服务器和客户端,在此基础上提供WEB服务。它可以分为四层:

  • 最底层的EVENT层处理IO事件;
  • TCP层实现了TCP服务器,负责数据传输;
  • HTTP/HTTPS层基于HTTP协议实现了HTTP服务器和客户端;
  • 最上层为WEB框架,包含了处理器、模板、数据库连接、认证、本地化等等WEB框架需要具备的功能。

理解Tornado的核心框架之后,就能便于我们后续的理解。
先来一段官方示例代码

import tornado.httpserver
import tornado.ioloop
import tornado.options
import tornado.web
from tornado.options import define, options

define("port", default=8888, help="run on the given port", type=int)
class MainHandler(tornado.web.RequestHandler):
    def get(self):
        self.write("Hello, world")

if __name__ == "__main__":
    tornado.options.parse_command_line()
    application = tornado.web.Application([
        (r"/", MainHandler),
    ],)

    http_server = tornado.httpserver.HTTPServer(application)
    http_server.listen(options.port)
    tornado.ioloop.IOLoop.current().start()
  • 从代码里可以看到的是:应用里定义了 URI 路由和对应的处理类,并以此构建了application对象,然后让这个对象监听在8888端口,最后由 ioloop 单例进入循环,不断分发事件。
  • 这里的URI路由就是r"/",对应处理类就是 MainHandler,它们被放在同一个 tuple 里形成了关联。可以看到,application 是接受一个列表的,因此可以定义多个全局路由对应不同处理,往列表里 append 就是了。

tornado.web 里的 RequestHandler 和 Application 类

Tornado 使用 web 模块的 Application 做URI转发,然后通过 RequestHandler处理请求。 Application 提供了一个 listen 方法作为 HTTPServer 中的 listen 的封装。

初始化 Application 时,一般将处理器直接传入,它会调用 add_handlers 添加这些处理器,初始化还包括 transforms (分块、压缩等)、UI模块、静态文件处理器的初始化。 add_handlers 方法负责添加URI和处理器的映射。

    def __init__(self, handlers=None, default_host=None, transforms=None,
                 **settings):

        self.default_host = default_host
        self.settings = settings
        ...代码缩减后

        self.wildcard_router = _ApplicationRouter(self, handlers)
        self.default_router = _ApplicationRouter(self, [
            Rule(AnyMatches(), self.wildcard_router)
        ])#全局路由初始化

        # Automatically reload modified modules
        if self.settings.get('autoreload'):
            from tornado import autoreload
            autoreload.start()

Application接收了list类型的handlers后用_ApplicationRouter 类进行封装,父类(_ApplicationRouter>ReversibleRuleRouter>RuleRouter)会自动调用self.add_rules方法遍历所有Rule的实例添加到list类型的self.rules中

Application 实现 URI 转发时使用了一个技巧,它实现了_call_ 方法,并将 Application 的实例传递给 HTTPServer ,当监听到请求时,它通过调用 Application 实例触发 _call_ 。 _call_ 方法中完成具体的URI转发工作,并调用已注册的处理器的 execute 方法,处理请求。

    def __call__(self, request):
        # Legacy HTTPServer interface
        dispatcher = self.find_handler(request)
        return dispatcher.execute()
    def find_handler(self, request, **kwargs):
        #self.default_router全局路由的实例,这里调用find_handler方法查找url对应的视图函数
        route = self.default_router.find_handler(request)

        if route is not None:
            return route

        if self.settings.get('default_handler_class'):
            return self.get_handler_delegate(
                request,
                self.settings['default_handler_class'],
                self.settings.get('default_handler_args', {}))
        #设置处理器类   暂时还不太清楚,估计是为了扩展
        return self.get_handler_delegate(
            request, ErrorHandler, {'status_code': 404})
        #如果全局路由中没有找到URI就返回404错误

execute这个方法很核心,也很重要。

(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类。

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 213,254评论 6 492
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 90,875评论 3 387
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 158,682评论 0 348
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 56,896评论 1 285
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 66,015评论 6 385
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 50,152评论 1 291
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 39,208评论 3 412
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 37,962评论 0 268
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 44,388评论 1 304
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 36,700评论 2 327
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 38,867评论 1 341
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 34,551评论 4 335
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 40,186评论 3 317
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 30,901评论 0 21
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 32,142评论 1 267
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 46,689评论 2 362
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 43,757评论 2 351

推荐阅读更多精彩内容

  • 引言 以Django为代表的python web应用部署时采用wsgi协议与服务器对接(被服务器托管),而这类服务...
    大熊_7d48阅读 2,033评论 0 3
  • tornado框架是一款相较于其他web framework处理服务器性能问题更加强健的轻量级的强大的Pytho...
    恶人未满阅读 7,121评论 3 10
  • 1.tornado是一个异步的http框架 2.常用模块 importtornado.httpserver imp...
    冬gua阅读 456评论 0 0
  • 官方文档中文文档Tornado概览浅谈Python Web 框架:Django, Twisted, Tornado...
    一只写程序的猿阅读 41,915评论 7 50
  • 折柳赠别,江湖又是天涯路。将行何处,啼鸟林中诉。 还忆少时,你我同床住。匆匆渡,回眸已暮,此情怎堪负。
    唐春元阅读 195评论 0 5