【python】asyncio异步socket通信 | asyncio streams编写TCP通信 | asyncio.StreamReader读取长串数据_asyncio 通信

一、asyncio异步通信

学习博客/文档归类一下放在下面：

官方文档

简单易懂的例子+各个函数详解：Python 使用asyncio tcp
协程等概念解释+github实例：python 异步socket编程
官方文档翻译：asyncio异步IO——Streams详解
详细函数解释：Python asyncio 异步编程（三）

二、解决asyncio.StreamReader读取长串数据

StreamReader一些内部函数功能博主翻译/理解

最近用asyncio做了异步socket tcp通信，在使用asyncio.StreamReader对象读取数据时出现了一点问题。
首先一些基本代码都是学习网上的，客户端代码：

 reader, writer = await asyncio.open_connection(
        '127.0.0.1', 8888)
1
2

但我发现如果服务端给客户端发的信息过长，reader.read()函数就不起作用，虽然官网对这个函数的解释是参数什么都不写就会读取所有的数据。网络查了一下也只发现一个解决办法（图中他其实遇到了跟我一样的问题也就是一调用reader.read()就会永久阻塞，并不会返回什么接收到的数据）：

但是我一用yield就出错
后来想了想干脆用at_eof()这个函数吧，但怎么打印它都返回False也就缓冲区不为空。看官方文档对这个函数的解释：

如果缓冲区为空并且 feed_eof() 被调用，则返回 True 。

查了半天也没找到feed_eof()这个函数到底干什么用，但在at_eof()之前调用一下就解决一切问题了。

官网解释：
feed_eof()
Acknowledge the EOF.

具体代码：（但并没有解决根本原因，第一次对方发送消息可以正常接收，但之后发送消息就会报错feed_data after feed_eof的错）

async def recv_msg(self):
	while True:
		data = bytearray()
		while True:
			chunk = await self.reader.read(100)
			if not chunk:
				break
			data += chunk
			
			self.reader.feed_eof()
			if self.reader.at_eof():
				print(data)	#这里就是一个完整的接收数据了
1
2
3
4
5
6
7
8
9
10
11
12

这么一看if not chunk好像也能直接判断缓冲区是不是空的。。。。并且发现await self.reader.read(100)好像不会因为对方没发送数据它就一直阻塞，而是会一直读取一直读取。那await这个功能意义何在？
feed_of()这个函数的发现权当我减少运用了一次await self.reader.read(100)吧

上述问题的出现我归结于用了feed_eof()这个函数，我现在还不懂这个函数的作用。但不使用它之前我可以确定的是：

• at_eof()永远返回False

• await self.reader.read(100)会在对方没有发消息的时候一直阻塞，而不是不断返回None或之类
  所以之后我还是改用self.reader.read(100)这种低级的方法了，只能将参数改大，保证大于对方会发送的最长消息的字节数。如果以后需要传输文件的话就麻烦了需要再想想办法。但其实还有一个弱智办法是让对方先把文件大小传输过来，我再动态改变参数，应该是可行的。
  上述方法又产生一个问题，如果参数设置过大，对方发送信息又过快，接收消息会产生TCP粘包的情况，再找一个解决方法就是使用await self.reader.readuntil(seperator = b"\xFF\xFF")，让发送方在每条发送数据包的后面都加上这个seperator，亲测有效解决问题。

三、一些想整理的

客户端判断是否还有在连接服务器，可以用writer.is_closing()，把writer设为类的属性，这样在不同的async函数里都可以获取，以控制reader函数，或者说整个的循环连接服务器的函数得以在连接断了之后，或是直接退出函数执行，或是开始不断连接服务器

writer函数肯定是放在一个循环中不断写入消息的，这个循环一定要写个asyncio.sleep()，以时不时的暂停一下，不然有可能会陷入死循环。

reader函数则不用asyncio.sleep()，它的await self.reader.readuntil(...)会在消息来的时候才执行，不然就停滞在这里并把执行权力让给其他协程。

客户端/服务器的例子，完整的代码