一个简单的C/S TCP文件传输出问题了

cookis

今天用测试了一下UDT, 局域网内网速能达到80Mb/sec,
然后我就写了一个简单的TCP的文件传输,,结果出问题了.
这是server端,

1. 
   
2. #include <sys/types.h>
   
3. #include <sys/stat.h>
   
4. #include <fcntl.h>
   
5. #include <errno.h>
   
6. #include <sys/socket.h>
   
7. #include <arpa/inet.h>
   
8. #include <netdb.h>
   
9. #include <unistd.h>
   
10. int main (int argc, char *argv[])
    
11. {
    
12.         int m_hSocket = 0;
    
13.         m_hSocket = socket (AF_INET, SOCK_STREAM, 0);
    
14.         struct sockaddr_in  m_nLocalAddr;
    
15.         struct sockaddr_in  m_nPeerAddr;
    
16.         memset (&m_nLocalAddr, 0, sizeof (struct sockaddr_in));
    
17.         m_nLocalAddr.sin_family      = AF_INET;
    
18.         m_nLocalAddr.sin_addr.s_addr = INADDR_ANY;//inet_addr ("192.168.51.250");//INADDR_ANY;
    
19.         m_nLocalAddr.sin_port        = htons (9991);
    
20.         int on = 1;
    
21.         int result = setsockopt(m_hSocket, SOL_SOCKET, SO_REUSEADDR, (char *) & on, sizeof(on));
    
22.         bind (m_hSocket, (struct sockaddr*)&m_nLocalAddr, sizeof(m_nLocalAddr));
    
23.         listen (m_hSocket, 5);
    
24.         socklen_t addrLen = sizeof (struct sockaddr);
    
25.         m_hSocket = accept (m_hSocket, (struct sockaddr *)&m_nPeerAddr, &addrLen);
    
26.         printf ("accept one\n");
    
27.         char buff[1400];
    
28.         memset (buff, 0, 1400);
    
29.         int fd = open ("file", O_RDWR);
    
30.         int len = 0;
    
31.         while (1)
    
32.         {
    
33.                 printf ("start to recv data\n");
    
34.                 len = read (fd, buff, 1400-4);
    
35.                 if (len <= 0)
    
36.                         {
    
37.                         perror ("read");
    
38.                         break;
    
39.                         }
    
40.                 //len = htonl (len);
    
41.                 struct iovec iov[2];
    
42.                 iov[0].iov_base = &len;
    
43.                 iov[0].iov_len  = sizeof (int);
    
44.                 iov[1].iov_base = buff;
    
45.                 iov[1].iov_len  = len;
    
46.                 int ret = writev (m_hSocket, iov, 2);
    
47.                 if (ret < 0)
    
48.                 {
    
49.                         perror ("writev");
    
50.                         break;
    
51.                 }
    
52.         }
    
53.         return 0;
    
54. }
    
55. 
    

复制代码

这是接入文件的client端

1. 
   
2. #include <sys/types.h>
   
3. #include <sys/stat.h>
   
4. #include <fcntl.h>
   
5. #include <errno.h>
   
6. #include <sys/socket.h>
   
7. #include <arpa/inet.h>
   
8. #include <netdb.h>
   
9. #include <unistd.h>
   
10. 
    
11. int main (int argc, char *argv[])
    
12. {
    
13.     struct sockaddr_in peerAddr;
    
14.     int ret = 0;
    
15.     memset (&peerAddr, 0, sizeof (peerAddr));
    
16.     peerAddr.sin_addr.s_addr = inet_addr (argv[1]);
    
17.     printf ("ip=%s\n", argv[1]);
    
18.     peerAddr.sin_family      = AF_INET;
    
19.     peerAddr.sin_port        = htons (9991);
    
20.     int m_hSocket = 0;
    
21.     m_hSocket = socket (AF_INET, SOCK_STREAM, 0);
    
22.     socklen_t addrLen = sizeof (peerAddr);
    
23.     if (connect (m_hSocket, (struct sockaddr*)&peerAddr, addrLen))
    
24.     {
    
25.         printf ("connect failed\n");
    
26.         perror ("connect");
    
27.         return 0;
    
28.     }
    
29. 
    
30.     printf ("connect succ\n");
    
31.     char buff[1400];
    
32.     memset (buff, 0, 1400);
    
33.     int fd = open ("localfile", O_CREAT | O_RDWR , 0644);
    
34.     while (1)
    
35.     {
    
36.         int len = recv (m_hSocket, buff, 4, 0);
    
37.         if (len <= 0)
    
38.         {
    
39.             perror ("recv");
    
40.             break;
    
41.         }
    
42.         int datelen = 0;
    
43.         memcpy (&datelen, buff, 4);
    
44.         //datelen = ntohl (datelen);
    
45.         printf ("date len = %d\n", datelen);
    
46.         len = recv (m_hSocket, buff, datelen, 0);
    
47.         if (len <= 0)
    
48.         {
    
49.             perror ("recv2");
    
50.             break;
    
51.         }
    
52.         int ret = write (fd, buff, len);
    
53.         if (ret <= 0)
    
54.         {
    
55.             perror ("write");
    
56.             break;
    
57.         }
    
58.         memset (buff, 0, 1400);
    
59.     }
    
60.     close (fd);
    
61.     close (m_hSocket);
    
62.     return 0;
    
63. }
    
64. 
    

复制代码

client 执行结果是

1. 
   
2. [root@localhost app]# ./recv 192.168.51.250
   
3. ip=192.168.51.250
   
4. connect succ
   
5. date len = 1396
   
6. date len = 1396
   
7. date len = 1396
   
8. date len = 1835887981
   

复制代码

为什么后来的数据长度就变成1835887981这么大了..
server 执行结果

1. 
   
2. [root@Enter-Dev-250 cui]# ./send
   
3. accept one
   
4. start to recv data
   
5. read len = 1396
   
6. start to recv data
   
7. read len = 1396
   
8. start to recv data
   
9. read len = 1396
   
10. start to recv data
    
11. read len = 1396
    
12. start to recv data
    
13. read len = 1396
    
14. start to recv data
    
15. read len = 1396
    
16. start to recv data
    
17. read len = 1396
    
18. start to recv data
    
19. read len = 1396
    
20. start to recv data
    
21. read len = 1396
    
22. start to recv data
    
23. read len = 1396
    
24. start to recv data
    
25. read len = 1396
    
26. start to recv data
    
27. read len = 1396
    
28. start to recv data
    
29. read len = 1396
    
30. start to recv data
    
31. read len = 1396
    
32. start to recv data
    
33. read len = 1396
    
34. start to recv data
    
35. read len = 1396
    
36. start to recv data
    
37. read len = 1396
    
38. start to recv data
    
39. read len = 1396
    
40. start to recv data
    
41. read len = 1396
    
42. start to recv data
    
43. read len = 1396
    
44. start to recv data
    
45. read len = 1396
    
46. start to recv data
    
47. read len = 1396
    
48. start to recv data
    
49. read len = 1396
    
50. start to recv data
    
51. read len = 1396
    
52. start to recv data
    
53. read len = 1396
    
54. start to recv data
    
55. read len = 1396
    
56. start to recv data
    
57. read len = 1396
    
58. start to recv data
    
59. read len = 1396
    
60. start to recv data
    
61. read len = 1396
    
62. start to recv data
    
63. read len = 1396
    
64. start to recv data
    
65. read len = 1396
    
66. start to recv data
    
67. read len = 1396
    
68. start to recv data
    
69. read len = 1396
    
70. start to recv data
    
71. read len = 1396
    
72. start to recv data
    
73. read len = 1396
    
74. start to recv data
    
75. read len = 1396
    
76. start to recv data
    
77. read len = 1396
    
78. writev: Connection reset by peer
    
79. 
    

复制代码

xhl

len = recv (m_hSocket, buff, datelen, 0);
        if (len <= 0)
        {
            perror ("recv2");
            break;
        }

这个函数并不能按你想象的那样， 叫他读多少， 他就读多少。

在这里起码要判断len == datalen才算读完。

你最好用readn的方法来做。

scutan

recv()的返回值为0并不表示出错,而是对方发送了一个EOF标志,比如在对方close()一个socket的时候.

cookis

呵呵..当时只是急于测试一下TCP的网络使用状况,写得也不太严谨,
听2楼的一说倒是想起来要用recvn了..
学习了..