首页 > 代码库 > 使用SOCKET TCP
使用SOCKET TCP
刚刚接触SOCKET编程，网上看了一些资料，发现做些简单的应用还是不难。但是要深入了解SOCKET编程还需要系统的看一些书。一般在进程间通信TCP是一种不错的方式。 ---XXX
TCP链接是面向流的链接，因此数据在应用程序看来应该是没有边界的，之前对send和recv函数中发送的大小和返回值没有理解，今天做了一个实验有了进一步的了解。socket一些常用的函数介绍可以在这里找到http://blog.csdn.net/ithzhang/article/details/8448655
之前有个疑问是如果一方向另一方一次发送大量的数据，超过了TCP缓冲区的大小，那么接收方该如何处理。这里就要用到recv函数的返回值了，它指示了本次调用函数实际接收的字节数，如果这个值小于我们需要接收的数据，那么就需要再一次调用recv函数。
下面是我测试的代码，代码是在VS2013下编译的。
欢迎一起讨论，指正错误。
服务器端：
1 #include <winsock2.h> 2 #include <iostream> 3 #include <numeric> 4 #include <vector> 5 #include <algorithm> 6 #pragma comment(lib,"ws2_32.lib") 7 8 9 using namespace std;10 11 const int port = 2048;12 13 int main(int argc,char**argv)14 {15 WSADATA ws;16 if (WSAStartup(MAKEWORD(2, 2), &ws) != 0)17 {18 cout << "init windows socket failed::" << GetLastError() << endl;19 return -1;20 }21 22 SOCKET serverSocket;23 24 serverSocket = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);25 26 sockaddr_in serverAddr;27 serverAddr.sin_family = AF_INET;28 serverAddr.sin_port = htons(port);29 //serverAddr.sin_addr.s_addr = inet_addr("192.168.182.1");30 serverAddr.sin_addr.s_addr = htonl(INADDR_ANY);31 memset(&(serverAddr.sin_zero), 0, sizeof(serverAddr.sin_zero));32 33 if (bind(serverSocket, (SOCKADDR*)&serverAddr, sizeof(serverAddr))!=0)34 {35 cout << "bind server socket failed\n";36 WSACleanup();37 return -1;38 }39 40 if (listen(serverSocket,10)!=0)41 {42 cout << "listen failded\n";43 return -1;44 }45 46 const int buf_size = 1024 * 1024;47 48 float *buf = new float[buf_size]; 49 50 for_each(buf, buf + buf_size, [](float &v){v = 1; });51 cout << std::accumulate(buf, buf + buf_size, 0) << endl;52 while (true)53 {54 int add_size = sizeof(SOCKADDR);55 56 sockaddr_in client_addr;57 SOCKET accept_sock = accept(serverSocket, (SOCKADDR*)&client_addr, &add_size);58 if (accept_sock == -1)59 {60 cout << "accept faild\n";61 continue;62 }63 64 int send_size = send(accept_sock, (char*)buf, buf_size*sizeof(float), 0);65 cout << send_size << endl;66 if (send_size==-1)67 {68 cout << "send data faild\n";69 continue;70 }71 72 }73 74 delete[] buf;75 return 0;76 }
客户端的：
1 #include <iostream> 2 #include <numeric> 3 #include <winsock2.h> 4 #include <algorithm> 5 6 #pragma comment(lib,"ws2_32.lib") 7 using namespace std; 8 const int port = 2048; 9 int main()10 {11 WSADATA ws;12 13 if (WSAStartup(MAKEWORD(2, 2), &ws) != 0)14 {15 cout << "load socket faild\n";16 WSACleanup();17 return -1;18 }19 20 SOCKET client_sock = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);21 22 sockaddr_in server_addr;23 server_addr.sin_family = AF_INET;24 server_addr.sin_port = htons(port);25 server_addr.sin_addr.s_addr = inet_addr("192.168.182.1");26 memset(&(server_addr.sin_zero), 0, sizeof(server_addr.sin_zero));27 28 if (connect(client_sock, (SOCKADDR*)&server_addr, sizeof(SOCKADDR)) != 0)29 {30 cout << "connect to server failed \n";31 WSACleanup();32 return -1;33 }34 const int buf_size = 1024 * 1024;35 36 float *buf = new float[buf_size] ;37 for_each(buf, buf + buf_size, [](float &v){v = 0; });38 cout << std::accumulate(buf, buf + buf_size, 0) << endl;39 40 int recved_size = 0;41 42 do 43 {44 int rsz = recv(client_sock, (char*)buf + recved_size, buf_size*sizeof(float)-recved_size, 0);45 if (rsz == -1)46 {47 cout << "recv data failed\n";48 WSACleanup();49 }50 recved_size += rsz;51 52 } while (recved_size<buf_size*sizeof(float));53 54 cout << std::accumulate(buf, buf + buf_size, 0) << endl;55 delete[] buf;56 57 58 closesocket(client_sock);59 }
使用SOCKET TCP
声明：以上内容来自用户投稿及互联网公开渠道收集整理发布，本网站不拥有所有权，未作人工编辑处理，也不承担相关法律责任，若内容有误或涉及侵权可进行投诉： 投诉/举报 工作人员会在5个工作日内联系你，一经查实，本站将立刻删除涉嫌侵权内容。