python 异步socket编程

asyncio

说起python异步编程肯定离不开这个包了，据说是python史上最具野心的库之一，采用事件循环驱动的协程实现并发，个人理解和epoll里边的I/O复用很类似，官方中文文档，下面来简单入门一下这个库的使用，此次项目最终源码请戳https://github.com/JanMCHEN/async_ftp

coroutine

协程，通过 async/await 语法进行声明，如下定义一个协程：

import asyncio


async def corou1():
	"""被async修饰的函数都是协程函数，且返回一个协程对象，并推荐用async声明一个协程
	await只能用在协程里并且后边要接一个可等待对象，和普通函数yield from有些类似"""
	await asyncio.sleep(1)		# awaitable
def gen():
	"""普通函数"""
	yield from 'abcd'      # 可迭代对象
print(type(corou1(), type(gen()))
# out:<class 'coroutine'> <class 'generator'>
# 并且有一个警告该协程没有被等待，这个等下在讨论
# 现在协程还没有运行起来，就好比生成器还没有产出值，等待被激活，主要用到以下方式

# 1 await,此时corou2启动corou1也会启动
async def corou2():
	await corou1()
	
# 2 asyncio.create_task(coro) 
# 此函数用来并发运行作为 asyncio 任务 的多个协程。
# 将 coro 协程 打包为一个 Task 排入日程准备执行。返回 Task 对象。
async def main():
	task1 = asyncio.create_task(corou1(
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23