Python はプロキシを使用して Web サイトの画像をクロールします (マルチスレッド)

import urllib2
import re
import threading
import time
import random

rawProxyList = []
checkedProxyList = []
imgurl_list = []

#抓取代理网站
portdicts ={'v':"3",'m':"4",'a':"2",'l':"9",'q':"0",'b':"5",'i':"7",'w':"6",'r':"8",'c':"1"}
targets = []
for i in xrange(1,9):
        target = r"http://www.cnproxy.com/proxy%d.html" % i
        targets.append(target)
#print targets

#抓取代理服务器正则
p = re.compile(r'''(.+?)(.+?).+?(.+?)''')

#获取代理的类
class ProxyGet(threading.Thread):
    def __init__(self,target):
        threading.Thread.__init__(self)
        self.target = target

    def getProxy(self):
        print "代理服务器目标网站： " + self.target
        req = urllib2.urlopen(self.target)
        result = req.read()
        #print chardet.detect(result)
        matchs = p.findall(result)
        for row in matchs:
            ip=row[0]
            port =row[1]
            port = map(lambda x:portdicts[x],port.split('+'))
            port = ''.join(port)
            agent = row[2]
            addr = row[3].decode("cp936").encode("utf-8")
            proxy = [ip,port,addr]
            #print proxy
            rawProxyList.append(proxy)

    def run(self):
        self.getProxy()

#检验代理的类
class ProxyCheck(threading.Thread):
    def __init__(self,proxyList):
        threading.Thread.__init__(self)
        self.proxyList = proxyList
        self.timeout = 5
        self.testUrl = "http://www.baidu.com/"
        self.testStr = "030173"

    def checkProxy(self):
        cookies = urllib2.HTTPCookieProcessor()
        for proxy in self.proxyList:
            proxyHandler = urllib2.ProxyHandler({"http" : r'http://%s:%s' %(proxy[0],proxy[1])})
            #print r'http://%s:%s' %(proxy[0],proxy[1])
            opener = urllib2.build_opener(cookies,proxyHandler)
            opener.addheaders = [('User-agent', 'Mozilla/5.0 (Windows NT 6.2; WOW64; rv:22.0) Gecko/20100101 Firefox/22.0')]
            #urllib2.install_opener(opener)
            t1 = time.time()

            try:
                #req = urllib2.urlopen("http://www.baidu.com", timeout=self.timeout)
                req = opener.open(self.testUrl, timeout=self.timeout)
                #print "urlopen is ok...."
                result = req.read()
                #print "read html...."
                timeused = time.time() - t1
                pos = result.find(self.testStr)
                #print "pos is %s" %pos

                if pos > 1:
                    checkedProxyList.append((proxy[0],proxy[1],proxy[2],timeused))
                    #print "ok ip: %s %s %s %s" %(proxy[0],proxy[1],proxy[2],timeused)
                else:
                     continue
            except Exception,e:
                #print e.message
                continue

    def run(self):
        self.checkProxy()

#获取图片地址函数
def imgurlList(url_home):
    global imgurl_list
    home_page = urllib2.urlopen(url_home)
    url_re = re.compile(r'

')
    pic_re = re.compile(r'    url_list = re.findall(url_re,home_page.read())
    for url in url_list:
        #print url_home+url
        url_page = urllib2.urlopen(url_home+url)
        for imgurlList in re.findall(pic_re,url_page.read()):
            imgurl_list.append(imgurlList)

#ダウンロード画像クラス
class getPic(threading.Thread):
def __init__(self,imgurl_list):
threading.Thread.__init__(self)
self.imgurl_list = imgurl_list
self.timeout = 5
def downloadimg(self):
for imgurl in self.imgurl_list:
pic_suffix = imgurl.split('.')[-1] #画像サフィックスを取得します
pic_name = str(random.randint(0,10000000000))+'.'+pic_suffix
cookies = urllib2.HTTPCookieProcessor()
randomCheckedProxy = random.choice(checkedProxyList) #プロキシ サーバーのグループをランダムに選択します
proxyHandler = urllib2.ProxyHandler({"http" : r'http://%s:%s' %(randomCheckedProxy[0],randomCheckedProxy[1])})
opener = urllib2.build_opener(cookies,proxyHandler) )
OpenEr.addheaders = [('User-Agent', 'Mozilla/5.0 (Windows NT 6.2; Wow64; RV: 22.0) GECKO/20100101 Firefox/22.0')]
Urllib2.Install_o PENER (オープナー) ）
if __name__ == "__main__":
getThreads = []
checkThreads = []
imgurlList('http://www.ivsky.com')
getPicThreads = []

#プロキシのクロールを担当するターゲット Web サイトごとにスレッドを開きます
for i in range(len(targets)):
t = ProxyGet(targets[i])

getThreads.append(t )

for i in range(len(getThreads)):
getThreads[i].start()

for i in range(len(getThreads)):

getThreads[i].join()

print '.'*10+"合計 %s プロキシがキャプチャされました" %len(rawProxyList) +'.'*10

#検証のために 20 のスレッドを開き、キャプチャしたプロキシを 20 の部分に分割し、スレッドごとに 1 つの部分を検証します。

for i in range(20):

t = ProxyCheck(rawProxyList[( (len(rawProxyList) )+19)/20) * i:((len(rawProxyList)+19)/20) * (i+1)])
checkThreads.append(t)

for i in range(len(checkThreads)):
checkThreads[i].start()

for i in range(len(checkThreads)):

checkThreads[i].join()

print '.'*10+"合計 %s プロキシが検証に合格しました" %len(checkedProxyList) +'.'*10

#20 のスレッドを開き、写真をダウンロードするエージェントをランダムに選択します

for i in range(20):

t = getPic(imgurl_list[((len(imgurl_list)+19)/20) * i: ( (len(imgurl_list)+19)/20) * (i+1)])
getPicThreads.append(t)

for i in range(len(getPicThreads)):
getPicThreads[i].start()

for i in range(len(getPicThreads)):

getPicThreads[i].join()

print '.'*10+"合計 %s の画像がダウンロードされました" %len(imgurl_list) +'.'*10

#プロキシのソート永続性

f= open("proxy_list.txt",'w+')

sorted(checkedProxyList,cmp=lambda x,y:cmp(x[3],y) のプロキシ用 [ 3])):
#print "チェックしたプロキシは: %s:%st%st%s" %(proxy[0],proxy[1],proxy[2],proxy[3])

f.write("%s:%st%st%sn"%(proxy[0],proxy[1],proxy[2],proxy[3]))

f.close()

2. テスト結果:

コードをコピー

コードは次のとおりです:

# ls
proxy_getpic.py
# python proxy_getpic.py
プロキシ サーバーのターゲット Web サイト: http://www.cnproxy.com/proxy1.html
プロキシ サーバーのターゲット Web サイト: http://www.cnproxy.com/proxy2.html
プロキシ サーバーのターゲット Web サイト: http://www.cnproxy.com/proxy3.html
プロキシ サーバーのターゲット Web サイト: http://www.cnproxy .com/proxy4.html
プロキシ サーバーのターゲット Web サイト: http://www.cnproxy.com/proxy5.html
プロキシ サーバーのターゲット Web サイト: http://www.cnproxy.com/proxy6.html
プロキシ サーバーのターゲット Web サイト: http://www.cnproxy.com/proxy7.html
プロキシ サーバーのターゲット Web サイト: http://www.cnproxy.com/proxy8.html
.... .合計 800 個のプロキシがキャプチャされました....
....合計 458 個のプロキシが検証に合格しました....
....合計 154 個の画像がダウンロードされました.. ...
# cat proxy_list.txt | 詳細
173.213.113.111:3128 米国 0.432188987732
173.213.113.111:8089 米国 0.441318035126
173.213.113。 111:7808 米国 0.444597005844
110.4 24.170:80 香港移動通信有限公司 0.489440202713
211.142.236.135:8080 湖南省株州市 携帯 0.490673780441
211.142.236.135:8081 湖南省株州市 携帯0.518096923828
211.142.236.135 :8000 湖南省株州市 携帯 0.51860499382
211.142.236.135:8082 湖南省株州市 携帯 0.520448207855
# ls
1001117689.jpg 3097883176.jpg 34319709.jpg 7012274766.jpg 8504924248.jpg
1076458640.jpg 3144369522.jpg 5 387877704.jpg 7106183143.jpg 867723868.jpg
1198548712.jpg 3161307031.jpg 5572092752.jpg 7361254661.jpg 33 06931164.jpg 5610740708.jpg 7407358698.jpg 8973834958.jpg
1742167711.jpg 3320152673.jpg 5717429022.jpg 7561176207.jpg 8976862152.jpg
.................