• <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

            国产精品99久久久精品无码| 激情伊人五月天久久综合| 狠狠色伊人久久精品综合网| 久久精品国产99久久香蕉| 亚洲精品tv久久久久| 天天爽天天狠久久久综合麻豆| 久久国产精品无码一区二区三区| 久久99精品国产99久久6男男| 久久久久亚洲精品男人的天堂| 亚洲中文字幕无码久久综合网 | 狠色狠色狠狠色综合久久| 久久精品不卡| 久久99国产乱子伦精品免费| 成人亚洲欧美久久久久| 亚洲午夜久久久久久久久电影网| 久久精品国产亚洲一区二区| 亚洲人AV永久一区二区三区久久 | 精品久久久久久久中文字幕| 久久这里只精品99re66| 久久国产成人精品麻豆| 少妇人妻综合久久中文字幕| 狠狠精品久久久无码中文字幕 | 久久婷婷五月综合色奶水99啪| 无码AV中文字幕久久专区| 久久久久久久亚洲精品| 91精品国产91久久久久福利| 久久精品国产亚洲AV久| 欧美亚洲日本久久精品| 91精品日韩人妻无码久久不卡| 久久精品人人槡人妻人人玩AV| 亚洲国产小视频精品久久久三级| 狠狠久久综合伊人不卡| 国产成人精品久久亚洲| 久久亚洲精品中文字幕三区| 国产精品久久久久…| 99国产精品久久久久久久成人热| 亚洲AV无一区二区三区久久| 亚洲精品无码成人片久久| 久久国产精品无码HDAV| av无码久久久久不卡免费网站 | 久久久久亚洲av综合波多野结衣|