tornado 非同步客戶端 AsyncHTTPClient

前面瞭解Tornado的非同步任務的常用做法，姑且歸結為非同步服務。通常在我們的服務內，還需要非同步的請求第三方服務。針對HTTP請求，Python的庫Requests是最好用的庫，沒有之一。官網宣稱：HTTP for Human。然而，在tornado中直接使用requests將會是一場惡夢。requests的請求會block整個服務程序。

上帝關上門的時候，往往回開啟一扇窗。Tornado提供了一個基於框架本身的非同步HTTP客戶端（當然也有同步的客戶端）— AsyncHTTPClient。

AsyncHTTPClient 基本用法

AsyncHTTPClient是 tornado.httpclinet 提供的一個非同步http客戶端。使用也比較簡單。與服務程序一樣，AsyncHTTPClient也可以callback和yield兩種使用方式。前者不會返回結果，後者則會返回response。

如果請求第三方服務是同步方式，同樣會殺死效能。

class SyncHandler(tornado.web.RequestHandler):
    def get(self, *args, **kwargs):

        url = 'https://api.github.com/'
        resp = requests.get(url)
        print
 
 resp.status_code

        self.finish('It works')

使用 AsyncHTTPClient
使用 yield協程 返回respond,這個雖然使用了非同步，但是掛起了任務，類似阻塞，少量還可以，大量效能就下降了

@tornado.gen.coroutine
    def AsyncGet(self, url,timeout=7):
        Authorization = self.__Create_AuthorizationText()
        headers = {'Content-Type': 'application/json'
 
,'Authorization': Authorization}
        http_client = tornado.httpclient.AsyncHTTPClient()
        resp = yield http_client.fetch(url,method='GET',headers=headers,request_timeout=timeout)
        raise tornado.gen.Return(resp.body)

所以callback的方式是效能最高的

    def AsyncPost(self, url, params,timeout=7):
        Authorization = self.__Create_AuthorizationText()
        headers = {'Content-Type': 'application/json', 'Authorization': Authorization}
        http_client = tornado.httpclient.AsyncHTTPClient()
        body = JsonHelper.encode(params)
        req = tornado.httpclient.HTTPRequest(
            url=url,
            method='POST',
            headers=headers,
            request_timeout=timeout,
            body=body,
            validate_cert=False)
        http_client.fetch(req, callback=self.handler_response)

    def AsyncGetClient(self, url,timeout=7):
        Authorization = self.__Create_AuthorizationText()
        headers = {'Content-Type': 'application/json','Authorization': Authorization}
        http_client = tornado.httpclient.AsyncHTTPClient()
        http_client.fetch(url,callback=self.handler_response,method='GET',headers=headers,request_timeout=timeout)
        # raise tornado.gen.Return(resp.body)

     def handler_response(self, response):
        print response.body
        self.log.info(response.body)

總結

通過AsyncHTTPClient的使用方式，可以輕鬆的實現handler對第三方服務的請求。結合前面關於tornado非同步的使用方式。無非還是兩個key。是否需要返回結果，來確定使用callback的方式還是yield的方式。當然，如果不同的函式都yield，yield也可以一直傳遞。這個特性，tornado的中的tornado.auth 裡面對oauth的認證。