Windows -- UDP Socket

骑猪看日落 2021-11-02 13:10 271阅读 0赞

### 1、服务端代码 ###

//========================================== 
    // Filename : UDP_Send_Message_Server.cpp 
    // Time : 2019年8月13日 
    // Author : 柚子树 
    // Email : gz_duyong@163.com 
    //==========================================
    
    /* Socket服务器端代码 服务器端口8887 接受Client发送的消息 循环接受来自客户端的消息，并输出到屏幕 */
    
    #include <tchar.h>
    #include <stdio.h>
    #include <WinSock2.h>
    #include <stdlib.h>
    #include <string.h>
    #include <WS2tcpip.h>
    #pragma comment(lib, "ws2_32.lib")
    
    #define BUFFER_SIZE 2048
    
    int main(int argc, char* argv[])
    { 
    	/* 初始化WSA，使得程序可以调用windows socket WSA版本指定为2.2 */
    	WORD sockVersion = MAKEWORD(2, 2);
    	WSADATA wsaData;
    	if (WSAStartup(sockVersion, &wsaData) != 0)
    	{ 
    		return 0;
    	}
    
    	/* 创建套接字，server_socket 类型为UDP 并检测是否创建成功 */
    	SOCKET server_socket = socket(AF_INET, SOCK_DGRAM, IPPROTO_UDP);
    	if (server_socket == INVALID_SOCKET)
    	{ 
    		//如果创建的socket无效，则结束程序
    		perror("socket error!\n");
    		return 0;
    	}
    
    	/* 创建地址结构，server_addr，并设置端口和IP */
    	sockaddr_in server_addr;
    	server_addr.sin_family = AF_INET;
    	//端口号 8887
    	server_addr.sin_port = htons(8887);
    	//此处INADDR_ANY表示所有本机IP地址
    	server_addr.sin_addr.S_un.S_addr = INADDR_ANY;
    
    	//将socket与地址server_addr绑定
    	if (bind(server_socket, (LPSOCKADDR)&server_addr, sizeof(server_addr)) == SOCKET_ERROR)
    	{ 
    		perror("bind error!\n");
    		return 0;
    	}
    
    	//循环接受来自客户端的消息
    	while (1)
    	{ 
    		//定义客户端的socket地址结构
    		sockaddr_in client_addr;
    		int client_addr_length = sizeof(client_addr);
    
    		//recv函数接受数据到缓冲区buffer
    		char buffer[BUFFER_SIZE];
    		memset(buffer, 0, BUFFER_SIZE);
    		if (recvfrom(server_socket, buffer, BUFFER_SIZE, 0, (struct sockaddr*)&client_addr, &client_addr_length) == -1)
    		{ 
    			perror("接受消息失败：\n");
    			break;
    		}
    
    		//将收到的消息输出到命令行
    		TCHAR IP_BUFFER[256];
    		memset(IP_BUFFER, 0, 256);
    		InetNtop(AF_INET, &client_addr.sin_addr, IP_BUFFER, 256);
    		printf("从%s：%d处收到消息：%s\n", IP_BUFFER, ntohs(client_addr.sin_port), buffer);
    	}
    
    	//关闭服务器socket，并注销WSA
    	closesocket(server_socket);
    	WSACleanup();
    	system("pause");
    	return 0;
    }

### 2、客户端代码 ###

//========================================== 
    // Filename : UDP_Send_Message_Client.cpp 
    // Time : 2019年8月13日 
    // Author : 柚子树 
    // Email : gz_duyong@163.com 
    //==========================================
    
    /* Socket客户端代码 向服务器发送消息 服务器IP：127.0.0.1 服务器端口：8887 从键盘中读取消息，发送给服务端 */
    
    #include <tchar.h>
    #include <stdio.h>
    #include <WinSock2.h>
    #include <stdlib.h>
    #include <string.h>
    #include <WS2tcpip.h>
    
    #pragma comment(lib, "ws2_32.lib")
    
    #define BUFFER_SIZE 2048
    
    int main(int argc, char* argv[])
    { 
    	/* 初始化WSA，使得程序可以调用windows socket */
    	WORD sockVersion = MAKEWORD(2, 2);
    	WSADATA wsaData;
    	if (WSAStartup(sockVersion, &wsaData) != 0)
    	{ 
    		return 0;
    	}
    
    	/* 创建客户端套接字，client_socket 类型是UDP 并检测是否创建成功 */
    	SOCKET client_socket = socket(AF_INET, SOCK_DGRAM, IPPROTO_UDP);
    	if (client_socket == INVALID_SOCKET)
    	{ 
    		//如果创建的socket无效，则结束程序
    		perror("socket error!\n");
    		return 0;
    	}
    
    	/* 创建地址，server_addr，并设置端口和IP */
    	sockaddr_in server_addr;
    	memset(&server_addr, 0, sizeof(server_addr));
    	server_addr.sin_family = AF_INET;
    	//要连接的服务器端口号 8887
    	server_addr.sin_port = htons(8887);
    	//绑定服务器的地址127.0.0.1
    	InetPton(AF_INET, L"127.0.0.1", &server_addr.sin_addr.s_addr);
    
    	printf("请输入发送给服务器的消息：\n");
    
    	while (1)
    	{ 
    		char buffer[BUFFER_SIZE];
    		memset(buffer, 0, BUFFER_SIZE);
    
    		// 从键盘中读取输入到BUFFER中
    		gets_s(buffer, BUFFER_SIZE);
    
    		//发送数据给服务器
    		if (sendto(client_socket, buffer, BUFFER_SIZE, 0, (struct sockaddr*)&server_addr, sizeof(SOCKADDR)) == -1)
    		{ 
    			perror("发送消息失败:\n");
    			break;
    		}
    	}
    
    	// 关闭服务器socket 并注销 WSA
    	closesocket(client_socket);
    	WSACleanup();
    	system("pause");
    	return 0;
    }

### 3、测试示例 ###

![在这里插入图片描述][20190813231509511.png_pic_center]

[20190813231509511.png_pic_center]: /images/20211101/a7202cfe687e48bbb23ef2e111363c01.png