【python 异步编程】10分钟快速入门aiohttp教程

2024-09-07 06:08

本文主要是介绍【python 异步编程】10分钟快速入门aiohttp教程,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

无意中发现了一个巨牛的人工智能教程,忍不住分享一下给大家。教程不仅是零基础,通俗易懂,而且非常风趣幽默,像看小说一样!觉得太牛了,所以分享给大家。点这里可以跳转到教程。人工智能教程

一、先搞清楚什么是同步编程和异步编程?

同步编程:接到上峰指令:有两件事当天要处理完成,越快越好。那么同步是怎么工作呢,第一时间接到指令后,先处理第一件事情,等第一件事情做完了,再做第二件事情,通俗讲就是有点类似工厂的流水线啦,比较鸡肋,得先处理第一件事,才能腾出时间处理第二件事情,分身乏术阿。
异步编程:接到上峰指令:有两件事当天要处理完成,越快越好。那么异步又是如何工作呢,第一时间接到指令后,第一件事情和第二件事同时并发处理,互不影响,哪件事情处理好了立马返回结果。可见异步的最慢速度,也就是耗时最长的那个任务。这么一看,异步优势很明显嘛。异步编程速度远远高于同步编程,简直堪称是编程处理的神器啊。由此可见,学习异步编程,可以加快代码处理速度。加快服务响应速度。分身有术哦。

二、什么是aiohttp?
平时大家用requests发起请求,获取响应结果,这是一个同步请求,同步编程的一种,用的flask也是同步编程一种。那么aiohttp这个异步编程又是什么东西呢?
aiohttp是一个为Python提供异步HTTP 客户端/服务端编程,基于asyncio(Python用于支持异步编程的标准库)的异步库。

核心功能:

  • 同时支持客户端使用和服务端使用。
  • 同时支持服务端WebSockets组件和客户端WebSockets组件,开箱即用呦。
  • web服务器具有中间件,信号组件和可插拔路由的功能。

三、如何安装aiohttp?

pip install aiohttp

四、快速开始吧!

python版本要求python3.5及以上版本哦。
客服端例子:

import aiohttp
import asyncio
import async_timeoutasync def fetch(session, url):with async_timeout.timeout(10):async with session.get(url) as response:return await response.text()async def main():async with aiohttp.ClientSession() as session:html = await fetch(session, 'http://python.org')print(html)loop = asyncio.get_event_loop()
loop.run_until_complete(main())

web服务端例子:


from aiohttp import webasync def handle(request):name = request.match_info.get('name', "Anonymous")text = "Hello, " + namereturn web.Response(text=text)app = web.Application()
app.router.add_get('/', handle)
app.router.add_get('/{name}', handle)web.run_app(app)

本地浏览器访问地址:http://127.0.0.1:8080/,即可得到返回结果:

Hello, Anonymous

想写一个异步服务的 hello,world 咋写呢,也简单:

from aiohttp import webasync def index(request):return web.Response(text="hello,world!")app = web.Application()
# 添加路由
app.router.add_get('/', index)web.run_app(app, host='127.0.0.1', port=8080)

aiohttp的服务端程序都是 aiohttp.web.Application实例对象。用于创建信号,连接路由等。

客服端访问,得到相应结果测试例子:


# -*- coding:utf-8 -*-
import asyncio
from aiohttp import ClientSessionasync def fetch(session, url):async with session.get(url) as response:return await response.text()async def get_html(url):async with ClientSession() as session:html = await fetch(session,url)print(html)url='http://127.0.0.1:8080/'
loop = asyncio.get_event_loop()
loop.run_until_complete(get_html(url))
loop.close()

运行结果:

hello,world!Process finished with exit code 0

get方式和post方式都采用的例子:


# -*- coding:utf-8 -*-
from aiohttp import web
import json# get请求
async def index(request):return web.Response(text="hello,world!")# post请求
async def post_handler(request):data = await request.post()print(data)name = data['name']age = data['age']print(name,age)result = {"name": "赖德发", "sex": "男", "wechat":"laidefa"}return web.Response(text=json.dumps(result,ensure_ascii=False))app = web.Application()app.router.add_get('/', index)
app.router.add_post('/post', post_handler)web.run_app(app, host='127.0.0.1', port=8080)

客户端获取响应结果:发起get请求和post请求:


# -*- coding:utf-8 -*-
import asyncio
from aiohttp import ClientSessionasync def get_fetch(session, url):async with session.get(url) as response:return await response.text()async def get_html(url):async with ClientSession() as session:html = await get_fetch(session,url)print(html)async def post_fetch(session, url):form_data = {"name": "张三", "age": "22"}async with session.post(url,data=form_data) as response:return await response.text()async def post_html(url):async with ClientSession() as session:html=await post_fetch(session,url)print(html)if __name__ == '__main__':get_url='http://127.0.0.1:8080'post_url='http://127.0.0.1:8080/post'loop = asyncio.get_event_loop()loop.run_until_complete(post_html(post_url))loop.run_until_complete(get_html(get_url))loop.close()# 第二种方式也可以
# if __name__ == '__main__':
#     get_url='http://127.0.0.1:8080'
#     post_url='http://127.0.0.1:8080/post'
#     loop = asyncio.get_event_loop()
# 
#     tasks=[]
# 
#     task1 = asyncio.ensure_future(get_html(get_url))
#     task2 = asyncio.ensure_future(post_html(post_url))
#     tasks.append(task1)
#     tasks.append(task2)
#     loop.run_until_complete(asyncio.wait(tasks))
#     loop.close()

运行结果:

{"wechat": "laidefa", "name": "赖德发", "sex": "男"}
hello,world!Process finished with exit code 0

这篇关于【python 异步编程】10分钟快速入门aiohttp教程的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/1144268

相关文章

Java AOP面向切面编程的概念和实现方式

《JavaAOP面向切面编程的概念和实现方式》AOP是面向切面编程,通过动态代理将横切关注点(如日志、事务)与核心业务逻辑分离,提升代码复用性和可维护性,本文给大家介绍JavaAOP面向切面编程的概... 目录一、AOP 是什么?二、AOP 的核心概念与实现方式核心概念实现方式三、Spring AOP 的关

Python版本信息获取方法详解与实战

《Python版本信息获取方法详解与实战》在Python开发中,获取Python版本号是调试、兼容性检查和版本控制的重要基础操作,本文详细介绍了如何使用sys和platform模块获取Python的主... 目录1. python版本号获取基础2. 使用sys模块获取版本信息2.1 sys模块概述2.1.1

一文详解Python如何开发游戏

《一文详解Python如何开发游戏》Python是一种非常流行的编程语言,也可以用来开发游戏模组,:本文主要介绍Python如何开发游戏的相关资料,文中通过代码介绍的非常详细,需要的朋友可以参考下... 目录一、python简介二、Python 开发 2D 游戏的优劣势优势缺点三、Python 开发 3D

Python函数作用域与闭包举例深度解析

《Python函数作用域与闭包举例深度解析》Python函数的作用域规则和闭包是编程中的关键概念,它们决定了变量的访问和生命周期,:本文主要介绍Python函数作用域与闭包的相关资料,文中通过代码... 目录1. 基础作用域访问示例1:访问全局变量示例2:访问外层函数变量2. 闭包基础示例3:简单闭包示例4

Python实现字典转字符串的五种方法

《Python实现字典转字符串的五种方法》本文介绍了在Python中如何将字典数据结构转换为字符串格式的多种方法,首先可以通过内置的str()函数进行简单转换;其次利用ison.dumps()函数能够... 目录1、使用json模块的dumps方法:2、使用str方法:3、使用循环和字符串拼接:4、使用字符

Python版本与package版本兼容性检查方法总结

《Python版本与package版本兼容性检查方法总结》:本文主要介绍Python版本与package版本兼容性检查方法的相关资料,文中提供四种检查方法,分别是pip查询、conda管理、PyP... 目录引言为什么会出现兼容性问题方法一:用 pip 官方命令查询可用版本方法二:conda 管理包环境方法

基于Python开发Windows自动更新控制工具

《基于Python开发Windows自动更新控制工具》在当今数字化时代,操作系统更新已成为计算机维护的重要组成部分,本文介绍一款基于Python和PyQt5的Windows自动更新控制工具,有需要的可... 目录设计原理与技术实现系统架构概述数学建模工具界面完整代码实现技术深度分析多层级控制理论服务层控制注

pycharm跑python项目易出错的问题总结

《pycharm跑python项目易出错的问题总结》:本文主要介绍pycharm跑python项目易出错问题的相关资料,当你在PyCharm中运行Python程序时遇到报错,可以按照以下步骤进行排... 1. 一定不要在pycharm终端里面创建环境安装别人的项目子模块等,有可能出现的问题就是你不报错都安装

全网最全Tomcat完全卸载重装教程小结

《全网最全Tomcat完全卸载重装教程小结》windows系统卸载Tomcat重新通过ZIP方式安装Tomcat,优点是灵活可控,适合开发者自定义配置,手动配置环境变量后,可通过命令行快速启动和管理... 目录一、完全卸载Tomcat1. 停止Tomcat服务2. 通过控制面板卸载3. 手动删除残留文件4.

Python打包成exe常用的四种方法小结

《Python打包成exe常用的四种方法小结》本文主要介绍了Python打包成exe常用的四种方法,包括PyInstaller、cx_Freeze、Py2exe、Nuitka,文中通过示例代码介绍的非... 目录一.PyInstaller11.安装:2. PyInstaller常用参数下面是pyinstal