Tcp传输大文件问题请教！

mikzh

使用Windows作为客户端，Linux作为服务端；

代码纯 C 书写；

传送超过20K的文件时，并将文件写入到服务端同一文件中，总是会少一些字节。

经过抓包，在 Windows发送端的包，和Linux接收端的包是一样的。说明传输过程中没有丢包；

一直怀疑是否是文件发送/接收的速度太快，而Linux端写文件速度太慢导致的。

但是，就算是写得慢，Socket也会将未写完的字符存入缓存中， 之后慢慢写。

那么，消失的字节数哪里去了？

请高人指点一下。

谢谢！

附上代码：
说明：为了大家看得不那么乱，网络连接之类的代码省略了。

接收端：

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);                        //此处是否会影响性能，每写入一点数据就更新一次缓存
   
10.         }
    
11. }
    

复制代码

发送端：

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. }
    

复制代码

yulihua49

使用Windows作为客户端，Linux作为服务端；

代码纯 C 书写；

传送超过20K的文件时，并将文件写入到服 ...
mikzh 发表于 2011-07-07 13:55

最后一包fdata里到底有多少字节要发？

mikzh

回复 2# yulihua49

写错了，应改成 fread的结果值： sendInt。

本意是读到多少发多少。

yulihua49

回复  yulihua49

写错了，应改成 fread的结果值： sendInt。

本意是读到多少发多少。
mikzh 发表于 2011-07-07 14:22

    那么，对端读多少？

mikzh

回复 4# yulihua49


对端也是读这么多的。

我将发送buf定长了，长度为1024字节。


对端读到的，也是 recv实际得到的。

会不会这个有差异，发送的和recv的会不会有问题，导致数据不全？

yulihua49

回复  yulihua49


对端也是读这么多的。

我将发送buf定长了，长度为1024字节。


对端读到的，也 ...
mikzh 发表于 2011-07-07 14:40

    要先发一个长度，好让对方知道读多少。读不够这个数，就再读。就不会丢了。

mikzh

回复 6# yulihua49

OK。我先试试。

我是将文件放在数据结构中发过去的

结构定义

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

这样，控制发送长度为 1024.
但是，刚才测试的时候，发现读取的时候有分片。

hellioncu

一次send不一定能把你想要发送的数据发送完成，检查下send的返回值

mikzh

回复 6# yulihua49


    有没有例子让我参考参考，谢谢！

yulihua49

回复  yulihua49


    有没有例子让我参考参考，谢谢！
mikzh 发表于 2011-07-07 15:11

这是我的包头：

1. #define HEADPACKLENGTH 48
   
2. 
   
3. #define         PARANUM 9
   
4. #define         PROTO_NUM   para[0]             /*协议号:
   
5.                                         客户呼叫服务器时是调用号，
   
6.                                         服务器返回时是事件号，1－65535 */
   
7. #define         ERRNO1      para[1]             /*主错误码      */
   
8. #define         ERRNO2      para[2]             /*辅助错误码    */
   
9. #define         PKG_REC_NUM para[3]             /*数据记录数    */
   
10. #define         PKG_LEN     para[4]             /*数据包长度    */
    
11. #define         T_LEN       para[5]             /* 传输长度  */
    
12. #define         O_NODE      para[6]             /*原结点地址*/
    
13. #define         D_NODE      para[7]             /*目的结点描述*/
    
14. #define         PKG_CRC     para[8]             /*数据包CRC */
    
15. 
    
16. typedef struct {                /*协议头        */
    
17.         u_int   para[PARANUM];
    
18.         char    *data;
    
19. } T_NetHead;
    

复制代码

9个整数共36字节。转化成BASE64，变成48字节。因此，我的包头是固定长度48字节。
接收端按固定长度48先收包头。
然后根据T_LEN收数据。

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. }
    

复制代码

参数n就是要收的数据。如果读的不够数，就不断的读，直到够数或超时。