C++UDP通信源码

妖狐艹你老母 2022-08-18 02:03 209阅读 0赞

// \_UDPSvr.cpp : 定义控制台应用程序的入口点。  
//  
  
  
\#include "stdafx.h"  
\#pragma comment(lib,"WS2\_32.lib")  
\#include <stdio.h>  
\#include <WINSOCK2.H>  
  
  
  
  
\#define BUF\_SIZE    64  
  
  
int main(void)  
\{  
WSADATA wsd;  
SOCKET  s;  
int     nRet;  
  
  
// 初始化套接字动态库  
if(WSAStartup(MAKEWORD(2,2),&wsd) != 0)  
\{  
printf("WSAStartup failed !\\n");  
return 1;  
\}  
  
  
// 创建套接字  
s = socket(AF\_INET,SOCK\_DGRAM,0);  
if(s == INVALID\_SOCKET)  
\{  
printf("socket() failed ,Error Code:%d\\n",WSAGetLastError());  
WSACleanup();  
return 1;  
\}  
  
  
SOCKET      socketSrv = socket(AF\_INET,SOCK\_DGRAM,0);  
SOCKADDR\_IN addrSrv;  
SOCKADDR\_IN addrClient;  
char        buf\[BUF\_SIZE\];  
int         len = sizeof(SOCKADDR);  
  
  
// 设置服务器地址  
ZeroMemory(buf,BUF\_SIZE);  
addrSrv.sin\_addr.S\_un.S\_addr = htonl(INADDR\_ANY);  
addrSrv.sin\_family = AF\_INET;  
addrSrv.sin\_port = htons(5000);  
  
  
// 绑定套接字  
nRet = bind(socketSrv,(SOCKADDR\*)&addrSrv,sizeof(SOCKADDR));  
if(SOCKET\_ERROR == nRet)     
\{     
printf("bind failed !\\n");     
closesocket(s);     
WSACleanup();     
return -1;     
\}  
  
  
// 从客户端接收数据  
nRet = recvfrom(socketSrv,buf,BUF\_SIZE,0,(SOCKADDR\*)&addrClient,&len);  
if(SOCKET\_ERROR == nRet)     
\{     
printf("recvfrom failed !\\n");     
closesocket(s);     
WSACleanup();     
return -1;     
\}  
// 打印来自客户端发送来的数据  
printf("Recv From Client:%s\\n",buf);  
  
  
// 向客户端发送数据  
sendto(socketSrv,"UDP Hello World !",sizeof("UDP Hello World !"),0,(SOCKADDR\*)&addrClient,len);  
closesocket(s);  
WSACleanup();  
return 0;  
\}  
  
  
  
// \_UDPClient.cpp : 定义控制台应用程序的入口点。  
//  
  
  
\#include "stdafx.h"  
\#pragma comment(lib,"WS2\_32.lib")  
\#include <stdio.h>  
\#include <WINSOCK2.H>  
\#define BUF\_SIZE    64  
  
  
int \_tmain(int argc, \_TCHAR\* argv\[\])  
\{  
WSADATA wsd;      
SOCKET  s;  
  
  
// 初始化套接字动态库  
if(WSAStartup(MAKEWORD(2,2),&wsd) != 0)  
\{  
printf("WSAStartup failed !\\n");  
return 1;  
\}  
  
  
// 创建套接字  
s = socket(AF\_INET,SOCK\_DGRAM,0);  
if(s == INVALID\_SOCKET)  
\{  
printf("socket() failed, Error Code:%d\\n",WSAGetLastError());  
WSACleanup();  
return 1;  
\}  
  
  
char        buf\[BUF\_SIZE\];  // 接受数据  
SOCKADDR\_IN servAddr;       // 服务器套接字地址  
SOCKET      sockClient = socket(AF\_INET,SOCK\_DGRAM,0);  
int         nRet;  
  
  
ZeroMemory(buf,BUF\_SIZE);  
strcpy(buf,"UDP Hello World !");  
  
  
// 设置服务器地址  
servAddr.sin\_family = AF\_INET;  
servAddr.sin\_addr.S\_un.S\_addr = inet\_addr("127.0.0.1");  
servAddr.sin\_port = htons(5000);  
  
  
// 向服务器发送数据  
int nServAddLen = sizeof(servAddr);  
if(sendto(sockClient,buf,BUF\_SIZE,0,(sockaddr \*)&servAddr,nServAddLen) == SOCKET\_ERROR)  
\{  
printf("recvfrom() failed:%d\\n",WSAGetLastError());  
closesocket(s);  
WSACleanup();  
return 1;  
\}  
nRet = recvfrom(sockClient,buf,BUF\_SIZE,0,(sockaddr \*)&servAddr,&nServAddLen);  
if(SOCKET\_ERROR == nRet)     
\{     
printf("recvfrom failed !\\n");     
closesocket(s);     
WSACleanup();     
return -1;     
\}  
  
  
// 打印来自服务端发送来的数据  
printf("Recv From Server:%s\\n",buf);  
closesocket(s);  
WSACleanup();  
return 0;  
\}