试试博客
2016-04-29 15:21
232 查看
从tornado自带的helloword例子出发:
上面的例子构造了一个最简单的基于tornado的helloworld的web服务器:用户访问8888端口得到helloworld的反馈。那么在这个过程中,tornado到底做了哪些工作呢,它的异步架构是怎么得到体现的呢?
从大的层面上看,构造上述tornado的web服务器使用了4个元素: RequestHandler, Application, HTTPServer和ioloop. 了解服务器的同学应该能够猜到它们之间的关系了:HTTPServer提供了面向client的web服务,Application将client的访问路由到具体的RequestHandler,ioloop提供tornado中的事件监控调度。
从main函数当中开始看起:
首先实例化了一个Application对象,传入的参数是一个tuple。url是一个字符串,MainHandler是RequestHandler的子类,它实现了其中的get方法,该方法的定义是:
(所以如果你没有实现这个方法而直接使用的话是会直接报405错误的,这个技巧到时可以在写框架类的时候用到)。言归正传,get方法中什么都不干,直接向client发送“Hello, world”。
而在application中,参数是一个list,所以我们可以定义多个(url, handler)的tuple对。正如代码中对application的定义:一组request handler构成了一个application。
再来看看Application对传入的handler都做了什么:
然后是初始化了一个httpserver:
监听端口:
删除一些代码后,可以看到每隔timeout时间会poll出event出来到events中,然后对event进行处理,这里的_handler[fd]来进行处理,这里是handler是对该fd的读写操作。
晕死,写的乱七八糟的。
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") def 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() if __name__ == "__main__": main()
上面的例子构造了一个最简单的基于tornado的helloworld的web服务器:用户访问8888端口得到helloworld的反馈。那么在这个过程中,tornado到底做了哪些工作呢,它的异步架构是怎么得到体现的呢?
从大的层面上看,构造上述tornado的web服务器使用了4个元素: RequestHandler, Application, HTTPServer和ioloop. 了解服务器的同学应该能够猜到它们之间的关系了:HTTPServer提供了面向client的web服务,Application将client的访问路由到具体的RequestHandler,ioloop提供tornado中的事件监控调度。
从main函数当中开始看起:
application = tornado.web.Application([ (r"/", MainHandler), ])
首先实例化了一个Application对象,传入的参数是一个tuple。url是一个字符串,MainHandler是RequestHandler的子类,它实现了其中的get方法,该方法的定义是:
def get(self, *args, **kwargs): raise HTTPError(405)
(所以如果你没有实现这个方法而直接使用的话是会直接报405错误的,这个技巧到时可以在写框架类的时候用到)。言归正传,get方法中什么都不干,直接向client发送“Hello, world”。
而在application中,参数是一个list,所以我们可以定义多个(url, handler)的tuple对。正如代码中对application的定义:一组request handler构成了一个application。
再来看看Application对传入的handler都做了什么:
if handlers: self.add_handlers(".*$", handlers)所以它维护了一个包含了一个或者多个handlers的字典,url是key,value是handler。
然后是初始化了一个httpserver:
http_server = tornado.httpserver.HTTPServer(application)HttpServer继承了TcpServer类,来处理由tcp数据接收到handler处理的流程。
监听端口:
http_server.listen(options.port)最后启动ioloop,直接看代码中的死循环了:
while True: event_pairs = self._impl.poll(poll_timeout) self._events.update(event_pairs) while self._events: fd, events = self._events.popitem() fd_obj, handler_func = self._handlers[fd] handler_func(fd_obj, events)
删除一些代码后,可以看到每隔timeout时间会poll出event出来到events中,然后对event进行处理,这里的_handler[fd]来进行处理,这里是handler是对该fd的读写操作。
晕死,写的乱七八糟的。
相关文章推荐
- 什么是jQuery?
- Python 中 os.path模板
- 【DirectX11-Tutorial】Initializing Direct3D
- 剑指offer(5) 旋转数组中的最小值
- Mysql接口大全
- scala学习第一弹:基本语法和语法特性
- 内存寻址优化
- swift 的高阶函数的使用代码
- pyqt4 基本窗口,窗口布局,设置logo,窗口最大最小化
- pyinstaller生成exe笔记
- 一个简单python语言web server,输出机器上的HW信息
- MJRefresh的那些坑
- 配置emacs python 开发环境
- io流写入操作日记记录中换行需要注意的点
- Socket、TCP/IP、HTTP、FTP和网络编程
- Jlink20P接口定义
- SQL-创建和操纵表
- 链表常见问题
- EventBus的使用详解
- hdu 1159 最长公共子序列