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

python环境搭建（普通python、PyCharm ）

python环境搭建（普通python、PyCharm ）

步骤 1：安装 PyCharm 1. 访问 JetBrains 官网：https://www.jetbrains.com/pycharm/download/Download PyCharm: The Python IDE for data science and web development by JetBrains 2. 最后点击完成即可 下载完成后，运行安装程序，按照提示完成安装 向下滚动界面 找到PyCharm Community Edition 进行下载Community 版免费 选择适合你系统的版本（Community 版免费，Professional 版功能更丰富但需付费） 步骤 2：安装 Python 解释器 如果你还没有安装 Python，

By Ne0inhk

window 11 安装pyenv-win管理不同的版本的python

window 11 安装pyenv-win管理不同的版本的python * 一、pyenv-win 安装（Windows 系统） * 方式 1：通过 Chocolatey 安装（推荐） * 方式 2：手动安装（无 Chocolatey 时） * 二、pyenv-win 核心使用命令（和 NVM 高度相似） * 1. 基础命令：查看版本 / 帮助 * 2. 安装指定 Python 版本 * 3. 切换 Python 版本（核心） * 4. 卸载 Python 版本 * 5. 其他实用命令 * 三、常见问题与解决 * 四、使用建议 一、

By Ne0inhk

06 Python 数据分析入门：集中趋势与离散程度

Python 数据分析入门：一文搞懂集中趋势与离散程度（附 Pandas 实战） 适合人群：Python 初学者 / 数据分析入门 / 统计学基础学习者 / 教学案例分享 在做数据分析时，我们经常会遇到这样的问题： * 一组数据的“平均水平”到底是多少？ * 为什么两组数据均值差不多，但实际情况完全不同？ * 如何判断数据是否稳定，波动大不大？ * 数据里有没有异常值？ 这些问题，本质上都离不开两个统计学基础概念： * 集中趋势 * 离散程度 本文用一个非常简单的案例——班级成绩分析，带你从 0 到 1 学会这些统计指标，并用 Pandas 完成实战分析。 一、先看一个问题：平均分差不多，班级情况就一样吗？ 假设现在有两个班级的数学成绩： A班成绩 =[85,82,88,84,86,83,87,85,

By Ne0inhk
Python 小工具实战：图片水印批量添加工具

Python 小工具实战：图片水印批量添加工具

Python 小工具实战：图片水印批量添加工具 Python 小工具实战：图片水印批量添加工具，本文详细介绍了使用 Python开发 给图片加水印的工具，该工具基于 Pillow 和 tkinter 库构建，可解决单图处理耗时、专业软件操作复杂的问题。工具支持单图与批量处理，用户能自定义水印文字、字体大小、透明度及颜色，还可选择 9 个常用水印位置或设置行列重复分布。新增的全屏水印模式可通过调整旋转角度与间距，生成铺满图片的版权保护水印，且界面采用卡片式布局，搭配浅灰背景与蓝色按钮，简洁美观，底部状态栏实时显示操作进度。文中提供完整可运行代码，并给出参数校验、字体兼容、常见报错解决等实用内容，新手按步骤即可上手，或者直接运行使用。 前言     Python作为一门简洁、易读、功能强大的编程语言，其基础语法是入门学习的核心。掌握好基础语法，能为后续的编程实践打下坚实的基础。本文将全面讲解Python3的基础语法知识，适合编程初学者系统学习。Python以其简洁优雅的语法和强大的通用性，成为当今最受欢迎的编程语言。本专栏旨在系统性地带你从零基础入门到精通Python核心。无论你是

By Ne0inhk