如何使用Python asyncio实现稳定的长连接心跳检测？-Python教程-PHP中文网

asyncio.create_task启动的心跳协程易意外退出，主因是未捕获连接类异常（如connectionreseterror），导致任务静默终止；正确做法是用try/except包裹循环，捕获后关闭资源并return退出，避免盲目重试。

如何使用python asyncio实现稳定的长连接心跳检测？

为什么 `asyncio.create_task` 启动的心跳协程容易意外退出？

心跳协程一旦抛出未捕获异常（比如网络中断时 await writer.drain() 报 ConnectionResetError），任务就静默结束，没人知道连接已断。这不是“不稳定”，是根本没做错误兜底。

正确做法是把心跳逻辑包进 try/except 循环里，并在捕获连接类异常后主动关闭资源、通知上层：

async def heartbeat(writer, interval=30):
    while True:
        try:
            writer.write(b'{"type":"ping"}\n')
            await writer.drain()
            await asyncio.sleep(interval)
        except (ConnectionResetError, BrokenPipeError, OSError) as e:
            print(f"心跳发送失败：{e}")
            writer.close()
            await writer.wait_closed()
            return  # 退出协程，避免无限重试

注意：return 比 break 更安全，能确保协程真正终止；不要用 continue 盲目重试——底层连接已失效，再写只会触发更多异常。

如何避免心跳和业务读写竞争导致 `ConnectionAbortedError`？

常见错误是让心跳协程和业务读取协程（如 reader.readline()）共用一个 StreamWriter，而 TCP 连接关闭时，两个协程可能同时触发写操作，其中一个会收到 ConnectionAbortedError。

根本解法是统一连接生命周期管理，所有 I/O 操作都通过同一个上下文协调：

用 asyncio.Lock 保护 writer.write() + drain() 组合操作（尤其当业务也发消息时）
心跳协程只负责“定时触发”，不直接写；改由主循环或专用发送队列统一调度
监听 reader.at_eof() 或 reader.exception()，一旦检测到读端关闭，立刻取消心跳任务并清理

示例中可加一句：if reader.at_eof() or reader.exception(): break 在每次心跳前检查，比等写失败更早止损。

testing-python

使用pytest编写和评估有效的Python测试。适用于编写测试、审查测试代码、调试测试失败或提高测试覆盖率。

下载

心跳超时判断该用 `asyncio.wait_for` 还是自建计时器？

用 asyncio.wait_for(heartbeat_coro, timeout=45) 是错的——它只限制单次心跳耗时，无法发现“连续多次未收到 pong”的场景。真实需求是：发 ping 后 45 秒内没收到 pong，才算超时。

必须配合响应监听逻辑实现双向心跳：

心跳协程发出 b'{"type":"ping"}' 后，启动一个 asyncio.create_task(asyncio.wait_for(wait_for_pong(), timeout=45))
wait_for_pong() 需监听 reader.readline() 并匹配 "pong"，成功则 set_result(True)
若超时，任务抛 asyncio.TimeoutError，此时应主动断连，而不是仅记录日志

注意：不要在 wait_for_pong() 里用 while True 循环读——万一对方根本没 pong，会卡死整个协程。务必用 wait_for 包裹单次读取。