tornado异步请求的理解（转）

太过爱你忘了你带给我的痛 2021-11-10 03:28 263阅读 0赞

## tornado异步请求的理解 ##

http://www.kankanews.com/ICkengine/archives/88953.shtml

[官网][Link 1]第一段话：

> Tornado is a Python web framework and `asynchronous` networking library, originally developed at FriendFeed. By using non-blocking network I/O, Tornado can scale to tens of thousands of open connections, making it ideal for long polling, WebSockets, and other applications that require a long-lived connection to each user.

翻译理解一下：Tornado是一个python实现的web框架，是`异步网络请求包`，起源于friendFeed; 是`无阻塞网络I/O`, Tornado可以很好处理成千上万的连接（C10K）；处理轮询，webSockets和其他应用长连接等请求

个人理解异步网络等同于无阻塞网络

在官网中提供的一个Hello world的这个Demo中，是`不支持异步`的，只有在使用`@tornado.web.asynchronous`这个装饰器的时候才能算的上真正异步；参考[博客][Link 2]

在blog中还有一个装饰`@tornado.gen.coroutine`这个装饰器是干什么的呢?? 查看tornado源码在gen.py中   
For example, the following asynchronous handler::

class AsyncHandler(RequestHandler):                                             
        @asynchronous                                                                                                                                       
        def get(self):                                                              
            http_client = AsyncHTTPClient()                                         
            http_client.fetch("http://example.com",                                 
                              callback=self.on_fetch)                               
    
        def on_fetch(self, response):                                               
            do_something_with_response(response)                                    
            self.render("template.html")
            self.finish()

从上面的代码可以看出在使用`@asynchronous`的时候，而且需要注意的是 Tornado默认在函数处理返回时关闭客户端的连接,但是当你使用@tornado.web.asynchonous装饰器时，Tornado永远不会自己关闭连接，需要显式的`self.finish()`关闭;每次需要一个显示命名一个callBack方法，为了`省略`写这个方法和   
`self.finish()`，

就有如下的代码:

### Future方式： ###

class GenAsyncHandler(RequestHandler):                                          
        @asynchronous                                                               
        @gen.coroutine                                                              
        def get(self):                                                              
            http_client = AsyncHTTPClient()                                         
            response = yield http_client.fetch("http://example.com")                
            do_something_with_response(response)                                    
            self.render("template.html")

### Task方式： ###

class GenAsyncHandler2(RequestHandler):                                      
        @asynchronous                                                            
        @gen.coroutine                                                           
        def get(self):                                                           
            http_client = AsyncHTTPClient()                                      
            http_client.fetch("http://example.com", callback=(yield gen.Callback("key")) # 1                                                                                        
            response = yield gen.Wait("key")                                             # 2
            do_something_with_response(response)                                 
            self.render("template.html")

并且`@gen.coroutine`和`yield`都是配对使用的

### Task方式改良版： ###

细看gen.py注释文档我们会发现还有一种方式可以省略装饰器`@asynchronous`和简化\#1和\#2代码, 使用gen.Task

@gen.coroutine                                                               
    def get(self):                                                               
         yield gen.Task(AsyncHTTPClient().fetch, "http://example.com")#替换上面的#1和#2

### 一次异步多个请求，适用于Future和Task版， 以下是Future版本 ###

@gen.coroutine                                                               
    def get(self):                                                               
        http_client = AsyncHTTPClient()                                          
        response1, response2 = yield [http_client.fetch(url1),                   
                                      http_client.fetch(url2)]

自己理解，仅供参考；

声明：OSCHINA 博客文章版权属于作者，受法律保护。未经作者同意不得转载。

No tags for this post.

除非注明，本站文章均为原创或编译，转载请注明： 文章来自 [KENGINE | Kankanews.com][KENGINE _ Kankanews.com]

转载于:https://www.cnblogs.com/DjangoBlog/p/4058948.html

[Link 1]: http://www.tornadoweb.org/en/stable/
[Link 2]: http://www.dongwm.com/archives/shi-yong-tornadorang-ni-de-qing-qiu-yi-bu-fei-zu-sai/
[KENGINE _ Kankanews.com]: http://www.kankanews.com/ICkengine/archives/88953.shtml