python多线程爬取某网站全部h漫画_Python多线程爬虫爬取网页图片
'''基于多页面多线程'''
import os #引入文件模块
import re #正则表达式
importurllib.requestimportthreading#连接网页并返回源码
defopen_url(url):try:
req=urllib.request.Request(url)
req.add_header("User-Agent","Mozilla/5.0 (Windows NT 10.0; WOW64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/55.0.2883.87 Safari/537.36")
response=urllib.request.urlopen(req)
status_code=response.code
html=response.read()returnhtmlexcept:print(url + "404")return 404
defmkdir(path):''':param path: 路径
:return:'''
#引入模块
importos#去除首位空格
path =path.strip()#去除尾部 \ 符号
path = path.rstrip("\\")#判断路径是否存在
#存在 True
#不存在 False
isExists =os.path.exists(path)#判断结果
if notisExists:#如果不存在则创建目录
#创建目录操作函数
os.makedirs(path)print(path + '创建成功')returnTrueelse:#如果目录存在则不创建，并提示目录已存在
print(path + '目录已存在')returnFalsedefYande1(i):
imgs= 1url= 'https://yande.re/post?page=' +str(i)
floder= "E:\\Python\\爬虫\\yande\\img\\page" +str(i)
mkdir(floder)
html=open_url(url)
html= html.decode('gbk', 'ignore')
img_adds=[]
filename= floder + "\\" + str(imgs) + '.jpg'imgs+= 1img_html=open_url(i)if img_html == 404:continuewith open(filename,'wb') as f:
f.write(img_html)print(i + '下载完成......')
exitflag=0classmyThread(threading.Thread):def __init__(self, threadID, name, list):
threading.Thread.__init__(self)
self.threadID=threadID
self.name=name
self.list=listdefrun(self):print("开始线程：" +self.name)#threadLock.acquire()
get_img(self.name, self.list)#threadLock.release()
print("退出线程："+self.name)defget_img(threadname, list):iflen(list):for i inlist:ifexitflag:
threadname.exit()
Yande1(i)if __name__ == '__main__':
pages1= int(input('请输入你要下载的起始页面数：'))
pages2= int(input('请输入你要下载的末尾页面数：'))
mkdir('img')#for i in range()
list1 =[]
list2=[]
list3=[]for i in range(pages1, pages2+1):if i % 3 ==0:
list3.append(i)if i % 3 == 1:
list1.append(i)if i % 3 == 2:
list2.append(i)
threadLock=threading.Lock()
threads=[]
thread1= myThread(1, "thread-1", list1)
thread2= myThread(2, "thread-2", list2)
thread3= myThread(3, "thread-3", list3)
thread1.start()
thread2.start()
thread3.start()
threads.append(thread1)
threads.append(thread2)
threads.append(thread3)for t inthreads:
t.join()print("退出主线程")