Python 用多線程上傳和下載文件

# -*- coding: utf-8 -*-
__author__ = 'louis'

from ftplib import FTP
import multiprocessing
import time


def ftpconnect():
    ftp = FTP()
    timeout = 30
    port = 22
    ftp.connect('localhost',port,timeout) # 連接FTP服務器
    ftp.login('user','password') # 登錄
    return ftp

def upload(FileName, FileLocalation):
    ftp = ftpconnect()
    # print ftp.getwelcome() # 獲得歡迎信息
    ftp.cwd(r"") # 設置FTP路徑
    for i in range(len(FileName)):
        print "%s The start of upload, %s" % (time.ctime(),FileName[i])
        fp = open(FileLocalation[i], 'rb')

        ftp.storbinary('STOR ' + FileName[i], fp)
        fp.close()
        print "%s The end of the %s" % (time.ctime(), FileName[i])
    ftp.quit() # 退出FTP服務器

def download(FileName, FilePath):
    ftp = ftpconnect()
    ftp.cwd(r"") # 設置FTP路徑
    for i in range(len(FileName)):
        print "%s The start of downloading, %s" % (time.ctime(), FileName[i])
        file_handle = open(FilePath[i], 'w').write

        ftp.retrbinary("RETR " + FileName[i], file_handle)
        print "%s The end of the %s" % (time.ctime(), FileName[i])

    ftp.quit()


if __name__=='__main__':
    # 上傳視頻文件到服務器  前提是在c:\te中，已經有1000個視頻文件，它們的名字分別是1.avi, 2.avi. 3.avi, ..., 1000.avi
    # p = [None]*1000
    # filelocal = r'c:\Te'          
    #
    # for i in range(20):
    #     baiWei = i * 50
    #     filename = [None] * 50
    #     filelocalation = [None] * 50
    #     for j in range(50):
    #         filename_pre = baiWei + j + 1
    #         filename[j] = "%s.avi" % filename_pre
    #         filelocalation[j] = filelocal + "\\" + filename[j]
    #     print filelocalation
    #     p[i] = multiprocessing.Process(target=upload, args=(filename, filelocalation))
    #
    # for i in range(20):
    #     p[i].start()


    # 下載視頻文件到本地,  前提是ftp服務器中已經有100個視頻文件，它們的名字是1.avi, 2.avi, 3.avi, ..., 100.avi
    p = [None]*100
    fileDir = r'D:\local'
    for i in range(10):
        shiWei = i * 10
        fileName = [None]*10
        filePath = [None]*10
        for j in range(10):
            fileName_pre = shiWei + j + 1
            fileName[j] = "%s.avi" % fileName_pre
            filePath[j] = fileDir + "\\" + fileName[j]
        print filePath
        p[i] = multiprocessing.Process(target=download, args=(fileName, filePath))

    for i in range(10):
        p[i].start()