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