【Echo】實驗 -- 實現 C/C++下UDP, 服務器/客戶端 通訊

本次實驗利用UDP協議, 語言環境為 C/C++

利用套接字Socket編程，實現Server/CLient 之間簡單的通訊。

結果應為類似所示：

 

下面貼上代碼（參考參考...)

 

Server 部分：

/* UDPServer.cpp */

#include <stdlib.h>
#include <stdio.h>
#include <winsock2.h>
#include <string.h>
#include "conio.h"
#include <time.h>

#define    BUFLEN        2000                  // 緩沖區大小
#define WSVERS        MAKEWORD(2, 2)        // 指明版本2.2 
#pragma comment(lib,"ws2_32.lib")         // 加載winsock 2.2 Llibrary

/*------------------------------------------------------------------------
 * main - TCP client for DAYTIME service
 *------------------------------------------------------------------------
 */
void
main(int argc, char *argv[])
{
    char   *host = "127.0.0.1";        /* server IP Address to connect */

    char   *service = "5050";          /* server port to connect       */
    struct sockaddr_in sin;            /* an Internet endpoint address    */
    struct sockaddr_in from;        /* sender address               */
    int    fromsize = sizeof(from);
    char   buf[BUFLEN+1];           /* buffer for one line of text    */
    char   buf1[BUFLEN+1];  
    SOCKET    sock;                      /* socket descriptor            */
    int    cc;                            /* recv character count            */

    char    *pts;    
    time_t    now;

    WSADATA wsadata;
    WSAStartup(WSVERS, &wsadata);   /* 加載winsock library，WSVERS為請求版本,wsadata返回系統實際支持的最高版本。    */        
    sock = socket(PF_INET, SOCK_DGRAM,IPPROTO_UDP); // 創建UDP套接字, 參數：因特網協議簇(family)，數據報套接字，UDP協議號， 返回：要監聽套接字的描述符或INVALID_SOCKET
    memset(&sin, 0, sizeof(sin));
    sin.sin_family = AF_INET;
    sin.sin_addr.s_addr = INADDR_ANY;                     // 綁定(監聽)所有的接口。
    sin.sin_port = htons((u_short)atoi(service));         // 綁定指定接口。atoi--把ascii轉化為int，htons -- 主機序(host)轉化為網絡序(network), 為short類型。 
    bind(sock, (struct sockaddr *)&sin, sizeof(sin));     // 綁定本地端口號（和本地IP地址)

    (void) time(&now);                                      // 取得系統時間
       pts = ctime(&now);                                      // 把時間轉換為字符串
       printf("           \t     UDP(Server) Echo增強程序\n\n"); 
     while(!_kbhit()){                                    //檢測是否有按鍵
flag1:        cc = recvfrom(sock, buf, BUFLEN, 0, (SOCKADDR *)&from, &fromsize);  //接收客戶數據。返回結果：cc為接收的字符數，from中將包含客戶IP地址和端口號。
        sprintf(buf1," \t\t 時間：  %s \t\t Client【IP: %s  端口號： %d  】\n  \t\t  數據：   %s",pts,inet_ntoa(from.sin_addr),from.sin_port,buf);
        if (cc == SOCKET_ERROR){
            printf("recvfrom() failed; %d\n", WSAGetLastError());
            break;
        }
        else if (cc == 0)
            break;
        else{
            buf[cc] = '\0';
            printf("您收到的數據為：\n   %s\n", buf1);
            printf("將自動把此數據返回給 Client  \n");
            goto flag2;
        }

    }

flag2:    cc = sendto(sock, buf1, 1000, 0,(SOCKADDR *)&from, sizeof(from));
   if (cc == SOCKET_ERROR){
        printf("發送失敗，錯誤號：%d\n", WSAGetLastError());
          }
    else{
        printf("發送成功\n");
        goto flag1;
         }

//    cc = recvfrom(sock, buf, BUFLEN, 0, (SOCKADDR *)&from, &fromsize);

    closesocket(sock);
    GlobalFree(buf);
    WSACleanup();                     /* 卸載某版本的DLL */
}

 

Client 部分：

/* UDPClient.cpp */

#include <stdlib.h>
#include <stdio.h>
#include <winsock2.h>
#include <string.h>
#include <time.h>

#define    BUFLEN        2000                  // 緩沖區大小
#define WSVERS        MAKEWORD(2, 2)        // 指明版本2.2 
#pragma comment(lib,"ws2_32.lib")         // 加載winsock 2.2 Llibrary

void
main(int argc, char *argv[])
{
    char    *host = "127.0.0.1";        /* server IP to connect         */

    char    *service = "5050";          /* server port to connect       */
    struct sockaddr_in toAddr;            /* an Internet endpoint address    */
    char    buf[BUFLEN+1];                   /* buffer for one line of text    */
    SOCKET    sock;                          /* socket descriptor            */
    int    cc;                                /* recv character count            */
    char    *pts;                    /* pointer to time string            */
    time_t    now;                    /* current time                        */

    int    toAddrsize = sizeof(toAddr);

    WSADATA wsadata;
    WSAStartup(WSVERS, &wsadata);       /* 啟動某版本Socket的DLL        */    

    sock = socket(PF_INET, SOCK_DGRAM,IPPROTO_UDP);

    memset(&toAddr, 0, sizeof(toAddr));
    toAddr.sin_family = AF_INET;
    toAddr.sin_port = htons((u_short)atoi(service));    //atoi：把ascii轉化為int. htons：主機序(host)轉化為網絡序(network), s--short
    toAddr.sin_addr.s_addr = inet_addr(host);           //如果host為域名，需要先用函數gethostbyname把域名轉化為IP地址


//    memset(buf,' ',1000);  //fill 1000 bytes with 'e'
    buf[1000] = '\0';
    (void) time(&now);                                      // 取得系統時間
    pts = ctime(&now);                                      // 把時間轉換為字符串
//    memcpy(buf,pts,strlen(pts));
    sprintf(buf,"%s ",pts);
    printf("                        UDP(Client) Echo增強程序\n\n"); 
     printf("  時間 ：%s",buf);



    cc = sendto(sock, buf, 1000, 0,(SOCKADDR *)&toAddr, sizeof(toAddr));
 flag2:   if (cc == SOCKET_ERROR){
        printf("發送失敗，錯誤號：%d\n", WSAGetLastError());
     }
    else{
        printf("       發送成功 \n");
         cc = recvfrom(sock, buf, BUFLEN, 0, (SOCKADDR *)&toAddr, & toAddrsize);
         printf(" 您接收到的數據為:\n %s \n",buf);
        printf("鍵入 # 繼續發送，鍵入 @ 停止發送\n");
        scanf("%s",pts);
        if(pts[0]=='#')
        {
            printf("    請輸入要發送的數據 ：\n");
            goto flag1;
        }
        if(pts[0]=='@')
            goto end;


    }

flag1:
    scanf("%s",pts);
    sprintf(buf,"%s ",pts);
    cc = sendto(sock, buf, 1000, 0,(SOCKADDR *)&toAddr, sizeof(toAddr));

    goto flag2;



    getchar();

    closesocket(sock);

end:    GlobalFree(buf);
    WSACleanup();                     /* 卸載某版本的DLL */  

    getchar();

}