一步步疑难解析 —— 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

主要思路：

完整代码：

步骤解析