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