讲师中心 微信公众号
AI工具推荐 视频效率加速

Python利用asyncio实现多路复用_高效处理多个套接字输入输出

千杰君_3451

千杰君_3451

发布时间:2026-03-21 12:38:32

|

949人浏览过

|

来源于php中文网

原创

asyncio.select() 不存在,应使用 asyncio.wait_for() 或 loop.add_reader()/add_writer() 等替代方案;推荐优先使用 asyncio.start_server() 处理多客户端。

python利用asyncio实现多路复用_高效处理多个套接字输入输出

asyncio.select() 不存在,别白费劲搜了

Python 的 asyncio 不提供 select()、epoll() 或 kqueue() 的直接封装——它自己在底层用这些机制,但不暴露给你。你写 asyncio.select(...) 会报 AttributeError,不是你环境没装好,是压根没这个函数。

真正该用的是 asyncio.wait_for() 配合 asyncio.create_connection() / asyncio.start_server(),或者更底层一点:用 loop.create_future() + loop.add_reader() / loop.add_writer() 手动注册套接字事件。

  • add_reader() 对应可读事件(比如客户端发来数据、服务端 accept 到新连接)
  • add_writer() 对应可写事件(比如 socket.send() 曾经阻塞,现在可以写了)
  • 这两个方法只接受已设为非阻塞的套接字,调用前必须执行 sock.setblocking(False)
  • 注册后,回调函数里要主动调用 loop.remove_reader(sock),否则下次就重复触发

用 asyncio.start_server() 处理多个 TCP 客户端最省心

如果你只是想同时收发多个 TCP 连接(比如做简单代理、日志转发、设备心跳),asyncio.start_server() 是默认推荐路径。它自动帮你把每个连接包装成独立协程,不用手动管理 fd 和事件循环注册。

常见误区是以为得自己 socket.listen() 再丢进 add_reader() ——那等于绕开 asyncio 的调度器,反而容易出错。

立即学习“Python免费学习笔记(深入)”;

python 查询技能
python 查询技能

查询客流数据,输出JSON格式,可直接导入Bitable等可视化工具

下载
  • 服务器启动后,每个客户端连接都会触发一次 client_connected_cb() 回调,传入 reader 和 writer 对象
  • reader.read(1024) 会挂起直到有数据或断连;writer.write(data) 不阻塞,但要记得 await writer.drain() 等缓冲区清空
  • 别在回调里直接 await 耗时操作(如数据库查询),会卡住整个事件循环;该扔到线程池的用 loop.run_in_executor()
async def handle_client(reader, writer):
    addr = writer.get_extra_info('peername')
    while True:
        data = await reader.read(1024)
        if not data:
            break
        writer.write(data.upper())
        await writer.drain()
    writer.close()

手动 add_reader() 时,fd 关闭顺序很关键

当你用 add_reader() 监听原始 socket(比如 UDP 或自定义协议),最容易崩的地方不是读逻辑,而是关闭时机不对。常见错误现象:程序退出时报 ResourceWarning: unclosed socket,或者某次回调里 recv() 报 OSError: [Errno 9] Bad file descriptor。

根本原因是:你在回调中调用了 sock.close(),但事件循环还不知道这个 fd 已失效,下一轮仍尝试 read() 它。

  • 必须先 loop.remove_reader(sock),再 sock.close()
  • 如果 socket 同时注册了读和写(比如半双工场景),两个都要 remove
  • 在异常分支(如 recv() 抛 ConnectionResetError)里也要做同样清理,不能只在正常流程里关
  • Windows 下对 UDP socket 调用 remove_reader() 后再 close() 是安全的;Linux 下某些内核版本要求顺序严格,颠倒大概率 crash

asyncio.open_connection() 超时控制比 socket.connect() 更可靠

同步代码里用 socket.connect((host, port)) 设超时,靠的是 settimeout(),但它在 DNS 解析阶段不生效——如果域名卡住,整个 connect 就卡死。而 asyncio.open_connection() 的 timeout 参数覆盖 DNS 查询 + TCP 握手全过程。

不过要注意:这个 timeout 是给整个协程用的,不是单次重试间隔。如果你需要指数退避重连,得自己包一层。

  • 显式传 ssl=True 会走 TLS 握手,耗时更长,timeout 值建议比纯 TCP 大 2–3 秒
  • 若目标地址是 IPv6 双栈,且系统优先查 AAAA 记录但 DNS 慢,timeout 会等完所有解析尝试才触发
  • 连接成功后,reader 和 writer 的生命周期与 event loop 绑定,不要跨 loop 使用(比如在子线程里 await)

手动管理 fd 的边界情况太多,能用 start_server() 和 open_connection() 就别碰 add_reader();真要碰,记住三件事:非阻塞、先 remove 后 close、异常路径也清理。

热门AI工具

更多
PixTV
PixTV Hot

PixTV是一款面向AIGC内容创作的AI视频生成工具。

PixPix
PixPix Hot

PixPix是一款面向电商视觉生产的AI商品图生成工具。

DeepSeek

DeepSeek是一款面向对话、写作、编程和推理场景的AI大模型工具。

Loomy
Loomy Hot

一款AI工具,主要用于科大讯飞发布的桌面级 AI 助理,比 OpenClaw 更易用、更安全!,适合需要提升相关任务效率的用户。

豆包大模型

豆包大模型是一款由字节跳动推出的企业级大语言模型服务平台。

咔片AIPPT

一款在线AI演示文稿制作工具,可根据主题和内容需求辅助生成PPT结构与页面,提高演示材料制作效率。

VibeKnow
VibeKnow Hot

一款AI视频创作工具,主要用于全球首个AI知识视频创作平台,文档、文章、网页,一键生成视频,适合需要提升相关任务效率的用户。

WorkBuddy

一款AI办公效率工具,主要用于腾讯云推出的AI原生桌面智能体工作台,适合需要提升相关任务效率的用户。

SkildArt
SkildArt Hot

SkildArt是一款AI文本写作工具,一站式 AI 视觉创作平台。

相关专题

更多
python打包成可执行文件
python打包成可执行文件

本专题为大家带来python打包成可执行文件相关的文章,大家可以免费的下载体验。

1691

2023.07.20

python能做什么
python能做什么

python能做的有:可用于开发基于控制台的应用程序、多媒体部分开发、用于开发基于Web的应用程序、使用python处理数据、系统编程等等。本专题为大家提供python相关的各种文章、以及下载和课程。

4284

2023.07.25

format在python中的用法
format在python中的用法

Python中的format是一种字符串格式化方法,用于将变量或值插入到字符串中的占位符位置。通过format方法,我们可以动态地构建字符串,使其包含不同值。php中文网给大家带来了相关的教程以及文章,欢迎大家前来阅读学习。

1689

2023.07.31

python教程
python教程

Python已成为一门网红语言,即使是在非编程开发者当中,也掀起了一股学习的热潮。本专题为大家带来python教程的相关文章,大家可以免费体验学习。

24937

2023.08.03

python环境变量的配置
python环境变量的配置

Python是一种流行的编程语言,被广泛用于软件开发、数据分析和科学计算等领域。在安装Python之后,我们需要配置环境变量,以便在任何位置都能够访问Python的可执行文件。php中文网给大家带来了相关的教程以及文章,欢迎大家前来学习阅读。

3047

2023.08.04

python eval
python eval

eval函数是Python中一个非常强大的函数,它可以将字符串作为Python代码进行执行,实现动态编程的效果。然而,由于其潜在的安全风险和性能问题,需要谨慎使用。php中文网给大家带来了相关的教程以及文章,欢迎大家前来学习阅读。

3067

2023.08.04

scratch和python区别
scratch和python区别

scratch和python的区别:1、scratch是一种专为初学者设计的图形化编程语言,python是一种文本编程语言;2、scratch使用的是基于积木的编程语法,python采用更加传统的文本编程语法等等。本专题为大家提供scratch和python相关的文章、下载、课程内容,供大家免费下载体验。

1163

2023.08.11

python合并两个列表
python合并两个列表

Python是一种强大的编程语言,具有许多方便的功能和工具。在Python中,有多种方法可以合并两个列表。php中文网给大家带来了相关的教程以及文章,欢迎大家前来学习阅读。

596

2023.08.10

Kratos框架HTTP与gRPC服务开发教程
Kratos框架HTTP与gRPC服务开发教程

本专题围绕Kratos框架双协议服务开发,涵盖HTTP路由与处理器编写、参数获取、gRPC服务实现与客户端调用、metadata上下文传递、encoding编解码注册、统一响应封装、超时控制与流式响应实现方法。

0

2026.10.10

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号
PHP中文网订阅号
每天精选资源文章推送

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn