img
img

网上学习资料一大堆,但如果学到的知识不成体系,遇到问题时只是浅尝辄止,不再深入研究,那么很难做到真正的技术提升。

需要这份系统化的资料的朋友,可以戳这里获取

一个人可以走的很快,但一群人才能走的更远!不论你是正从事IT行业的老鸟或是对IT行业感兴趣的新人,都欢迎加入我们的的圈子(技术交流、学习资源、职场吐槽、大厂内推、面试辅导),让我们一起学习成长!

在 Python 中,我们可以使用 async/await 来声明异步函数和执行异步操作。异步函数将返回一个协程对象,它可以在事件循环中被调度执行。

  1. 协程 (Coroutine): 协程是一种可以暂停执行并在稍后恢复的函数,它允许我们在函数内部进行状态保存。在异步编程中,协程非常有用,因为它们允许我们在等待I/O操作的同时,执行其他任务。
  2. 事件循环 (Event Loop): 事件循环是异步编程的核心,它是一个循环结构,负责不断地监听并处理事件。在 Python 中,可以使用 asyncio 模块提供的事件循环来驱动异步协程的执行。

aiohttp 框架介绍

官方地址

aiohttp 的官方地址是:docs.aiohttp.org/

背景

aiohttp 最初由 Andrew Svetlov 开发,旨在提供一个快速、灵活且易于使用的异步 Web 框架。特点和优势:

  • 异步 Web 服务器:aiohttp 可以作为异步 Web 服务器,处理并发请求,支持 WebSocket 和 HTTP/2 协议。
  • 异步 HTTP 客户端:aiohttp 提供了一个高性能的异步 HTTP 客户端,用于向其他服务器发出异步请求。
  • 轻量级:aiohttp 的设计简单,代码量较少,易于理解和维护。
  • 内置WebSocket支持:aiohttp 内置了对 WebSocket 的支持,可以轻松地实现实时双向通信。
  • 兼容性:aiohttp 兼容 Python 3.5+ 版本,并且可以与其他异步库和框架无缝集成。

怎么使用 aiohttp?

安装 aiohttp

在开始使用 aiohttp 之前,我们需要先安装它。可以使用 pip 进行安装:

pip install aiohttp

实践案例 - 异步 HTTP 服务器

aiohttp 提供了两个主要模块:aiohttp.webaiohttp.client。前者用于构建Web应用程序,后者用于创建异步 HTTP 客户端。

首先,我们来看看aiohttp.web模块,它是我们构建 Web 应用程序的关键。以下是一个简单的异步 HTTP 服务器:

import asyncio
from aiohttp import web

async def handle(request):
    return web.Response(text="Hello, aiohttp!")

app = web.Application()
app.router.add_get('/', handle)

# 手动启动事件循环
async def start_app():
    runner = web.AppRunner(app)
    await runner.setup()
    site = web.TCPSite(runner, 'localhost', 8080)
    await site.start()

if __name__ == "__main__":
    loop = asyncio.get_event_loop()
    try:
        loop.run_until_complete(start_app())
        loop.run_forever()
    except KeyboardInterrupt:
        pass
    finally:
        loop.run_until_complete(loop.shutdown_asyncgens())
        loop.close()


在你的 IDE 编辑器中运行上面的代码,你将会看到 aiohttp 服务器已经在本地运行,并监听在默认端口上。当你在浏览器中打开 http://localhost:8080,将会看到 “Hello, aiohttp!” 的响应。

调试 aiohttp 接口

Apifox = Postman + Swagger + Mock + JMeter,Apifox 支持调试 http(s)、WebSocket、Socket、gRPCDubbo 等协议的接口,在后端人员写完服务接口时,测试阶段可以通过 Apifox 来校验接口的正确性,图形化界面极大的方便了项目的上线效率。

在本文的例子中,就可以通过 Apifox 来测试接口。新建一个项目后,在项目中选择 “调试模式” ,填写请求地址后即可快速发送请求,并获得响应结果,上文的实践案例如图所示:

处理异步请求 - POST 请求示例

下面我们来演示如何处理异步的 POST 请求:

from aiohttp import web

async def handle(request):
    data = await request.post()
    name = data.get('name')
    return web.Response(text=f"Hello, {name}!")

app = web.Application()
app.router.add_post('/', handle)

web.run_app(app)

img
img

网上学习资料一大堆,但如果学到的知识不成体系,遇到问题时只是浅尝辄止,不再深入研究,那么很难做到真正的技术提升。

需要这份系统化的资料的朋友,可以戳这里获取

一个人可以走的很快,但一群人才能走的更远!不论你是正从事IT行业的老鸟或是对IT行业感兴趣的新人,都欢迎加入我们的的圈子(技术交流、学习资源、职场吐槽、大厂内推、面试辅导),让我们一起学习成长!

rums/4f45ff00ff254613a03fab5e56a57acb)**

一个人可以走的很快,但一群人才能走的更远!不论你是正从事IT行业的老鸟或是对IT行业感兴趣的新人,都欢迎加入我们的的圈子(技术交流、学习资源、职场吐槽、大厂内推、面试辅导),让我们一起学习成长!

Logo

GitCode 天启AI是一款由 GitCode 团队打造的智能助手,基于先进的LLM(大语言模型)与多智能体 Agent 技术构建,致力于为用户提供高效、智能、多模态的创作与开发支持。它不仅支持自然语言对话,还具备处理文件、生成 PPT、撰写分析报告、开发 Web 应用等多项能力,真正做到“一句话,让 Al帮你完成复杂任务”。

更多推荐