小男孩‘自慰网亚洲一区二区,亚洲一级在线播放毛片,亚洲中文字幕av每天更新,黄aⅴ永久免费无码,91成人午夜在线精品,色网站免费在线观看,亚洲欧洲wwwww在线观看

搜索
分享

socket實現(xiàn)大型文件傳輸

 orion360doc 2011-12-21

2011-12-18 17:03

       最近需要做網(wǎng)絡(luò)傳輸?shù)捻椖?，需要實現(xiàn)較大文件的傳輸。在網(wǎng)上收集了不少資料，但是各有各的做法，尤其是關(guān)于文件自動接收這一塊不太清楚。 經(jīng)過圖書館查閱后還是找到了一種解決辦法，雖然做的不太專業(yè)，但是思路比較精簡、清晰，也希望能給大家尤其是剛學(xué)習(xí)socket套接字的人一些啟示。

                               

   對于套接字socket我其實也不太懂，并且一般資料都可以查找到，所以不交易累贅了，直接說如何實現(xiàn)文件的傳輸吧。

    對于發(fā)送文件，有三步：發(fā)送文件長度，發(fā)送文件名，發(fā)送文件內(nèi)容。 

    關(guān)于發(fā)送文件內(nèi)容，又可以根據(jù)文件大小進(jìn)行直接傳輸和分塊傳輸，如果是分塊傳輸還需要多線程，否則會容易使程序失去響應(yīng)。 在這里其實我也有一個疑惑，就是通過CFileDialog類GetFileName函數(shù)獲取文件名，一般沒有問題，但是當(dāng)文件名很長（如大于60）時不能完整讀取，導(dǎo)致接收方無法判別文件類型。 所以保險起見，我就從GetFilePath中截取出了文件名。

  1. void CChatDlg::OnSend()   
  2. {  
  3.     if(flag==-1)  
  4.     {  
  5.         MessageBox("處于未連接狀態(tài)");  
  6.         return;  
  7.     }  
  8.       
  9.     CFileDialog  dlg(TRUE);  
  10.     dlg.m_ofn.lpstrTitle="選擇圖片";  
  11.     dlg.m_ofn.lpstrFilter="All Files";  
  12.     CString path="";  
  13.     CString name="";  
  14.     if(dlg.DoModal()==IDOK)  
  15.     {  
  16.         path=dlg.GetPathName();//獲取文件路徑名   
  17.         //name=dlg.GetFileName();//獲取文件名   
  18.     }  
  19.     if(path=="")  
  20.         return ;//表示沒有選擇任何元素   
  21.   
  22.      //不直接讀取文件名，而是從路徑名中截取   
  23.     int pos=0,start=0;  
  24.     while(1)  
  25.     {  
  26.         start=pos;  
  27.         pos=path.Find('\\',start+1);  
  28.         if(pos<0)  
  29.             break;  
  30.     }  
  31.     name=path.Right(path.GetLength()-start-1);  
  32.     file.Open(path,CFile::modeRead);//打開文件   
  33.      dwlen=file.GetLength();//獲取文件長度   
  34.     m_se.SetRange32(0,dwlen);  
  35.     CString te;  
  36.     te.Format("%d",dwlen);  
  37.     if(flag==0)//發(fā)送圖片數(shù)據(jù)   
  38.         send(m_accept, te.GetBuffer(0), 10, 0);//發(fā)送文件的長度   
  39.     if(flag==1)  
  40.         send(m_local, te.GetBuffer(0), 10, 0);  
  41.     Sleep(500);//延時   
  42.       
  43.     if(flag==0)//發(fā)送圖片數(shù)據(jù)   
  44.         send(m_accept, name.GetBuffer(0), name.GetLength(), 0);//發(fā)送文件的名   
  45.     if(flag==1)  
  46.         send(m_local, name.GetBuffer(0), name.GetLength(), 0);  
  47.     Sleep(500);//延時   
  48.       
  49.       
  50.     if(dwlen<=1024*1024)//如果小于1M就直接傳輸   
  51.     {  
  52.         if(date!=NULL)  
  53.         {  
  54.             delete []date;  
  55.             date=NULL;  
  56.         }  
  57.         date=new char[dwlen];//開辟neicun   
  58.         memset(date,0,dwlen);//初始化   
  59.         file.Read(date,dwlen);//讀取文件   
  60.         file.Close();  
  61.         int n=0;  
  62.         if(flag==0)//發(fā)送圖片數(shù)據(jù)   
  63.             n=send(m_accept, date, dwlen, 0);  
  64.         if(flag==1)  
  65.             n=send(m_local, date, dwlen, 0);  
  66.         m_se.SetPos(n);  
  67.         CString ss;  
  68.         ss.Format("%d   %d",dwlen,n);    
  69.         ss+="發(fā)送完成";  
  70.         MessageBox(ss);  
  71.         delete []date;  
  72.         date=NULL;  
  73.     }  
  74.     else  
  75.     {  
  76.        //需要選擇多線程，創(chuàng)建一個線程   
  77.         p_thread=AfxBeginThread(SEND,this,0,0,0,NULL);//開啟一個線程   
  78.     }     
  79. }  

    注解中的什么圖片的是錯誤的，是可以傳輸任意格式的文件的。大家可以看到我提取文件名的過程繁瑣，原因我

上面一段已經(jīng)說明了，也希望大家更好的解決方法。其中flag的值時表示是服務(wù)端還是客戶端，0-服務(wù)端，1-客戶端，集合在了一個程序中。  

     注意：：： 其中的Sleep(500)的延時是因為為了讓接受方有足夠多的時間獲取文件長度和文件名關(guān)鍵信息，如果不延時，接收方會先接受到文件內(nèi)容后接收到文件長度和文件名，順序是相反的，具體原因我也沒弄清楚，希望大家指教。

      最后是關(guān)于一個線程的函數(shù)，具體如下：

  1. UINT SEND(LPVOID pThreadParam)//線程函數(shù)   
  2. {  
  3.     CChatDlg *dlg=(CChatDlg *)pThreadParam;  
  4.     if(date!=NULL)  
  5.         {  
  6.             delete []date;  
  7.             date=NULL;  
  8.         }  
  9.         int total=0,len=0;  
  10.         while(total<dwlen)//直到全部發(fā)送完成   
  11.         {   
  12.                 if(dwlen-total>=1024*100)  
  13.                 {  
  14.                    date=new char[1024*100];  
  15.                    memset(date,0,1024*100);  
  16.                    file.Read(date,1024*100);  
  17.                    if(dlg->flag==0)//發(fā)送數(shù)據(jù)   
  18.                     len=send(dlg->m_accept, date, 1024*100, 0);  
  19.                 if(dlg->flag==1)  
  20.                     len=send(dlg->m_local, date, 1024*100, 0);  
  21.                 }  
  22.                 else  
  23.                 {  
  24.                     date=new char[dwlen-total];  
  25.                      memset(date,0,dwlen-total);  
  26.                     file.Read(date,dwlen-total);  
  27.                     if(dlg->flag==0)//發(fā)送數(shù)據(jù)   
  28.                     len=send(dlg->m_accept, date, dwlen-total, 0);  
  29.                     if(dlg->flag==1)  
  30.                     len=send(dlg->m_local, date, dwlen-total, 0);  
  31.                 }  
  32.             Sleep(1);  
  33.             total+=len;//累計已經(jīng)發(fā)送的數(shù)據(jù)   
  34.             dlg->m_se.SetPos(total);  
  35.             delete []date;  
  36.             date=NULL; //回收內(nèi)存空間   
  37.         }  
  38.         file.Close();  
  39.         CString ss;  
  40.         ss.Format("%d",total);    
  41.         ss+="發(fā)送完成";  
  42.         MessageBox(dlg->m_hWnd,ss,"提示",MB_OK);  
  43.            
  44.         DWORD exit=0;  
  45.    
  46.         BOOL ret=GetExitCodeThread(dlg->p_thread->m_hThread,&exit);//獲取線程退出代碼   
  47.         if(exit==STILL_ACTIVE) //如果進(jìn)程仍在進(jìn)行   
  48.         {  
  49.             dlg->p_thread->ExitInstance();//退出進(jìn)程   
  50.             dlg->p_thread=NULL;  
  51.         }  
  52.       
  53.     return 0;  
  54. }  

   線程的好處是不會讓程序失去響應(yīng)，而且對于大型文件傳輸來說這是必須的。

    其次，關(guān)于文件的接受，就是一個注冊的OnSocket中的FD_READ,通過這個方式設(shè)置WSAAsyncSelect模型的。

  1. int nRet = WSAAsyncSelect(m_local, m_hWnd, WM_SOCKET, FD_ACCEPT|FD_CONNECT|FD_READ|FD_WRITE|FD_CLOSE);  
  2.     if (nRet != 0)  
  3.     {  
  4.         TRACE("設(shè)置WSAAsyncSelect模型失敗");  
  5.     }  
  6.       
    關(guān)于OnSocket 函數(shù)完整如下，處理FD_READ|FD_CONNECT|FD_ACCEPT等消息

  1. void CChatDlg::OnSocket(WPARAM wParam,LPARAM lParam)  
  2. {  
  3.     int nError = WSAGETSELECTERROR(lParam);     //讀取錯誤代碼   
  4.     int nEvent = WSAGETSELECTEVENT(lParam);     //讀取網(wǎng)絡(luò)事件   
  5.     SOCKET sock = wParam;  
  6.     switch (nEvent)   
  7.     {  
  8.     case FD_ACCEPT:  
  9.         {  
  10.             //接收客戶端的連接   
  11.             closesocket(m_accept);  
  12.             sockaddr_in sockAddr;  
  13.             int nAddrSize = sizeof(sockaddr_in);  
  14.             m_accept = accept(sock, (sockaddr*)&sockAddr, &nAddrSize);  
  15.             WSAAsyncSelect(m_accept, m_hWnd, WM_SOCKET, FD_CLOSE|FD_READ);  
  16.             state=true;  
  17.             flag=0; //表示作為服務(wù)器   
  18.             m_connect.EnableWindow(FALSE);//由于被連接，需要是連接功能喪失   
  19.             break;  
  20.         }  
  21.     case FD_READ:   //接收數(shù)據(jù)   
  22.         {  
  23.             switch(flag1)  
  24.             {  
  25.             case 1:  
  26.                 memset(buffer,0,10);  
  27.                 recv(sock, buffer, 10, 0);//這個語句用于接收文件的長   
  28.                    m_length=atoi(buffer);  
  29.                    UpdateData(false);  
  30.                    flag1=2;  //做接下來一步   
  31.                    m_get.SetRange32(0,m_length); //設(shè)置接受進(jìn)度條的范圍   
  32.                    break;  
  33.             case 2: recv(sock, filename, 200, 0); //接受文件名   
  34.                 flag1=3;//做接下來一步   
  35.                 f.Open(filename,CFile::modeCreate|CFile::modeWrite);//創(chuàng)建一個文件   
  36.                 break;  
  37.             case 3:if(temp!=NULL)  
  38.                    {  
  39.                        delete [] temp;  
  40.                        temp=NULL;  
  41.                    }  
  42.                 temp=new char[1024*56];//開辟一個內(nèi)存   
  43.                 memset(temp,0,1024*56);  
  44.                 x=recv(sock,temp,1024*56,0);  
  45.                 f.Write(temp,x);  
  46.                 total+=x;  
  47.                 m_get.SetPos(total);  
  48.                 delete []temp;  
  49.                 temp=NULL;  
  50.                 if(total>=m_length)//表示接受完成   
  51.                 {  
  52.                     f.Close();  
  53.                     memset(filename,0,200);  
  54.                     flag1=1;  
  55.                   CString sd; sd.Format("%d",total);sd+="接受完成";  
  56.                   MessageBox(sd);  
  57.                   total=x=0;  
  58.                 }  
  59.                 break;  
  60.             }  
  61.         }  
  62.         break;  
  63.     case FD_CLOSE:  
  64.         {  
  65.             if(flag==0)  
  66.                 closesocket(m_accept);  
  67.             state= FALSE;  
  68.             flag=-1;  
  69.             m_connect.EnableWindow(TRUE);//是連接功能恢復(fù)正常   
  70.             break;  
  71.         }  
  72.     case FD_CONNECT:                            //連接網(wǎng)絡(luò)事件   
  73.         {  
  74.             if(nError == 0)                     //連接成功   
  75.             {  
  76.                 state= TRUE;  
  77.                 flag=1;//表示作為客戶端   
  78.                 MessageBox("連接成功");  
  79.             }  
  80.             break;  
  81.         }  
  82.           
  83.     }     
  84. }  

     其中接受就在FD_READ消息中，flag1-1接受文件長度,flag1-2接受文件名，flag1-3接受文件內(nèi)容。

     當(dāng)然整個函數(shù)太長了，本來應(yīng)該一些語句應(yīng)該設(shè)置成一些函數(shù)的，那樣也更直觀。

     這基本上是這個工程的全部了，還是比較簡潔的。在同一臺電腦上測試結(jié)果是：732577734字節(jié)共耗時114秒，平均6.12M/s,也不是體太慢。

       整個項目還是有不少弊端的，有疑惑的可以相互交流討論。

    本站是提供個人知識管理的網(wǎng)絡(luò)存儲空間，所有內(nèi)容均由用戶發(fā)布，不代表本站觀點。請注意甄別內(nèi)容中的聯(lián)系方式、誘導(dǎo)購買等信息，謹(jǐn)防詐騙。如發(fā)現(xiàn)有害或侵權(quán)內(nèi)容，請點擊一鍵舉報。
    轉(zhuǎn)藏 分享 獻(xiàn)花（0）

    0條評論

    發(fā)表

    請遵守用戶 評論公約

    類似文章 更多