底层服务器

这一节介绍了aiohttp.web的基础底层服务器。

抽象基础

有时候用户不需要更高级的封装,像是 application,routers和signals。
只是需要一个支持异步调用并且是接受请求返回响应对象的东西。
在aiohttp.web.Server类中有介绍过一个服务协议工厂——asyncio.AbstractEventLoop.create_server(),并可以将数据流桥接到web处理器以及反馈结果。
底层web处理器应该接收单个BaseRequest参数并且执行下列中的其中一个:

  1. 返回一个包含HTTP响应体的响应对象。
  2. 创建一个StreamResponse对象,然后可以调用StreamResponse.prepare()发送头信息,调用StreamResponse.write() / StreamResponse.drain()发送数据块,最后结束响应。
  3. 抛出HTTPException派生的异常(看Exception部分)。
  4. 使用WebSocketResponse发起/处理Web-Socket连接。

运行基础底层服务器

请看下列代码:

  1. import asyncio
  2. from aiohttp import web
  3. async def handler(request):
  4. return web.Response(text="OK")
  5. async def main(loop):
  6. server = web.Server(handler)
  7. await loop.create_server(server, "127.0.0.1", 8080)
  8. print("======= Serving on http://127.0.0.1:8080/ ======")
  9. # pause here for very long time by serving HTTP requests and
  10. # waiting for keyboard interruption
  11. await asyncio.sleep(100*3600)
  12. loop = asyncio.get_event_loop()
  13. try:
  14. loop.run_until_complete(main(loop))
  15. except KeyboardInterrupt:
  16. pass
  17. loop.close()

这样我们有了一个返回”OK”标准响应的处理器。

这个处理器经由服务器调用。调用loop.create_server创建的网络交流通道,随后可以访问http://127.0.0.1:8080/来查看。
这个处理器可以接受所有的请求: 不论GET, POST, Web-Socket都可以,无论哪一个路径的访问也都同样由其处理。
不过也同样很基础: 无论如何处理器都只返回200 OK。实际生活中所产生的状态要复杂的多。