博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
C++基础--Socket C/S UDP通信
阅读量:7219 次
发布时间:2019-06-29

本文共 5061 字,大约阅读时间需要 16 分钟。

原来,UDP通信,比我想象中简单的多!

// WindowsSocketServer.cpp : 定义控制台应用程序的入口点。//#include "stdafx.h"#include 
#include
#include
#include
#include
#pragma comment(lib,"Ws2_32.lib")using namespace std;#define PORT 8080#define IP_ADDRESS "172.16.20.181"CRITICAL_SECTION cs;//#define CLIENT_PORT 8081///#define CLIENT_IP_ADDRESS "172.16.20.181"//接收每个客户端连接的处理函数DWORD WINAPI ClientThread(LPVOID lpParameter);//连接和服务器端有连接的客户端DWORD WINAPI ConnectClientsThread(LPVOID lpParameter); int main(int argc, char* argv[]) { //版本协商 WORD wVersionRequested; WSADATA wsaData; int err; wVersionRequested = MAKEWORD( 1, 1 ); err = WSAStartup( wVersionRequested, &wsaData ); if ( err != 0 ) { /* Tell the user that we could not find a usable */ /* WinSock DLL. */ return 0; } /* Confirm that the WinSock DLL supports 2.2.*/ /* Note that if the DLL supports versions greater */ /* than 2.2 in addition to 2.2, it will still return */ /* 2.2 in wVersion since that is the version we */ /* requested. */ if ( LOBYTE( wsaData.wVersion ) != 1 || HIBYTE( wsaData.wVersion ) != 1) { /* Tell the user that we could not find a usable */ /* WinSock DLL. */ WSACleanup( ); return 0; } /* The WinSock DLL is acceptable. Proceed. */ //创建数据报套接字 SOCKET svr = socket(AF_INET,SOCK_DGRAM,IPPROTO_UDP); //创建本地地址信息 SOCKADDR_IN addr; addr.sin_family = AF_INET; addr.sin_port = htons(6000); addr.sin_addr.S_un.S_addr = htonl(INADDR_ANY); int len = sizeof(sockaddr); int bindflag = bind(svr,(sockaddr*)&addr,len); if( bindflag ==SOCKET_ERROR ) { printf("服务器绑定失败!\n"); system("pause"); return 0; } else { printf("服务器端绑定完成。\n"); } //创建客户端地址对象 SOCKADDR_IN addrClient; char recvBuf[128]; char sendBuf[128]; char tempBuf[256]; while(true) { //接收数据 recvfrom(svr,recvBuf,128,0,(sockaddr*)&addrClient,&len); char* ipClient = inet_ntoa(addrClient.sin_addr); sprintf(tempBuf,"接收来自客户端 %s 的数据: %s\n",ipClient,recvBuf); printf("%s",tempBuf); gets_s(sendBuf); //发送数据 sendto(svr,sendBuf,strlen(sendBuf)+1,0,(sockaddr*)&addrClient,len); } closesocket(svr); WSACleanup(); return 0; }
// WindowsSocketClient.cpp : 定义控制台应用程序的入口点。//#include "stdafx.h"#include 
#include
#include
#include
#include
#include
#include
#pragma comment(lib,"Ws2_32.lib")using namespace std;#define PORT 8080#define IP_ADDRESS "172.16.20.181"#define LISTEN_PORT 8081#define LISTEN_IP_ADDRESS "172.16.20.181"//发送消息结构体struct SendMsgStruct{ SOCKET clientSocket; string msg; struct sockaddr_in ServerAddr;};//接收消息结构体struct RecvMsgStruct{ SOCKET clientSocket; struct sockaddr_in ServerAddr;};//发送消息子线程DWORD WINAPI SendThread(LPVOID lpParameter);//接收消息子线程DWORD WINAPI RecvThread(LPVOID lpParameter);//去除字符串首尾空格void trim(string &str);//监听服务器的连接DWORD WINAPI ListenServerThread(LPVOID lpParameter);int _tmain(int argc, _TCHAR* argv[]){ //版本协商 WORD wVersionRequested; WSADATA wsaData; int err; wVersionRequested = MAKEWORD( 1, 1 ); err = WSAStartup( wVersionRequested, &wsaData ); if ( err != 0 ) { /* Tell the user that we could not find a usable */ /* WinSock DLL. */ return 0; } /* Confirm that the WinSock DLL supports 2.2.*/ /* Note that if the DLL supports versions greater */ /* than 2.2 in addition to 2.2, it will still return */ /* 2.2 in wVersion since that is the version we */ /* requested. */ if ( LOBYTE( wsaData.wVersion ) != 1 || HIBYTE( wsaData.wVersion ) != 1 ) { /* Tell the user that we could not find a usable */ /* WinSock DLL. */ WSACleanup( ); return 0; } /* The WinSock DLL is acceptable. Proceed. */ //创建服务器套接字 SOCKET Svr = socket(AF_INET,SOCK_DGRAM,IPPROTO_UDP); //创建地址 SOCKADDR_IN addrSvr; addrSvr.sin_family = AF_INET; addrSvr.sin_port = htons(6000); addrSvr.sin_addr.S_un.S_addr = inet_addr("127.0.0.1"); char recvBuf[128]; char sendBuf[128]; int len = sizeof(sockaddr); while(true) { printf("输入数据,传输给服务端"); gets(sendBuf); //发送数据 sendto(Svr,sendBuf,strlen(sendBuf)+1,0,(sockaddr*)&addrSvr,len); //接收数据 recvfrom(Svr,recvBuf,128,0,(sockaddr*)&addrSvr,&len); char* ipSvr = inet_ntoa(addrSvr.sin_addr); printf("来自 %s 的消息: %s\n",ipSvr,recvBuf); } closesocket(Svr); WSACleanup(); return 0;}//接收消息子线程DWORD WINAPI RecvThread(LPVOID lpParameter){ RecvMsgStruct *recvStruct=(RecvMsgStruct *)lpParameter; SOCKET clientSocket = recvStruct->clientSocket; struct sockaddr_in ServerAddr = recvStruct->ServerAddr; char recvBuf[500]={ "0"}; int byteRecv = recv(clientSocket, recvBuf, 500, 0); int connectState; while( byteRecv == 0 ) { //连接断开,重连 cout<<"byteRecv == 0"<

转载于:https://www.cnblogs.com/kingdom_0/articles/2572035.html

你可能感兴趣的文章
test
查看>>
说无可说
查看>>
mysql 语句优化
查看>>
SCP 命令参数使用详解(最详细使用指南)
查看>>
windows cmd color setup
查看>>
一些问题
查看>>
ubuntu配置cudnn
查看>>
P1242 新汉诺塔 && UVA10795 A Different Task
查看>>
从零开始学习PYTHON3讲义(十一)计算器升级啦
查看>>
从零开始学习PYTHON3讲义(三)写第一个程序
查看>>
WebGis设计模式
查看>>
cocos2dx ScrollView 测试一 触摸事件优先级和自动调整
查看>>
django 使用mysql数据库的流程
查看>>
Android系统移植与调试之------->如何修改Android设备的默认休眠时间
查看>>
我的Android进阶之旅------>Java文件大小转换工具类 (B,KB,MB,GB,TB,PB之间的大小转换)...
查看>>
uboot 传递的参数 mtdparts
查看>>
六种排序算法C语言版(上)
查看>>
292. Nim Game(easy)
查看>>
ERROR 1786 (HY000)
查看>>
Kubernetes 学习7 Pod控制器应用进阶2
查看>>