欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  IT编程

Python实现多线程下载文件的代码实例

程序员文章站 2023-11-16 12:56:16
实现简单的多线程下载,需要关注如下几点:1.文件的大小:可以从reponse header中提取,如“content-length:911”表示大小是911字节2.任务拆分...

实现简单的多线程下载,需要关注如下几点:
1.文件的大小:可以从reponse header中提取,如“content-length:911”表示大小是911字节
2.任务拆分:指定各个线程下载的文件的哪一块,可以通过request header中添加“range: bytes=300-400”(表示下载300~400byte的内容),注意可以请求的文件的range是[0, size-1]字节的。
3.下载文件的聚合:各个线程将自己下载的文件块保存为临时文件,所有线程都完成后,再将这些临时文件按顺序聚合写入到最终的一个文件中。

实现代码:

复制代码 代码如下:

#!/usr/bin/python
# -*- coding: utf-8 -*-
# filename: paxel.py
# from: http://jb51.net/code/view/58/full/
# jay modified it a little and save for further potential usage.

'''it is a multi-thread downloading tool

    it was developed following axel.
        author: volans
        e-mail: volansw [at] gmail.com
'''

import sys
import os
import time
import urllib
from threading import thread

# in case you want to use http_proxy
local_proxies = {'http': 'http://131.139.58.200:8080'}

 
class axelpython(thread, urllib.fancyurlopener):
    '''multi-thread downloading class.

        run() is a vitural method of thread.
    '''
    def __init__(self, threadname, url, filename, ranges=0, proxies={}):
        thread.__init__(self, name=threadname)
        urllib.fancyurlopener.__init__(self, proxies)
        self.name = threadname
        self.url = url
        self.filename = filename
        self.ranges = ranges
        self.downloaded = 0

    def run(self):
        '''vertual function in thread'''
        try:
            self.downloaded = os.path.getsize(self.filename)
        except oserror:
            #print 'never downloaded'
            self.downloaded = 0

        # rebuild start poind
        self.startpoint = self.ranges[0] + self.downloaded

        # this part is completed
        if self.startpoint >= self.ranges[1]:
            print 'part %s has been downloaded over.' % self.filename
            return

        self.onetimesize = 16384  # 16kbyte/time
        print 'task %s will download from %d to %d' % (self.name, self.startpoint, self.ranges[1])

        self.addheader("range", "bytes=%d-%d" % (self.startpoint, self.ranges[1]))
        self.urlhandle = self.open(self.url)

        data = self.urlhandle.read(self.onetimesize)
        while data:
            filehandle = open(self.filename, 'ab+')
            filehandle.write(data)
            filehandle.close()

            self.downloaded += len(data)
            #print "%s" % (self.name)
            #progress = u'\r...'

            data = self.urlhandle.read(self.onetimesize)

 
def geturlfilesize(url, proxies={}):
    urlhandler = urllib.urlopen(url, proxies=proxies)
    headers = urlhandler.info().headers
    length = 0
    for header in headers:
        if header.find('length') != -1:
            length = header.split(':')[-1].strip()
            length = int(length)
    return length

 
def spliteblocks(totalsize, blocknumber):
    blocksize = totalsize / blocknumber
    ranges = []
    for i in range(0, blocknumber - 1):
        ranges.append((i * blocksize, i * blocksize + blocksize - 1))
    ranges.append((blocksize * (blocknumber - 1), totalsize - 1))

    return ranges

 
def islive(tasks):
    for task in tasks:
        if task.isalive():
            return true
    return false

 
def paxel(url, output, blocks=6, proxies=local_proxies):
    ''' paxel
    '''
    size = geturlfilesize(url, proxies)
    ranges = spliteblocks(size, blocks)

    threadname = ["thread_%d" % i for i in range(0, blocks)]
    filename = ["tmpfile_%d" % i for i in range(0, blocks)]

    tasks = []
    for i in range(0, blocks):
        task = axelpython(threadname[i], url, filename[i], ranges[i])
        task.setdaemon(true)
        task.start()
        tasks.append(task)

    time.sleep(2)
    while islive(tasks):
        downloaded = sum([task.downloaded for task in tasks])
        process = downloaded / float(size) * 100
        show = u'\rfilesize:%d downloaded:%d completed:%.2f%%' % (size, downloaded, process)
        sys.stdout.write(show)
        sys.stdout.flush()
        time.sleep(0.5)

    filehandle = open(output, 'wb+')
    for i in filename:
        f = open(i, 'rb')
        filehandle.write(f.read())
        f.close()
        try:
            os.remove(i)
            pass
        except:
            pass

    filehandle.close()

if __name__ == '__main__':
    url = 'http://dldir1.qq.com/qqfile/qqformac/qq_v3.1.1.dmg'
    output = 'download.file'
    paxel(url, output, blocks=4, proxies={})