這期內(nèi)容當(dāng)中小編將會(huì)給大家?guī)?lái)有關(guān)Python中怎么實(shí)現(xiàn)代理服務(wù)器，文章內(nèi)容豐富且以專業(yè)的角度為大家分析和敘述，閱讀完這篇文章希望大家可以有所收獲。

專注于為中小企業(yè)提供成都網(wǎng)站設(shè)計(jì)、做網(wǎng)站、成都外貿(mào)網(wǎng)站建設(shè)公司服務(wù),電腦端+手機(jī)端+微信端的三站合一,更高效的管理,為中小企業(yè)婁星免費(fèi)做網(wǎng)站提供優(yōu)質(zhì)的服務(wù)。我們立足成都，凝聚了一批互聯(lián)網(wǎng)行業(yè)人才，有力地推動(dòng)了數(shù)千家企業(yè)的穩(wěn)健成長(zhǎng)，幫助中小企業(yè)通過(guò)網(wǎng)站建設(shè)實(shí)現(xiàn)規(guī)模擴(kuò)充和轉(zhuǎn)變。

這里就是使用Python簡(jiǎn)單的實(shí)現(xiàn)一個(gè)二級(jí)代理。

#coding=utf-8 
import socket 
import select 
import sys 
import threading
import time
import logging
import os
logsDir = "logs"
if not os.path.isdir(logsDir):
    os.mkdir(logsDir)
    
logging.basicConfig(level=logging.DEBUG,
                format='%(asctime)s %(filename)s[line:%(lineno)d] %(levelname)s %(message)s',
                datefmt='%a, %d %b %Y %H:%M:%S',
                filename='logs/logs.log',
                filemode='a')
 
#C的IP和端口 
to_addr = ('127.0.0.1', 8087)


maxConnetions = 32
class Proxy: 
    def __init__(self, addr): 
        self.proxy = socket.socket(socket.AF_INET, socket.SOCK_STREAM) 
        self.proxy.bind(addr) 
        self.proxy.listen(maxConnetions) 
        self.inputs = {self.proxy:None} 
        self.route = {} 
   
    def serve_forever(self): 
        logging.info('proxy listen...')
        while 1: 
            readable, _, _ = select.select(list(self.inputs.keys()), [], []) 
            for self.sock in readable: 
                if self.sock == self.proxy: 
                    self.on_join() 
                else:
                    try:
                        data = self.sock.recv(8192)
                    except Exception, e:
                        logging.error(str(e))
                        self.on_quit()
                        continue
                    
                    if not data: 
                        self.on_quit() 
                    else:
                        try:
                            self.route[self.sock].send(data)
                        except Exception, e:
                            logging.error(str(e))
                            self.on_quit()
                            continue
   
    def on_join(self): 
        client, addr = self.proxy.accept() 
        logging.info("proxy client " + str(addr) + 'connect')
        forward = socket.socket(socket.AF_INET, socket.SOCK_STREAM) 
        try:
            forward.connect(to_addr)
        except Exception, e:
            logging.error(str(e))
            client.close()
            return
        self.inputs [client] = None
        self.inputs [forward] = None


        self.route[client] = forward 
        self.route[forward] = client 
    
    #刪除連接
    def on_quit(self):
        ls = [self.sock]
        if self.sock in self.route:
            ls.append(self.route[self.sock])
        for s in ls:
            if s in self.inputs:
                del self.inputs[s]
            if s in self.route:
                del self.route[s] 
            s.close() 
            
if __name__ == "__main__":
    try: 
        Proxy(('', 8192)).serve_forever()
    except KeyboardInterrupt, e: 
        logging.error("KeyboardInterrupt" + str(e))

上述就是小編為大家分享的Python中怎么實(shí)現(xiàn)代理服務(wù)器了，如果剛好有類似的疑惑，不妨參照上述分析進(jìn)行理解。如果想知道更多相關(guān)知識(shí)，歡迎關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道。

分享題目：Python中怎么實(shí)現(xiàn)代理服務(wù)器
分享網(wǎng)址：http://aaarwkj.com/article34/ijhspe.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供軟件開(kāi)發(fā)、搜索引擎優(yōu)化、網(wǎng)站排名、網(wǎng)站導(dǎo)航、Google、企業(yè)建站

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請(qǐng)盡快告知，我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng)，如需處理請(qǐng)聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時(shí)需注明來(lái)源： 創(chuàng)新互聯(lián)