Python开发从入门到精通：异步编程与协程

Ne0inhk

— 7 min read
Python开发从入门到精通：异步编程与协程

《Python开发从入门到精通》设计指南第二十一篇：异步编程与协程

在这里插入图片描述

一、学习目标与重点

💡 学习目标：掌握Python异步编程的基本概念和方法，包括协程、任务调度、事件循环等；学习asyncio、aiohttp等核心库的使用；通过实战案例开发异步应用程序。
⚠️ 学习重点：协程的定义与使用、任务调度、事件循环、asyncio库、aiohttp库、异步编程实战。

21.1 异步编程概述

21.1.1 什么是异步编程

异步编程是一种并发编程方式，通过非阻塞的操作提高程序的执行效率。在异步编程中，程序可以在等待I/O操作完成时继续执行其他任务，而不需要阻塞等待。

21.1.2 异步编程的优势

  • 提高执行效率：在等待I/O操作完成时，程序可以继续执行其他任务。
  • 降低资源消耗：减少了线程切换的开销。
  • 简化代码结构：通过协程和任务调度，代码结构更加简洁。

21.1.3 异步编程的应用场景

  • 网络通信：如HTTP请求、Web服务器、WebSocket通信等。
  • 文件操作：如大文件的读取和写入。
  • 数据库操作：如异步数据库查询。

21.2 协程的定义与使用

21.2.1 协程的定义

协程（Coroutine）是一种轻量级的线程，可以在程序中进行暂停和恢复。在Python中，协程可以通过async def关键字定义。

21.2.2 协程的使用

import asyncio # 定义协程asyncdefhello():print('Hello, World!')await asyncio.sleep(1)print('Hello again!')# 运行协程 asyncio.run(hello())

21.2.3 协程的暂停与恢复

import asyncio # 定义协程asyncdefcount():print('Counting...')await asyncio.sleep(1)print('Counted!')# 运行多个协程asyncdefmain():await asyncio.gather(count(), count(), count()) asyncio.run(main())

21.3 任务调度

21.3.1 创建任务

import asyncio # 定义协程asyncdefhello():print('Hello, World!')await asyncio.sleep(1)print('Hello again!')# 创建任务asyncdefmain(): task1 = asyncio.create_task(hello()) task2 = asyncio.create_task(hello())await task1 await task2 asyncio.run(main())

21.3.2 任务的取消

import asyncio # 定义协程asyncdefhello():try:print('Hello, World!')await asyncio.sleep(1)print('Hello again!')except asyncio.CancelledError:print('Task cancelled!')# 创建任务并取消asyncdefmain(): task = asyncio.create_task(hello())await asyncio.sleep(0.5) task.cancel()try:await task except asyncio.CancelledError:print('Main: Task cancelled!') asyncio.run(main())

21.3.3 任务的超时

import asyncio # 定义协程asyncdefhello():print('Hello, World!')await asyncio.sleep(2)print('Hello again!')# 任务超时asyncdefmain():try:await asyncio.wait_for(hello(), timeout=1)except asyncio.TimeoutError:print('Task timed out!') asyncio.run(main())

21.4 事件循环

21.4.1 事件循环的概述

事件循环是异步编程的核心组件，负责调度任务的执行。事件循环会不断地从任务队列中取出任务并执行，直到任务队列为空。

21.4.2 获取事件循环

import asyncio # 获取事件循环 loop = asyncio.get_event_loop()# 定义协程asyncdefhello():print('Hello, World!')await asyncio.sleep(1)print('Hello again!')# 运行协程 loop.run_until_complete(hello())

21.4.3 事件循环的运行

import asyncio # 获取事件循环 loop = asyncio.get_event_loop()# 定义协程asyncdefhello():print('Hello, World!')await asyncio.sleep(1)print('Hello again!')# 运行多个协程 loop.run_until_complete(asyncio.gather(hello(), hello(), hello()))

21.5 asyncio库

21.5.1 asyncio的基本用法

import asyncio # 定义协程asyncdefhello():print('Hello, World!')await asyncio.sleep(1)print('Hello again!')# 运行协程 asyncio.run(hello())

21.5.2 asyncio的常用函数

  • asyncio.run()：运行协程。
  • asyncio.create_task()：创建任务。
  • asyncio.gather()：收集多个协程的结果。
  • asyncio.wait_for()：等待协程完成，设置超时。
  • asyncio.sleep()：暂停协程。

21.5.3 asyncio的高级用法

import asyncio # 定义协程asyncdefhello():print('Hello, World!')await asyncio.sleep(1)print('Hello again!')# 使用Future对象asyncdefmain(): future = asyncio.Future() task = asyncio.create_task(hello()) task.add_done_callback(lambda t: future.set_result(t.result()))await future asyncio.run(main())

21.6 aiohttp库

21.6.1 安装aiohttp

pip install aiohttp

21.6.2 发送HTTP请求

import aiohttp import asyncio # 发送GET请求asyncdeffetch(session, url):asyncwith session.get(url)as response:returnawait response.text()asyncdefmain():asyncwith aiohttp.ClientSession()as session: html =await fetch(session,'https://www.example.com')print(html) asyncio.run(main())

21.6.3 发送POST请求

import aiohttp import asyncio import json # 发送POST请求asyncdefpost_data(session, url, data):asyncwith session.post(url, data=data)as response:returnawait response.text()asyncdefmain():asyncwith aiohttp.ClientSession()as session: data ={'name':'张三','age':25} response =await post_data(session,'https://httpbin.org/post', data)print(response) asyncio.run(main())

21.6.4 发送JSON请求

import aiohttp import asyncio import json # 发送JSON请求asyncdefpost_json(session, url, data):asyncwith session.post(url, json=data)as response:returnawait response.text()asyncdefmain():asyncwith aiohttp.ClientSession()as session: data ={'name':'张三','age':25} response =await post_json(session,'https://httpbin.org/post', data)print(response) asyncio.run(main())

21.7 实战案例：异步HTTP客户端

21.7.1 需求分析

开发一个异步HTTP客户端，支持以下功能：

  • 发送HTTP请求。
  • 并发发送多个HTTP请求。
  • 处理响应数据。

21.7.2 代码实现

import aiohttp import asyncio import time # 发送HTTP请求asyncdeffetch(session, url): start_time = time.time()asyncwith session.get(url)as response: text =await response.text() elapsed_time = time.time()- start_time return url,len(text), elapsed_time # 并发发送HTTP请求asyncdefmain(): urls =['https://www.example.com','https://www.google.com','https://www.github.com','https://www.python.org','https://www.djangoproject.com']asyncwith aiohttp.ClientSession()as session: tasks =[asyncio.create_task(fetch(session, url))for url in urls] results =await asyncio.gather(*tasks)for url, length, elapsed_time in results:print(f'URL: {url}, 响应长度: {length}, 耗时: {elapsed_time:.2f}秒')# 运行程序if __name__ =='__main__': start_time = time.time() asyncio.run(main()) elapsed_time = time.time()- start_time print(f'总耗时: {elapsed_time:.2f}秒')

21.7.3 实施过程

  1. 安装aiohttp库。
  2. 定义发送HTTP请求的协程函数。
  3. 定义并发发送HTTP请求的协程函数。
  4. 运行程序。

21.7.4 最终效果

通过异步HTTP客户端，我们可以实现以下功能：

  • 发送HTTP请求。
  • 并发发送多个HTTP请求。
  • 处理响应数据。

21.8 实战案例：异步Web服务器

21.8.1 需求分析

开发一个异步Web服务器，支持以下功能：

  • 处理HTTP请求。
  • 提供静态文件服务。
  • 实现简单的API接口。

21.8.2 代码实现

from aiohttp import web import asyncio # 处理根路径请求asyncdefhandle_root(request):return web.Response(text='Hello, World!')# 处理API接口请求asyncdefhandle_api(request): data ={'name':'张三','age':25}return web.json_response(data)# 提供静态文件服务asyncdefhandle_static(request):return web.FileResponse('static/index.html')# 创建Web应用asyncdefcreate_app(): app = web.Application()# 添加路由 app.add_routes([ web.get('/', handle_root), web.get('/api', handle_api), web.get('/static/{name}', handle_static)])return app # 运行Web服务器if __name__ =='__main__': asyncio.run(web.run_app(create_app(), host='localhost', port=8080))

21.8.3 实施过程

  1. 安装aiohttp库。
  2. 定义处理HTTP请求的协程函数。
  3. 创建Web应用。
  4. 添加路由。
  5. 运行Web服务器。

21.8.4 最终效果

通过异步Web服务器，我们可以实现以下功能：

  • 处理HTTP请求。
  • 提供静态文件服务。
  • 实现简单的API接口。

总结

✅ 本文详细介绍了Python异步编程的基本概念和方法，包括协程、任务调度、事件循环等；学习了asyncio、aiohttp等核心库的使用；通过实战案例开发了异步HTTP客户端和异步Web服务器。
✅ 建议读者在学习过程中多练习，通过编写代码加深对知识点的理解。

Read more

蓝桥杯手把手教你备战（C/C++ B组）（最全面！最贴心！适合小白！）

蓝桥杯手把手教你备战（C/C++ B组）（最全面！最贴心！适合小白！）

比赛环境：网盘资源分享 通过网盘分享的文件：蓝桥杯比赛环境 链接: https://pan.baidu.com/s/1eh85AW-y83ibCmEo8ByBwA?pwd=1234 提取码: 1234 1 常见问题答疑 1.1 蓝桥杯含金量高不高？ 说起蓝桥杯，不得不提ACM。 ACM是国际大学生程序设计竞赛（ACM-ICPC），被誉为计算机领域的“奥运会”，是世界上，规模最大、水平最高、最具影响力的国际大学生程序设计竞赛。 ACM难度较高，当然含金量也更高， 那么蓝桥杯的含金量肯定比不过ACM，但是其具有独特的优势。 蓝桥杯难度更低，更易拿奖，同时在计算机行业具有较高认可度。 ACM适合那些智商高或者编程经验丰富（学习算法1年以上）的选手参赛。而蓝桥杯适合小白，适合期望快速获得编程领域一个认可证书而没有太多时间投入的参赛者。 1.2 获奖到底难不难？ 蓝桥杯分为省赛和国赛。 省赛时： 与你竞争的是同省的人，所以获奖难度与你所在的省份有一定关系。 强省(

By Ne0inhk
C++ ODB ORM 完全指南：从入门到实战应用

C++ ODB ORM 完全指南：从入门到实战应用

文章目录 * ODB基本概念 * ODB框架安装 * 常见操作 * ODB类与接口 * 测试示例 ODB基本概念 ODB 是一个针对 C++ 的对象关系映射（ORM）库，它允许开发者以面向对象的方式操作数据库，将C++ 对象与数据库表进行映射，从而避免直接编写 SQL 语句，简化数据库操作。 特点： * 对象 - 关系映射：将 C++ 类映射到数据库表，类的成员变量映射到表的字段，对象的创建、修改、删除等操作会自动转换为对应的数据库操作（如 INSERT、UPDATE、DELETE）。 * 代码生成机制：ODB 不依赖运行时反射（C++ 本身不支持），而是通过编译期代码生成实现映射：开发者使用特殊的注解（如 #pragma db object）标记需要持久化的类，然后通过 ODB 编译器生成与数据库交互的代码（

By Ne0inhk
C++可变参数队列与压栈顺序：从模板语法到汇编调用约定的深度解析

C++可变参数队列与压栈顺序：从模板语法到汇编调用约定的深度解析

C++可变参数队列与压栈顺序：从模板语法到汇编调用约定的深度解析 本文聚焦一个具体而关键的技术主题：C++ 可变参数模板（Variadic Templates）。我们将从现代 C++ 的优雅写法出发，深入剖析其在 x86-64 架构下的真实行为，特别澄清一个长期被误解的核心问题——可变参数是否“从右向左压栈”？它们在寄存器和栈中究竟是如何排布的？ 如果你正在实现一个类型安全的消息队列、日志系统或任务调度器，并希望理解 enqueue(1, "hello", 3.14) 这行代码在 CPU 层面到底发生了什么，那么这篇文章就是为你量身打造的。 一、引言：可变参数 ≠ va_list —— 一场范式革命 很多初学者将 C++ 的可变参数模板与 C 语言的 va_list 混为一谈。这是重大误区，甚至会导致错误的性能假设和安全漏洞。 1.1

By Ne0inhk
RabbitMQ如何成为分布式系统的“神经中枢“？——从安装部署到C++调用实战的完整流程，带你体验它的奥妙所在！​

RabbitMQ如何成为分布式系统的“神经中枢“？——从安装部署到C++调用实战的完整流程，带你体验它的奥妙所在！​

文章目录 * 本篇摘要 * ①·RabbitMq（轻量级消息队列中间件） 介绍 * RabbitMQ 是什么？ * 核心功能与特点 * 1. **核心功能** * 2. **核心优势** * RabbitMQ 的核心概念 * 1. **生产者（Producer）** * 2. **消费者（Consumer）** * 3. **队列（Queue）** * 4. **交换机（Exchange）** * 5. **绑定（Binding）** * 工作流程（以 Direct 交换机为例） * 常见应用场景 * RabbitMQ 与相关技术对比 * 图像理解 * 总结一句话 * ②·RabbitMq 安装教程 * RabbitMq安装 * **1. 安装 RabbitMQ** * **2. 启动 & 检查状态** * **3. 创建管理员用户（

By Ne0inhk