python asyncio构建服务器

image.png asyncio

asyncio是Python 3.4版本引入的标准库，直接内置了对异步IO的支持。

asyncio 是用来编写 并发 代码的库，使用 async/await 语法。

asyncio 被用作多个提供高性能 Python 异步框架的基础，包括网络和网站服务，数据库连接库，分布式任务队列等等。

asyncio 往往是构建 IO 密集型和高层级 结构化 网络代码的最佳选择。

asyncio 提供一组 API 用于:

• 并发地运行Python协程并对其执行过程实现完全控制
• 执行 网络 IO 和 IPC
• 控制子进程
• 通过队列实现分布式任务
• 同步并发代码;

使用介绍

关于asyncio的一些关键字的说明：

1. event_loop 事件循环：程序开启一个无限循环，把一些函数注册到事件循环上，当满足事件发生的时候，调用相应的协程函数
2. coroutine 协程：协程对象，指一个使用async关键字定义的函数，它的调用不会立即执行函数，而是会返回一个协程对象。
   

   
   

   协程对象需要注册到事件循环，由事件循环调用。
   

   
   

3. task 任务：一个协程对象就是一个原生可以挂起的函数，任务则是对协程进一步封装，其中包含了任务的各种状态
4. future: 代表将来执行或没有执行的任务的结果。
   

   
   

   它和task上没有本质上的区别

5. async/await 关键字：python3.5用于定义协程的关键字，async定义一个协程，await用于挂起阻塞的异步调用接口。
   

   
   

实际使用 获取事件循环

函数	说明
asyncio.get_running_loop()	获取当前运行的事件循环首选函数
asyncio.get_event_loop()	获得一个事件循环实例(当前或通过策略)
asyncio.set_event_loop()	通过当前策略将事件循环设置当前事件循环
asyncio.new_event_loop()	创建一个新的事件循环

代码：

import time
import asyncio

# 定义异步函数
async def hello():
    asyncio.sleep(1)
    print('Hello World:%s' % time.time())

def run():
    for i in range(5):
        loop.run_until_complete(hello())

loop = asyncio.get_event_loop()
if __name__ =='__main__':
    run()

运行效果：

image.png

更多的使用参考官网。

Ｏ(∩＿∩)Ｏ

参考

asyncioasyncio API

image.png