• <ins id="pjuwb"></ins>
    <blockquote id="pjuwb"><pre id="pjuwb"></pre></blockquote>
    <noscript id="pjuwb"></noscript>
          <sup id="pjuwb"><pre id="pjuwb"></pre></sup>
            <dd id="pjuwb"></dd>
            <abbr id="pjuwb"></abbr>

            Benjamin

            靜以修身,儉以養(yǎng)德,非澹薄無以明志,非寧靜無以致遠(yuǎn)。
            隨筆 - 397, 文章 - 0, 評(píng)論 - 196, 引用 - 0
            數(shù)據(jù)加載中……

            python Tornado異步客戶端


            AsyncHTTPClient是 tornado.httpclinet 提供的一個(gè)異步http客戶端。使用也比較簡單。與服務(wù)進(jìn)程一樣,AsyncHTTPClient也可以callback和yield兩種使用方式。前者不會(huì)返回結(jié)果,后者則會(huì)返回response。
            示例:
             1 class AsyncHandler(tornado.web.RequestHandler):
             2   @tornado.web.asynchronous
             3   def get(self, *args, **kwargs):
             4  
             5     url = 'https://api.github.com/'
             6     http_client = tornado.httpclient.AsyncHTTPClient()
             7     http_client.fetch(url, self.on_response)
             8     self.finish('It works')
             9  
            10   @tornado.gen.coroutine
            11   def on_response(self, response):
            12     print response.code
            同樣,為了獲取response的結(jié)果,只需要yield函數(shù)。使用yield的時(shí)候,handler是需要 tornado.gen.coroutine。
             1 class AsyncResponseHandler(tornado.web.RequestHandler):
             2   @tornado.web.asynchronous
             3   @tornado.gen.coroutine
             4   def get(self, *args, **kwargs):
             5  
             6     url = 'https://api.github.com/'
             7     http_client = tornado.httpclient.AsyncHTTPClient()
             8     response = yield tornado.gen.Task(http_client.fetch, url)
             9     print response.code
            10     print response.body

            如果業(yè)務(wù)處理并不是在handlers寫的,而是在別的地方,當(dāng)無法直接使用tornado.gen.coroutine的時(shí)候,可以構(gòu)造請(qǐng)求,使用callback的方式。
             1 body = urllib.urlencode(params)
             2 req = tornado.httpclient.HTTPRequest(
             3  url=url, 
             4  method='POST'
             5  body=body, 
             6  validate_cert=False) 
             7  
             8 http_client.fetch(req, self.handler_response)
             9  
            10 def handler_response(self, response):
            11  
            12   print response.code
            AsyncHTTPClient中的fetch方法,第一個(gè)參數(shù)其實(shí)是一個(gè)HTTPRequest實(shí)例對(duì)象,因此對(duì)于一些和http請(qǐng)求有關(guān)的參數(shù),例如method和body,可以使用HTTPRequest先構(gòu)造一個(gè)請(qǐng)求,再扔給fetch方法
             1  def getURL():
             2  2     # 接口地址
             3  3     url = "http://ip:port/Get2"
             4  4 
             5  5 
             6  6     payload = {"key":"914683196200","timestamp":"2019-07-11 11:27:21","partner_id":"1","sign":"C77CAAA496FE0D385410A"}
             7  7     # verify = False 忽略SSH 驗(yàn)證
             8  8 
             9  9       try:
            10             response = requests.post(url, json=payload, timeout=5)  # 超時(shí)的時(shí)候回報(bào)錯(cuò)并重試
            11             print(r.json())
            12         except ReadTimeout:
            13             # 超時(shí)異常
            14             print('Timeout')
            15             return 1
            16         except ConnectionError:
            17             # 連接異常
            18             print('Connection error')
            19             return 2
            20         except RequestException as e:
            21             # 請(qǐng)求異常
            22             print('Error')
            23             print('str(Exception):\t', str(Exception))
            24             print('str(e):\t\t', str(e))
            25             print('repr(e):\t', repr(e))
            注意:使用異步,必須tornado.ioloop.IOLoop.instance().start啟動(dòng) IOLoop 的實(shí)例,啟動(dòng)事件循環(huán)機(jī)制,配合非阻塞的 HTTP Server 工作
            callback_async

            posted on 2019-07-14 15:22 Benjamin 閱讀(463) 評(píng)論(0)  編輯 收藏 引用 所屬分類: python

            日韩人妻无码精品久久久不卡| 成人久久免费网站| 国产精品免费久久久久电影网| 久久精品成人免费观看97| 国产精品亚洲综合久久| 久久久久亚洲av无码专区| 亚洲欧美精品伊人久久| 久久精品国产2020| 国产精品丝袜久久久久久不卡 | 97久久综合精品久久久综合| 九九久久精品国产| 老色鬼久久亚洲AV综合| 欧美一级久久久久久久大片| 99热成人精品热久久669| 久久久无码精品亚洲日韩京东传媒| 国产美女久久久| 精产国品久久一二三产区区别| 9191精品国产免费久久| 久久久久久久亚洲Av无码| 一本色综合久久| 久久精品国产福利国产琪琪| 国产精品久久久久久久久鸭| 伊人久久大香线蕉综合影院首页| 久久e热在这里只有国产中文精品99| 国产综合久久久久| 麻豆AV一区二区三区久久| 综合网日日天干夜夜久久| 伊人精品久久久久7777| 久久午夜无码鲁丝片午夜精品| 青青草原综合久久大伊人精品| 久久w5ww成w人免费| 久久精品国产亚洲av水果派| 亚洲香蕉网久久综合影视| 久久久久久国产精品无码下载 | 亚洲精品无码久久一线| 看全色黄大色大片免费久久久| 精品久久人人妻人人做精品| 国产精品成人久久久久三级午夜电影 | 狠狠色丁香久久婷婷综合五月| 久久综合亚洲欧美成人| 久久亚洲精品成人AV|