前言

在學(xué)習(xí)協(xié)程的時(shí)候，會(huì)有一個(gè)疑問(wèn)，使用協(xié)程語(yǔ)法進(jìn)行異步請(qǐng)求時(shí)，比如async + requests，會(huì)有用嗎？

其實(shí)細(xì)想一下就知道，由于requests庫(kù)是用同步的方式寫(xiě)的，因此async + requests是肯定沒(méi)用的。

但是本著實(shí)踐出真知的思想，順便復(fù)習(xí)鞏固一下多線程、async、aiohttp的寫(xiě)法，還是手動(dòng)來(lái)驗(yàn)證一下。

為了規(guī)避網(wǎng)絡(luò)波動(dòng)等影響，在本地用Flask搭建一個(gè)簡(jiǎn)易的服務(wù)器用于測(cè)試。

先放結(jié)論：

• threading + requests 能夠并發(fā)請(qǐng)求
• async + requests 不能并發(fā)請(qǐng)求
• async + aiohttp 能并發(fā)請(qǐng)求

因此在進(jìn)行爬蟲(chóng)的時(shí)候，要想加快效率，要么使用threading + requests ，要么就使用async + aiohttp

初始環(huán)境準(zhǔn)備

安裝測(cè)試所需要的庫(kù)

pip install flask
pip install requets
pip install aiohttp

在任意路徑創(chuàng)建一個(gè)文件夾（文件夾名隨意），例如./async_test

在該文件夾下創(chuàng)建一個(gè)空的py文件app.py用于后續(xù)搭建測(cè)試用后端。

再創(chuàng)建3個(gè)py文件分別對(duì)應(yīng)3個(gè)實(shí)驗(yàn)，創(chuàng)建完畢后文件目錄結(jié)構(gòu)如下（此時(shí)的py文件都是空的）

|- async_test
  |- app.py
  |- 1_threading_requests.py
  |- 2_async_requests.py
  |- 3_async_aiohttp.py

搭建測(cè)試用的后端

讓每次請(qǐng)求的時(shí)候先沉睡2秒，再返回結(jié)果，以此來(lái)模擬網(wǎng)絡(luò)延遲。

在app.py文件中添加如下代碼

## app.py ##
from flask import Flask
import time
app = Flask(__name__)
@app.route("/")
def index():
    time.sleep(2)
    return "Hello World!"
if __name__ == '__main__':
    app.run()

在./async_test目錄下運(yùn)行

python app.py

 * Serving Flask app "app" (lazy loading)
 * Environment: production
   WARNING: This is a development server. Do not use it in a production deployment.
   Use a production WSGI server instead.
 * Debug mode: off
 * Running on http://127.0.0.1:5000/ (Press CTRL+C to quit)

訪問(wèn) http://127.0.0.1:5000/ 延遲2秒后會(huì)看到Hello World!

完成這一步就搭建好了測(cè)試用后端

1.threading requests

在1_threading_requests.py文件中添加如下代碼

## 1_threading_requests.py ##
import time
import threading
import requests
def get(i):
    print(time.strftime('%X'), 'start', i)
    resp = requests.get('http://127.0.0.1:5000/')
    print(time.strftime('%X'), 'end', i)
start = time.perf_counter()
for i in range(4):
    threading.Thread(target=get, args=(i,)).start()
print(f'total {time.perf_counter() - start:.2f}s ')

在./async_test目錄下運(yùn)行

python 1_threading_requests.py

09:23:19 start 0
09:23:19 start 1
09:23:19 start 2
09:23:19 start 3
09:23:21 end 2
09:23:21 end 0
09:23:21 end 3
09:23:21 end 1

發(fā)現(xiàn)使用多線程的寫(xiě)法是能夠并發(fā)請(qǐng)求的。

2.async requests

在2_async_requests.py文件中添加如下代碼

## 2_async_requests.py ##
import time
import asyncio
import requests
async def get(i):
    print(time.strftime('%X'), 'start', i)
    resp = requests.get('http://127.0.0.1:5000/')
    print(time.strftime('%X'), 'end', i)
async def main():
    for i in range(4):
        asyncio.create_task(get(i))
asyncio.run(main())

在./async_test目錄下運(yùn)行

python 2_async_requests.py

09:27:11 start 0
09:27:13 end 0
09:27:13 start 1
09:27:15 end 1
09:27:15 start 2
09:27:17 end 2
09:27:17 start 3
09:27:19 end 3

發(fā)現(xiàn)async+requests的寫(xiě)法，代碼是順序執(zhí)行的，異步并沒(méi)有起到效果

于是將get(i)函數(shù)用aiohttp重寫(xiě)

3.async aiohttp

在3_async_aiohttp.py文件中添加如下代碼

## 3_async_aiohttp.py ##
import time
import asyncio
import aiohttp
import requests
async def get(i):
    print(time.strftime('%X'), 'start', i)
    async with aiohttp.ClientSession() as session:
        async with session.get('http://127.0.0.1:5000/') as response:
            html = await response.text()
    print(time.strftime('%X'), 'end', i)
async def main():
    tasks = [asyncio.create_task(get(i)) for i in range(4)]
    await asyncio.gather(*tasks)
asyncio.run(main())

在./async_test目錄下運(yùn)行

python 3_async_aiohttp.py

09:37:43 start 0
09:37:43 start 1
09:37:43 start 2
09:37:43 start 3
09:37:45 end 0
09:37:45 end 2
09:37:45 end 3
09:37:45 end 1

發(fā)現(xiàn)代碼成功異步執(zhí)行了，總耗時(shí)只有兩秒

說(shuō)明python的協(xié)程語(yǔ)法需要配合異步python庫(kù)才會(huì)生效。

到此這篇關(guān)于Python async+request與async+aiohttp實(shí)現(xiàn)異步網(wǎng)絡(luò)請(qǐng)求探索的文章就介紹到這了,更多相關(guān)Python異步網(wǎng)絡(luò)請(qǐng)求內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

最新評(píng)論