51Testing软件测试论坛

 找回密码
 (注-册)加入51Testing

QQ登录

只需一步,快速开始

微信登录,快人一步

查看: 2100|回复: 0

[Robot] Socket之UDP通信例子

[复制链接]

该用户从未签到

发表于 2017-11-3 15:10:14 | 显示全部楼层 |阅读模式

UDP通信方式:

1,客户端不需要进行连接,而是直接访问服务器通过sendto来发送数据,recvfrom接受数据

2,服务端,不需要监听、接受等待客户端请求,当收到客户端socket通过sendto来回应客户端请求。

Client端:

  1. #include <winsock2.h>  
  2. #include <iostream>  
  3.   
  4. #pragma comment(lib, "WS2_32.lib")  
  5. const unsigned int PORT = 11024;  
  6. const int kBufferSize   = 1024;  
  7.   
  8. int main() {  
  9.   
  10.     WSADATA wsData;  
  11.     if(WSAStartup(MAKEWORD(2, 2), &wsData) != 0) {  
  12.         std::cout << "start up failed\n" << std::endl;  
  13.         return 0;  
  14.     }  
  15.     // connect the socket;  
  16.   
  17.     SOCKET s = socket(AF_INET, SOCK_DGRAM, IPPROTO_UDP);  
  18.     SOCKADDR_IN addIn;  
  19.     addIn.sin_family = AF_INET;  
  20.     addIn.sin_port = htons(PORT);  
  21.     addIn.sin_addr.S_un.S_addr = inet_addr("127.0.0.1");  
  22.       
  23.     char cSendBuffer[kBufferSize] = "Client sends a Message to the Server, please confirm?";  
  24.     int bRecvLen = sizeof(addIn);  
  25.     int bSendRet = sendto(s, cSendBuffer, kBufferSize, 0, (LPSOCKADDR)&addIn, sizeof(addIn));  
  26.     while(bSendRet != SOCKET_ERROR) {  
  27.         char cRecvBuffer[kBufferSize] = "#";  
  28.         int bRecv = recvfrom(s, cRecvBuffer, kBufferSize, 0, (LPSOCKADDR)&addIn, &bRecvLen);  
  29.         if(bRecv != SOCKET_ERROR) {  
  30.             std::cout << "Client recvie the infromation from the server is: " << cRecvBuffer << std::endl;  
  31.             ZeroMemory(cSendBuffer, kBufferSize);  
  32.             std::cout << "please input the information the sends to the server: ";  
  33.             std::cin >> cSendBuffer;  
  34.             bSendRet = sendto(s, cSendBuffer, kBufferSize, 0, (LPSOCKADDR)&addIn, sizeof(addIn));  
  35.         } else{  
  36.             break;  
  37.         }  
  38.     }  
  39.   
  40.     if(WSACleanup() != 0) {  
  41.         std::cout << "clean up failed\n";  
  42.         return -1;  
  43.     }  
  44.     closesocket(s);  
  45.     return 0;  
  46. }  
复制代码

Server端:

  1. #include <iostream>  
  2. #include <winsock2.h>  
  3.   
  4. #pragma comment(lib, "WS2_32.lib")  
  5.   
  6. const unsigned int PORT = 11024;  
  7. const int kBufferSize   = 1024;  
  8.   
  9. int main() {  
  10.     WSADATA wsData;  
  11.     if(WSAStartup(MAKEWORD(2, 2), &wsData) != 0) {  
  12.         std::cout << "start failed" << std::endl;  
  13.         return -1;  
  14.     }  
  15.     //  
  16.     SOCKET s = socket(AF_INET, SOCK_DGRAM, IPPROTO_UDP);  
  17.     SOCKADDR_IN addIn;  
  18.       
  19.     addIn.sin_family = AF_INET;  
  20.     addIn.sin_port = htons(PORT);  
  21.     addIn.sin_addr.S_un.S_addr = inet_addr("127.0.0.1");  
  22.     int bBindRet = bind(s, (LPSOCKADDR) &addIn, sizeof(addIn));  
  23.     if(bBindRet != 0) {  
  24.         std::cout << "bind failed" << std::endl;  
  25.         return -1;  
  26.     }  
  27.   
  28.     char cRecvBuffer[kBufferSize];  
  29.     int ilen = sizeof(addIn);                 
  30.     int iRecv = recvfrom(s, cRecvBuffer, kBufferSize, 0, (LPSOCKADDR)&addIn, &ilen);  
  31.     while(iRecv != SOCKET_ERROR) {  
  32.         std::cout << "recvie information: " << std::endl;  
  33.         char cSendBuffer[kBufferSize];  
  34.         std::cout << "Input the information that the client sends; " << std::endl;  
  35.         std::cin >> cSendBuffer;  
  36.         sendto(s, cSendBuffer, kBufferSize, 0, (LPSOCKADDR)&addIn, sizeof(addIn));  
  37.     }  
  38.   
  39.     if(WSACleanup() != 0) {  
  40.         std::cout << "Clean up failed" << std::endl;  
  41.         return -1;  
  42.     }  
  43.   
  44.     return 0;  
  45. }  
复制代码


回复

使用道具 举报

本版积分规则

关闭

站长推荐上一条 /1 下一条

小黑屋|手机版|Archiver|51Testing软件测试网 ( 沪ICP备05003035号 关于我们

GMT+8, 2024-3-29 23:52 , Processed in 0.061798 second(s), 24 queries .

Powered by Discuz! X3.2

© 2001-2024 Comsenz Inc.

快速回复 返回顶部 返回列表