asyncio.start_server是处理万级tcp长连接最省心可靠的选择,因其内置事件循环调度、连接生命周期管理与协程隔离,避免手动处理select/epoll、缓冲区拆包及连接泄漏等底层陷阱。

asyncio.start_server 是处理万级 TCP 长连接最省心、最可靠的选择,不是因为它“高级”,而是它把连接生命周期、协程隔离、缓冲区管理这些容易出错的环节全包了——你只要写好 handle_client,剩下的交给事件循环。
为什么不能用裸 socket + setblocking(False) 撑长连接
手动用 socket.socket() 配 select/epoll 确实能做,但你会立刻撞上三类硬伤:
- 连接数一过千,
recv()返回空字节后要不要close()?漏关就是连接泄漏;多线程清理又得加锁,协程里根本不敢碰 - 客户端只发 2 字节就停,你
recv(1024)就永远卡住——asyncio 的StreamReader默认不阻塞,但你得选对读法 - 写数据时没调
await writer.drain(),TCP 发送缓冲区满了,writer.write()看似成功,其实对方永远收不到
asyncio.start_server 启动时最容易踩的参数坑
启动失败往往不是代码逻辑问题,而是传参姿势错了:
-
asyncio.start_server(handle_client(), ...)—— 错!括号会让函数立即执行,返回None,必须写成handle_client(无括号) - 不指定
host,默认只监听127.0.0.1,外部机器连不上;生产环境建议显式写host='0.0.0.0'或'::'(IPv6) -
backlog默认是 100,万级连接下新连接会被内核直接拒绝,现象是客户端报Connection refused;建议设为2048或更高 - 需要延迟启动(比如先加载配置再开服),用
start_serving=False,但之后必须显式调用await server.serve_forever()
handle_client 协程里怎么安全读写不卡死
长连接的核心不是“一直连着”,而是“连着时能及时响应又不饿死其他协程”。关键在读写方式:
- 别用
reader.read(1024)读固定长度:协议不保证每次发满,协程会挂起直到超时或 EOF - 按协议选读法:
reader.readline()(需换行符)、reader.readexactly(n)(提前知道包头长度)、reader.readuntil(b'\x00')(自定义分隔符) - 每次
writer.write(data)后,必须await writer.drain(),否则背压时内存持续上涨,OOM 风险极高 - 连接结束前务必
writer.close()+await writer.wait_closed(),否则 fd 泄漏,系统级资源耗尽
长连接场景下容易被忽略的边界点
真正跑通一个稳定万级长连接服务,最后卡住你的往往不是主逻辑,而是这几个细节:
- 心跳检测不能只靠
reader.read(...)超时:要配合asyncio.wait_for(reader.read(...), timeout=30),否则网络抖动时协程卡住,整个连接就僵死 - 客户端异常断开(如拔网线),
reader.read()会抛asyncio.IncompleteReadError,不是ConnectionResetError,漏捕获就导致协程退出、连接未清理 - 不要在
handle_client里用time.sleep()或任何同步阻塞调用,10ms 以上的 CPU 计算就会拖慢整个事件循环 - 如果服务端要主动推送消息,别在协程外存
writer并并发写——writer不是线程安全的,推送必须通过asyncio.create_task()调度进事件循环
Python免费学习笔记(深入):立即使用
在学习笔记中,你将探索 Python 的核心概念和高级技巧!











