(这篇文章主要写一下在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表达式