如何用 Python 实现网络请求转发

用Python实现网络请求转发，核心是搭建一个代理服务器。最直接的方法是使用标准库的 http.server 模块，或者功能更强大的第三方库如 Flask、aiohttp。下面我提供一个基于 http.server 的基础示例，它清晰展示了转发的核心逻辑。

这个 ProxyHandler 会拦截请求，修改目标URL（这里是硬编码到 http://httpbin.org），然后代为请求并将响应原样返回给客户端。

from http.server import HTTPServer, BaseHTTPRequestHandler
import urllib.request
import urllib.parse

class ProxyHandler(BaseHTTPRequestHandler):
    # 目标服务器的基础URL
    TARGET_BASE = "http://httpbin.org"

    def do_GET(self):
        # 1. 构建目标URL
        target_url = urllib.parse.urljoin(self.TARGET_BASE, self.path)
        self.log_message(f"Forwarding GET to: {target_url}")

        # 2. 代为发起请求
        try:
            with urllib.request.urlopen(target_url) as response:
                # 3. 将目标服务器的状态码和头信息复制给客户端
                self.send_response(response.status)
                for key, value in response.headers.items():
                    self.send_header(key, value)
                self.end_headers()
                # 4. 将响应体数据流式传输回客户端
                self.wfile.write(response.read())
        except Exception as e:
            self.send_error(500, f"Proxy error: {str(e)}")

    # 同样处理POST等其他方法
    def do_POST(self):
        target_url = urllib.parse.urljoin(self.TARGET_BASE, self.path)
        content_length = int(self.headers.get('Content-Length', 0))
        post_data = self.rfile.read(content_length) if content_length else None

        self.log_message(f"Forwarding POST to: {target_url}")
        req = urllib.request.Request(target_url, data=post_data, method='POST')
        # 复制原始请求头（可选，可根据需要过滤）
        for key, value in self.headers.items():
            req.add_header(key, value)

        try:
            with urllib.request.urlopen(req) as response:
                self.send_response(response.status)
                for key, value in response.headers.items():
                    self.send_header(key, value)
                self.end_headers()
                self.wfile.write(response.read())
        except Exception as e:
            self.send_error(500, f"Proxy error: {str(e)}")

if __name__ == '__main__':
    server = HTTPServer(('localhost', 8888), ProxyHandler)
    print("Proxy server running on http://localhost:8888")
    server.serve_forever()

运行后，访问 http://localhost:8888/anything/foo，代理服务器会实际请求 http://httpbin.org/anything/foo 并将结果返回给你。

核心要点：

1. 请求转发：在 do_GET、do_POST 等方法中，根据原始请求的路径 (self.path)、方法、头信息和体，构建一个新的请求发送到目标服务器。
2. 响应回传：接收目标服务器的响应，将其状态码、头部和正文原样写回给原始客户端 (self.send_response, self.send_header, self.wfile.write)。
3. 错误处理：用 try...except 包裹对目标服务器的请求，避免代理进程因目标服务器问题而崩溃。

对于生产环境，这个基础版本过于简单。你需要考虑连接池、超时控制、HTTPS支持、请求头过滤（避免循环或敏感信息泄露）、并发性能和认证等。这时可以考虑使用成熟的库：

• 同步场景：requests + Flask/FastAPI 是经典组合，易于控制和扩展。
• 高并发异步场景：aiohttp 或 httpx 是更好的选择，能高效处理大量并发连接。

一句话建议：根据场景复杂度选择基础 http.server 或功能更全的 Flask/aiohttp 方案。