Python实现代理服务器转发：简单步骤与示例代码解析

Python实现代理服务器转发

使用Python实现一个简单的代理服务器转发请求是一个有趣的项目。通过这个项目，你可以了解网络请求的基本原理以及如何处理HTTP请求。本文将介绍如何使用Python的`socket`和`threading`模块来实现一个基本的HTTP代理服务器。

1. 准备工作

在开始之前，请确保你已经安装了Python环境。你可以使用Python 3.x版本进行开发。接下来，我们将编写一个简单的HTTP代理服务器，它能够接收客户端的请求，并将请求转发到目标服务器，然后将响应返回给客户端。

2. 代码实现

import socket
import threading

# 定义代理服务器的主机和端口
HOST = '127.0.0.1'  # 代理服务器监听的地址
PORT = 8888          # 代理服务器监听的端口

def handle_client(client_socket):
    # 接收客户端请求
    request = client_socket.recv(1024).decode('utf-8')
    print(f"Received request:\n{request}")

    # 从请求中提取目标地址
    lines = request.splitlines()
    if len(lines) > 0:
        # 获取目标地址
        url = lines[0].split()[1]
        if url.startswith("http://"):
            url = url[7:]  # 去掉"http://"
        else:
            client_socket.close()
            return

        # 分离主机和路径
        host, path = url.split('/', 1) if '/' in url else (url, '')
        path = '/' + path

        # 创建与目标服务器的连接
        server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
        try:
            server_socket.connect((host, 80))  # 连接目标服务器
            # 转发请求到目标服务器
            server_socket.sendall(f"GET {path} HTTP/1.1\r\nHost: {host}\r\n\r\n".encode('utf-8'))

            # 接收目标服务器的响应
            while True:
                response = server_socket.recv(4096)
                if not response:
                    break
                # 将响应转发给客户端
                client_socket.sendall(response)
        except Exception as e:
            print(f"Error: {e}")
        finally:
            server_socket.close()

    # 关闭与客户端的连接
    client_socket.close()

def start_proxy():
    # 创建一个TCP socket
    server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    server_socket.bind((HOST, PORT))
    server_socket.listen(5)
    print(f"Proxy server listening on {HOST}:{PORT}")

    while True:
        # 接受客户端连接
        client_socket, addr = server_socket.accept()
        print(f"Accepted connection from {addr}")
        # 启动一个新线程处理客户端请求
        client_thread = threading.Thread(target=handle_client, args=(client_socket,))
        client_thread.start()

if __name__ == "__main__":
    start_proxy()