本文主要是介绍【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教程的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!