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 響應

完整代碼：

 1 import logging; 
 2 logging.basicConfig(level=logging.INFO)
 3 import asyncio, os, json, time
 4 from datetime import datetime
 5 from aiohttp import web
 6 
 7 def index(request):
 8     return web.Response(body=b'<h1>My Bolg</h1>')
 9 
10 @asyncio.coroutine
11 def init(loop):
12     app = web.Application(loop=loop)
13     app.router.add_route('GET', '/', index)
14     srv = yield from loop.create_server(app.make_handler(), '127.0.0.1', 9000)
15     logging.info('server started at http://127.0.0.1:9000...')
16     return srv
17 
18 loop = asyncio.get_event_loop()
19 loop.run_until_complete(init(loop))
20 loop.run_forever()
21 
22 CompleteCode

View Code

步驟解析：

一，編寫處理函數：

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