说明:
本程序是基于windows socket的套接字库实现网络编程; 当WSAStartup函数调用成功后,在程序的最后都需要相应的调用WSACleanup函数 以便释放为该应用程序分配的资源,终止对WinSock动态库的使用。
基于UDP的服务器端流程
创建套接字(socket) 将套接字和IP地址、端口号绑定在一起(bind) 等待客户端发起数据通信(recvfrom/recvto) 关闭套接字
基于UDP的客户端流程
创建套接字(socket) 向服务器发起通信(recvfrom/recvto) 关闭套接字
基于UDP的socket编程流程图
基于UDP的socket编程不需要设置监听和发起/接收请求,可以直接相互通信,流程如下: 这里写图片描述
服务器端代码:
#include "stdafx.h" #include <Winsock2.h>
int _tmain(int argc, _TCHAR* argv[]) { WORD dwVersionReq = MAKEWORD(1,1); WSAData wsData = {0}; //加载套接字库 if (0 != WSAStartup(dwVersionReq,&wsData)) { WSACleanup(); return 0; } //socket版本确认 if (LOBYTE(wsData.wVersion) != 1 || HIBYTE(wsData.wVersion != 1)) { WSACleanup(); return 0; }
//创建服务套接字 SOCKET socketSrv = socket(AF_INET,SOCK_DGRAM,0/*自动选择协议*/);
//对socket绑定端口号和IP地址 SOCKADDR_IN addrServer; addrServer.sin_family = AF_INET; addrServer.sin_port = htons(6000); addrServer.sin_addr.S_un.S_addr = htonl(ADDR_ANY); bind(socketSrv,(SOCKADDR*)&addrServer,sizeof(addrServer));
//保存client端socket信息 SOCKADDR_IN addClient; int len = sizeof(SOCKADDR_IN);
while (1) { //等待并接收数据 char szBuffer[100] = {0}; recvfrom(socketSrv,szBuffer,100,0,(SOCKADDR*)&addClient,&len); printf("client->server:%s\n",szBuffer); //发送数据 char szSendBuf[100] = "this is server"; sendto(socketSrv, szSendBuf, 100,0,(SOCKADDR*)&addClient,len); }
//关闭套接字 closesocket(socketSrv);
//关闭winsocket库 WSACleanup();
system("pause");
return 0; }
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58
客户端代码:
#include "stdafx.h" #include <Winsock2.h>
int _tmain(int argc, _TCHAR* argv[]) { //指定wind socket版本 WORD dwVersionReq = MAKEWORD(1,1); WSAData wsData = {0};
//加载套接字库dll if (0 != WSAStartup(dwVersionReq,&wsData)) { WSACleanup(); return 0; }
//版本判断 if (LOBYTE(wsData.wVersion) != 1 || HIBYTE(wsData.wVersion != 1)) { WSACleanup(); return 0; }
//创建套接字 SOCKET socketClient = socket(AF_INET,SOCK_DGRAM,0);
//填充服务器socket信息 SOCKADDR_IN addrServer; int nLength = sizeof(addrServer); addrServer.sin_family = AF_INET; //服务器的应用程序端口 addrServer.sin_port = htons(6000); //服务器的IP地址,同一台电脑就是本地IP addrServer.sin_addr.S_un.S_addr = inet_addr("127.0.0.1");
//发送数据 char szClientBuf[100]= "this is client"; sendto(socketClient,szClientBuf,100,0,(SOCKADDR*)&addrServer,nLength);
//介绍数据 char szRecvBuf[100] = {0}; recvfrom(socketClient,szRecvBuf,100,0,(SOCKADDR*)&addrServer,&nLength); printf("server->client:%s\n", szRecvBuf);
//关闭套接字 closesocket(socketClient);
//关闭winsocket库 WSACleanup();
system("pause"); return 0; }
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53