(这篇文章主要写一下在tornado项目中写异步代码,但是对源码理解不了,写给自己看)
当初做项目的时候,我选择了facebook的开源框架tornado,首先在项目中有一些比较耗时或者远程调用的逻辑,另外是它的高性能,加上以前自己做个人的东西,算是熟悉,最好名字很酷
1.为什么要写异步代码,在项目中有这样一个需求,需要调用第三方短信平台发送用户的短信注册码,对于这种远程调用api的业务写异步代码可能比同步要好了。
tornado对异步代码做了处理,使用装饰器和异步客户端就会改变传统的callback回调方式,像写同步代码一样写异步代码了。装饰器@gen.coroutine，在tornado3.0以前使用@gen.engine 。异步客户端tornado.httpclient.AsyncHTTPClient(). 先上代码
class SMS_bechtech:
@gen.coroutine #1.异步装饰器
def send_sms(self, pnumber, temp, temp_param ,msgTemplate=None) :
content = '尊敬的%s用户，%s是您本次的验证码，感谢您的使用！【xxxxx】'%(
str(temp_param['pnumber']), str(temp_param['vc']))
try:
h = tornado.httpclient.AsyncHTTPClient() #2.异步客户端
params = urllib.urlencode( {'accesskey': 'xxxxx
, 'secretkey':'xxxxx'
, 'mobile': str(pnumber)
, 'content' : content})
h_response = yield h.fetch('http://sms.bechtech.cn/Api/send/data/json?%s'%(params)) #3.远程调用
result = int(json.loads(h_response.body).get("result"))
except Exception as e:
logging.exception('SMS_bechtech send sms.')
raise ecode.SMS_REQ_API_ERROR
''
主要关注斜体的部分就好了,关键三步
@gen.coroutine #1.异步装饰器
看源码coroutine函数调用_make_coroutine_wrapper(func, replace_callback)函数 我想IOLoop.current().add_future(future, lambda future: callback(future.result())) 将回调函数注册到了ioloop的_callback事件列表中去了，此时进程不会处于挂起或者就绪状态等待IO,依然可以处理其他请求。
还要调用Runner(result, future, yielded) 在Runner构造函数中调用了run()函数，yielded = self.gen.send(value) 通过send把参数传递给yield表达式
需要注意的是使用异步装饰器, 还要是用异步的客户端, 保证这2点才能保证请求是异步的, 比如函数中tornado.httpclient.AsyncHTTPClient()是http的异步客户端, 还有比如motor的mongodb客户端, 还有mysql等等实现的异步客户端
