多线程支持断点续传的文件传输－－（摘自大富翁）
?
點(diǎn)到點(diǎn)的多線程支持?jǐn)帱c(diǎn)續(xù)傳的文件傳輸
?
轉(zhuǎn)粘一個(gè)，可惜是VC的，沒(méi)空轉(zhuǎn)為Delphi，將就著，基本思想都在那：
編寫(xiě)斷點(diǎn)續(xù)傳和多線程下載模塊?
分類(lèi):開(kāi)發(fā)? 作者:原創(chuàng)? 發(fā)表于:《程序員》? 下載附件
概述
??? 在當(dāng)今的網(wǎng)絡(luò)時(shí)代，下載軟件是使用最為頻繁的軟件之一。幾年來(lái)，下載技術(shù)也在不停地發(fā)展。最原始的下載功能僅僅是個(gè)“下載”過(guò)程，即從WEB服務(wù)器上連續(xù)地讀取文件。其最大的問(wèn)題是，由于網(wǎng)絡(luò)的不穩(wěn)定性，一旦連接斷開(kāi)使得下載過(guò)程中斷，就不得不全部從頭再來(lái)一次。
??? 隨后，“斷點(diǎn)續(xù)傳”的概念就出來(lái)了，顧名思義，就是如果下載中斷，在重新建立連接后，跳過(guò)已經(jīng)下載的部分，而只下載還沒(méi)有下載的部分。
無(wú)論“多線程下載”技術(shù)是否洪以容先生的發(fā)明，洪以容使得這項(xiàng)技術(shù)得到前所未有的關(guān)注是不爭(zhēng)的事實(shí)。在“網(wǎng)絡(luò)螞蟻”軟件流行開(kāi)后，許多下載軟件也都紛紛效仿，是否具?quot;多線程下載"技術(shù)、甚至能支持多少個(gè)下載線程都成了人們?cè)u(píng)測(cè)下載軟件的要素。"多線程下載"的基礎(chǔ)是WEB服務(wù)器支持遠(yuǎn)程的隨機(jī)讀取，也即支持"斷點(diǎn)續(xù)傳"。這樣，在下載時(shí)可以把文件分成若干部分，每一部分創(chuàng)建一個(gè)下載線程進(jìn)行下載。
??? 現(xiàn)在，不要說(shuō)編寫(xiě)專(zhuān)門(mén)的下載軟件，在自己編寫(xiě)的軟件中，加入下載功能有時(shí)也非常必要。如讓自己的軟件支持自動(dòng)在線升級(jí)，或者在軟件中自動(dòng)下載新的數(shù)據(jù)進(jìn)行數(shù)據(jù)更新，這都是很有用、而且很實(shí)用的功能。本文的主題即怎樣編寫(xiě)一個(gè)支持"斷點(diǎn)續(xù)傳"和"多線程"的下載模塊。當(dāng)然，下載的過(guò)程非常復(fù)雜，在一篇文章中難以全部闡明，所以，與下載過(guò)程關(guān)系不直接的部分基本上都忽略了，如異常處理和網(wǎng)絡(luò)錯(cuò)誤處理等，敬請(qǐng)各位讀者注意。我使用的開(kāi)發(fā)環(huán)境是C++ Builder 5.0，使用其他開(kāi)發(fā)環(huán)境或者編程語(yǔ)言的朋友請(qǐng)自行作適當(dāng)修改。
HTTP協(xié)議簡(jiǎn)介
??? 下載文件是電腦與WEB服務(wù)器交互的過(guò)程，它們交互的"語(yǔ)言"的專(zhuān)業(yè)名稱(chēng)是協(xié)議。傳送文件的協(xié)議有多種，最常用的是HTTP（超文本傳輸協(xié)議）和FTP（文件傳送協(xié)議），我采用的是HTTP。
??? HTTP協(xié)議最基本的命令只有三條：Get、Post和Head。Get從WEB服務(wù)器請(qǐng)求一個(gè)特定的對(duì)象，比如HTML頁(yè)面或者一個(gè)文件，WEB服務(wù)器通過(guò)一個(gè)Socket連接發(fā)送此對(duì)象作為響應(yīng)；Head命令使服務(wù)器給出此對(duì)象的基本描述，比如對(duì)象的類(lèi)型、大小和更新時(shí)間。Post命令用于向WEB服務(wù)器發(fā)送數(shù)據(jù)，通常使把信息發(fā)送給一個(gè)單獨(dú)的應(yīng)用程序，經(jīng)處理生成動(dòng)態(tài)的結(jié)果返回給瀏覽器。下載即是通過(guò)Get命令實(shí)現(xiàn)。
基本的下載過(guò)程
??? 編寫(xiě)下載程序，可以直接使用Socket函數(shù)，但是這要求開(kāi)發(fā)人員理解、熟悉TCP/IP協(xié)議。為了簡(jiǎn)化Internet客戶(hù)端軟件的開(kāi)發(fā)，Windows提供了一套WinInet API，對(duì)常用的網(wǎng)絡(luò)協(xié)議進(jìn)行了封裝，把開(kāi)發(fā)Internet軟件的門(mén)檻大大降低了。我們需要使用的WinInet API函數(shù)如圖1所示，調(diào)用順序基本上是從上到下，其具體的函數(shù)原型請(qǐng)參考MSDN。
圖1
??? 在使用這些函數(shù)時(shí)，必須嚴(yán)格區(qū)分它們使用的句柄。這些句柄的類(lèi)型是一樣的，都是HINTERNET，但是作用不同，這一點(diǎn)非常讓人迷惑。按照這些句柄的產(chǎn)生順序和調(diào)用關(guān)系，可以分為三個(gè)級(jí)別，下一級(jí)的句柄由上一級(jí)的句柄得到。
??? InternetOpen是最先調(diào)用的函數(shù)，它返回的HINTERNET句柄級(jí)別最高，我習(xí)慣定義為hSession，即會(huì)話句柄。
??? InternetConnect使用hSession句柄，返回的是http連接句柄，我把它定義為hConnect。
??? HttpOpenRequest使用hConnect句柄，返回的句柄是http請(qǐng)求句柄，定義為hRequest。
??? HttpSendRequest、HttpQueryInfo、InternetSetFilePointer和InternetReadFile都使用HttpOpenRequest返回的句柄，即hRequest。
??? 當(dāng)這幾個(gè)句柄不再使用是，應(yīng)該用函數(shù)InternetCloseHandle把它關(guān)閉，以釋放其占用的資源。
??? 首先建立一個(gè)名為T(mén)HttpGetThread、創(chuàng)建后自動(dòng)掛起的線程模塊，我希望線程在完成后自動(dòng)銷(xiāo)毀，所以在構(gòu)造函數(shù)中設(shè)置：
FreeOnTerminate = True; // 自動(dòng)刪除
??? 并增加以下成員變量：
char Buffer[HTTPGET_BUFFER_MAX+4]; // 數(shù)據(jù)緩沖區(qū)
AnsiString FURL; // 下載對(duì)象的URL
AnsiString FOutFileName; // 保存的路徑和名稱(chēng)
HINTERNET FhSession; // 會(huì)話句柄
HINTERNET FhConnect; // http連接句柄
HINTERNET FhRequest; // http請(qǐng)求句柄
bool FSuccess; // 下載是否成功
int iFileHandle; // 輸出文件的句柄
1、建立連接
??? 按照功能劃分，下載過(guò)程可以分為4部分，即建立連接、讀取待下載文件的信息并分析、下載文件和釋放占用的資源。建立連接的函數(shù)如下，其中ParseURL的作用是從下載URL地址中取得主機(jī)名稱(chēng)和下載的文件的WEB路徑，DoOnStatusText用于輸出當(dāng)前的狀態(tài)：
//初始化下載環(huán)境
void THttpGetThread::StartHttpGet(void)
{
?? AnsiString HostName,FileName;
?? ParseURL(HostName, FileName);
?? try
?? {
????? // 1.建立會(huì)話
????? FhSession = InternetOpen("http-get-demo",
??????????? INTERNET_OPEN_TYPE_PRECONFIG,
??????????? NULL,NULL,
??????????? 0); // 同步方式
????? if( FhSession==NULL)throw(Exception("Error：InterOpen"));
????? DoOnStatusText("ok：InterOpen");
????? // 2.建立連接
????? FhConnect=InternetConnect(FhSession,
??????????? HostName.c_str(),
??????????? INTERNET_DEFAULT_HTTP_PORT,
??????????? NULL,NULL,
??????????? INTERNET_SERVICE_HTTP, 0, 0);
????? if(FhConnect==NULL)throw(Exception("Error：InternetConnect"));
????? DoOnStatusText("ok：InternetConnect");
????? // 3.初始化下載請(qǐng)求
????? const char *FAcceptTypes = "*/*";
????? FhRequest = HttpOpenRequest(FhConnect,
??????????? "GET", // 從服務(wù)器獲取數(shù)據(jù)
??????????? FileName.c_str(), // 想讀取的文件的名稱(chēng)
??????????? "HTTP/1.1", // 使用的協(xié)議
??????????? NULL,
??????????? &FAcceptTypes,
??????????? INTERNET_FLAG_RELOAD,
??????????? 0);
????? if( FhRequest==NULL)throw(Exception("Error：HttpOpenRequest"));
????? DoOnStatusText("ok：HttpOpenRequest");
????? // 4.發(fā)送下載請(qǐng)求
????? HttpSendRequest(FhRequest, NULL, 0, NULL, 0);
????? DoOnStatusText("ok：HttpSendRequest");
?? }catch(Exception &exception)
?? {
????? EndHttpGet(); // 關(guān)閉連接，釋放資源
????? DoOnStatusText(exception.Message);
?? }
}
// 從URL中提取主機(jī)名稱(chēng)和下載文件路徑
void THttpGetThread::ParseURL(AnsiString &HostName,AnsiString &FileName)
{
?? AnsiString URL=FURL;
?? int i=URL.Pos("http://");
?? if(i>0)
?? {
????? URL.Delete(1, 7);
?? }
?? i=URL.Pos("/");
?? HostName = URL.SubString(1, i-1);
?? FileName = URL.SubString(i, URL.Length());
}
??? 可以看到，程序按照?qǐng)D1中的順序，依次調(diào)用InternetOpen、InternetConnect、HttpOpenRequest函數(shù)得到3個(gè)相關(guān)的句柄，然后通過(guò)HttpSendRequest函數(shù)把下載的請(qǐng)求發(fā)送給WEB服務(wù)器。
??? InternetOpen的第一個(gè)參數(shù)是無(wú)關(guān)的，最后一個(gè)參數(shù)如果設(shè)置為INTERNET_FLAG_ASYNC，則將建立異步連接，這很有實(shí)際意義，考慮到本文的復(fù)雜程度，我沒(méi)有采用。但是對(duì)于需要更高下載要求的讀者，強(qiáng)烈建議采用異步方式。
??? HttpOpenRequest打開(kāi)一個(gè)請(qǐng)求句柄，命令是"GET"，表示下載文件，使用的協(xié)議是"HTTP/1.1"。
??? 另外一個(gè)需要注意的地方是HttpOpenRequest的參數(shù)FAcceptTypes，表示可以打開(kāi)的文件類(lèi)型，我設(shè)置為"*/*"表示可以打開(kāi)所有文件類(lèi)型，可以根據(jù)實(shí)際需要改變它的值。
2、讀取待下載的文件的信息并分析
??? 在發(fā)送請(qǐng)求后，可以使用HttpQueryInfo函數(shù)獲取文件的有關(guān)信息，或者取得服務(wù)器的信息以及服務(wù)器支持的相關(guān)操作。對(duì)于下載程序，最常用的是傳遞HTTP_QUERY_CONTENT_LENGTH參數(shù)取得文件的大小，即文件包含的字節(jié)數(shù)。模塊如下所示：
// 取得待下載文件的大小
int __fastcall THttpGetThread::GetWEBFileSize(void)
{
?? try
?? {
????? DWORD BufLen=HTTPGET_BUFFER_MAX;
??????????? DWORD dwIndex=0;
??????????? bool RetQueryInfo=HttpQueryInfo(FhRequest,
??????????? HTTP_QUERY_CONTENT_LENGTH,
??????????? Buffer, &BufLen,
??????????? &dwIndex);
????? if( RetQueryInfo==false) throw(Exception("Error：HttpQueryInfo"));
????? DoOnStatusText("ok：HttpQueryInfo");
????? int FileSize=StrToInt(Buffer); // 文件大小
????? DoOnGetFileSize(FileSize);
?? }catch(Exception &exception)
?? {
????? DoOnStatusText(exception.Message);
?? }
?? return FileSize;
}
??? 模塊中的DoOnGetFileSize是發(fā)出取得文件大小的事件。取得文件大小后，對(duì)于采用多線程的下載程序，可以按照這個(gè)值進(jìn)行合適的文件分塊，確定每個(gè)文件塊的起點(diǎn)和大小。
3、下載文件的模塊
??? 開(kāi)始下載前，還應(yīng)該先安排好怎樣保存下載結(jié)果。方法很多，我直接采用了C++ Builder提供的文件函數(shù)打開(kāi)一個(gè)文件句柄。當(dāng)然，也可以采用Windows本身的API，對(duì)于小文件，全部緩沖到內(nèi)存中也可以考慮。
// 打開(kāi)輸出文件，以保存下載的數(shù)據(jù)
DWORD THttpGetThread::OpenOutFile(void)
{
?? try
?? {
?? if(FileExists(FOutFileName))
????? DeleteFile(FOutFileName);
?? iFileHandle=FileCreate(FOutFileName);
?? if(iFileHandle==-1) throw(Exception("Error：FileCreate"));
?? DoOnStatusText("ok:CreateFile");
?? }catch(Exception &exception)
?? {
????? DoOnStatusText(exception.Message);
?? }
?? return 0;
}
// 執(zhí)行下載過(guò)程
void THttpGetThread::DoHttpGet(void)
{
?? DWORD dwCount=OpenOutFile();
?? try
?? {
????? // 發(fā)出開(kāi)始下載事件
????? DoOnStatusText("StartGet：InternetReadFile");
????? // 讀取數(shù)據(jù)
????? DWORD dwRequest; // 請(qǐng)求下載的字節(jié)數(shù)
????? DWORD dwRead; // 實(shí)際讀出的字節(jié)數(shù)
????? dwRequest=HTTPGET_BUFFER_MAX;
????? while(true)
????? {
???????? Application->ProcessMessages();
???????? bool ReadReturn = InternetReadFile(FhRequest,
????????????? (LPVOID)Buffer,
????????????? dwRequest,
????????????? &dwRead);
???????? if(!ReadReturn)break;
???????? if(dwRead==0)break;
???????? // 保存數(shù)據(jù)
???????? Buffer[dwRead]='\0';
???????? FileWrite(iFileHandle, Buffer, dwRead);
???????? dwCount = dwCount + dwRead;
???????? // 發(fā)出下載進(jìn)程事件
???????? DoOnProgress(dwCount);
????? }
????? Fsuccess=true;
?? }catch(Exception &exception)
?? {
????? Fsuccess=false;
????? DoOnStatusText(exception.Message);
?? }
?? FileClose(iFileHandle);
?? DoOnStatusText("End：InternetReadFile");
}
??? 下載過(guò)程并不復(fù)雜，與讀取本地文件一樣，執(zhí)行一個(gè)簡(jiǎn)單的循環(huán)。當(dāng)然，如此方便的編程還是得益于微軟對(duì)網(wǎng)絡(luò)協(xié)議的封裝。
4、釋放占用的資源
??? 這個(gè)過(guò)程很簡(jiǎn)單，按照產(chǎn)生各個(gè)句柄的相反的順序調(diào)用InternetCloseHandle函數(shù)即可。
void THttpGetThread::EndHttpGet(void)
{
?? if(FConnected)
?? {
????? DoOnStatusText("Closing:InternetConnect");
????? try
????? {
???????? InternetCloseHandle(FhRequest);
???????? InternetCloseHandle(FhConnect);
???????? InternetCloseHandle(FhSession);
????? }catch(...){}
????? FhSession=NULL;
????? FhConnect=NULL;
????? FhRequest=NULL;
????? FConnected=false;
????? DoOnStatusText("Closed:InternetConnect");
?? }
}
??? 我覺(jué)得，在釋放句柄后，把變量設(shè)置為NULL是一種良好的編程習(xí)慣。在這個(gè)示例中，還出于如果下載失敗，重新進(jìn)行下載時(shí)需要再次利用這些句柄變量的考慮。
5、功能模塊的調(diào)用
??? 這些模塊的調(diào)用可以安排在線程對(duì)象的Execute方法中，如下所示：
void __fastcall THttpGetThread::Execute()
{
?? FrepeatCount=5;
?? for(int i=0;i<FRepeatCount;i++)
?? {
????? StartHttpGet();
????? GetWEBFileSize();
????? DoHttpGet();
????? EndHttpGet();
????? if(FSuccess)break;
?? }
?? // 發(fā)出下載完成事件
?? if(FSuccess)DoOnComplete();
?? else DoOnError();
}
??? 這里執(zhí)行了一個(gè)循環(huán)，即如果產(chǎn)生了錯(cuò)誤自動(dòng)重新進(jìn)行下載，實(shí)際編程中，重復(fù)次數(shù)可以作為參數(shù)自行設(shè)置。
實(shí)現(xiàn)斷點(diǎn)續(xù)傳功能
??? 在基本下載的代碼上實(shí)現(xiàn)斷點(diǎn)續(xù)傳功能并不是很復(fù)雜，主要的問(wèn)題有兩點(diǎn)：
1、 檢查本地的下載信息，確定已經(jīng)下載的字節(jié)數(shù)。所以應(yīng)該對(duì)打開(kāi)輸出文件的函數(shù)作適當(dāng)修改。我們可以建立一個(gè)輔助文件保存下載的信息，如已經(jīng)下載的字節(jié)數(shù)等。我處理得較為簡(jiǎn)單，先檢查輸出文件是否存在，如果存在，再得到其大小，并以此作為已經(jīng)下載的部分。由于Windows沒(méi)有直接取得文件大小的API，我編寫(xiě)了GetFileSize函數(shù)用于取得文件大小。注意，與前面相同的代碼被省略了。
DWORD THttpGetThread::OpenOutFile(void)
{
?? ……
?? if(FileExists(FOutFileName))
?? {
????? DWORD dwCount=GetFileSize(FOutFileName);
????? if(dwCount>0)
????? {
???????? iFileHandle=FileOpen(FOutFileName,fmOpenWrite);
???????? FileSeek(iFileHandle,0,2); // 移動(dòng)文件指針到末尾
???????? if(iFileHandle==-1) throw(Exception("Error：FileCreate"));
???????? DoOnStatusText("ok:OpenFile");
???????? return dwCount;
????? }
????? DeleteFile(FOutFileName);
?? }
?? ……
}
2、 在開(kāi)始下載文件（即執(zhí)行InternetReadFile函數(shù)）之前，先調(diào)整WEB上的文件指針。這就要求WEB服務(wù)器支持隨機(jī)讀取文件的操作，有些服務(wù)器對(duì)此作了限制，所以應(yīng)該判斷這種可能性。對(duì)DoHttpGet模塊的修改如下，同樣省略了相同的代碼：
void THttpGetThread::DoHttpGet(void)
{
?? DWORD dwCount=OpenOutFile();
?? if(dwCount>0) // 調(diào)整文件指針
?? {
????? dwStart = dwStart + dwCount;
????? if(!SetFilePointer()) // 服務(wù)器不支持操作
????? {
???????? // 清除輸出文件
???????? FileSeek(iFileHandle,0,0); // 移動(dòng)文件指針到頭部
????? }
?? }
?? ……
}
多線程下載
??? 要實(shí)現(xiàn)多線程下載，最主要的問(wèn)題是下載線程的創(chuàng)建和管理，已經(jīng)下載完成后文件的各個(gè)部分的準(zhǔn)確合并，同時(shí)，下載線程也要作必要的修改。
1、下載線程的修改
??? 為了適應(yīng)多線程程序，我在下載線程加入如下成員變量：
int FIndex; // 在線程數(shù)組中的索引
DWORD dwStart; // 下載開(kāi)始的位置
DWORD dwTotal; // 需要下載的字節(jié)數(shù)
DWORD FGetBytes; // 下載的總字節(jié)數(shù)
??? 并加入如下屬性值：
__property AnsiString URL = { read=FURL, write=FURL };
__property AnsiString OutFileName = { read=FOutFileName, write=FOutFileName};
__property bool Successed = { read=FSuccess};
__property int Index = { read=FIndex, write=FIndex};
__property DWORD StartPostion = { read=dwStart, write=dwStart};
__property DWORD GetBytes = { read=dwTotal, write=dwTotal};
__property TOnHttpCompelete OnComplete = { read=FOnComplete, write=FOnComplete };
??? 同時(shí)，在下載過(guò)程DoHttpGet中增加如下處理，
void THttpGetThread::DoHttpGet(void)
{
?? ……
?? try
?? {
????? ……
????? while(true)
????? {
???????? Application->ProcessMessages();
???????? // 修正需要下載的字節(jié)數(shù)，使得dwRequest + dwCount <dwTotal;
???????? if(dwTotal>0) // dwTotal=0表示下載到文件結(jié)束
???????? {
??????????? if(dwRequest+dwCount>dwTotal)
??????????? dwRequest=dwTotal-dwCount;
???????? }
???????? ……
???????? if(dwTotal>0) // dwTotal <=0表示下載到文件結(jié)束
???????? {
??????????? if(dwCount>=dwTotal)break;
???????? }
????? }
?? }
?? ……
?? if(dwCount==dwTotal)FSuccess=true;
}
2、建立多線程下載組件
??? 我先建立了以TComponent為基類(lèi)、名為T(mén)HttpGetEx的組件模塊，并增加以下成員變量：
// 內(nèi)部變量
THttpGetThread **HttpThreads; // 保存建立的線程
AnsiString *OutTmpFiles; // 保存結(jié)果文件各個(gè)部分的臨時(shí)文件
bool *FSuccesss; // 保存各個(gè)線程的下載結(jié)果
// 以下是屬性變量
int FHttpThreadCount; // 使用的線程個(gè)數(shù)
AnsiString FURL;
AnsiString FOutFileName;
??? 各個(gè)變量的用途都如代碼注釋，其中的FSuccess的作用比較特別，下文會(huì)再加以詳細(xì)解釋。因?yàn)榫€程的運(yùn)行具有不可逆性，而組件可能會(huì)連續(xù)地下載不同的文件，所以下載線程只能動(dòng)態(tài)創(chuàng)建，使用后隨即銷(xiāo)毀。創(chuàng)建線程的模塊如下，其中GetSystemTemp函數(shù)取得系統(tǒng)的臨時(shí)文件夾，OnThreadComplete是線程下載完成后的事件，其代碼在其后介紹：
// 分配資源
void THttpGetEx::AssignResource(void)
{
?? FSuccesss=new bool[FHttpThreadCount];
?? for(int i=0;i<FHttpThreadCount;i++)
????? FSuccesss[i]=false;
?? OutTmpFiles = new AnsiString[FHttpThreadCount];
?? AnsiString ShortName=ExtractFileName(FOutFileName);
?? AnsiString Path=GetSystemTemp();
?? for(int i=0;i<FHttpThreadCount;i++)
????? OutTmpFiles[i]=Path+ShortName+"-"+IntToStr(i)+".hpt";
?? HttpThreads = new THttpGetThread *[FHttpThreadCount];
}
// 創(chuàng)建一個(gè)下載線程
THttpGetThread * THttpGetEx::CreateHttpThread(void)
{
?? THttpGetThread *HttpThread=new THttpGetThread(this);
?? HttpThread->URL=FURL;
?? …… // 初始化事件
?? HttpThread->OnComplete=OnThreadComplete; // 線程下載完成事件
?? return HttpThread;
}
// 創(chuàng)建下載線程數(shù)組
void THttpGetEx::CreateHttpThreads(void)
{
?? AssignResource();
?? // 取得文件大小，以決定各個(gè)線程下載的起始位置
?? THttpGetThread *HttpThread=CreateHttpThread();
?? HttpThreads[FHttpThreadCount-1]=HttpThread;
?? int FileSize=HttpThread->GetWEBFileSize();
?? // 把文件分成FHttpThreadCount塊
?? int AvgSize=FileSize/FHttpThreadCount;
?? int *Starts= new int[FHttpThreadCount];
?? int *Bytes = new int[FHttpThreadCount];
?? for(int i=0;i<FHttpThreadCount;i++)
?? {
????? Starts[i]=i*AvgSize;
????? Bytes[i] =AvgSize;
?? }
?? // 修正最后一塊的大小
?? Bytes[FHttpThreadCount-1]=AvgSize+(FileSize-AvgSize*FHttpThreadCount);
?? // 檢查服務(wù)器是否支持?jǐn)帱c(diǎn)續(xù)傳
?? HttpThread->StartPostion=Starts[FHttpThreadCount-1];
?? HttpThread->GetBytes=Bytes[FHttpThreadCount-1];
?? bool CanMulti=HttpThread->SetFilePointer();
?? if(CanMulti==false) // 不支持，直接下載
?? {
????? FHttpThreadCount=1;
????? HttpThread->StartPostion=0;
????? HttpThread->GetBytes=FileSize;
????? HttpThread->Index=0;
????? HttpThread->OutFileName=OutTmpFiles[0];
?? }else
?? {
????? HttpThread->OutFileName=OutTmpFiles[FHttpThreadCount-1];
????? HttpThread->Index=FHttpThreadCount-1;
????? // 支持?jǐn)帱c(diǎn)續(xù)傳，建立多個(gè)線程
????? for(int i=0;i<FHttpThreadCount-1;i++)
????? {
???????? HttpThread=CreateHttpThread();
???????? HttpThread->StartPostion=Starts[i];
???????? HttpThread->GetBytes=Bytes[i];
???????? HttpThread->OutFileName=OutTmpFiles[i];
???????? HttpThread->Index=i;
???????? HttpThreads[i]=HttpThread;
????? }
?? }
?? // 刪除臨時(shí)變量
?? delete Starts;
?? delete Bytes;
}
??? 下載文件的下載的函數(shù)如下：
void __fastcall THttpGetEx::DownLoadFile(void)
{
?? CreateHttpThreads();
?? THttpGetThread *HttpThread;
?? for(int i=0;i<FHttpThreadCount;i++)
?? {
????? HttpThread=HttpThreads[i];
????? HttpThread->Resume();
?? }
}
??? 線程下載完成后，會(huì)發(fā)出OnThreadComplete事件，在這個(gè)事件中判斷是否所有下載線程都已經(jīng)完成，如果是，則合并文件的各個(gè)部分。應(yīng)該注意，這里有一個(gè)線程同步的問(wèn)題，否則幾個(gè)線程同時(shí)產(chǎn)生這個(gè)事件時(shí)，會(huì)互相沖突，結(jié)果也會(huì)混亂。同步的方法很多，我的方法是創(chuàng)建線程互斥對(duì)象。
const char *MutexToThread="http-get-thread-mutex";
void __fastcall THttpGetEx::OnThreadComplete(TObject *Sender, int Index)
{
?? // 創(chuàng)建互斥對(duì)象
?? HANDLE hMutex= CreateMutex(NULL,FALSE,MutexToThread);
?? DWORD Err=GetLastError();
?? if(Err==ERROR_ALREADY_EXISTS) // 已經(jīng)存在,等待
?? {
????? WaitForSingleObject(hMutex,INFINITE);//8000L);
????? hMutex= CreateMutex(NULL,FALSE,MutexToThread);
?? }
?? // 當(dāng)一個(gè)線程結(jié)束時(shí)，檢查是否全部認(rèn)為完成
?? FSuccesss[Index]=true;
?? bool S=true;
?? for(int i=0;i<FHttpThreadCount;i++)
?? {
????? S = S && FSuccesss[i];
?? }
?? ReleaseMutex(hMutex);
?? if(S)// 下載完成，合并文件的各個(gè)部分
?? {
????? // 1. 復(fù)制第一部分
????? CopyFile(OutTmpFiles[0].c_str(),FOutFileName.c_str(),false);
????? // 添加其他部分
????? int hD=FileOpen(FOutFileName,fmOpenWrite);
????? FileSeek(hD,0,2); // 移動(dòng)文件指針到末尾
????? if(hD==-1)
????? {
???????? DoOnError();
???????? return;
????? }
????? const int BufSize=1024*4;
????? char Buf[BufSize+4];
????? int Reads;
????? for(int i=1;i<FHttpThreadCount;i++)
????? {
???????? int hS=FileOpen(OutTmpFiles[i],fmOpenRead);
???????? // 復(fù)制數(shù)據(jù)
???????? Reads=FileRead(hS,(void *)Buf,BufSize);
???????? while(Reads>0)
???????? {
??????????? FileWrite(hD,(void *)Buf,Reads);
??????????? Reads=FileRead(hS,(void *)Buf,BufSize);
???????? }
???????? FileClose(hS);
????? }
????? FileClose(hD);
?? }
}
結(jié)語(yǔ)
??? 到此，多線程下載的關(guān)鍵部分就介紹完了。但是在實(shí)際應(yīng)用時(shí)，還有許多應(yīng)該考慮的因素，如網(wǎng)絡(luò)速度、斷線等等都是必須考慮的。當(dāng)然還有一些細(xì)節(jié)上的考慮，但是限于篇幅，就難以一一寫(xiě)明了。如果讀者朋友能夠參照本文編寫(xiě)出自己滿意的下載程序，我也就非常欣慰了。我也非常希望讀者能由此與我互相學(xué)習(xí)，共同進(jìn)步。
??? 關(guān)于本文的詳細(xì)示例（包括下載組件和使用程序），請(qǐng)到《程序員》網(wǎng)址下載。
?
轉(zhuǎn)載于:https://www.cnblogs.com/duhai_lee/archive/2005/03/30/128513.html
總結(jié)
以上是生活随笔為你收集整理的多线程支持断点续传的文件传输－－（摘自大富翁）的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。
