调用asyncio.StreamReader.read()会触发哪些异常？如何获取相关信息？

我正在用asyncio开发TCP服务器，想要给代码添加异常处理逻辑，比如下面这段示例：

try:
    data = await reader.read(SERVER_IO_BUFFER_SIZE)
except SomeError:
    # 错误处理逻辑

我查阅了asyncio官方文档，但没找到StreamReader.read()方法可能触发的异常相关信息，请问该如何获取这些异常信息？

作为经常处理asyncio网络开发问题的开发者，我给你几个实用的思路：

首先，StreamReader.read()的异常其实和底层IO操作、asyncio的任务调度密切相关，官方文档没列全的话，可以从这几个方向入手：

• 从依赖组件推导常见异常：

  • ConnectionResetError：客户端突然断开连接时大概率会触发这个错误
  • ConnectionAbortedError：连接被主动中止（比如系统层面关闭连接）时抛出
  • asyncio.CancelledError：如果当前读取任务被cancel()调用取消，会触发这个异常
  • OSError：涵盖其他底层IO相关的错误，比如文件描述符失效、权限问题等

• 实际模拟异常场景测试：
  手动制造一些异常场景，比如在读取过程中强制断开客户端连接、调用任务的取消方法，然后捕获并查看抛出的异常类型，这是最直观的方式。

• 查看CPython源码：
  你可以去看asyncio模块的streams.py源码，StreamReader.read()最终会调用底层的读取逻辑，里面会明确抛出哪些异常，这是最权威的信息来源。

• 调试阶段捕获通用异常排查：
  在开发调试时，可以先捕获所有Exception，打印异常的类型和详情，等明确了具体会遇到的异常后，再替换成针对性的捕获：

try:
    data = await reader.read(SERVER_IO_BUFFER_SIZE)
except Exception as e:
    print(f"捕获到异常: {type(e).__name__} - {str(e)}")
    # 后续根据实际捕获的异常类型调整处理逻辑

内容的提问来源于stack exchange，提问作者임근영