时间:2021-05-22
代码:
def thread(url): r = requests.get(url, headers=None, stream=True, timeout=30) # print(r.status_code, r.headers) headers = {} all_thread = 1 # 获取视频大小 file_size = int(r.headers['content-length']) # 如果获取到文件大小,创建一个和需要下载文件一样大小的文件 if file_size: fp = open('2.mp4', 'wb') fp.truncate(file_size) print('视频大小:' + str(int(file_size / 1024 / 1024)) + "MB") fp.close() # 每个线程每次下载大小为5M size = 5242880 # 当前文件大小需大于5M if file_size > size: # 获取总线程数 all_thread = int(file_size / size) # 设最大线程数为10,如总线程数大于10 # 线程数为10 if all_thread > 10: all_thread = 10 part = file_size // all_thread threads = [] starttime = datetime.datetime.now().replace(microsecond=0) for i in range(all_thread): # 获取每个线程开始时的文件位置 start = part * i # 获取每个文件结束位置 if i == all_thread - 1: end = file_size else: end = start + part if i > 0: start += 1 headers = headers.copy() headers['Range'] = "bytes=%s-%s" % (start, end) t = threading.Thread(target=Handler, name='th-' + str(i), kwargs={'start': start, 'end': end, 'url': url, 'filename': '2.mp4', 'headers': headers}) t.setDaemon(True) threads.append(t) # 线程开始 for t in threads: time.sleep(0.2) t.start() # 等待所有线程结束 for t in threads: t.join() endtime = datetime.datetime.now().replace(microsecond=0) print('用时:%s' % (endtime - starttime))def Handler(start, end, url, filename, headers={}): tt_name = threading.current_thread().getName() print(tt_name + ' is begin') r = requests.get(url, headers=headers, stream=True) total_size = end - start downsize = 0 startTime = time.time() with open(filename, 'r+b') as fp: fp.seek(start) var = fp.tell() for chunk in r.iter_content(204800): if chunk: fp.write(chunk) downsize += len(chunk) line = tt_name + '-downloading %d KB/s - %.2f MB, 共 %.2f MB' line = line % ( downsize / 1024 / (time.time() - startTime), downsize / 1024 / 1024, total_size / 1024 / 1024) print(line, end='\r')if __name__ == '__main__': url = input('输入视频链接(请输入视频原链):') thread(url)效果:
可以看见,38MB,一秒下完。
唯一的缺点就是,要有视频原链,而一般这个视频原链都是不会轻易被找到的,这就叫反爬。
找视频原链,就找爬虫,视频爬虫只是爬虫的一种。
可以根据视频大小,改变线程数。
总结
以上所述是小编给大家介绍的python 实现多线程下载视频的代码,希望对大家有所帮助,如果大家有任何疑问请给我留言,小编会及时回复大家的。在此也非常感谢大家对网站的支持!
如果你觉得本文对你有帮助,欢迎转载,烦请注明出处,谢谢!
声明:本页内容来源网络,仅供用户参考;我单位不保证亦不表示资料全面及准确无误,也不保证亦不表示这些资料为最新信息,如因任何原因,本网内容或者用户因倚赖本网内容造成任何损失或损害,我单位将不会负任何法律责任。如涉及版权问题,请提交至online#300.cn邮箱联系删除。
本文代码实现Python多线程扫描端口,具体实现代码如下。#coding:utf-8importsocketimportthreadimporttimesock
本文实例讲述了python基于queue和threading实现多线程下载的方法,分享给大家供大家参考。具体方法如下:主代码如下:#downloadworker
前面已经演示了Python:使用threading模块实现多线程编程二两种方式起线程和Python:使用threading模块实现多线程编程三threading
本文实例讲述了python实现的多线程端口扫描功能。分享给大家供大家参考,具体如下:下面的程序给出了对给定的ip主机进行多线程扫描的Python代码#!/usr
对于多线程的使用,我们经常是用thread来创建,比较繁琐.在Python中,可以使用map函数简化代码。map可以实现多任务的并发简单说明map()实现多线程