基于CAsyncSocket类模拟TCP网络传输之服务端

男娘i 2022-03-10 21:07 371阅读 0赞

本例程对应的客户端请看[https://blog.csdn.net/qq\_34911636/article/details/88218891][https_blog.csdn.net_qq_34911636_article_details_88218891]

本例程通信的流程和操作请看[https://blog.csdn.net/qq\_34911636/article/details/88256403][https_blog.csdn.net_qq_34911636_article_details_88256403]

编译环境：系统:WIN7，Visual C++ 2015，建立一个ServerDlg的对话框程序

1、基于MFC创建对话框应用程序,在创建对话框应用程序时“windows套接字”选项需要打钩

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0OTExNjM2_size_16_color_FFFFFF_t_70][]

二、创建ServerSocket类和ListenSocket类，两个都继承CAsyncSocket类

项目->添加类->选择MFC类->添加，如下图所示：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0OTExNjM2_size_16_color_FFFFFF_t_70 1][]

类名：ServerSocket类和ListenSocket类，基类选择：CAsyncSocket，点击完成，这时在项目中生成ServerSocket.h；ServerSocket.cpp和生成ListenSocket.h；ListenSocket.cpp四个文件

三、重写CAsyncSocket类的回调函数OnAccept(int nErrorCode);OnClose(int nErrorCode);OnReceive(int nErrorCode)等

打开类视图，选中左边ListenSocket类，点击右边工具栏的属性，在用鼠标点击对应的OnAccept等函数，这时在ListenSocket.h文件中生成OnAccept(int nErrorCode)函数。

打开类视图，选中左边ServerSocket类，点击右边工具栏的属性，在用鼠标点击对应的OnReceive和OnClose等函数，这时在ServerSocket.h文件中生成OnClose(int nErrorCode);OnReceive(int nErrorCode)函数。

如下图示：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0OTExNjM2_size_16_color_FFFFFF_t_70 2][]

四、服务端界面的搭建，如下图所示:

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0OTExNjM2_size_16_color_FFFFFF_t_70 3][]

五、添加控件的变量和处理函数

ServerDlg.h头文件中的变量：

public:  
    CIPAddressCtrl m\_IP;  //IP控件变量（control类型）  
    CString m\_Port;   //端口控件变量（value）  
    CListBox m\_StringWord;   //列表框控件变量（control类型）  
    afx\_msg void OnInternetQuit();  //“退出”按键处理函数  
    afx\_msg void OnStartMonitor();  //“开始监听”按键处理函数  
    afx\_msg void OnStopMonitor();   //“停止监听”按键处理函数  
public:  
    ListenSocket m\_listensocket;    //网络监听类  
    ServerSocket m\_serversocket;    //网络服务类  
    afx\_msg void OnBnaboutTo();     //“关于”程序版本按键  
    afx\_msg void OnBnReceiveClean(); //“接收清空”按键处理函数  
    CEdit m\_SendWork;  //编辑框发送变量（control类型）  
    afx\_msg void OnBnEditClean(); //“发送清除”按键处理函数  
    afx\_msg void OnBnSendMessage(); //“发送”按键处理函数  
    afx\_msg void OnBnInternectQuit();  //“断开连接”按键处理函数  
    afx\_msg void OnBnSetAddress();  //“设置地址”按键处理函数  
private:  
    BYTE SETIP\[4\];  
public:  
    CEdit m\_SetPort;  //端口控件变量（control）  
    CButton m\_SetAddress; //“设置地址”按键变量（control）  
    CButton m\_InternectQuit;  //“断开连接”按键变量（control）  
    CButton m\_StartMonitor;  //“开始监听”按键变量（control）  
    CButton m\_StopMonitor;  //“停止监听”按键变量（control）

ServerDlg.cpp文件中如下添加程序：

void CServerDlg::OnInternetQuit()  //退出程序  
\{  
    // TODO: 在此添加控件通知处理程序代码  
    m\_listensocket.Close();  
    CDialog::OnCancel();  
\}

void CServerDlg::OnStartMonitor()  
\{  
    // TODO: 在此添加控件通知处理程序代码  
    BYTE IPBYTE\[4\];  
    CString s\_IP,ipport,port;  
    UINT sPort;  
    UpdateData(TRUE);  
    m\_IP.GetAddress(IPBYTE\[0\], IPBYTE\[1\], IPBYTE\[2\], IPBYTE\[3\]);  
    s\_IP.Format(\_T("%d.%d.%d.%d"), IPBYTE\[0\], IPBYTE\[1\], IPBYTE\[2\], IPBYTE\[3\]);  
    sPort = \_ttoi(m\_Port);  
    m\_listensocket.Create(sPort,1,FD\_ACCEPT,s\_IP);  
    m\_listensocket.Listen(1);

port.Format(\_T("地址:%s"), s\_IP);  
    ipport.Format(\_T("端口:%s"), m\_Port);  
    m\_StringWord.AddString(\_T("开始监听"));  
    m\_StringWord.AddString(port);  
    m\_StringWord.AddString(ipport);  
    m\_StringWord.AddString(\_T("等待客户端连接......"));  
    m\_StringWord.SetTopIndex(m\_StringWord.GetCount() + 1);

m\_IP.EnableWindow(FALSE);  
    m\_SetPort.EnableWindow(FALSE);  
    m\_SetAddress.EnableWindow(FALSE);  
    m\_StartMonitor.EnableWindow(FALSE);  
\}

void CServerDlg::OnStopMonitor()  
\{  
    m\_listensocket.Close();  
    m\_StringWord.AddString(\_T("停止监听"));  
    m\_StringWord.SetTopIndex(m\_StringWord.GetCount() - 1);

m\_StartMonitor.EnableWindow(TRUE);  
    m\_IP.EnableWindow(TRUE);  
    m\_SetPort.EnableWindow(TRUE);  
    m\_SetAddress.EnableWindow(TRUE);  
    // TODO: 在此添加控件通知处理程序代码  
\}

void CServerDlg::OnBnSendMessage()  
\{  
    // TODO: 在此添加控件通知处理程序代码  
    //UpdateData(TRUE);  
    CString sendwork,str;  
    m\_SendWork.GetWindowTextW(sendwork);  
    if (sendwork.GetLength() != 0)  
    \{  
        m\_serversocket.Send(sendwork, 2\*sendwork.GetLength());  
        //m\_serversocket.Send(sendwork, strlen(sendwork));  
        str.Format(\_T("发送:%s"), sendwork);  
        m\_StringWord.AddString(str);  
        m\_StringWord.SetTopIndex(m\_StringWord.GetCount() - 1);  
    \}  
\}

void CServerDlg::OnBnaboutTo()  
\{  
    // TODO: 在此添加控件通知处理程序代码  
    CAboutDlg aboutdlg;  
    aboutdlg.DoModal();  
\}

void CServerDlg::OnBnReceiveClean()  
\{  
    // TODO: 在此添加控件通知处理程序代码  
    m\_StringWord.ResetContent();  
\}

void CServerDlg::OnBnEditClean()  
\{  
    // TODO: 在此添加控件通知处理程序代码  
    m\_SendWork.SetWindowTextW(\_T(""));  
\}

void CServerDlg::OnBnInternectQuit()   //断开连接  
\{  
    // TODO: 在此添加控件通知处理程序代码  
    m\_serversocket.Close();  
    m\_StringWord.AddString(\_T("断开连接"));  
    m\_StringWord.SetTopIndex(m\_StringWord.GetCount() + 1);  
\}

void CServerDlg::OnBnSetAddress()  
\{  
    // TODO: 在此添加控件通知处理程序代码  
    m\_IP.SetAddress(SETIP\[0\], SETIP\[1\], SETIP\[2\], SETIP\[3\]);  
    m\_SetPort.SetWindowTextW(\_T("1035"));

六、ServerSocket.cpp中添加以下代码

void ServerSocket::OnReceive(int nErrorCode)  
\{  
    // TODO: 在此添加专用代码和/或调用基类  
    char Rmessage\[200\] = \{NULL\};  
    CString Rstring;  
    int n = Receive(Rmessage,200);  
    //int stringcount = ((CServerDlg\*)AfxGetApp()->m\_pMainWnd)->m\_StringWord.GetCount();  
    Rmessage\[n\] = \_T('\\0');  
    Rstring.Format(\_T("收到:%s"), Rmessage);  
      
    //for (int i = 0; i < stringcount; i++)  
    //\{  
    //    ((CServerDlg\*)AfxGetApp()->m\_pMainWnd)->m\_StringWord.DeleteString(0);  
    //\}  
    ((CServerDlg\*)AfxGetApp()->m\_pMainWnd)->m\_StringWord.AddString(Rstring);  
    ((CServerDlg\*)AfxGetApp()->m\_pMainWnd)->m\_StringWord.SetTopIndex(((CServerDlg\*)AfxGetApp()->m\_pMainWnd)->m\_StringWord.GetCount() - 1);

CAsyncSocket::OnReceive(nErrorCode);  
\}

void ServerSocket::OnClose(int nErrorCode)  
\{  
    // TODO: 在此添加专用代码和/或调用基类  
    int stringcount = ((CServerDlg\*)AfxGetApp()->m\_pMainWnd)->m\_StringWord.GetCount();  
    for (int i = 0; i < stringcount; i++)  
    \{  
        ((CServerDlg\*)AfxGetApp()->m\_pMainWnd)->m\_StringWord.DeleteString(0);  
    \}  
    ((CServerDlg\*)AfxGetApp()->m\_pMainWnd)->m\_StringWord.AddString(\_T("已断开连接"));  
    CAsyncSocket::OnClose(nErrorCode);  
\}

在上述的代码中((CClientDlg\*)(AfxGetApp()->m\_pMainWnd))的作用;

其中AfxGetApp()获取的是应用程序类的指针，比如利用vs2010或vc6.0自动生成一个mfc工程，假设名称为Pro，若是基于单文档的程序，里面一定有CPro、CProDoc、CProView还有CMainFrame这几个类，其中，CPro代表了这个应用程序运行实例的对象，该类里面有很多成员变量，其中有不少代表窗口的变量，而m\_pMainWnd正是其中的一个变量，它代表了程序的主体窗口，且它是属于CMainFrame类。MFC提供的应用程序设计理念就是文档、框架、视图  结构，这三个结构是由三个类来体现的，分别是上面提到的CProDoc（文档，代表程序的数据）、CMainFrame（框架，代表应用程序界面的框架窗口）、CProView（视图，代表应用程序的客户区界面部分），MFC基于单文档或多文档的应用程序，都是基于这个结构来实现的。而者三个结构成员是由应用程序实例的类来统一管理的，这就是上面所说的CPro类。AfxGetCpp()正是返回了这个类的指针。虽然m\_pMainWnd和AfxGetCpp()的返回值都是指针，但他们的指向不同。

所以上述代码“((CClientDlg\*)(AfxGetApp()->m\_pMainWnd))”作用是在ClientSocket类中调用整个函数的实例，并且指向该实例的句柄，其该实例的句柄就是所看到程序运行的窗口，在通过指针引用到实例中的具体变量上，例如“ ((CClientDlg\*)AfxGetApp()->m\_pMainWnd)->m\_Message.AddString(RWord);”就是对窗口的列表框加载字符串操作。

七、ListenSocket.cpp中添加以下代码

void ListenSocket::OnAccept(int nErrorCode)  
\{  
    // TODO: 在此添加专用代码和/或调用基类  
    int stringcount = ((CServerDlg\*)AfxGetApp()->m\_pMainWnd)->m\_StringWord.GetCount();  
    Accept(((CServerDlg\*)(AfxGetApp()->m\_pMainWnd))->m\_serversocket);  
    (((CServerDlg\*)AfxGetApp()->m\_pMainWnd)->m\_serversocket).AsyncSelect(FD\_READ|FD\_CLOSE);

for (int i = 0; i < stringcount; i++)  
    \{  
        (((CServerDlg\*)AfxGetApp()->m\_pMainWnd)->m\_StringWord).DeleteString(0);  
    \}  
    (((CServerDlg\*)AfxGetApp()->m\_pMainWnd)->m\_StringWord.AddString(\_T(" 接收客户的一个连接请求")));

CAsyncSocket::OnAccept(nErrorCode);  
\}

八、在BOOL CServerDlg::OnInitDialog()添加代码

SetIcon(m\_hIcon, TRUE);            // 设置大图标  
    SetIcon(m\_hIcon, FALSE);        // 设置小图标

上述代码后面添加如下代码：

SETIP\[0\] = 127;  
    SETIP\[1\] = 0;  
    SETIP\[2\] = 0;  
    SETIP\[3\] = 1;

九、运行代码

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0OTExNjM2_size_16_color_FFFFFF_t_70 4][]

[https_blog.csdn.net_qq_34911636_article_details_88218891]: https://blog.csdn.net/qq_34911636/article/details/88218891
[https_blog.csdn.net_qq_34911636_article_details_88256403]: https://blog.csdn.net/qq_34911636/article/details/88256403
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0OTExNjM2_size_16_color_FFFFFF_t_70]: /images/20220311/2830051d27d04bebb1e661a798531c0a.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0OTExNjM2_size_16_color_FFFFFF_t_70 1]: /images/20220311/c82439e8eae7416fb56baed37688cb67.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0OTExNjM2_size_16_color_FFFFFF_t_70 2]: /images/20220311/50d9785f76b34d1e9b461bc5a36ab185.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0OTExNjM2_size_16_color_FFFFFF_t_70 3]: /images/20220311/14da2251899e4847bf19642f8d17d0e3.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0OTExNjM2_size_16_color_FFFFFF_t_70 4]: /images/20220311/92e055fbe48f44b6aa1cb014ae2a20b3.png