• 计算机网络 CTCP 对客户端的封装

    完整代码如下

    类声明

    1. #ifndef CTCPMAP_H
    2. #define CTCPMAP_H
    3. #include
    4. #include
    5. #include
    6. #include
    7. #include
    8. using namespace std;
    9. class client
    10. {
    11. public:
    12.     client();
    13.     ~client();
    14.     //初始化网络
    15.     bool InitnewWork();
    16.     //销毁网络
    17.     void DeleteWork();
    18.     //发送数据
    19.     bool sendDate(char*szbuf,int nLen);
    20.     //接收数据
    21.     void recvDate();
    22.     //线程函数
    23.     static DWORD WINAPI ThreadWork(LPVOID lpvoid);
    24. private:
    25. SOCKET m_client;
    26. HANDLE m_hThread;
    27. bool bFlagQuit;
    28. };
    29.  
    30. #endif // CLIENT_H

    类定义

    1. #include "client.h"
    2.  
    3. client::client()
    4. {
    5.     m_client=0;
    6.     m_hThread=NULL;
    7.     bFlagQuit=true;
    8.  
    9. }
    10.  
    11. client::~client()
    12. {
    13.  
    14. }
    15.  
    16. bool client::InitnewWork()
    17. {
    18.     WORD wVersionRequested;
    19.     WSADATA wsaData;
    20.     int err;
    21.  
    22.  
    23.     wVersionRequested = MAKEWORD(2, 2);
    24.  
    25.     err = WSAStartup(wVersionRequested, &wsaData);
    26.     if (err != 0) {
    27.  
    28.         printf("WSAStartup failed with error: %d\n", err);
    29.         return false;
    30.     }
    31.  
    32.  
    33.  
    34.     if (LOBYTE(wsaData.wVersion) != 2 || HIBYTE(wsaData.wVersion) != 2) {
    35.  
    36.        DeleteWork();
    37.         return false;
    38.     }
    39.     else
    40.         printf("The Winsock 2.2 dll was found okay\n");
    41.  
    42.  
    43. //创建套接字
    44.     m_client=socket(AF_INET,SOCK_STREAM,0);
    45.     if(m_client==INVALID_SOCKET)
    46.     {
    47.        DeleteWork();
    48.         return false;
    49.     }
    50.  
    51.  
    52.  
    53. //connect()
    54.  
    55.  
    56.     //绑定IP
    57.     sockaddr_in addrserver;
    58.     addrserver.sin_addr.S_un.S_addr=inet_addr("127.0.0.1");
    59.     addrserver.sin_port=htons(8899);
    60.     addrserver.sin_family=AF_INET;
    61.     if(SOCKET_ERROR==connect(m_client,(sockaddr*)&addrserver,sizeof(addrserver)))
    62.     {
    63.            DeleteWork();
    64.             return false;
    65.  
    66.     }
    67.     //创建线程
    68.     m_hThread=CreateThread(0,0,&ThreadWork,this,0,0);
    69.     return  true;
    70.  
    71.  
    72.  
    73. }
    74.  
    75. DWORD WINAPI  client::ThreadWork(LPVOID lpvoid)
    76. {
    77.     client* pthis=(client* ) lpvoid;
    78.  
    79.  
    80.  
    81.  
    82.     while(pthis->bFlagQuit)
    83.     {
    84.  
    85.  
    86.     }
    87. return 0;
    88. }
    89. void client::DeleteWork()
    90. {
    91.  
    92.     bFlagQuit=false;
    93.     if(m_hThread)
    94.     {
    95.         if(WAIT_TIMEOUT==WaitForSingleObject(m_hThread,100))
    96.             TerminateThread(m_hThread,-1);
    97.  
    98.         CloseHandle(m_hThread);
    99.  
    100.         m_hThread=NULL;
    101.  
    102.     }
    103.  
    104.  
    105.     if(m_client)
    106.     {
    107.         closesocket(m_client);
    108.         m_client=0;
    109.  
    110.     }
    111.  
    112.     WSACleanup();
    113.  
    114. }
    115. bool client::sendDate(char*szbuf,int nLen)
    116. {
    117.  
    118.    if(!szbuf||nLen<=0)
    119.        return  false;
    120.    if(send(m_client,(char*)&nLen,sizeof(int),0)<=0)
    121.        return  false;
    122.    if(send(m_client,szbuf,nLen,0)<=0)
    123.        return false;
    124.  
    125.  
    126.    return  true;
    127.  
    128. }
    129. void client::recvDate()
    130. {
    131.     int  nRecvNum;
    132.     int  nPackNum;
    133.     char *szbuf;
    134.     int  noffest;
    135.     while(bFlagQuit)
    136.     {
    137.         nRecvNum=recv(m_client,(char*)&nPackNum,sizeof(int),0);
    138.         if(nRecvNum<=0)
    139.         {
    140.             DeleteWork();
    141.             break;
    142.         }
    143.         if(nPackNum<=0) continue;
    144.         szbuf=new char[nPackNum];
    145.         noffest=0;
    146.         while(nPackNum)
    147.         {
    148.             nRecvNum=recv(m_client,szbuf+noffest,nPackNum,0);
    149.             if(nRecvNum>0)
    150.             {
    151.                 nPackNum-=nRecvNum;
    152.                 noffest+=nRecvNum;
    153.             }
    154.         }
    155.  
    156.     }
    157.  
    158.  
    159.  
    160. }

    主函数的测试

    1. #include 
    2. #include
    3. #include
    4. #include"client.h"
    5. using namespace std;
    6. int main(int argc, char *argv[])
    7. {
    8.     client cli;
    9.     if(cli.InitnewWork())
    10.     {
    11.         cout<<"connect sucess"<
    12.         char szbuf[1024];
    13.         cin>>szbuf;
    14.         cli.sendDate(szbuf,sizeof (szbuf));
    15.     }
    16.  
    17.  
    18. }

  • 相关阅读:
    设计模式简介
    I2S总线介绍以及通信注意事项
    LeetCode_哈希表_简单_594.最长和谐子序列
    ES主要功能特性和使用场景
    VTK网格细分-vtkAdaptiveSubdivisionFilter
    金融业务系统云原生技术转型：从传统架构到云原生的跨越
    Go语言入门之数组切片
    vue 使用qrcode生成二维码并可下载保存
    postman 获取HTML 里name=token 的值
    【软考】-- 计算机组成体系结构（上）【我的1024】
  • 原文地址：https://blog.csdn.net/van9527/article/details/126463245