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

步骤解析：一，编写处理函数：

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