一步步疑難解析 —— Python 異步編程構建博客

聲明：該項目學習資源主要來自廖雪峯的Python教程，參見

http://www.liaoxuefeng.com/wiki/0014316089557264a6b348958f449949df42a6d3a2e542c000

和Pythong官方文檔，參見

https://pypi.python.org/pypi

 

 

第一步，搭建開發環境

所需第三方庫：

　　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

　　

 

第三步，編寫ORM

主要思路：

完整代碼：

步驟解析