Tornado异步之-协程与回调

Posted 2021-01-31 b02330224

回调处理异步请求

• 回调 callback 处理异步官方例子

# 导入所需库
from tornado.httpclient import AsyncHTTPClient

def asynchronous_fetch(url, callback):
    http_client = AsyncHTTPClient()
    def handle_response(response):
        callback(response.body)
    http_client.fetch(url, callback=handle_response)

• 当http_client处理请求时http_client.fetch(url, callback=handle_response),参数url是请求的url, 关键字参数callback传入方法handle_response 此方法即为回调方法, 就是说当http_client请求完成后才会调用callback=handle_response中的 handle_response函数.
• 请求网络是耗时操作,传入关键字参数callback来‘表明‘这是异步请求, 以此来确定这是异步处理请求

协程处理异步

from tornado import gen

@gen.coroutine
def fetch_coroutine(url):
    http_client = AsyncHTTPClient()
    response = yield http_client.fetch(url)
    raise gen.Return(response.body)

• @gen.coroutine此装饰器代表的是协程, 与关键字yield搭配使用
• http_client.fetch(url)请求网络是耗时操作, 通过关键字yield来挂起调用, 而当http_client.fetch(url)请求完成时再继续从函数挂起的位置继续往下执行.
• raise gen.Return(response.body)在python3.3以后作用相当于return, 在python3.3之前作用是返回一个异常值, 跟 返回一个value, 以及python3.3之前generators不可以return value, 所以tornado定义了一个特殊的返回值raise gen.Return.
• 在python3.3以后直接用return