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

 

本次實驗利用TCP/IP, 語言環境為 C/C++

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

結果應為類似所示：

 

 

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

 

Server 部分：

/* TCPServer.cpp - main */

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

#define QLEN       5
#define    WSVERS    MAKEWORD(2, 0)
#define    BUFLEN        20000  
#pragma comment(lib,"ws2_32.lib")  //使用winsock 2.2 library
/*------------------------------------------------------------------------
 * main - Iterative TCP server for TIME service
 *------------------------------------------------------------------------
 */
char buf[20000];
char buf1[20000];
char buf2[20000];
void main(int argc, char *argv[]) 
/* argc: 命令行參數個數， 例如：C:\> TCPServer 8080 
                     argc=2 argv[0]="TCPServer",argv[1]="8080" */
{
    struct    sockaddr_in fsin;        /* the from address of a client      */
    SOCKET    msock, ssock;            /* master & slave sockets          */
    WSADATA wsadata; 
    char    *service = "5050";
    struct  sockaddr_in sin;        /* an Internet endpoint address        */
    int        alen;                    /* from-address length                */
    char    *pts;                    /* pointer to time string            */
//    char pts[2000];
    time_t    now;                    /* current time                        */
    int cc;

    WSAStartup(WSVERS, &wsadata);                        // 加載winsock library。WSVERS指明請求使用的版本。wsadata返回系統實際支持的最高版本
    msock = socket(PF_INET, SOCK_STREAM, IPPROTO_TCP);    // 創建套接字，參數：因特網協議簇(family)，流套接字，TCP協議
                                                        // 返回：要監聽套接字的描述符或INVALID_SOCKET

    memset(&sin, 0, sizeof(sin));                        // 從&sin開始的長度為sizeof(sin)的內存清0
    sin.sin_family = AF_INET;                            // 因特網地址簇(INET-Internet)
    sin.sin_addr.s_addr = INADDR_ANY;                    // 監聽所有(接口的)IP地址。
    sin.sin_port = htons((u_short)atoi(service));        // 監聽的端口號。atoi--把ascii轉化為int，htons--主機序到網絡序(16位)
    bind(msock, (struct sockaddr *)&sin, sizeof(sin));  // 綁定監聽的IP地址和端口號

    listen(msock, 5);                                   // 等待建立連接的隊列長度為5

    while(!_kbhit()){                                      // 檢測是否有按鍵
       alen = sizeof(struct sockaddr);                   // 取到地址結構的長度
       ssock = accept(msock, (struct sockaddr *)&fsin, &alen); // 如果有新的連接請求，返回連接套接字，否則，被阻塞。fsin包含客戶端IP地址和端口號
        
       (void) time(&now);                                      // 取得系統時間
       pts = ctime(&now);                                      // 把時間轉換為字符串
       sprintf(buf,"IP :%s 端口號: %d\n",inet_ntoa(fsin.sin_addr),fsin.sin_port);
       // sprintf(buf,"%d:%d Hello my friends ! %s",inet_ntoa(sin.sin_addr),fsin.sin_port,pts);
       (void) send(ssock, buf, strlen(pts), 0);          // 把緩沖區(指針,長度)的數據發送出去
       printf("             TCP(Server) Echo增強程序 \n\n");
        printf(" 時間：  %s\n", pts);
       printf(" %s\n", buf);                                      // 顯示發送字符串
        printf("請等待接收數據 ：\n");

//flag1: 
//       printf("\n您還要傳送什么？\n");
//       printf(" 如果想臨時改為接收，請鍵入 * \n");
//    scanf("%s",pts);
    
//    if(pts[0] == '*')
//    {
//        printf("\n請等待接收數據\n");
//        sprintf(buf1,"%s",pts);
//    (void) send(ssock, buf1, strlen(pts), 0); 
//        goto flag2;
//    }
//    sprintf(buf1,"%s",pts);
//    (void) send(ssock, buf1, strlen(pts), 0);  
//    goto flag1;
    //     ssock = accept(msock, (struct sockaddr *)&fsin, &alen);

flag2:         cc = recv(ssock, buf1, BUFLEN, 0); 
         if(cc == SOCKET_ERROR || cc==0)
         printf("Error: %d.\n",GetLastError());     //出錯。其后必須關閉套接字sock。
    else if(cc > 0) {
         buf1[cc] = '\0';    // ensure null-termination
         buf2[cc] = '\0';
//         if(buf1[0] == '#')
//         {
//             printf("\n您接收到的數據為： # , 請傳輸數據 \n");
//             goto flag2;
//         }
         (void) time(&now); 
          pts = ctime(&now); 
         sprintf(buf2,"%s   \n  %s",pts,buf1);
    //    strcat(buf2,buf1);
         printf("\n您接收到的數據為：");
    //     printf(" 時間：  %s\n", pts);
           printf("%s\n", buf2);  
           printf("\n         將自動把此數據返回給客戶！\n");
           (void) send(ssock, buf1, strlen(pts), 0);  
           goto flag2;
    }
       (void) closesocket(ssock);                              // 關閉連接套接字
     }
    (void) closesocket(msock);                                 // 關閉監聽套接字
     WSACleanup();                                             // 卸載winsock library

}

 

Client 部分：

/* TCPClient.cpp */

#include <stdlib.h>
#include <stdio.h>
#include <winsock2.h>
#include <string.h>
#include <time.h>
#include "conio.h"
#define    BUFLEN        20000                  // 緩沖區大小
#define WSVERS        MAKEWORD(2, 0)        // 指明版本2.0 
#pragma comment(lib,"ws2_32.lib")         // 使用winsock 2.0 Llibrary

/*------------------------------------------------------------------------
 * main - TCP client for TIME service
 *------------------------------------------------------------------------
 */
char    buf1[BUFLEN+1];
char    buf[BUFLEN+1];                   /* buffer for one line of text    */
void main(int argc, char *argv[])
{
    char *host = "127.0.0.1";
//    char    *host = "10.4.4.146";        /* server IP to connect         */

    char    *service = "5050";          /* server port to connect       */
    struct sockaddr_in sin,fsin;                /* an Internet endpoint address    */
    
     
    SOCKET    sock,ssock;                          /* socket descriptor            */
    int    cc,alen;   /* recv character count            */
    char    *pts ;
    time_t    now;
    WSADATA wsadata;
    WSAStartup(WSVERS, &wsadata);                          //加載winsock library。WSVERS為請求的版本，wsadata返回系統實際支持的最高版本
  
    sock = socket(PF_INET, SOCK_STREAM, IPPROTO_TCP);      //創建套接字，參數：因特網協議簇(family)，流套接字，TCP協議

                                                      //返回：要監聽套接字的描述符或INVALID_SOCKET

    memset(&sin, 0, sizeof(sin));                          // 從&sin開始的長度為sizeof(sin)的內存清0
    sin.sin_family = AF_INET;                              // 因特網地址簇
    sin.sin_addr.s_addr = inet_addr(host);                // 服務器IP地址(32位)
    sin.sin_port = htons((u_short)atoi(service));         // 服務器端口號  
    connect(sock, (struct sockaddr *)&sin, sizeof(sin));  // 連接到服務器
//    alen = sizeof(struct sockaddr); 
//    ssock = accept(sock, (struct sockaddr *)&fsin, &alen);    
               printf("             TCP(Client) Echo增強程序 \n\n");
 flag1:   cc = recv(sock, buf1, BUFLEN+1, 0);                // cc為接收到的字符的個數(>0)或對方已關閉(=0)或連接出錯(<0)
    if(cc == SOCKET_ERROR || cc==0)
         printf("Error: %d.\n",GetLastError());     //出錯。其后必須關閉套接字sock。
    else if(cc > 0) {
         buf1[cc] = '\0';    // ensure null-termination
//         if(buf[0] == '*')
//         {
//             printf("\n您接收到的數據為： * , 請傳輸數據 \n");
//             goto flag2;
//         }
         (void) time(&now);                                      // 取得系統時間
       pts = ctime(&now);  
         printf("您接收到的數據為：\n");
         printf(" 時間：  %s\n",pts);
         printf(" %s\n",buf1);                         // 顯示所接收的字符串
    }    
       goto flag2;

flag2:
    


    printf("\n您想傳送什么？\n");
    printf("    如果想關閉連接，請輸入 @ \n");
//    printf("\n 如果想臨時改為接收，請鍵入 # \n");
    scanf("%s",pts);
    if(pts[0] == '@')
        goto end;
//    if(pts[0] == '#')
//    {
//        printf("\n請等待接收數據\n");
//        sprintf(buf1,"%s",pts);
//     (void) send(sock, buf1, strlen(pts), 0);
//        goto flag1;
//    }
    sprintf(buf1,"%s",pts);
     (void) send(sock, buf1, strlen(pts), 0);
     goto flag1;
end:    closesocket(sock);                             // 關閉監聽套接字

    WSACleanup();                                  // 卸載winsock library

    printf("\n按回車鍵繼續...");
    getchar();                                        // 等待任意按鍵
}