Windows系統下C++ Socket UDP編程

/***********

*服務端程序*

************/

#include <Winsock2.h>

#include <stdio.h>

 

void main(){

WORD wVersionRequested;

WSADATA wsaData;

int err;

 

wVersionRequested = MAKEWORD( 1, 1 );

 

err = WSAStartup( wVersionRequested, &wsaData );

if ( err != 0 ) {                           

return;

}

 

if ( LOBYTE( wsaData.wVersion ) != 1 ||

        HIBYTE( wsaData.wVersion ) != 1 ) {

WSACleanup( );

return;

}

 

//創建套接字

SOCKET sockSrv = socket(AF_INET, SOCK_DGRAM, 0);

//創建地址結構體.

SOCKADDR_IN addrSrv;

addrSrv.sin_addr.S_un.S_addr = htonl(INADDR_ANY);

addrSrv.sin_family = AF_INET;

addrSrv.sin_port = htons(6000);

 

//綁定套接字和地址.

bind(sockSrv, (SOCKADDR *)&addrSrv, sizeof(SOCKADDR));

char recvBuf[100];

char sendBuf[100];

char tempBuf[200];

 

SOCKADDR_IN addrClient;

int len = sizeof(SOCKADDR);

 

while(1){

//接收數據.

recvfrom(sockSrv, recvBuf, 100, 0, (SOCKADDR *)&addrClient, &len);

if('q'==recvBuf[0]){

sendto(sockSrv, "q", 1, 0, (SOCKADDR *)&addrClient, sizeof(SOCKADDR));

printf("chat end ! \n");

break;

}

sprintf(tempBuf, "%s say: %s", inet_ntoa(addrClient.sin_addr), recvBuf);

printf("%s\n", tempBuf);

printf("please input data:\n");

gets(sendBuf);

//發送數據.

sendto(sockSrv, sendBuf, 100, 0, (SOCKADDR*)&addrClient, sizeof(SOCKADDR));

 

}

//關閉套接字.

closesocket(sockSrv);

//關閉套接字庫.

WSACleanup();

}

 

/***********

*客戶端程序*

************/

#include <Winsock2.h>

#include <stdio.h>

 

void main(){

WORD wVersionRequested;

WSADATA wsaData;

int err;

 

wVersionRequested = MAKEWORD( 1, 1 );

 

err = WSAStartup( wVersionRequested, &wsaData );

if ( err != 0 ) {                           

return;

}

 

if ( LOBYTE( wsaData.wVersion ) != 1 ||

        HIBYTE( wsaData.wVersion ) != 1 ) {

WSACleanup();

return;

}

 

SOCKET sockClient = socket(AF_INET, SOCK_DGRAM, 0);

SOCKADDR_IN addrClient;

addrClient.sin_addr.S_un.S_addr = inet_addr("127.0.0.1");

addrClient.sin_family = AF_INET;

addrClient.sin_port = htons(6000);

 

char recvBuf[100];

char sendBuf[100];

char tempBuf[200];

 

int len = sizeof(SOCKADDR);

 

while(1){

printf("please input date:");

gets(sendBuf);

sendto(sockClient, sendBuf,strlen(sendBuf)+1, 0, (SOCKADDR*)&addrClient, len);

recvfrom(sockClient, recvBuf, 100, 0, (SOCKADDR*)&addrclient, &len);

if(recvBuf[0] == 'q'){

sendto(sockClient, 'q', strlen('q')+1, 0, (SOCKADDR*)&addrClient,len);

printf("Chat end!\n");

break;

}

sprintf(tempBuf, "%s say: %s", inet_ntoa(addrClient.sin_addr), recvBuf);

printf("%s \n",tempBuf);

}

closesocket(sockClient);

WSACleanup();

}