请教关于socket发送大量数据的问题

ideawu

按你的描述应该是不会那样的问题的, 程序应该不少, 把关键点代码贴上来吧.

如戏

1. int g_isendpackage = 10*1024;
   
2. 
   
3. DWORD WINAPI recvthread(void *param)
   
4. {
   
5.         SOCKET sock = (SOCKET)param;
   
6.         char buf[1024];
   
7.         while(true)
   
8.         {
   
9.                 int iRet = recv(sock, buf, sizeof(buf), 0);
   
10.                 if (iRet <= 0)
    
11.                 {
    
12.                         printf("接收失败 %d %d\n", iRet, WSAGetLastError());
    
13.                         break;
    
14.                 }
    
15.                 else
    
16.                 {
    
17.                         printf("接收 %d\n", iRet);
    
18.                 }
    
19.         }
    
20.         return 0;
    
21. }
    
22. 
    
23. DWORD WINAPI sendthread(void *param)
    
24. {
    
25.         SOCKET sock = (SOCKET)param;
    
26.         char *pdata = new char[g_isendpackage];
    
27.         while(true)
    
28.         {
    
29.                 int iRet = send(sock, pdata, g_isendpackage, 0);
    
30.                 if (iRet <= 0)
    
31.                 {
    
32.                         printf("发送失败 %d %d\n", iRet, WSAGetLastError());
    
33.                         break;
    
34.                 }
    
35.                 else
    
36.                 {
    
37.                         printf("发送 %d\n", iRet);
    
38.                 }
    
39.         }
    
40.         delete []pdata;
    
41.         return 0;
    
42. }

复制代码

这是个测试例子, 没有任何业务.
我还发现, 如果服务端每次发64K不会断, 每次发10K竟然会断. 完全相不明白, 是不是和网通与电信的网关设置有关系?

如戏

1. 
   
2. #include <stdio.h>
   
3. #include <winsock.h>
   
4. #pragma comment(lib, "ws2_32.lib")
   
5. 
   
6. int main(int argc, char *argv[])
   
7. {
   
8.         WSADATA wsaData;
   
9.         if ( WSAStartup( MAKEWORD(2,2), &wsaData ) != 0 )
   
10.         {
    
11.                 printf("init error: %d\n",WSAGetLastError());
    
12.                 return -1;
    
13.         }
    
14. 
    
15.         int iPort = 8002;
    
16.         if (argc > 1)
    
17.         {
    
18.                 iPort = atoi(argv[1]);
    
19.         }
    
20.         if (argc > 2)
    
21.         {
    
22.                 g_isendpackage = atoi(argv[2]);
    
23.         }
    
24. 
    
25.         printf("port %d len %d\n", iPort, g_isendpackage);
    
26. 
    
27.         SOCKET sock = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
    
28. 
    
29.         sockaddr_in service;
    
30.         service.sin_family = AF_INET;
    
31.         service.sin_addr.s_addr = 0;
    
32.         service.sin_port = htons(iPort);
    
33. 
    
34.         if (bind(sock, (SOCKADDR*)&service, sizeof(service)) == SOCKET_ERROR)
    
35.         {
    
36.                 printf("bind() failed. %d\n", WSAGetLastError());
    
37.                 closesocket(sock);
    
38.                 return -1;
    
39.         }
    
40. 
    
41.         if (listen(sock, 5) == SOCKET_ERROR)
    
42.         {
    
43.                 printf("listen failed %d\n", WSAGetLastError());
    
44.                 return -1;
    
45.         }
    
46.         printf("listen success\n");
    
47.         while(true)
    
48.         {
    
49.                 SOCKET accsock = accept(sock, NULL, NULL);
    
50.                 if (accsock == SOCKET_ERROR)
    
51.                 {
    
52.                         continue;
    
53.                 }
    
54. 
    
55.                 HANDLE hrecv = CreateThread(NULL, 0, recvthread, (void*)accsock, 0, NULL);
    
56.                 CloseHandle(hrecv);
    
57.                 HANDLE hsend = CreateThread(NULL, 0, sendthread, (void*)accsock, 0, NULL);
    
58.                 CloseHandle(hsend);
    
59.         }
    
60. 
    
61.         WSACleanup();
    
62.         return 0;
    
63. }

复制代码

VC++2005编译的

如戏

我的电信的ADSL, 连电信的服务器又没问题.
一次send发64K正常, 发10K出错
我想应该是防火墙的原因, 因为发10发得快. 发64K发得慢.
也许被认为是出站攻击吧

独臂剑客

send(sock, pdata, g_isendpackage, 0);
recv(sock, buf, sizeof(buf), 0);

看下这两个函数的具体参数长度的意思。
LZ你换成这样 前成四个字节表示数据长度，后面是内容，接收和发送都按实际的buf发送和接收就不会有问题了，特别对于阻塞这种操作。send和recv要判断返回值，send一次要把buf数据全发送出去,recv一次要接收完前四个字节定义的长度值。

你这种发送，接收不会有问题的，问题在上面说的这个原因。

ideawu

还以为你在单机测试呢, 原来还跨电信网通. 你先在单机或者内网中的两台机器测试下, 如果没问题, 估计是网络的问题了.

如戏

回复 16# ideawu


    同是电信的网络就没有问题

如戏

回复 15# 独臂剑客


  我这个只是测试网络, 要不要协议头部都没有关系吧?
我发送和接收的数据都没有一点意义, 纯粹是测试网络.

独臂剑客

回复 18# 如戏


    给你说个简单的例子吧
   
   int send( SOCKET s,      const char FAR *buf,      int len,      int flags );  
    你的buf发送长度是10K 这个时候只发送了8K, 里面还有2K
   
    你下次再发10K数据，其实buf里有12K数据，你下次最多一次只发送10K,再第三次发送的时候里面其实只有2K数据，send不会返回的
   其它的不多说了。

byjxy

断开链接是什么意思，是你的程序执行返回了，还是socket自动断开？