设为首页收藏本站
切换到窄版

鱼C论坛

 找回密码
 立即注册
鱼C论坛»论坛 › 技术交流 › Python交流 › python多线程爬取，不等子线程完成，主线程就结束了
返回列表 发新帖
查看: 2196|回复: 3

[已解决]python多线程爬取，不等子线程完成，主线程就结束了

[复制链接]
景暄
发表于 2020-10-25 17:30:42 | 显示全部楼层 |阅读模式
50鱼币
本帖最后由 景暄 于 2020-10-25 17:39 编辑

爬取糗事百科的段子，可能是join（）函数设置的有问题，每次运行都没报错，但也没把结果打印出来
from threading import Thread
from queue import Queue
from fake_useragent import UserAgent
import requests
from lxml import etree

#爬虫类
class CrawlInfo(Thread):
    def __init__(self,url_queue,html_queue):
        Thread.__init__(self)
        self.url_queue = url_queue
        self.html_queue = html_queue
    def run(self):
        headers = {
            'User-Agent':UserAgent().random
        }
        while self.url_queue.empty() == False:
            url = self.url_queue.get()
            response = requests.get(url, headers=headers)
            if response.status_code == 200:
                self.html_queue.put(response.text)

#解析类
class ParseInfo(Thread):
    def __init__(self, html_queue):
        Thread.__init__(self)
        self.html_queue  = html_queue

    def run(self):
        while self.html_queue.empty() == False:
            e = etree.HTML(self.html_queue.get())
            span_contents = e.xpath('//div[@class="content"]/sapn[1]')
            for span in span_contents:
                info = span.xpath('string(.)')
                print(info)

if __name__ == '__main__':
    # 存储url的容器
    url_queue = Queue()
    #存储内容的容器
    html_queue = Queue()
    base_url = 'https://www.qiushibaike.com/text/page/{}/'
    for i in range(1, 14):
        new_url = base_url.format(i)
        url_queue.put(new_url)
    #创建一个爬虫
    crawl_list = []
    for i in range(0, 3):
        crawl1 = CrawlInfo(url_queue, html_queue)
        crawl_list.append(crawl1)
        crawl1.start()

    for crawl in crawl_list:
        crawl.join()

    parse = ParseInfo(html_queue)
    parse.start()
最佳答案
月排行榜 / 总排行榜
jy02188990
2020-10-25 17:30:43
多线程爬一个不可描述网站
import requests
import bs4
import time
import os,sys
import random
from threading import Thread
import re

def down_jpg(url1,numm):
    headers = {'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; WOW64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/78.0.3904.108 Safari/537.36',
               
               'referer':'newurl',
               'cookie':'__cfduid=dccf7de8219a41296cc717949a14788851601881784; existmag=mag; 4fJN_2132_saltkey=aU1VYvxu; 4fJN_2132_lastvisit=1601882439; 4fJN_2132_visitedfid=36D2; PHPSESSID=6be8caov3lgjr4dhlsq9bm7rm7; 4fJN_2132_st_p=0%7C1602987046%7C5bc121f439bbf8cfe7e3512e0335a580; 4fJN_2132_viewid=tid_2117; 4fJN_2132_sid=IBh6Aq; 4fJN_2132_sendmail=1; 4fJN_2132_lastact=1602987586%09forum.php%09forumdisplay; 4fJN_2132_st_t=0%7C1602987586%7C88bfb33921f3da072fadcaf37c081bc4; 4fJN_2132_forum_lastvisit=D_2_1602946097D_36_1602987586'
               ,"Connection": "close"
               }
    re = requests.get(url1,headers = headers)
    img = re.content
    print('downlond jpg',url1)
    name = os.listdir()
    for i in name:
        if i !='http.txt' and i[-3:-1] =='tx':
            name1 = name[0]+str(numm)+'1'
    with open(name1+'.jpg','wb')as f:
        f.write(img)

def jpg_list(listy):
    plist = []
    num = len(listy)
    for i in range(num):
        t = Thread(target = down_jpg,args = (listy[i],i))
        t.start()
        plist.append(t)
    for i in plist:
        i.join()
        print('图',i,'完成')
    print('------over------')
    time.sleep(10)
    

def find_new(res2,newurl):
    num = 0
    soup = bs4.BeautifulSoup(res2.text,'html.parser')
    aaa = soup.find_all(onload='thumbImg(this)')
    print('jpg...')
    with open('http.txt','w',encoding='utf-8')as f:
        f.write(soup.text)
    listy = []
    numy = 0
    for i in aaa:
        x = i.get('src')
        listy.append(x)

    jpg_list(listy)

            

def open_new(ilist):
    headers = {'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; WOW64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/78.0.3904.108 Safari/537.36',
               
               'referer':url,
               'cookie':'自己添加'
               }
    global newurl
    newurl = 'https://www.busfan.cloud/forum/'+ilist
    res2 = requests.get(newurl,headers = headers)
    code = res2.status_code
    if code ==200:
        print('子页面连接成功',newurl)
        time.sleep(random.randint(1,3))
        soup = bs4.BeautifulSoup(res2.text,'html.parser')
        print('txt...')
        name0 = os.getcwd()
        name = re.findall("[\u4e00-\u9fa5]+",name0)    
        find_new(res2,newurl)
    else:
        print('打不开')


        
def find_data(res):
    print('解析主页拿到子页面地址和名称')
    zlist = []
    pathlist = []
    soup = bs4.BeautifulSoup(res.text,'html.parser')
    aaa = soup.find_all(onclick = 'atarget(this)')
    for new in aaa:
        ilist = new.get('href')#子页面地址
        name = new.text   #子页面名称
        print('得到：',name)
        path = 'M:\\3\\'+name
        os.chdir('M:\\3')
        lj = os.listdir()
        for xi in lj:
            if name == xi:
                print('删除重复文件夹',xi)
                os.chdir(path)
                file = os.listdir()
                for zi in file:
                    os.remove(zi)
                os.chdir('M:\\3')
                os.rmdir(path)
        
        zlist.append(ilist)
        pathlist.append(path)

    num = len(zlist)
    for i in range(num):
        t = Thread(target = open_new,args = (zlist[i],))
        os.mkdir(pathlist[i])
        os.chdir(pathlist[i])
        with open(name + '.txt','w')as f:
            f.write(name)
        t.start()
        print(zlist[i])
        t.join(15)        
    print('下一页')

    


def open_url(url):
    time.sleep(1)
    headers = {'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; WOW64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/78.0.3904.108 Safari/537.36',
               
               'referer':'https://www.busfan.cloud/',
               'cookie':'自己添加'
               ,"Connection": "close"
               }
    res = requests.get(url,headers = headers)
    code = res.status_code
    if code ==200:
        print('成功打开主页:',res)
        time.sleep(random.randint(1,3))
        return res
    else:
        time.sleep(3)




def main():
    res = open_url(url)
    find_data(res)

if __name__ == '__main__':
        
    numx = 299
    while numx >0:
        url = 'https://www.busfan.cloud/forum/forum.php?mod=forumdisplay&fid=36&typeid=5&typeid=5&filter=typeid&page='+str(numx)
        numx=numx-1
        print('---------------开始--------------------','\n',numx,'@@##')
        main()

如图所示没有打印结果

如图所示没有打印结果

最佳答案

jy02188990

查看完整内容

多线程爬一个不可描述网站
想知道小甲鱼最近在做啥？请访问 -> ilovefishc.com
回复

使用道具 举报

jy02188990
发表于 2020-10-25 17:30:43 | 显示全部楼层    本楼为最佳答案   
多线程爬一个不可描述网站
import requests
import bs4
import time
import os,sys
import random
from threading import Thread
import re

def down_jpg(url1,numm):
    headers = {'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; WOW64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/78.0.3904.108 Safari/537.36',
               
               'referer':'newurl',
               'cookie':'__cfduid=dccf7de8219a41296cc717949a14788851601881784; existmag=mag; 4fJN_2132_saltkey=aU1VYvxu; 4fJN_2132_lastvisit=1601882439; 4fJN_2132_visitedfid=36D2; PHPSESSID=6be8caov3lgjr4dhlsq9bm7rm7; 4fJN_2132_st_p=0%7C1602987046%7C5bc121f439bbf8cfe7e3512e0335a580; 4fJN_2132_viewid=tid_2117; 4fJN_2132_sid=IBh6Aq; 4fJN_2132_sendmail=1; 4fJN_2132_lastact=1602987586%09forum.php%09forumdisplay; 4fJN_2132_st_t=0%7C1602987586%7C88bfb33921f3da072fadcaf37c081bc4; 4fJN_2132_forum_lastvisit=D_2_1602946097D_36_1602987586'
               ,"Connection": "close"
               }
    re = requests.get(url1,headers = headers)
    img = re.content
    print('downlond jpg',url1)
    name = os.listdir()
    for i in name:
        if i !='http.txt' and i[-3:-1] =='tx':
            name1 = name[0]+str(numm)+'1'
    with open(name1+'.jpg','wb')as f:
        f.write(img)

def jpg_list(listy):
    plist = []
    num = len(listy)
    for i in range(num):
        t = Thread(target = down_jpg,args = (listy[i],i))
        t.start()
        plist.append(t)
    for i in plist:
        i.join()
        print('图',i,'完成')
    print('------over------')
    time.sleep(10)
    

def find_new(res2,newurl):
    num = 0
    soup = bs4.BeautifulSoup(res2.text,'html.parser')
    aaa = soup.find_all(onload='thumbImg(this)')
    print('jpg...')
    with open('http.txt','w',encoding='utf-8')as f:
        f.write(soup.text)
    listy = []
    numy = 0
    for i in aaa:
        x = i.get('src')
        listy.append(x)

    jpg_list(listy)

            

def open_new(ilist):
    headers = {'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; WOW64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/78.0.3904.108 Safari/537.36',
               
               'referer':url,
               'cookie':'自己添加'
               }
    global newurl
    newurl = 'https://www.busfan.cloud/forum/'+ilist
    res2 = requests.get(newurl,headers = headers)
    code = res2.status_code
    if code ==200:
        print('子页面连接成功',newurl)
        time.sleep(random.randint(1,3))
        soup = bs4.BeautifulSoup(res2.text,'html.parser')
        print('txt...')
        name0 = os.getcwd()
        name = re.findall("[\u4e00-\u9fa5]+",name0)    
        find_new(res2,newurl)
    else:
        print('打不开')


        
def find_data(res):
    print('解析主页拿到子页面地址和名称')
    zlist = []
    pathlist = []
    soup = bs4.BeautifulSoup(res.text,'html.parser')
    aaa = soup.find_all(onclick = 'atarget(this)')
    for new in aaa:
        ilist = new.get('href')#子页面地址
        name = new.text   #子页面名称
        print('得到：',name)
        path = 'M:\\3\\'+name
        os.chdir('M:\\3')
        lj = os.listdir()
        for xi in lj:
            if name == xi:
                print('删除重复文件夹',xi)
                os.chdir(path)
                file = os.listdir()
                for zi in file:
                    os.remove(zi)
                os.chdir('M:\\3')
                os.rmdir(path)
        
        zlist.append(ilist)
        pathlist.append(path)

    num = len(zlist)
    for i in range(num):
        t = Thread(target = open_new,args = (zlist[i],))
        os.mkdir(pathlist[i])
        os.chdir(pathlist[i])
        with open(name + '.txt','w')as f:
            f.write(name)
        t.start()
        print(zlist[i])
        t.join(15)        
    print('下一页')

    


def open_url(url):
    time.sleep(1)
    headers = {'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; WOW64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/78.0.3904.108 Safari/537.36',
               
               'referer':'https://www.busfan.cloud/',
               'cookie':'自己添加'
               ,"Connection": "close"
               }
    res = requests.get(url,headers = headers)
    code = res.status_code
    if code ==200:
        print('成功打开主页:',res)
        time.sleep(random.randint(1,3))
        return res
    else:
        time.sleep(3)




def main():
    res = open_url(url)
    find_data(res)

if __name__ == '__main__':
        
    numx = 299
    while numx >0:
        url = 'https://www.busfan.cloud/forum/forum.php?mod=forumdisplay&fid=36&typeid=5&typeid=5&filter=typeid&page='+str(numx)
        numx=numx-1
        print('---------------开始--------------------','\n',numx,'@@##')
        main()
想知道小甲鱼最近在做啥？请访问 -> ilovefishc.com
回复

使用道具 举报

Stubborn
发表于 2020-10-25 18:20:03 | 显示全部楼层
对于一个生产消费者模型的两个线程。
def main():
    pageQueue = Queue()   #给一个队列
    for page in range(1,4): #爬去页数
        pageQueue.put(page)  #往队列里面增加数据

    #初始化采集线程
    crawl_threads = []
    crwal_name_list = ["crawl_1","crawl_2","crwal_3"]
    for thread_id in crwal_name_list:
        thread = Crawl_thread(thread_id,pageQueue)
        thread.start()#启动线程
        crawl_threads.append(thread)

    #初始化解析线程
    parser_threads = []
    parser_name = ["parser_1","parser_2","parser_3"]
    for thread_id in parser_name:
        thread = Parser_thread(thread_id,data_queue)
        thread.start()#启动线程
        parser_threads.append(thread)

    #等待队列情况
    while not pageQueue.empty(): #判断是否为空 采集队列
        pass

    #等待所有线程结束
    for t in crawl_threads:
        t.join()

    while not data_queue.empty():  #解析的队列
        pass

    #通知线程退出
    global flag
    flag =True
    for t in parser_threads:
        t.join()
    print("退出主线程")


data_queue = Queue() #创建一个队列
flag = False
if __name__ == "__main__":
    main()
想知道小甲鱼最近在做啥？请访问 -> ilovefishc.com
回复

使用道具 举报

笨鸟学飞
发表于 2020-10-25 20:45:51 | 显示全部楼层
你看代码没用的。你首先得理解多线程的概念。 主线程—启动N个线程后，N个线程和主线程是同时在运行的，你如果想让N个线程执行完后再继续执行主线程，可以用一个循环函数（如while）分别获取N个函数的返回值（或者是用其他操作来判断是否执行完毕），如果每个线程都提供了返回值，则跳出循环
想知道小甲鱼最近在做啥？请访问 -> ilovefishc.com
回复

使用道具 举报

返回列表 发新帖
高级模式
B Color Image Link Quote Code Smilies
您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

小黑屋|手机版|Archiver|鱼C工作室 ( 粤ICP备18085999号-1 | 粤公网安备 44051102000585号)

GMT+8, 2025-1-18 04:44

Powered by Discuz! X3.4

© 2001-2023 Discuz! Team.

快速回复 返回顶部 返回列表