tornado 学习笔记7 RequestHandler功能分析

       在第5部分讲到，构建一个tornado网站，必须包含一个或者多个handler，这些handler是RequestHandler的子类。每个请求都会被映射到handler中进行处理，处理后再将结果返回给客户端。所以，可以看到hanlder作为客户端请求跟业务服务逻辑间的桥梁，如果拿MVC的模式来类比的话，每个handler就相当于MVC中的Controller。

       RequestHanlder作为所有hanlder的父类，我们看看他有哪些方法与接口，子类需要怎样继承？

 

7.1构造函数

定义：

def __init__(self, application, request, **kwargs):

参数：

      application: Application对象

      request: request请求对象

       kwargs:其他参数，在hanlder映射配置时，可以设置。

处理过程：

super(RequestHandler, self).__init__()

self.application = application
self.request = request
self._headers_written = False
self._finished = False
self._auto_finish = True
self._transforms = None  # will be set in _execute
self._prepared_future = None
self.path_args = None
self.path_kwargs = None
self.ui = ObjectDict((n, self._ui_method(m)) for n, m in
                     application.ui_methods.items())
# UIModules are available as both `modules` and `_tt_modules` in the
# template namespace.  Historically only `modules` was available
# but could be clobbered by user additions to the namespace.
# The template {% module %} directive looks in `_tt_modules` to avoid
# possible conflicts.
self.ui["_tt_modules"] = _UIModuleNamespace(self,
                                            application.ui_modules)
self.ui["modules"] = self.ui["_tt_modules"]
self.clear()
self.request.connection.set_close_callback(self.on_connection_close)
self.initialize(**kwargs)
  1. 对外部属性跟内部属性（带下划线）的赋值。
  2. 然后对ui的处理，这个暂时不做深入细读。
  3. self.clear() 调用clear方法，初始化一些属性。
  4. 设置请求连接关闭时的回调函数。
          self.request.connection.set_close_callback(self.on_connection_close)

   5.    调用初始化函数。

          self.initialize(**kwargs)

       这个被子类继承，针对每个hanlder实现自己的初始化过程。

 

入点函数

7.2 initialize方法

      该方法被子类重写，实现初始化过程。参数的来源于配置Application时，传递的参数。举例如下：

# -*- coding: utf-8 -*-
from tornado.ioloop import IOLoop
from tornado.web import Application, RequestHandler

__author__ = ‘Administrator‘

class BookRequestHandler(RequestHandler):
    def initialize(self, welcome):
        self.welcome = welcome

    def get(self, *args, **kwargs):
        print(self.welcome)
        self.write(self.welcome)

welcome = "**大学图书馆"
app = Application(handlers=[
    (r"/book", BookRequestHandler, dict(welcome=welcome)),
])

def main():
    app.listen(8888)
    IOLoop.current().start()

if __name__ == "__main__":
    main()

         

          将welcome初始化的值传递到BookRequestHandler的self.welcome属性中。当访问http://localhost:8888/book时，打印出welcome的值。

          结果如下图：

7.3 prepare 、 on_finish方法

          prepare方法用于当真正调用请求处理方法之前的初始化处理，比如get、post方法。而on_finish用于请求处理结束后的一些清理工作。这两个方法一个在处理前，一个在处理后，可以根据实际需要进行重写。比如用prepare方法做些初始化操作（比如赋值设置全局变量，比如打开I/O），而on_finish方法可以做一些清理对象占用的内存或者关闭数据库连接等等。举个例子，来证明他们的执行顺序。

class BookRequestHandler(RequestHandler):
    def initialize(self, welcome,value2):
        print("initialize method:initilize some variables....")
        self.welcome = welcome
        self.value2=value2

    def get(self, *args, **kwargs):
        #print(self.welcome + "\r\n" + "and value2 =" + self.value2)
        print("get method: Processing get Method...........")
        self.write(self.welcome + "\r\n" + "and value2 =" + self.value2)

    def set_default_headers(self):
        self._headers.add("custom_header1", "custom_header1")
        self._headers.add("custom_header2", "custom_header2")

    def prepare(self):
        print("prepare method:initilize some variables....")

    def on_finish(self):
        print("on_finish method:clear some memory or close database connection")

      执行的结果如下：

       所以得出执行的顺序为：

       initialize > prepare > get > on_finish

       如果有熟悉Java 的JUnit的话呢，prepare跟on_finish方法相当于before跟behind两个注解的功能。

获得输入的函数：

7.4  get_argument、get_arguments方法

        返回给定参数的值,get_argument获得单个值，而get_arguments是针对参数存在多个值得情况下使用，返回多个值的列表。看一get_arguments方法的源代码，如下：

          它的实现是调用了内部方法_get_arguments，注意传递的参数self.request.arguments,从request（HTTPServerRequest对象）的arguments属性中去查询给定名称的值。看看HTTPServerRequest源代码(位于tornado>httputil.py)对arguments的解释，如下截图：

          大体意思就是说，这里存储的是客户端GET/POST方法提交上来的合并后的参数列表集合。也就是说RequestHanlder的get_arguments方法是能获得不管是Get还是POST得参数的值。举个GET提交参数的例子，

          修改BookRequestHanlder的get方法。如下：

def get(self, *args, **kwargs):
    #print(self.welcome + "\r\n" + "and value2 =" + self.value2)
    print("get method: Processing get Method...........")
    #self.write(self.welcome + "\r\n" + "and value2 =" + self.value2)
    self.write("参数name的值为：" + self.get_argument("name", "liaofei"))

       向游览器中打印出参数name的值，游览器中访问：http://localhost:8888/book?name=brain，结果如下图所示：

          在举个POST方式提交参数的例子，在BookRequestHanlder 中新增POST方法，如下：

def post(self, *args, **kwargs):
    print(self.request.arguments)
    print("POS age：" + self.get_argument("age"))
    self.write("POS age：" + self.get_argument("age"))

        网上下载一个模拟工具进行POST数据提交，我找了很久用了，找到如下工具（很多工具不能用，这个稍微能用一下），

          后台打印的结果为：，HTTPRequest 的arguments属性是一个字典。

         提一个问题？如果URL中带有age查询参数，而post过去也有age参数，这时HTTPRequest 的arguments中age的值会是什么？？？测试一下便知。按照如下访问，

        后台打印的结果为：，age的值是一个列表集合，将POST提交方式age参数值跟GET提交方式age参数值合并啦，而且是GET在前，POST再后。而get_arguments获得最后一个。

7.5 get_query_argument、get_query_arguments方法

       与get_argument、get_arguments功能类似，只是他仅仅是从URL查询参数中获取值。

7.6  get_body_argument、get_body_arguments方法

      与get_argument、get_arguments功能类似，只是他仅仅是从body中获取值。

   再提一个问题？？？？？get_query_argument、get _argument、get_body_argument的区别？？？？测试一下便知。

   按如下修改post方法，

def post(self, *args, **kwargs):
    print(self.request.query_arguments)
    print(self.request.arguments)
    print(self.request.body_arguments)
    print("POS age：" + self.get_argument("age"))
    self.write("POS age：" + self.get_argument("age"))

        按如下方式模拟访问：

           后台打印的结果如下图：

           所以得出结论就是，get _argument获取的值范围是get_query_argument与get_body_argument两者范围的合并。

输出响应函数：

7.7 clear方法

      重置响应的所有的头部以及内容。

"""Resets all headers and content for this response."""
self._headers = httputil.HTTPHeaders({
    "Server": "TornadoServer/%s" % tornado.version,
    "Content-Type": "text/html; charset=UTF-8",
    "Date": httputil.format_timestamp(time.time()),
})
self.set_default_headers()
self._write_buffer = []
self._status_code = 200
self._reason = httputil.responses[200]

      处理过程

  1. 首先默认设置3个响应头部，分别是Server,Content_Type、Date.
  2. 调用set_default_headers 方法，实现自定义header的设置。
  3. 其他参数的默认设置。

7.9 set_default_headers方法

      上面说了set_default_headers 方法是实现请求响应头部的自定义实现，被子类重写。举个例子。

       在上面的BookRequestHandler中加入以下代码

def set_default_headers(self):
    self._headers.add("custom_header1", "custom_header1")
    self._headers.add("custom_header2", "custom_header2")

       通过游览器访问http://localhost:8888/book，用firebug查询响应头。结果如下：

7.10 write方法

        将给定的块输出到输出缓存中。如果给定的块是一个字典，就会将这个快当成是JSON并且将Content_Type设置成application/json返回给客户端。但是，如果你想用不同的Content_Type发送JSON,可以在调用write方法后再调用set_header方法进行设置。

       注意,list 列表集合是不会转化成JSON的，原因是考虑到跨域的安全。所有的JSON输出都必须用字典包装。具体源码说明如下：

7.11 rend 方法

        用给定的参数渲染模板。这个涉及到模板的概念，后续再学。

7.12  write_error方法

        重写自定义错误页面的实现。

        如果error是由没有捕获的异常（包括HTTPError）引起的，通过kwargs[|”exc_info”]能获取exc_info元组。实现代码如下：

            举个例子实现一个自定义的错误页面，在BookRequestHandler中添加如下代码：

def write_error(self, status_code, **kwargs):
    self.write("oh,my god!出错啦！！！！请联系系统管理员。\n")
    self.write("呵呵，也没关系，我已经讲错误信息记录在日志中去了，系统管理员会看到的。\r\n")
    if "exc_info" in kwargs:
        self.write("错误信息为：\r\n")
        for line in traceback.format_exception(*kwargs["exc_info"]):
            self.write(line)
    self.finish()

并将get方法修改成：

def get(self, *args, **kwargs):
    # print(self.welcome + "\r\n" + "and value2 =" + self.value2)
    print("get method: Processing get Method...........")
    # self.write(self.welcome + "\r\n" + "and value2 =" + self.value2)

    # print(self.request.query_arguments)
    # print(self.request.arguments)
    # print(self.request.body_arguments)
    # self.write("参数name的值为：" + self.get_argument("name", "liaofei"))

    print(1/0)

   

             print(1/0)语句，人为地制造一个错误。在游览器中访问http://localhost:8888/book，得到如下结果，

            就是使用了重写write_error中的方法实现。

Cookie相关函数

7.13 get_cookie、set_cookie

      获取与设置cookie的值。这个对熟悉web开发的人，一看就明白。就不多解释。

7.14 get_secure_cookie、set_secure_cookie

        获取与设置安全cookie的值。与7.13 相比加了一个单词secure（安全），就说明是为cookie安全加密解密的作用。这个方法涉及到cookie_secret 的Application 设置选项。来举个列子说明他们之间的区别：

加入以下代码：

class CookieRequestHandler(RequestHandler):
    def get(self, flag):
        if flag == ‘0‘:
            self.set_cookie("user", "liaofei")
        elif flag == ‘1‘:
            userCookie = self.get_cookie("user")
            self.write(userCookie)

      修改application的配置

settings = {
    "debug":False,
    "cookie_secret":"gagagaarwrslijwlrjoiajfoajgojowurwojrowjojgfoaguuuu9",
}

app = Application(handlers=[
    (r"/book", BookRequestHandler, dict(welcome=welcome, value2=value2)),
    (r"/cookie/([0-1]+)", CookieRequestHandler),
], **settings)
    (r"/cookie/([0-1]+)", CookieRequestHandler),
], **settings)

     

        注意settings中设置了cookie_secret的值。

       访问http://localhost:8888/cookie/0时，调用set_cookie设置cookie中user的值为liaofei，并调用set_secure_cookie设置cookie 中usersecure的值同样为liaofei。用firebug查看这个相同值得cookie（都是liaofei），发现在游览器客户端的值是不一样的，一个加密过，一个未加密。具体结果如下图：

时间： 2024-10-14 06:33:34

tornado 学习笔记7 RequestHandler功能分析的相关文章

python框架之 Tornado 学习笔记（一）

tornado 一个简单的服务器的例子: 首先,我们需要安装 tornado ,安装比较简单: pip  install tornado 测试安装是否成功,可以打开python 终端,输入: import     tornado.httpserver 若无报错,则证明安装成功 接下来就可以写一个简单的服务器了,如下: import tornado.httpserver import tornado.ioloop import tornado.options import tornado.web

Tornado 学习笔记 Tornado基础 1

这是根据官方文档学习后总结的笔记: Tornado基础 Tornado是一套web框架和异步网络功能库,使用非阻塞是IO,可支持数万个活动连接.支持长活跃连接,支持 long polling长连接,支持WebSockets. A web framework (including RequestHandler which is subclassed to create web applications, and various supporting classes). Client- and se

Tornado学习笔记(一)

最近开始用Tornado做开发了,究其原因,主要是Tornado基于Python,一来代码量少开发速度快,二来采用epoll方式,能够承载的并发量很高.在我的i5台式机上用ab测试,不连接数据库的情况下,单用get生成页面,大概平均的并发量在7900左右.这比php或者java能够承载并发量都高很多很多.三来Python代码可维护性相对来说比php好很多,语法结构清晰.四来,tornado的框架设计的很黄很暴力,以HTTP请求方式作为方法名称,通常情况下,用户写一个页面只需要有get和post两

Tornado学习笔记(三)

记录一些Tornado中的常用知识. 获取远端IP,直连tornado,用self.request.remote_ip,如果是走nginx反向代理方式,需要在nginx中的Server/Location配置如下                 proxy_pass http://data.xxx.com;                 #proxy_redirect off;                 proxy_set_header Host $host;               

tornado 学习笔记

import tornado.ioloop import tornado.web class MainHanlwe(tornado.web.RequestHandler): def get(self): login_user=self.get_secure_cookie('login_user',None) if login_user: self.write(login_user) else: self.redirect('/login') class LoginHanmder(tornado.

tornado学习笔记19 Tornado框架分析

19.1 Http服务器请求处理流程图   (1) 调用HTTPServer的bind方法,绑定Socket的监听端口号: (2) 调用HTTPServer的listen方法,初始化一个listen socket对象: (3) 调用add_hander方法,将初始化的listen socket对象添加至IOLoop池中,这时的socket就开始监听来自客户端的请求. (4) 客户端发送HTTP请求: (5) listen socket监听到客户端的请求,调用listen socket的accep

tornado学习笔记（四）

4 Databases 1 pymongo 2 simple word dictionary 3 Burts books read from database editing and adding books 4 Databases 1 pymongo pymongo是python用来连接MongoDB数据库的一个库,可以pip安装:pip install pymongo 命令行mongod运行mongodb服务器后,可以使用pymongo来进行连接 >>> import pymongo

Tornado 学习笔记3 tornado started

这个笔记是看Introduction.to.Tornado 一书时总结的. Tornado适合创建可灵活扩展的社区程序.实时的分析引擎,以及REST风格的API.由Bret Taylor等人为FriendFeed开发,后被Facebook收购. 多数的社区程序实时更新显示新消息,状态更改以及用户提示,需要客户端一直保持连接用来等待服务器的响应.使用线程模式的服务器如apache及其comet实现很容易因为达到线程池最大值,而无法接受新的请求. 相对于使用线程模式管理缓冲池的方式,Tornado使

tornado学习笔记（三）

3 Extending Templates 1 blocks and substitutions 2 autoescaping 3 UI modules basic module usage modules in depth embedding javascript and css 3 Extending Templates 1 blocks and substitutions 模板可以继承于基类模板,这样可以重复使用很多模块减少代码量 如在index.html中继承main.html,在ind