我在tornado项目中写异步代码

(这篇文章主要写一下在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等等实现的异步客户端