asyncio創建協程解析——分析廖雪峰的Python教程之創建WEB服務（轉）

第一步，搭建開發環境

所需第三方庫：

　　aiohttp，異步 Web 開發框架；jinja2，前端模板引擎；aiomysql，異步 mysql 數據庫驅動

所需內置庫：

　　logging，系統日志；asyncio，異步IO；os，系統接口；json，json 編碼解碼模塊；time，系統時間模塊；datetime，日期模塊

　　接下來僅對用到的功能進行講解

第二步，構建 Web 框架

主要思路：

　　理解 asyncio、aiohttp 基本應用

　　使用 asyncio 異步 IO 模塊創建服務協程，監聽相應端口

　　使用 aiohttp 異步 Web 開發框架，處理 HTTP 請求，構建並返回 HTTP 響應

完整代碼：

import logging; 
logging.basicConfig(level=logging.INFO)
import asyncio, os, json, time
from datetime import datetime
from aiohttp import web

def index(request):
    return web.Response(body=b'<h1>My Bolg</h1>')

@asyncio.coroutine
def init(loop):
    app = web.Application(loop=loop)
    app.router.add_route('GET', '/', index)
    srv = yield from loop.create_server(app.make_handler(), '127.0.0.1', 9000)
    logging.info('server started at http://127.0.0.1:9000...')
    return srv

loop = asyncio.get_event_loop()
loop.run_until_complete(init(loop))
loop.run_forever()

CompleteCode

步驟解析：

一，編寫處理函數：

def index(request):
    return web.Response(body=b'<h1>My Bolg</h1>')

1.函數名隨意取。該函數的作用是處理URL，之后將與具體URL綁定

　　2.參數，aiohttp.web.request實例，包含了所有瀏覽器發送過來的 HTTP 協議里面的信息，一般不用自己構造

　　   具體文檔參見 http://aiohttp.readthedocs.org/en/stable/web_reference.html

　　3.返回值，aiohttp.web.response實例，由web.Response(body='')構造，繼承自StreamResponse，功能為構造一個HTTP響應

　　   類聲明 class aiohttp.web.Response(*, status=200, headers=None, content_type=None, body=None, text=None)

　　4.HTTP 協議格式為： POST /PATH /1.1 /r/n Header1:Value  /r/n .. /r/n HenderN:Valule /r/n Body:Data

 二，創建Web服務器，並將處理函數注冊進其應用路徑(Application.router)

app = web.Application(loop=loop)
app.router.add_route('GET', '/', index)

1.創建Web服務器實例app，也就是aiohttp.web.Application類的實例，該實例的作用是處理URL、HTTP協議

　　　　1.1 Application，構造函數 def __init__(self, *, logger=web_logger, loop=None,

　　　　　　　　　 　　　　　　　　　　　　　router=None, handler_factory=RequestHandlerFactory,
　　　　　　　　    　　　　　　　　　　　　　middlewares=(), debug=False):

　　　　1.2使用app時，首先要將URLs注冊進router，再用aiohttp.RequestHandlerFactory 作為協議簇創建套接字 

　　　　1.3 aiohttp.RequestHandlerFactory 可以用 make_handle() 創建，用來處理 HTTP 協議，接下來將會看到

 　　2.將處理函數注冊到創建app.router中

　　　　2.1 router，默認為UrlDispatcher實例，UrlDispatcher類中有方法add_route(method, path, handler, *, name=None, expect_handler=None)，該方法將處理函數（其參數名為handler）與對應的URL（HTTP方法metho，URL路徑path）綁定，瀏覽器敲擊URL時返回處理函數的內容

 

三，用協程創建監聽服務，並使用aiohttp中的HTTP協議簇(protocol_factory)

srv = yield from loop.create_server(app.make_handler(), '127.0.0.1', 9000)

1.用協程創建監聽服務，其中loop為傳入函數的協程，調用其類方法創建一個監聽服務，聲明如下

　　 coroutine BaseEventLoop.create_server(protocol_factory, host=None, port=None, *, family=socket.AF_UNSPEC, flags=socket.AI_PASSIVE, sock=None, backlog=100, ssl=None, reuse_address=None, reuse_port=None)

　　2.yield from 返回一個創建好的，綁定IP、端口、HTTP協議簇的監聽服務的協程。yield from的作用是使srv的行為模式和 loop.create_server()一致

 

四，創建協程，初始化協程，返回監聽服務，進入協程執行

loop = asyncio.get_event_loop()
loop.run_until_complete(init(loop))
loop.run_forever()

1.創建協程，loop = asyncio.get_event_loop()，為asyncio.BaseEventLoop的對象，協程的基本單位。

　　2.運行協程，直到完成，BaseEventLoop.run_until_complete(future)

　　3.運行協程，直到調用 stop()，BaseEventLoop.run_forever()

五，補充說明

　　1.app，Application

　　2.loop，WindowsSelectEventLoop

　　3.srv，SocketSever