欧美一区二区三区老妇人-欧美做爰猛烈大尺度电-99久久夜色精品国产亚洲a-亚洲福利视频一区二区

Tornado學(xué)習(xí)筆記Tornado基礎(chǔ)1-創(chuàng)新互聯(lián)

內(nèi)容原子官方文檔：

成都一家集口碑和實(shí)力的網(wǎng)站建設(shè)服務(wù)商，擁有專業(yè)的企業(yè)建站團(tuán)隊(duì)和靠譜的建站技術(shù)，10年企業(yè)及個(gè)人網(wǎng)站建設(shè)經(jīng)驗(yàn) ,為成都上千余家客戶提供網(wǎng)頁(yè)設(shè)計(jì)制作,網(wǎng)站開發(fā),企業(yè)網(wǎng)站制作建設(shè)等服務(wù),包括成都營(yíng)銷型網(wǎng)站建設(shè)，成都品牌網(wǎng)站建設(shè)，同時(shí)也為不同行業(yè)的客戶提供網(wǎng)站設(shè)計(jì)制作、網(wǎng)站設(shè)計(jì)的服務(wù),包括成都電商型網(wǎng)站制作建設(shè),裝修行業(yè)網(wǎng)站制作建設(shè)，傳統(tǒng)機(jī)械行業(yè)網(wǎng)站建設(shè),傳統(tǒng)農(nóng)業(yè)行業(yè)網(wǎng)站制作建設(shè)。在成都做網(wǎng)站,選網(wǎng)站制作建設(shè)服務(wù)商就選創(chuàng)新互聯(lián)建站。

 Tornado基礎(chǔ)

Tornado是一套web框架和異步網(wǎng)絡(luò)功能庫(kù)，使用非阻塞式IO，可支持?jǐn)?shù)萬個(gè)活動(dòng)連接。支持長(zhǎng)活躍連接，支持 long polling長(zhǎng)連接，支持WebSockets。

A web framework (including RequestHandler which is subclassed to create web applications, and various supporting classes).

  • Client- and server-side implementions of HTTP (HTTPServer and AsyncHTTPClient).

  • An asynchronous networking library (IOLoop and IOStream), which serve as the building blocks for the HTTP components and can also be used to implement other protocols.

  • A coroutine library (tornado.gen) which allows asynchronous code to be written in a more straightforward way than chaining callbacks.

●一個(gè)web框架，包含RequestHandler 用于創(chuàng)建web應(yīng)用程序。

●客戶端和服務(wù)端HTTP實(shí)現(xiàn)（HTTPServer and AsyncHTTPClient）。

●異步網(wǎng)絡(luò)庫(kù)(IOLoop and IOStream)，可以用來建立HTTP組件，還可以實(shí)現(xiàn)其他協(xié)議。

●一個(gè)協(xié)程庫(kù) (tornado.gen)，可允許比鏈?zhǔn)交卣{(diào)地更加直接地編寫使用異步代碼。

Tornado可以作為WSGI容器，也可以被包含在其他WSGI容器。

的幾種異步接口：

  • Callback argument

  • Return a placeholder (Future, Promise, Deferred)

  • Deliver to a queue

  • Callback registry (e.g. POSIX signals)

●回調(diào)參數(shù)

●返回一個(gè)占位類 (Future, Promise, Deferred)

●遞交到隊(duì)列

●回調(diào)注冊(cè)（例如POSIX信號(hào)）

同步方式的代碼示例：

from tornado.httpclient import HTTPClientdef synchronous_fetch(url):
    http_client = HTTPClient()
    response = http_client.fetch(url)
    return response.body

回調(diào)方式的示例代碼：

from tornado.httpclient import AsyncHTTPClientdef asynchronous_fetch(url, callback):
    http_client = AsyncHTTPClient()
    def handle_response(response):
        callback(response.body)
    http_client.fetch(url, callback=handle_response)

使用Future的示例代碼：

from tornado.concurrent import Futuredef async_fetch_future(url):
    http_client = AsyncHTTPClient()
    my_future = Future()
    fetch_future = http_client.fetch(url)
    fetch_future.add_done_callback(
        lambda f: my_future.set_result(f.result()))
    return my_future

使用gen和協(xié)程方式的實(shí)例代碼：

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

Coroutines 協(xié)程

另一個(gè)gen和協(xié)程的實(shí)現(xiàn)代碼：

from tornado import gen@gen.coroutinedef fetch_coroutine(url):
    http_client = AsyncHTTPClient()
    response = yield http_client.fetch(url)
    return response.body

包含yield的函數(shù)是一個(gè)generator，它是異步的，返回generator對(duì)象無需等到運(yùn)行完成。

def run(self):
    # send(x) makes the current yield return x.
    # It returns when the next yield is reached
    future = self.gen.send(self.next)
    def callback(f):
        self.next = f.result()
        self.run()
    future.add_done_callback(callback)

協(xié)程調(diào)用模式

 和回調(diào)交互：將調(diào)用包裹在Task中，可以返回一個(gè)Future對(duì)象，并加入回調(diào)的參數(shù)。

@gen.coroutinedef call_task():
    # Note that there are no parens on some_function.
    # This will be translated by Task into
    #   some_function(other_args, callback=callback)
    yield gen.Task(some_function, other_args)

 調(diào)用阻塞函數(shù)：使用ThreadPoolExecutor，可以返回和協(xié)程兼容的Future。

thread_pool = ThreadPoolExecutor(4)

@gen.coroutine
def call_blocking():
    yield thread_pool.submit(blocking_func, args)

 并行執(zhí)行：協(xié)程裝飾器能識(shí)別類型為Futures的列表和字典，并且等待所有這些Future并行執(zhí)行完成

@gen.coroutine
def parallel_fetch(url1, url2):
    resp1, resp2 = yield [http_client.fetch(url1),
                          http_client.fetch(url2)]@gen.coroutinedef parallel_fetch_many(urls):
    responses = yield [http_client.fetch(url) for url in urls]
    # responses is a list of HTTPResponses in the same order@gen.coroutinedef parallel_fetch_dict(urls):
    responses = yield {url: http_client.fetch(url)
                        for url in urls}
    # responses is a dict {url: HTTPResponse}

 交替執(zhí)行：有些時(shí)候需要保存Future而不是讓他立即執(zhí)行，可以在等待時(shí)開始一個(gè)新的操作

@gen.coroutinedef get(self):
    fetch_future = self.fetch_next_chunk()
    while True:
        chunk = yield fetch_future
        if chunk is None: break
        self.write(chunk)
        fetch_future = self.fetch_next_chunk()
        yield self.flush()

 循環(huán)：需要從訪問的結(jié)果拆解循環(huán)條件，類似在Motor中的用法

import motordb = motor.MotorClient().test
@gen.coroutine
def loop_example(collection):
    cursor = db.collection.find()
    while (yield cursor.fetch_next):
        doc = cursor.next_object()

基本程序結(jié)構(gòu)

from tornado.ioloop import IOLoop
from tornado.web import RequestHandler, Application, url

class HelloHandler(RequestHandler):
    def get(self):
        self.write("Hello, world")def make_app():
    return Application([
        url(r"/", HelloHandler),
        ])
    def main():
       app = make_app()
       app.listen(8888)
       IOLoop.current().start()

Application和路由

class MainHandler(RequestHandler):
    def get(self):
        self.write('<a href="%s">link to story 1</a>' %
                   self.reverse_url("story", "1"))class StoryHandler(RequestHandler):
    def initialize(self, db):
        self.db = db

    def get(self, story_id):
        self.write("this is story %s" % story_id)
        
app = Application([
    url(r"/", MainHandler),
    url(r"/story/([0-9]+)", StoryHandler, dict(db=db), name="story")
    ])

 處理輸入請(qǐng)求

 可以使用get_query_argument and get_body_argument方法，獲取get或表單的數(shù)據(jù)

class MyFormHandler(RequestHandler):
    def get(self):
        self.write('<html><body><form action="/myform" method="POST">'
                   '<input type="text" name="message">'
                   '<input type="submit" value="Submit">'
                   '</form></body></html>')
    def post(self):
        self.set_header("Content-Type", "text/plain")
        self.write("You wrote " + self.get_body_argument("message"))

如果數(shù)據(jù)是json方式的

def prepare(self):
    if self.request.headers["Content-Type"].startswith("application/json"):
        self.json_args = json.loads(self.request.body)
    else:
        self.json_args = None

覆蓋RequestHandler 中的方法

write_error - 輸出HTML的錯(cuò)誤頁(yè)面。

  • on_connection_close - 客戶端斷開連接時(shí)調(diào)用; 應(yīng)用程序可以檢測(cè)這種情況 并終止后續(xù)的處理。 注意不能保證連接斷開的檢測(cè)是準(zhǔn)確的。

  • get_current_user - 參看 User authentication （用戶授權(quán)）

  • get_user_locale - 返回 Locale 對(duì)象給當(dāng)前的用戶

  • set_default_headers - 可以用于設(shè)置附加的html相應(yīng)頭  (例如自定義Server 頭)

錯(cuò)誤處理

RequestHandler.write_error　用來產(chǎn)生一個(gè)錯(cuò)誤頁(yè)。

  tornado.web.HTTPError用來產(chǎn)生錯(cuò)誤狀態(tài)碼。

重定向

 可以通過兩種方式實(shí)現(xiàn)重定向。

 RequestHandler.redirect and with theRedirectHandler.

 RedirectHandler用于配置重定向在路由中。

app = tornado.web.Application([
    url(r"/app", tornado.web.RedirectHandler,
        dict(url="http://itunes.apple.com/my-app-id")),
    ])

支持正則表達(dá)式

app = tornado.web.Application([
    url(r"/photos/(.*)", MyPhotoHandler),
    url(r"/pictures/(.*)", tornado.web.RedirectHandler,
        dict(url=r"/photos/\1")),
    ])

異步處理

異步處理通常可以使用兩種形式：

 coroutine 裝飾器 + yield關(guān)鍵字

tornado.web.asynchronous裝飾器 + callback ，請(qǐng)求會(huì)一直保持打開，callback完成返回時(shí)調(diào)用RequestHandler.finish ，響應(yīng)這時(shí)再發(fā)出

callback模式的示例，使用內(nèi)置的AsyncHTTPClient:

class MainHandler(tornado.web.RequestHandler):
    @tornado.web.asynchronous
    def get(self):
        http = tornado.httpclient.AsyncHTTPClient()
        http.fetch("http://friendfeed-api.com/v2/feed/bret",
                   callback=self.on_response)

    def on_response(self, response):
        if response.error: raise tornado.web.HTTPError(500)
        json = tornado.escape.json_decode(response.body)
        self.write("Fetched " + str(len(json["entries"])) + " entries "
                   "from the FriendFeed API")
        self.finish()

協(xié)程模式的示例：

class MainHandler(tornado.web.RequestHandler):
    @tornado.gen.coroutine
    def get(self):
        http = tornado.httpclient.AsyncHTTPClient()
        response = yield http.fetch("http://friendfeed-api.com/v2/feed/bret")
        json = tornado.escape.json_decode(response.body)
        self.write("Fetched " + str(len(json["entries"])) + " entries "
                   "from the FriendFeed API")

另外有需要云服務(wù)器可以了解下創(chuàng)新互聯(lián)scvps.cn，海內(nèi)外云服務(wù)器15元起步，三天無理由+7*72小時(shí)售后在線，公司持有idc許可證，提供“云服務(wù)器、裸金屬服務(wù)器、高防服務(wù)器、香港服務(wù)器、美國(guó)服務(wù)器、虛擬主機(jī)、免備案服務(wù)器”等云主機(jī)租用服務(wù)以及企業(yè)上云的綜合解決方案，具有“安全穩(wěn)定、簡(jiǎn)單易用、服務(wù)可用性高、性價(jià)比高”等特點(diǎn)與優(yōu)勢(shì)，專為企業(yè)上云打造定制，能夠滿足用戶豐富、多元化的應(yīng)用場(chǎng)景需求。

分享文章：Tornado學(xué)習(xí)筆記Tornado基礎(chǔ)1-創(chuàng)新互聯(lián)
本文來源：http://www.chinadenli.net/article48/dpojep.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供微信公眾號(hào)、網(wǎng)站收錄、靜態(tài)網(wǎng)站、App設(shè)計(jì)、企業(yè)網(wǎng)站制作、全網(wǎng)營(yíng)銷推廣

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請(qǐng)盡快告知，我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng)，如需處理請(qǐng)聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時(shí)需注明來源： 創(chuàng)新互聯(lián)

成都做網(wǎng)站