python实现跨域代理服务器

黄鼠狼孵小鸡

• 准备环境
  

• python3.7+
  
• 依赖：aiohttp
  

• 代码实现（代理服务器，返回响应体和进行跨域处理后的headers）
  

1. import aiohttp
2. from functools import wraps
3. from aiohttp import web
6. corscode = {
7.                 'Access-Control-Allow-Origin': '*',
8.                 'Access-Control-Allow-Methods': 'GET, POST, OPTIONS', # 需要限制请求就在这里增删
9.                 'Access-Control-Allow-Headers': '*',
10.                 'Server':'is my server',
11.             }
13. # 实例化路由
14. routes = web.RouteTableDef()
16. # 异步json序列化
17. def jsondump(func):
18.     @wraps(func)
19.     async def wrapper(*args,**kwargs):
20.         result = await func(*args,**kwargs)
21.         try:
22.             return json.dumps(result ,ensure_ascii=False)
23.         except:
24.             return result
25.     return wrapper
27. # 封装一下web.json_resp
28. # def wj(dt):
29. #    return web.json_response(dt)
30. wj = lambda dt: web.json_response(dt)
32. # 处理OPTIONS和跨域的中间件
33. @jsondump
34. async def options_middleware(app, handler):
35.     async def middleware(request):
36.         # 处理 OPTIONS 请求，直接返回空数据和允许跨域的 header
37.         if request.method == 'OPTIONS':
38.             return web.Response(headers=corscode)
39.         # 继续处理其他请求
40.         response = await handler(request)
41.         # 为每次响应添加header
42.         try:
43.             response.headers.update(corscode)
44.         except Exception as e:
45.             return response
46.         return response
47.     return middleware
49. @jsondump
50. @routes.view(r'/get')
51. async def geturl(request):
52.     url = request.query.get('url')
53.     if not url:
54.         return wj({"data":"参数错误"})
55.     async with aiohttp.ClientSession() as session:
56.         async with session.get(url) as response:
57.             # 检查请求是否成功，如果不成功，可以根据需要进行处理
58.             if response.status == 200:
59.                 file = await response.read()
60.                 return web.Response(body=file, headers=response.headers)
62. if __name__ == '__main__':
63.     app = web.Application()
64.     app.add_routes(routes)
65.     app.middlewares.append(options_middleware)
66.     web.run_app(app)

复制代码

• 测试
  

• 写个get的方法
  

1. function downloadfile(url, fileName) {
2.   var xhr = new XMLHttpRequest();
3.   xhr.open('GET', url, true);
4.   xhr.responseType = 'blob';
6.   xhr.onload = function() {
7.     if (xhr.status === 200) {
8.       var blob = xhr.response;
9.       var a = document.createElement('a');
10.       var url = window.URL.createObjectURL(blob);
11.       a.href = url;
12.       a.download = fileName;
13.       document.body.appendChild(a);
14.       a.click();
15.       document.body.removeChild(a);
16.       window.URL.revokeObjectURL(url);
17.     }
18.   };
20.   xhr.send();
21. }

复制代码

• 下载测试
  

1. downloadfile(url, fileName)

复制代码

• 结果
  
  
  可以正常下载
  并且在响应头中能看到Server:is my server
  同时可以看到添加成功的Allow-Origin响应头
  
  
  

来源:https://www.cnblogs.com/ymer/p/17560121.html
免责声明：由于采集信息均来自互联网，如果侵犯了您的权益，请联系我们【E-Mail:cb@itdo.tech】 我们会及时删除侵权内容，谢谢合作！