python实现http代理

import socket
import threading
import requests


class Proxy:  # 初始化代理配置
    def __init__(self):

        # 用来连接服务器
        self.buffsize = 4096;
        self.clientSocket = socket.socket(socket.AF_INET, socket.SOCK_STREAM);
        self.clientSocket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1);
        # 用来等待客户端连接
        self.clientSocket.bind(("0.0.0.0", 11111));
        self.clientSocket.listen(10);  # 10个客户端同时连接
        self.Host = None
        self.server_address = None

    def accept_client(self):
        # d = threading.Thread(target=self.proxy_thread, args=(client_socket, client_address), daemon=True)
        # d.start()
        recv_client, client_addr = self.clientSocket.accept()  # 客户端打电话，我们接收
        request = recv_client.recv(4096).decode('utf-8');
        # 得到消息整体

        header = request.split('\r\n\r\n')[0];
        # data = request.split('\r\n\r\n')[1];
        print(header)  # 拿到数据头

        key_header = {}
        for single_header in header.split('\r\n'):
            key = single_header.split(':')[0];
            value = single_header.split(':')[1];
            if value == None:
                continue
            key_header[key] = value;
        # print(key_header['Host'])
        self.Host = key_header['Host'];
        print(type(self.Host))
        # 找到主机名+端口
        port = 80

    def connect_server(self):  # 创建代理到服务器的连接
        proxy_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
        proxy_socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)

        (fam, type, _, _, server_address) = socket.getaddrinfo(self.Host.strip(), 80)[0];

        # server_address = ("152.136.152.208", 80)
        print(server_address)
        proxy_socket.connect(server_address)
        while True:
            msg = 'GET / HTTP/1.1\r\nhost:{}\r\nConnection: close\r\n\r\n'.format(self.Host.strip())  # 用来连接和发送
            proxy_socket.send(msg.encode('utf-8'))
            rec_msg, address = proxy_socket.recvfrom(4096)  # back用来作接收返回消息
            print(rec_msg.decode('utf-8'))

    def run(self):
        self.accept_client()
        while True:
            self.connect_server()

from proxy import Proxy
def main():
    instance = Proxy();
    instance.run();

if __name__ == "__main__":
    while True:
        main();