Tcp傳輸大文件問(wèn)題請(qǐng)教！

mikzh

使用Windows作為客戶(hù)端，Linux作為服務(wù)端；

代碼純 C 書(shū)寫(xiě)；

傳送超過(guò)20K的文件時(shí)，并將文件寫(xiě)入到服務(wù)端同一文件中，總是會(huì)少一些字節(jié)。

經(jīng)過(guò)抓包，在 Windows發(fā)送端的包，和Linux接收端的包是一樣的。說(shuō)明傳輸過(guò)程中沒(méi)有丟包；

一直懷疑是否是文件發(fā)送/接收的速度太快，而Linux端寫(xiě)文件速度太慢導(dǎo)致的。

但是，就算是寫(xiě)得慢，Socket也會(huì)將未寫(xiě)完的字符存入緩存中， 之后慢慢寫(xiě)。

那么，消失的字節(jié)數(shù)哪里去了？

請(qǐng)高人指點(diǎn)一下。

謝謝！

附上代碼：
說(shuō)明：為了大家看得不那么亂，網(wǎng)絡(luò)連接之類(lèi)的代碼省略了。

接收端：

1. 
   
2. FILE * fp = fopen("xx.exe","ab+");
   
3. while(1)
   
4. {
   
5.         recvInt = recv( new_fd, recv_buf, sizeof(file_info), 0 );
   
6.         if(fp!=NULL)
   
7.         {
   
8.                 if (fwrite(recv_info.f_data, 1, recvInt , fp ) )
   
9.                         fflush(fp);                        //此處是否會(huì)影響性能，每寫(xiě)入一點(diǎn)數(shù)據(jù)就更新一次緩存
   
10.         }
    
11. }
    

復(fù)制代碼

發(fā)送端：

1. 
   
2. if( (err = fopen_s(&sendFp,fPath,"rb") != 0 ))
   
3.                 perror("Cannot open this file");
   
4.                
   
5. while(1)
   
6. {
   
7. 
   
8.         sendInt = fread( fData, 1, sizeof(fData), sendFp);               
   
9.         memcpy(sendBuf,fData,sizeof(fData));
   
10.         if( send(sockfd, sendBuf, nNumRead + 141, 0 ) == -1)
    
11.         {
    
12.                
    
13.                 perror("[Send Error]");
    
14.                 getchar();
    
15.                 exit(1);
    
16.         }
    
17. }
    

復(fù)制代碼

yulihua49

使用Windows作為客戶(hù)端，Linux作為服務(wù)端；

代碼純 C 書(shū)寫(xiě)；

傳送超過(guò)20K的文件時(shí)，并將文件寫(xiě)入到服 ...
mikzh 發(fā)表于 2011-07-07 13:55

最后一包fdata里到底有多少字節(jié)要發(fā)？

mikzh

回復(fù) 2# yulihua49

寫(xiě)錯(cuò)了，應(yīng)改成 fread的結(jié)果值： sendInt。

本意是讀到多少發(fā)多少。

yulihua49

回復(fù)  yulihua49

寫(xiě)錯(cuò)了，應(yīng)改成 fread的結(jié)果值： sendInt。

本意是讀到多少發(fā)多少。
mikzh 發(fā)表于 2011-07-07 14:22

    那么，對(duì)端讀多少？

mikzh

回復(fù) 4# yulihua49


對(duì)端也是讀這么多的。

我將發(fā)送buf定長(zhǎng)了，長(zhǎng)度為1024字節(jié)。


對(duì)端讀到的，也是 recv實(shí)際得到的。

會(huì)不會(huì)這個(gè)有差異，發(fā)送的和recv的會(huì)不會(huì)有問(wèn)題，導(dǎo)致數(shù)據(jù)不全？

yulihua49

回復(fù)  yulihua49


對(duì)端也是讀這么多的。

我將發(fā)送buf定長(zhǎng)了，長(zhǎng)度為1024字節(jié)。


對(duì)端讀到的，也 ...
mikzh 發(fā)表于 2011-07-07 14:40

    要先發(fā)一個(gè)長(zhǎng)度，好讓對(duì)方知道讀多少。讀不夠這個(gè)數(shù)，就再讀。就不會(huì)丟了。

mikzh

回復(fù) 6# yulihua49

OK。我先試試。

我是將文件放在數(shù)據(jù)結(jié)構(gòu)中發(fā)過(guò)去的

結(jié)構(gòu)定義

{
unsigned int send_flag;
unsigned int file_size;
char file_name[32];
char file_path[64];
char send_buf[920];
}

這樣，控制發(fā)送長(zhǎng)度為 1024.
但是，剛才測(cè)試的時(shí)候，發(fā)現(xiàn)讀取的時(shí)候有分片。

hellioncu

一次send不一定能把你想要發(fā)送的數(shù)據(jù)發(fā)送完成，檢查下send的返回值

mikzh

回復(fù) 6# yulihua49


    有沒(méi)有例子讓我參考參考，謝謝！

yulihua49

回復(fù)  yulihua49


    有沒(méi)有例子讓我參考參考，謝謝！
mikzh 發(fā)表于 2011-07-07 15:11

這是我的包頭：

1. #define HEADPACKLENGTH 48
   
2. 
   
3. #define         PARANUM 9
   
4. #define         PROTO_NUM   para[0]             /*協(xié)議號(hào):
   
5.                                         客戶(hù)呼叫服務(wù)器時(shí)是調(diào)用號(hào)，
   
6.                                         服務(wù)器返回時(shí)是事件號(hào)，1－65535 */
   
7. #define         ERRNO1      para[1]             /*主錯(cuò)誤碼      */
   
8. #define         ERRNO2      para[2]             /*輔助錯(cuò)誤碼    */
   
9. #define         PKG_REC_NUM para[3]             /*數(shù)據(jù)記錄數(shù)    */
   
10. #define         PKG_LEN     para[4]             /*數(shù)據(jù)包長(zhǎng)度    */
    
11. #define         T_LEN       para[5]             /* 傳輸長(zhǎng)度  */
    
12. #define         O_NODE      para[6]             /*原結(jié)點(diǎn)地址*/
    
13. #define         D_NODE      para[7]             /*目的結(jié)點(diǎn)描述*/
    
14. #define         PKG_CRC     para[8]             /*數(shù)據(jù)包CRC */
    
15. 
    
16. typedef struct {                /*協(xié)議頭        */
    
17.         u_int   para[PARANUM];
    
18.         char    *data;
    
19. } T_NetHead;
    

復(fù)制代碼

9個(gè)整數(shù)共36字節(jié)。轉(zhuǎn)化成BASE64，變成48字節(jié)。因此，我的包頭是固定長(zhǎng)度48字節(jié)。
接收端按固定長(zhǎng)度48先收包頭。
然后根據(jù)T_LEN收數(shù)據(jù)。

1. int RecvNet(int s,char *buf,int n,int timeout)
   
2. {
   
3. int bcount,br,ret,num=0;
   
4. struct timeval tmout;
   
5. 
   
6.         if(!buf) return 0;
   
7.         tmout.tv_sec=timeout;
   
8.         tmout.tv_usec=0;
   
9.         ret=setsockopt(s,SOL_SOCKET,SO_RCVTIMEO,(char *)&tmout,sizeof(tmout));
   
10. 
    
11.         *buf=0;
    
12.         if(n<=0) return 0;
    
13.         bcount=0;
    
14.         br=0;
    
15. 
    
16.         num=0;
    
17.         while(bcount<n){
    
18.                 if((br=read(s,buf,n-bcount))>0){
    
19.                         bcount+=br;
    
20.                         buf+=br;
    
21.                         continue;
    
22.                 }
    
23.                 if(br<0){
    
24.                     if(errno==11) return TIMEOUTERR;
    
25.                     ShowLog(1,"%s:br=%d,err=%d,%s",__FUNCTION__,br,errno,strerror(errno));
    
26.                     return -1;
    
27.                 }
    
28.                 if(!br ) {
    
29.                         if( ++num>100) break;
    
30.                         usleep(5000);
    
31.                         continue;
    
32.                 } else num=0;
    
33.         }
    
34.         if(bcount<=0) {
    
35.                 ShowLog(1,"%s:bcount=%d,err=%d,%s",__FUNCTION__,bcount,errno,strerror(errno));
    
36.                 return -1;
    
37.         }
    
38.         return bcount;
    
39. }
    

復(fù)制代碼

參數(shù)n就是要收的數(shù)據(jù)。如果讀的不夠數(shù)，就不斷的讀，直到夠數(shù)或超時(shí)。