快捷導(dǎo)航

python實(shí)現(xiàn)跨域代理服務(wù)器的方法

更新時(shí)間：2023年07月17日 15:28:50 作者：銘

這篇文章主要介紹了python實(shí)現(xiàn)跨域代理服務(wù)器的方法,本文通過(guò)實(shí)例代碼給大家介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值，需要的朋友可以參考下

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

python3.7+
依賴：aiohttp

代碼實(shí)現(xiàn)（代理服務(wù)器，返回響應(yīng)體和進(jìn)行跨域處理后的headers）

import aiohttp
from functools import wraps
from aiohttp import web
corscode = {
                'Access-Control-Allow-Origin': '*',
                'Access-Control-Allow-Methods': 'GET, POST, OPTIONS', # 需要限制請(qǐng)求就在這里增刪
                'Access-Control-Allow-Headers': '*',
                'Server':'is my server',
            }
# 實(shí)例化路由
routes = web.RouteTableDef()
# 異步j(luò)son序列化
def jsondump(func):
    @wraps(func)
    async def wrapper(*args,**kwargs):
        result = await func(*args,**kwargs)
        try:
            return json.dumps(result ,ensure_ascii=False)
        except:
            return result
    return wrapper
# 封裝一下web.json_resp
# def wj(dt):
#    return web.json_response(dt)
wj = lambda dt: web.json_response(dt)
# 處理OPTIONS和跨域的中間件
@jsondump
async def options_middleware(app, handler):
    async def middleware(request):
        # 處理 OPTIONS 請(qǐng)求，直接返回空數(shù)據(jù)和允許跨域的 header
        if request.method == 'OPTIONS':
            return web.Response(headers=corscode)
        # 繼續(xù)處理其他請(qǐng)求
        response = await handler(request)
        # 為每次響應(yīng)添加header
        try:
            response.headers.update(corscode)
        except Exception as e:
            return response
        return response
    return middleware
@jsondump
@routes.view(r'/get')
async def geturl(request): 
    url = request.query.get('url')
    if not url:
        return wj({"data":"參數(shù)錯(cuò)誤"})
    async with aiohttp.ClientSession() as session:
        async with session.get(url) as response:
            # 檢查請(qǐng)求是否成功，如果不成功，可以根據(jù)需要進(jìn)行處理
            if response.status == 200:
                file = await response.read()
                return web.Response(body=file, headers=response.headers)
if __name__ == '__main__':
    app = web.Application()
    app.add_routes(routes)
    app.middlewares.append(options_middleware)
    web.run_app(app)

測(cè)試

1.寫(xiě)個(gè)get的方法

function downloadfile(url, fileName) {
  var xhr = new XMLHttpRequest();
  xhr.open('GET', url, true);
  xhr.responseType = 'blob';
  xhr.onload = function() {
    if (xhr.status === 200) {
      var blob = xhr.response;
      var a = document.createElement('a');
      var url = window.URL.createObjectURL(blob);
      a.href = url;
      a.download = fileName;
      document.body.appendChild(a);
      a.click();
      document.body.removeChild(a);
      window.URL.revokeObjectURL(url);
    }
  };
  xhr.send();
}

2.下載測(cè)試