基本版：
#coding=utf-8import tornado.webimport tornado.httpserverimport tornado.optionsimport tornado.ioloopfrom tornado.options import options , definedefine("port",default=8001,help="跑在8001",type=int)import timeclass SleepHandler(tornado.web.RequestHandler): def get(self): time.sleep(5) self.write("this is SleepHandler...")class DirectHandler(tornado.web.RequestHandler): def get(self): self.write("this is DirectHandler...")if __name__ == "__main__": tornado.options.parse_command_line() app = tornado.web.Application( handlers = [ (r"/d",DirectHandler), (r"/s",SleepHandler), ], debug = True ) http_server = tornado.httpserver.HTTPServer(app) http_server.listen(options.port) tornado.ioloop.IOLoop.instance().start() 多进程版本
注意一定要关闭debug功能！！！否则：Cannot run in multiple processes: IOLoop instance
#coding:utf-8import tornado.webimport tornado.httpserverimport tornado.optionsimport tornado.ioloopfrom tornado.options import options , definedefine("port",default=8001,help="跑在8001",type=int)import timeclass SleepHandler(tornado.web.RequestHandler): def get(self): time.sleep(10) self.write("this is SleepHandler...")class DirectHandler(tornado.web.RequestHandler): def get(self): self.write("this is DirectHandler...")if __name__ == "__main__": tornado.options.parse_command_line() app = tornado.web.Application( handlers = [ (r"/d",DirectHandler), (r"/s",SleepHandler), ], debug = False ) http_server = tornado.httpserver.HTTPServer(app) http_server.bind(options.port) http_server.start(0) # [I 150610 10:42:05 process:115] Starting 4 processes tornado.ioloop.IOLoop.instance().start() bind文档翻译
def bind(self, port, address=None, family=socket.AF_UNSPEC, backlog=128): """ 绑定server到指定地址的端口上。 调用start来启动server。如果想把这个server跑在单线程上，可以调用listen方法，listen是bind和start方法的单进程模式的“快捷键”。 地址可能是ip地址或者hostname。如果是hostname，server将监听其所有关联ip。 地址若是空字符串将监听不到任何可用接口。family参数可设置为socket.AF_INET或socket.AF_INET6来约定ipv4或者是ipv6地址，缺省情况下会启用所有可用的。 backlog参数与socket.listen同义。 bind方法会多次在start方法前调用来监听多个端口或者接口。 """ sockets = bind_sockets(port, address=address, family=family, backlog=backlog) if self._started: self.add_sockets(sockets) else: self._pending_sockets.extend(sockets)
start文档翻译
def start(self, num_processes=1): """ 默认情况下，但进程运行server，不会fork任何额外的子进程。 如果num_processes为None或<=0 ，会根据机器的cpu核数fork子进程。若num_processes>=1，就fork这个数目的子进程。 因为我们使用的是进程而不是线程,所以不会在server code之间共享内存。 特别注意，多进程与自动装载模型不兼容。在调用TCPServer.start(n)前，任何IOLoop都不能创建和引用。 """ assert not self._started self._started = True if num_processes != 1: process.fork_processes(num_processes) sockets = self._pending_sockets self._pending_sockets = [] self.add_sockets(sockets)
异步版本1
#coding:utf-8import tornado.webimport tornado.httpserverimport tornado.optionsimport tornado.ioloopfrom tornado.options import options , definedefine("port",default=8001,help="跑在8001",type=int)import timeclass SleepHandler(tornado.web.RequestHandler): @tornado.web.asynchronous def get(self): tornado.ioloop.IOLoop.instance().add_timeout(time.time() + 5, callback=self.on_response) def on_response(self): self.write("this is SleepHandler...") self.finish()class DirectHandler(tornado.web.RequestHandler): def get(self): self.write("this is DirectHandler...")if __name__ == "__main__": tornado.options.parse_command_line() app = tornado.web.Application( handlers = [ (r"/d",DirectHandler), (r"/s",SleepHandler), ], debug = False ) http_server = tornado.httpserver.HTTPServer(app) http_server.bind(options.port) http_server.start(1) tornado.ioloop.IOLoop.instance().start() 将sleep.py的代码如上述一样改造，即在get()方法前面增加了装饰器@tornado.web.asynchronous，它的作用在于将tornado服务器本身默认的设置_auto_fininsh值修改为false。如果不用这个装饰器，客户端访问服务器的get()方法并得到返回值之后，两只之间的连接就断开了，但是用了@tornado.web.asynchronous之后，这个连接就不关闭，直到执行了self.finish()才关闭这个连接。
tornado.ioloop.IOLoop.instance().add_timeout()也是一个实现异步的函数，time.time()+17是给前面函数提供一个参数，这样实现了相当于time.sleep(17)的功能，不过，还没有完成，当这个操作完成之后，就执行回调函数on_response()中的self.render(“sleep.html”)，并关闭连接self.finish()。
异步版本二
#coding:utf-8import tornado.webimport tornado.httpserverimport tornado.optionsimport tornado.ioloopimport tornado.genfrom tornado.options import options , definedefine("port",default=8001,help="跑在8001",type=int)import timeclass SleepHandler(tornado.web.RequestHandler): @tornado.gen.coroutine def get(self): #使用yield得到了一个生成器，先把流程挂起，等完全完毕，再唤醒继续执行。另，生成器都是异步的。 yield tornado.gen.Task(tornado.ioloop.IOLoop.instance().add_timeout, time.time() + 5) self.write("this is SleepHandler...")class DirectHandler(tornado.web.RequestHandler): def get(self): self.write("this is DirectHandler...")if __name__ == "__main__": tornado.options.parse_command_line() app = tornado.web.Application( handlers = [ (r"/d",DirectHandler), (r"/s",SleepHandler), ], debug = False ) http_server = tornado.httpserver.HTTPServer(app) http_server.bind(options.port) http_server.start(1) tornado.ioloop.IOLoop.instance().start()