window下socket(udp)控制台程序

window下socket(udp)控制台程序

• server

#include <iostream>
#include <winsock2.h>

#pragma comment(lib, "WS2_32.lib")

const unsigned int PORT = 999;
const int kBufferSize = 1024;

int main() {
    
	WSADATA wsData;
	if (WSAStartup(MAKEWORD(2, 2), &wsData) != 0) {
    
		std::cout << "start failed" << std::endl;
		return -1;
	}
	SOCKET s = socket(AF_INET, SOCK_DGRAM, IPPROTO_UDP);
	SOCKADDR_IN addMe,addRemote;

	addMe.sin_family = AF_INET;
	addMe.sin_port = htons(PORT);
	addMe.sin_addr.S_un.S_addr = INADDR_ANY;//ip地址 泛指本机所有ip
	int ret= bind(s, (LPSOCKADDR)&addMe, sizeof(addMe));
	if (ret!= 0) {
    
		std::cout << "bind failed" << std::endl;
		return -1;
	}

	char cRecvBuffer[kBufferSize];
	int len = sizeof(addRemote);
	while (true)
	{
    
		int recv = recvfrom(s, cRecvBuffer, kBufferSize, 0, (LPSOCKADDR)&addRemote, &len);
		if (recv > 0)
		{
    
			char cSendBuffer[kBufferSize];
			std::cout << "Client; " << std::endl << cRecvBuffer;
			if (!strcmp(cRecvBuffer,"byby"))
			{
    
				break;
			}
			std::cout << std::endl << "Sever: " << std::endl;
			std::cin >> cSendBuffer;
			sendto(s, cSendBuffer, kBufferSize, 0, (LPSOCKADDR)&addRemote, len);
		}
		else
		{
    
			continue;
		}
	}
	

	if (WSACleanup() != 0) {
    
		std::cout << "Clean up failed" << std::endl;
		return -1;
	}

	return 0;
}

• client

#include <winsock2.h>
#include<WS2tcpip.h>
#include <iostream>

#pragma comment(lib, "WS2_32.lib")
const unsigned int PORT = 999;
const int kBufferSize = 1024;

int main() {
    

	WSADATA wsData;
	if (WSAStartup(MAKEWORD(2, 2), &wsData) != 0) {
    
		std::cout << "start up failed\n" << std::endl;
		return 0;
	}

	SOCKET s = socket(AF_INET, SOCK_DGRAM, IPPROTO_UDP);
	SOCKADDR_IN addRemote;
	addRemote.sin_family = AF_INET;
	addRemote.sin_port = htons(PORT);
	inet_pton(AF_INET, "127.0.0.1", &addRemote.sin_addr);//ip地址转换


	char cSendBuffer[kBufferSize] = "#";
	int len = sizeof(addRemote);
	std::cout << "Client: " << std::endl;
	std::cin >> cSendBuffer;
	int ret = sendto(s, cSendBuffer, kBufferSize, 0, (LPSOCKADDR)&addRemote, len);
	if (ret > 0)
	{
    
		while (true)
		{
    
			char cRecvBuffer[kBufferSize];
			int recv = recvfrom(s, cRecvBuffer, kBufferSize, 0, (LPSOCKADDR)&addRemote, &len);
			if (recv > 0) 
			{
    
				std::cout << "Server: " << std::endl << cRecvBuffer << std::endl;
				if (!strcmp(cRecvBuffer,"byby"))
				{
    
					break;
				}
				ZeroMemory(cSendBuffer, kBufferSize);
				std::cout << "Client: "<<std::endl;
				std::cin >> cSendBuffer;
				ret = sendto(s, cSendBuffer, kBufferSize, 0, (LPSOCKADDR)&addRemote, len);
			}
			else
			{
    
				continue;
			}
		}
	}
	
	

	if (WSACleanup() != 0) {
    
		std::cout << "clean up failed\n";
		return -1;
	}
	closesocket(s);
	return 0;
}

window下socket(TCP)控制台程序