Tornado中异步框架的使用

Posted 2023-01-05 shenjianping

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

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

一、Tornado中的同步框架

1、本站资源直接返回

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对象进行异步处理。

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

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()

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

二、Tornado中的异步框架

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

1、本站资源直接返回

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()

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

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