winsock做socket的server端效率就是低下?

yjm0573

winsock做server端

1. #include <stdio.h>
   
2. #include <stdlib.h>
   
3. #include <string.h>
   
4. #include <time.h>
   
5. #include <Winsock2.h>
   
6. 
   
7. #pragma comment(lib, "Ws2_32")
   
8. 
   
9. #define PORT 12345
   
10. #define MAXSOCKFD 10
    
11. 
    
12. int main()
    
13. {
    
14.         WORD wVersionRequested;
    
15.         WSADATA wsaData;
    
16.         int err;
    
17. 
    
18.         wVersionRequested = MAKEWORD( 2, 2 );
    
19. 
    
20.         err = WSAStartup( wVersionRequested, &wsaData );
    
21.         if ( err != 0 ) {
    
22.                 return -1;
    
23.         }
    
24. 
    
25.         if ( LOBYTE( wsaData.wVersion ) != 2 ||
    
26.                         HIBYTE( wsaData.wVersion ) != 2 ) {
    
27.                 WSACleanup( );
    
28.                 return -1;
    
29.         }
    
30. 
    
31.         int sockfd;
    
32.         if((sockfd = socket(AF_INET, SOCK_STREAM, 0)) < 0) {
    
33.                 WSACleanup( );
    
34.                 return -1;
    
35.         }
    
36. 
    
37.         struct sockaddr_in addr;
    
38.         int addr_len = sizeof(struct sockaddr_in);
    
39.         memset(&addr, 0, addr_len);
    
40. 
    
41.         addr.sin_family = AF_INET;
    
42.         addr.sin_port = htons(PORT);
    
43.         addr.sin_addr.s_addr = htonl(INADDR_ANY);
    
44. 
    
45.         printf("sockfd: %d\n", sockfd);
    
46.         if(bind(sockfd, (sockaddr*)&addr, addr_len) < 0) {
    
47.                 WSACleanup( );
    
48.                 return -1;
    
49.         }
    
50. 
    
51.         if(listen(sockfd, MAXSOCKFD) < 0) {
    
52.                 WSACleanup( );
    
53.                 return -1;
    
54.         }
    
55.        
    
56.         int newsockfd = accept(sockfd, (sockaddr*)&addr, &addr_len);
    
57.         printf("newsockfd: %d\n", newsockfd);
    
58. 
    
59.         long int sum = 0;
    
60.         time_t start; time(&start);
    
61.         while(1) {       
    
62.                 char buf[1024] = {0};
    
63.                 int ret = recv(newsockfd, buf, 1024, 0);
    
64.                 if(ret == -1 || ret == 0) break;
    
65.                 sum += ret;       
    
66.         }
    
67.         time_t end; time(&end);
    
68. 
    
69.         sum = sum/1024;
    
70.         printf("sum: %d\n", sum);
    
71. 
    
72.         int sec = end - start;
    
73.         printf("time sec: %d\n", sec);
    
74. 
    
75.         Sleep(10000000);
    
76.                
    
77.         return 0;
    
78. }
    

复制代码

linux做socket的client端

1. 
   
2. #include <stdio.h>
   
3. #include <stdlib.h>
   
4. #include <sys/stat.h>
   
5. #include <fcntl.h>
   
6. #include <unistd.h>
   
7. #include <sys/types.h>
   
8. #include <sys/socket.h>
   
9. #include <netinet/in.h>
   
10. #include <arpa/inet.h>
    
11. 
    
12. #define PORT 12345
    
13. #define SERVER_IP "192.168.16.39"
    
14. 
    
15. main()
    
16. {
    
17.         int sockfd;
    
18.         if((sockfd = socket(AF_INET, SOCK_STREAM, 0)) < 0) {
    
19.                 perror("socket");
    
20.                 exit(1);
    
21.         }
    
22. 
    
23.         struct sockaddr_in addr;
    
24.         addr.sin_family = AF_INET;
    
25.         addr.sin_port = htons(PORT);
    
26.         addr.sin_addr.s_addr = inet_addr(SERVER_IP);
    
27.        
    
28.         if(connect(sockfd, (sockaddr*)&addr, sizeof(addr)) < 0) {
    
29.                 perror("connect");
    
30.                 exit(1);
    
31.         }
    
32. 
    
33.         printf("sockfd: %d\n", sockfd);
    
34.         for(uint i=0; i<1024*100; i++) {
    
35.                 char buf[1024] = {0};
    
36.                 send(sockfd, buf, 1024, 0);
    
37.         }
    
38. }
    

复制代码

//////////////////////////////////////////////////////////////////////////////////////////////


linux做socket的server端

1. 
   
2. #include <stdio.h>
   
3. #include <stdlib.h>
   
4. #include <string.h>
   
5. #include <sys/types.h>
   
6. #include <sys/socket.h>
   
7. #include <sys/time.h>
   
8. #include <netinet/in.h>
   
9. #include <arpa/inet.h>
   
10. #include <unistd.h>
    
11. #include <pthread.h>
    
12. 
    
13. #define PORT 12345
    
14. #define MAXSOCKFD 10
    
15. 
    
16. int main()
    
17. {
    
18.         int sockfd;
    
19.         if((sockfd = socket(AF_INET, SOCK_STREAM, 0)) < 0) {
    
20.                 perror("socket");
    
21.                 exit(1);
    
22.         }
    
23. 
    
24.         struct sockaddr_in addr;
    
25.         int addr_len = sizeof(struct sockaddr_in);
    
26.         memset(&addr, 0, addr_len);
    
27. 
    
28.         addr.sin_family = AF_INET;
    
29.         addr.sin_port = htons(PORT);
    
30.         addr.sin_addr.s_addr = htonl(INADDR_ANY);
    
31. 
    
32.         printf("sockfd: %d\n", sockfd);
    
33.         if(bind(sockfd, (sockaddr*)&addr, addr_len) < 0) {
    
34.                 perror("bind");
    
35.                 exit(1);
    
36.         }
    
37. 
    
38.         if(listen(sockfd, MAXSOCKFD) < 0) {
    
39.                 perror("listen");
    
40.                 exit(1);
    
41.         }
    
42.        
    
43.         int newsockfd = accept(sockfd, (sockaddr*)&addr, (socklen_t*)&addr_len);
    
44.         struct timeval start,end;
    
45.         gettimeofday(&start, 0);
    
46.         long long int sum = 0;
    
47.         while(1) {
    
48.                 char buf[1024] = {0};
    
49.                 int ret = recv(newsockfd, buf, 1024, 0);
    
50.                 if(ret == 0 || ret == -1) break;
    
51.                 sum += ret;
    
52.         }
    
53.         sum = sum/1024;
    
54.         printf("sum: %d\n", sum);
    
55.         gettimeofday(&end, 0);
    
56.         long ltime = (end.tv_sec-start.tv_sec)*1000000+end.tv_usec-start.tv_usec;
    
57.         printf("time usec: %d ~= %d\n", ltime, ltime/1000000);
    
58. 
    
59.         return 0;
    
60. }
    

复制代码

winsock做socket的client端

1. 
   
2. #include <stdio.h>
   
3. #include <stdlib.h>
   
4. #ifdef WIN32
   
5. #include "Winsock2.h"
   
6. #else
   
7. #include <unistd.h>
   
8. #include <sys/types.h>
   
9. #include <sys/socket.h>
   
10. #include <netinet/in.h>
    
11. #include <arpa/inet.h>
    
12. #endif
    
13. 
    
14. #pragma comment(lib, "Ws2_32")
    
15. 
    
16. #define PORT 12345
    
17. #define SERVER_IP "127.0.0.1"
    
18. 
    
19. int main()
    
20. {
    
21. 
    
22.         WORD wVersionRequested;
    
23.         WSADATA wsaData;
    
24.         int err;
    
25. 
    
26.         wVersionRequested = MAKEWORD( 2, 2 );
    
27. 
    
28.         err = WSAStartup( wVersionRequested, &wsaData );
    
29.         if ( err != 0 ) {
    
30.                 return -1;
    
31.         }
    
32. 
    
33.         if ( LOBYTE( wsaData.wVersion ) != 2 ||
    
34.                         HIBYTE( wsaData.wVersion ) != 2 ) {
    
35.                 WSACleanup( );
    
36.                 return -1;
    
37.         }
    
38. 
    
39. 
    
40.         int sockfd;
    
41.         if((sockfd = socket(AF_INET, SOCK_STREAM, 0)) < 0) {
    
42.                 return -1;
    
43.         }
    
44. 
    
45.         struct sockaddr_in addr;
    
46.         addr.sin_family = AF_INET;
    
47.         addr.sin_port = htons(PORT);
    
48.         addr.sin_addr.s_addr = inet_addr(SERVER_IP);
    
49.        
    
50.         if(connect(sockfd, (sockaddr*)&addr, sizeof(addr)) < 0) {
    
51.                 return -1;
    
52.         }
    
53. 
    
54.         printf("sockfd: %d\n", sockfd);
    
55.         for(UINT i=0; i<1024*10; i++) {
    
56.                 char buf[1024] = {0};
    
57.                 send(sockfd, buf, 1024, 0);
    
58.         }
    
59. 
    
60.         WSACleanup( );
    
61. 
    
62. 
    
63. 
    
64.         return 0;
    
65. }
    

复制代码

两台不同的机器,一台windows,一台linux,linux做server端的效率明显要比windows做server端要高,这是我程序的问题?还是windows加了许多自己的东西所导致的?

yjm0573

在我的两台机器上测试出来.linux做server端的传输效率差不多是windows做server端效率的5倍.

醉卧水云间

先问你是怎么测试的?
1.linux client=> linux server
2.linux client=> win server
3.win client=> linux server
4.win client=> win server

都测试了? 各什么情况?

yjm0573

原帖由 醉卧水云间 于 2008-2-27 14:18 发表
先问你是怎么测试的?
1.linux client=> linux server
2.linux client=> win server
3.win client=> linux server
4.win client=> win server

都测试了? 各什么情况?

linux server => win client
win server => linux client



linux 做server端.传输了100M,如程序中显示.基本上能达到50M/s(可能网线有问题,一般应该是100M/s左右),千兆传输
反过来win做server端,传输了100M,但是明显差了一打截,只有可怜的10M/s.

yjm0573

是双机直连的

doctorjxd

原帖由 yjm0573 于 2008-2-27 14:36 发表



linux server => win client
win server => linux client



linux 做server端.传输了100M,如程序中显示.基本上能达到50M/s(可能网线有问题,一般应该是100M/s左右),千兆传输
反过来win做server端,传 ...

做实验，应该保持对照的一致性。你测试服务端的软件，应使客户端在两个条件下是一样的。要么都用Windows做客户端，要么Linux。

否则你上面那样是不能判断问题是出在客户端还是服务端。

醉卧水云间

测试方法不对, 应保持一头不动, 动另一头.

benjiam

应该没这么大的区别的。

可以将buff 的长度扩大。 再来看区别。

yjm0573

原帖由 doctorjxd 于 2008-2-27 15:41 发表


做实验，应该保持对照的一致性。你测试服务端的软件，应使客户端在两个条件下是一样的。要么都用Windows做客户端，要么Linux。

否则你上面那样是不能判断问题是出在客户端还是服务端。

哦,我可能说得不太明白.是这样的两台电脑,一台win,一台linux.

首先linux做server端, 然后win做client发送了100M数据,然后linux接受数据.我把接受数据需要的时间记录了下来,记为t1.
然后win做server端,然后linux做client同样发送了100M数据,然后win接受数据.我把接受数据需要的时间也记录了下来,记为t2.

结果是t2 远大于 t1.

我再试试 server端发送数据,client端接受数据,看看什么情况.

主要现在可能要在win端做socket的server端,要是真的如现在效率这么差,那就真太令人失望了.

yjm0573

原帖由 benjiam 于 2008-2-27 16:35 发表
应该没这么大的区别的。

可以将buff 的长度扩大。 再来看区别。

那些包装数据包需要的额外的字节比起1024来说,应该是比较小的了.我把他扩大试试.

现在的疑问是我怀疑win的socket自己做了一些杂七杂八的事.