Tornado中异步框架的使用

tornado的同步框架与其余web框架相同都是处理先来的请求，若是先来的请求阻塞，那么后面的请求也会处理不了。一直处于等待过程当中。可是请求一旦获得响应，那么：

• 请求发送过来后，将须要的本站资源直接返回给客户端
• 请求发送过来后，本站没有须要的资源，从其它站点获取过来，再返回给客户端

1、Tornado中的同步框架

一、本站资源直接返回

import tornado.web import time class LoginHandler(tornado.web.RequestHandler): def get(self): time.sleep(10) #第一个请求来后等10s，后面的请求没法处理，只有等这个请求结束后才能处理其余的请求
        self.write('LoginHandler') def post(self): pass
 
class IndexHandler(tornado.web.RequestHandler): def get(self): self.write('IndexHandler') def post(self): pass application=tornado.web.Application([ (r'/login/',LoginHandler), (r'/index/', IndexHandler), ],) if __name__ == '__main__': application.listen(8888) tornado.ioloop.IOLoop.instance().start()

能够看到由于回调函数中阻塞了10s，因此后面的请求必须等这个回调函数结束后才能处理后面的请求，在tornado中使用future对象进行异步处理。

二、从其它站点获取资源再返回

import tornado.web import requests class LoginHandler(tornado.web.RequestHandler): def get(self): requests.get('http://www.baidu.com') #此时没法处理其它请求
        self.write('LoginHandler') def post(self): pass
 
class IndexHandler(tornado.web.RequestHandler): def get(self): self.write('IndexHandler') def post(self): pass application=tornado.web.Application([ (r'/login/',LoginHandler), (r'/index/', IndexHandler), ],) if __name__ == '__main__': application.listen(8888) tornado.ioloop.IOLoop.instance().start()

从其它站点获取资源的过程也是阻塞的，服务端处理不了其它请求，必须等这个请求处理完毕才能处理其它请求。

2、Tornado中的异步框架

对于上面的两种状况tornado也是有对策的，就是使用future对象，进行异步处理。

一、本站资源直接返回

import tornado.web from tornado import gen from tornado.concurrent import Future import time class LoginHandler(tornado.web.RequestHandler): @gen.coroutine def get(self): future=Future() tornado.ioloop.IOLoop.current().add_timeout(time.time()+10,self.done) #此处的10s延迟不会影响处理其它请求
        yield future def done(self,*args,**kwargs): self.write('LoginHandler') self.finish() def post(self): pass
 
class IndexHandler(tornado.web.RequestHandler): def get(self): self.write('IndexHandler') def post(self): pass application=tornado.web.Application([ (r'/login/',LoginHandler), (r'/index/', IndexHandler), ],) if __name__ == '__main__': application.listen(8888) tornado.ioloop.IOLoop.instance().start()

二、从其它站点获取资源再返回

import tornado.web from tornado import gen from tornado import httpclient class LoginHandler(tornado.web.RequestHandler): @gen.coroutine def get(self): http=httpclient.AsyncHTTPClient() yield http.fetch('http://www.google.com',self.done) #访问其它网址不能用requests,应该使用tornado内置的,其实质也是返回future对象
 
    def done(self,*args,**kwargs): self.write('LoginHandler') self.finish() def post(self): pass
 
class IndexHandler(tornado.web.RequestHandler): def get(self): self.write('IndexHandler') def post(self): pass application=tornado.web.Application([ (r'/login/',LoginHandler), (r'/index/', IndexHandler), ],) if __name__ == '__main__': application.listen(8888) tornado.ioloop.IOLoop.instance().start()

　　tornado解决异步请求就是利用future对象。future对象中设定默认参数result=None，若是在某一时刻future的result中被设定值了，那么它就会自动执行回调函数，实际上这种执行回调函数的功能就是所谓的异步，不须要服务器等待，本身自动执行完后会进行回调（注意这都是在一个线程中）。详情参考：https://www.cnblogs.com/shenjianping/p/11622210.html