【文章內(nèi)容簡介】 //任務結束位置 }m_fromTo。 typedef struct InfroImpl{ String fileLoad。 //文件保存位置 DWORD fileSize。 //文件大小 int threadCnt。 //下載線程數(shù) DWORD alreadyDownloadCnt。 //已經(jīng)下載的文件大小 FromToImpl *fromToImpl。 //各個線程的任務描述}m_inforImpl。三 FTP多線程斷點續(xù)傳的實現(xiàn)以及編碼 實現(xiàn)方法仍采用服務器與客戶模式，需分別對其設計與編程。運用VC++編程語言，基于TCP/IP協(xié)議服務器端較簡單，主要就是加入待傳文件，監(jiān)聽客戶，和傳送文件。而那些斷點續(xù)傳的功能，以及文件的管理都放在客戶端上。 FTP工作流程 FTP典型工作流程如下： （1）客戶端創(chuàng)建socket；（2）客戶端連接FTP服務器；（3）客戶端發(fā)送命令到FTP服務器；（4）客戶端接收FTP服務的返回信息；（5）客戶端發(fā)送PORT命令請求建立數(shù)據(jù)鏈接；（6）客戶端連接FTP服務器返回的IP及端口；（7）客戶端發(fā)送數(shù)據(jù)到服務器；（8）客戶端發(fā)QUIT結束會話。 服務器端代碼實現(xiàn)一、首先介紹服務器端：最開始我們要定義一個簡單的協(xié)議，也就是定義一個服務器端與客戶端聽得懂的語言。而為了把問題簡化，就讓服務器只要聽懂兩句話，一就是客戶說“請求讀文件信息”，二就是“準備好了，可以傳文件了”。由于要實現(xiàn)多線程，必須把功能獨立出來，且包裝成線程，首先建一個監(jiān)聽線程，主要負責接入客戶，并啟動另一個客戶線程。用VC++實現(xiàn)如下：DWORD WINAPI listenthread(LPVOID lpparam){ //由主函數(shù)傳來的套接字 SOCKET pthis=(SOCKET)lpparam。 //開始監(jiān)聽 int rc=listen(pthis,30)。 //如果錯就顯示信息if(rc0){ CString aaa。 aaa=listen錯誤\n。 AfxGetMainWnd()SendMessageToDescendants(WM_AGE1,(LPARAM)(0),1)。 ()。 return 0。 } //進入循環(huán)，并接收到來的套接字 while(1){ //新建一個套接字，用于客戶端 SOCKET s1。 s1=accept(pthis,NULL,NULL)。 //給主函數(shù)發(fā)有人聯(lián)入消息 CString aa。 aa=一人聯(lián)入！\n。 AfxGetMainWnd()SendMessageToDescendants(WM_AGE1,(LPARAM)(0),1)。 ()。 DWORD dwthread。 //建立用戶線程 ::CreateThread(NULL,0,clientthread,(LPVOID)s1,0,amp。dwthread)。 } return 0。}接著來看用戶線程：先看文件消息類定義：struct fileinfo{ int fileno。//文件號 int type。//客戶端想說什么（前面那兩句話，用1,2表示） long len。//文件長度 int seek。//文件開始位置，用于多線程 char name[100]。//文件名}。用戶線程函數(shù): DWORD WINAPI clientthread(LPVOID lpparam){ //文件消息 fileinfo* fiinfo。 //接收緩存 char* m_buf。 m_buf=new char[100]。 //監(jiān)聽函數(shù)傳來的用戶套接字 SOCKET pthis=(SOCKET)lpparam。 //讀傳來的信息 int aa=readn(pthis,m_buf,100)。 //如果有錯就返回 if(aa0){ closesocket (pthis)。 return 1。 } //把傳來的信息轉為定義的文件信息 fiinfo=(fileinfo*)m_buf。 CString aaa。 //檢驗客戶想說什么 switch(fiinfotype) { //我要讀文件信息 case 0: //讀文件 aa=sendn(pthis,(char*)zmfile,1080)。 //有錯 if(aa0){ closesocket (pthis)。 return 1。 } //發(fā)消息給主函數(shù) aaa=收到LIST命令\n。 AfxGetMainWnd()SendMessageToDescendants(WM_AGE1,(LPARAM)(0),1)。 break。 //我準備好了，可以傳文件了 case 2: //發(fā)文件消息給主函數(shù)(%s 文件被請求！%s\n,zmfile[fiinfofileno].name,nameph[fiinfofileno])。 AfxGetMainWnd()SendMessageToDescendants(WM_AGE1,(LPARAM)(0),1)。 //讀文件，并傳送 readfile(pthis,fiinfoseek,fiinfolen,fiinfofileno)。 //聽不懂你說什么 default: aaa=接收協(xié)議錯誤！\n。 AfxGetMainWnd()SendMessageToDescendants(WM_AGE1,(LPARAM)(0),1)。 break。} return 0。}讀文件函數(shù) void readfile(SOCKET so,int seek,int len,int fino){ //文件名 CString myname。 (%s,nameph[fino])。 CFile myFile。 //打開文件 (myname, CFile::modeRead | CFile::typeBinary|CFile::shareDenyNone)。 //傳到指定位置 (seek,CFile::begin)。 char m_buf[SIZE]。 int len2。 int len1。 len1=len。 //開始接收，直到發(fā)完整個文件 while(len10){ len2=lenSIZE?SIZE:len。 (m_buf, len2)。 int aa=sendn(so,m_buf,len2)。 if(aa0){ closesocket (so)。 break。 }len1=len1aa。 len=lenaa。 } ()。} 客戶端代碼實現(xiàn) 客戶端最重要，也最復雜，它負責線程的管理，進度的記錄等工作。大概流程如下：先連接服務器，接著發(fā)送命令1（給我文件信息），其中包括文件長度，名字等，然后根據(jù)長度決定分幾個線程下載，并初使化下載進程，接著發(fā)送命令2（可以給我傳文件了），并記錄文件進程。最后，收尾。這其中有一個十分重要的類，就是cdownload類，定義如下： class cdownload {public: void createthread()。//開線程 DWORD finish1()。//完成線程 int sendlist()。//發(fā)命令1 downinfo doinfo。//文件信息（與服務器定義一樣） int startask(int n)。開始傳文件n long m_index。 BOOL good[BLACK]。 int filerange[100]。 CString fname。 CString fnametwo。 UINT threadfunc(long index)。//下載進程 int sendrequest(int n)。//發(fā)文件信息 cdownload(int thno1)。 virtual ~cdownload()。}。下面先介紹sendrequest(int n)，在開始前，向服務器發(fā)獲得文件消息命令，以便讓客戶端知道有哪些文件可傳 int cdownload::sendrequest(int n){ //建套接字 sockaddr_in local。SOCKET m_socket。 int rc=0。 //初使化服務器地址 =AF_INET。 =htons(1028)。 =inet_addr(ip)。 m_socket=socket(AF_INET,SOCK_STREAM,0)。 int ret。 //聯(lián)接服務器 ret=connect(m_socket,(LPSOCKADDR)amp。local,sizeof(local))。 //有錯的話 if(ret0){ AfxMessageBox(聯(lián)接錯誤)。 closesocket(m_socket)。 return 1。 } //初始化命令 fileinfo fileinfo1。 =n。 =50。 =1。 //發(fā)送命令 int aa=sendn(m_socket,(char*)amp。fileinfo1,100)。 if(aa0){ closesocket(m_socket)。 return 1。 } //接收服務器傳來的信息 aa=readn(m_socket,(char*)amp。fileinfo1,100)。 if(aa0){ closesocket(m_socket)。 return 1。 }//關閉 shutdown(m_socket,2)。 closesocket(m_socket)。 return 1。}有了文件消息后我們就可以下載文件了。在主函數(shù)中，用法如下： //下載第clno個文件，并為它建一個新cdownload類down[clno]=new cdownload(clno)。//開始下載，并初使化type=down[clno]startask(clno)。//建立各線程createthread(clno)。下面介紹開始方法: //開始方法int cdownload::startask(int n){ //讀入文件長度 =zmfile[n].length。 //讀入名字 fname=zmfile[n].name。 CString tmep。 //初使化文件名 (\\temp\\%s,fname)。 //給主函數(shù)發(fā)