MFC下CSocket编程详解

浅浅的花香味﹌ 2022-04-06 08:44 341阅读 0赞

MFC下CSocket编程详解:

1. 常用的函数和注意事项(详细的函数接口说明请查看MSDN):

CSocket::Create 初始化(一般写服务器程序都不要用为好,用下面的 CSocket::Socket 初始化)

CSocket::Socket初始化

CSocket::SetSockOpt 设置socket选项

CSocket::Bind 绑定地址端口

CSocket::Connect 连接

CSocket::Listen  监听

CSocket::Accept 接收外部连接的socket  
   
    CSocket::Send 发送内容

CSocket::Receive 接收内容

CSocket::Close 关闭(不等于delete)

1) 在使用MFC编写socket程序时，必须要包含<afxsock.h>都文件。

2) AfxSocketInit() 这个函数，在使用CSocket前一定要先调用该函数,否则使用CSocket会出错;并且该函数还有一个重要的使用方式，  
       就是在某个线程下使用 CSocket 前一定要调用,就算主线程调用了该函数,在子线程下使用 CSocket 也要先调用该函数,要不会出错。

3) 还要注意的是, Create 方法已经包含了 Bind 方法,如果是以 Create 方法初始化的前提下不能再调用 Bind ,要不一定出错。

2. 以下是使用例子代码，通过例子来学习如何使用 CSocket 进行编程, 并且附件上有完整的例子代码。例子的可以在我的发布资源中找到：MFC下CSocket编程例子 [http://download.csdn.net/source/379597][http_download.csdn.net_source_379597]

1) 客户端主要代码:

![None.gif][]   // 初始化   
![None.gif][]  AfxSocketInit();  
![None.gif][]    
![None.gif][]         // 创建 CSocket 对象   
![None.gif][]  CSocket aSocket;  
![None.gif][]  
![None.gif][] CString strIP;  
![None.gif][] CString strPort;  
![None.gif][] CString strText;  
![None.gif][]  
![None.gif][]  this \-> GetDlgItem(IDC\_EDIT\_IP) \-> GetWindowText(strIP);  
![None.gif][]  this \-> GetDlgItem(IDC\_EDIT\_PORT) \-> GetWindowText(strPort);  
![None.gif][]  this \-> GetDlgItem(IDC\_EDIT\_TEXT) \-> GetWindowText(strText);  
![None.gif][]  
![None.gif][]  // 初始化 CSocket 对象, 因为客户端不需要绑定任何端口和地址, 所以用默认参数即可   
![None.gif][]   if ( ! aSocket.Create())  
![ExpandedBlockStart.gif][]![ContractedBlock.gif][]  ... \{  
![ExpandedSubBlockStart.gif][]![ContractedSubBlock.gif][]  char szMsg\[1024\] = ...\{ 0\};  
![InBlock.gif][]  
![InBlock.gif][]  sprintf(szMsg, "create faild: %d", aSocket.GetLastError());  
![InBlock.gif][]  
![InBlock.gif][]  AfxMessageBox(szMsg);  
![InBlock.gif][]  return;  
![ExpandedBlockEnd.gif][] \}   
![None.gif][]  
![None.gif][]  // 转换需要连接的端口内容类型   
![None.gif][]   int  nPort  =  atoi(strPort);  
![None.gif][]   
![None.gif][]         // 连接指定的地址和端口   
![None.gif][]   if (aSocket.Connect(strIP, nPort))  
![ExpandedBlockStart.gif][]![ContractedBlock.gif][]  ... \{  
![ExpandedSubBlockStart.gif][]![ContractedSubBlock.gif][]  char szRecValue\[1024\] = ...\{ 0\};  
![InBlock.gif][]  
![InBlock.gif][]                //发送内容给服务器  
![InBlock.gif][]  aSocket.Send(strText, strText.GetLength());  
![InBlock.gif][]    
![InBlock.gif][]  //接收服务器发送回来的内容(该方法会阻塞, 在此等待有内容接收到才继续向下执行)  
![InBlock.gif][]  aSocket.Receive((void \*)szRecValue, 1024);  
![InBlock.gif][]  
![InBlock.gif][]  AfxMessageBox(szRecValue);  
![ExpandedBlockEnd.gif][] \}   
![None.gif][]  else   
![ExpandedBlockStart.gif][]![ContractedBlock.gif][]  ... \{  
![ExpandedSubBlockStart.gif][]![ContractedSubBlock.gif][]  char szMsg\[1024\] = ...\{ 0\};  
![InBlock.gif][]    
![InBlock.gif][]  sprintf(szMsg, "create faild: %d", aSocket.GetLastError());  
![InBlock.gif][]    
![InBlock.gif][]  AfxMessageBox(szMsg);  
![ExpandedBlockEnd.gif][] \}   
![None.gif][]  
![None.gif][]  // 关闭   
![None.gif][]  aSocket.Close();  
![None.gif][]

2)服务器端代码:

![None.gif][] unsigned  int  StartServer(LPVOID lParam)  
![ExpandedBlockStart.gif][]![ContractedBlock.gif][] ... \{

//初始化Winscok  
![InBlock.gif][]     if  ( ! AfxSocketInit())  
![ExpandedSubBlockStart.gif][]![ContractedSubBlock.gif][]     ... \{  
![InBlock.gif][]        AfxMessageBox(IDP\_SOCKETS\_INIT\_FAILED);  
![InBlock.gif][]        return 1;  
![ExpandedSubBlockEnd.gif][]    \}   
![InBlock.gif][]  
![InBlock.gif][]    m\_exit  =   false ;  
![InBlock.gif][]  
![InBlock.gif][]    CServerDlg  \* aDlg  =  (CServerDlg  \* )lParam;  
![InBlock.gif][]  
![InBlock.gif][]    CString strPort;  
![InBlock.gif][]      
![InBlock.gif][]    aDlg \-> GetDlgItemText(IDC\_EDIT\_PORT, strPort);  
![InBlock.gif][]      
![InBlock.gif][]    UINT nPort  =  atoi(strPort);  
![InBlock.gif][]      
![InBlock.gif][]     // socket------------------------------------------------   
![InBlock.gif][]       
![InBlock.gif][]    CSocket aSocket, serverSocket;  
![InBlock.gif][]    //最好不要使用aSocket.Create创建，因为容易会出现10048错误  
![InBlock.gif][]     if  ( ! aSocket.Socket())  
![ExpandedSubBlockStart.gif][]![ContractedSubBlock.gif][]     ... \{  
![ExpandedSubBlockStart.gif][]![ContractedSubBlock.gif][]        char szError\[256\] = ...\{ 0\};  
![InBlock.gif][]          
![InBlock.gif][]        sprintf(szError, "Create Faild: %d", GetLastError());  
![InBlock.gif][]          
![InBlock.gif][]        AfxMessageBox(szError);  
![InBlock.gif][]          
![InBlock.gif][]        return 1;   
![ExpandedSubBlockEnd.gif][]    \}   
![InBlock.gif][]  
![InBlock.gif][]    BOOL bOptVal  =  TRUE;  
![InBlock.gif][]     int  bOptLen  =   sizeof (BOOL);

![InBlock.gif][]     //设置Socket的选项, 解决10048错误必须的步骤  
![InBlock.gif][]    aSocket.SetSockOpt(SO\_REUSEADDR, ( void   \* ) & bOptVal, bOptLen, SOL\_SOCKET);

//监听  
![InBlock.gif][]     if ( ! aSocket.Listen( 10 ))  
![ExpandedSubBlockStart.gif][]![ContractedSubBlock.gif][]     ... \{      
![ExpandedSubBlockStart.gif][]![ContractedSubBlock.gif][]        char szError\[256\] = ...\{ 0\};  
![InBlock.gif][]          
![InBlock.gif][]        sprintf(szError, "Listen Faild: %d", GetLastError());  
![InBlock.gif][]          
![InBlock.gif][]        AfxMessageBox(szError);  
![InBlock.gif][]          
![InBlock.gif][]        return 1;  
![ExpandedSubBlockEnd.gif][]    \}   
![InBlock.gif][]      
![InBlock.gif][]    CString strText;  
![InBlock.gif][]      
![InBlock.gif][]    aDlg \-> GetDlgItemText(IDC\_EDIT\_LOG, strText);  
![InBlock.gif][]      
![InBlock.gif][]    strText  \+=   " Server Start!   " ;  
![InBlock.gif][]      
![InBlock.gif][]    aDlg \-> SetDlgItemText(IDC\_EDIT\_LOG, strText);  
![InBlock.gif][]  
![InBlock.gif][]     while ( ! m\_exit)  
![ExpandedSubBlockStart.gif][]![ContractedSubBlock.gif][]     ... \{  
![InBlock.gif][]        //接收外部连接  
![InBlock.gif][]        if(!aSocket.Accept(serverSocket))  
![ExpandedSubBlockStart.gif][]![ContractedSubBlock.gif][]        ...\{  
![InBlock.gif][]            continue;  
![ExpandedSubBlockEnd.gif][]        \}  
![InBlock.gif][]        else  
![ExpandedSubBlockStart.gif][]![ContractedSubBlock.gif][]        ...\{  
![ExpandedSubBlockStart.gif][]![ContractedSubBlock.gif][]            char szRecvMsg\[256\] = ...\{ 0\};  
![ExpandedSubBlockStart.gif][]![ContractedSubBlock.gif][]            char szOutMsg\[256\] = ...\{ 0\};      
![InBlock.gif][]

//接收客户端内容:阻塞  
![InBlock.gif][]            serverSocket.Receive(szRecvMsg,  256 );  
![InBlock.gif][]  
![InBlock.gif][]            sprintf(szOutMsg,  " Receive Msg: %s   " , szRecvMsg);  
![InBlock.gif][]              
![InBlock.gif][]            aDlg \-> GetDlgItemText(IDC\_EDIT\_LOG, strText);  
![InBlock.gif][]              
![InBlock.gif][]            strText  \+=  szOutMsg;  
![InBlock.gif][]              
![InBlock.gif][]            aDlg \-> SetDlgItemText(IDC\_EDIT\_LOG, strText);  
![InBlock.gif][]

//发送内容给客户端  
![InBlock.gif][]            serverSocket.Send( " Have Receive The Msg " ,  50 );  
![InBlock.gif][]

//关闭  
![InBlock.gif][]            serverSocket.Close();  
![ExpandedSubBlockEnd.gif][]        \}   
![InBlock.gif][]          
![ExpandedSubBlockEnd.gif][]    \}   
![InBlock.gif][]

//关闭  
![InBlock.gif][]    aSocket.Close();  
![InBlock.gif][]    serverSocket.Close();  
![InBlock.gif][]      
![InBlock.gif][]    aDlg \-> GetDlgItemText(IDC\_EDIT\_LOG, strText);  
![InBlock.gif][]      
![InBlock.gif][]    strText  \+=   " Have Close! " ;  
![InBlock.gif][]      
![InBlock.gif][]    aDlg \-> SetDlgItemText(IDC\_EDIT\_LOG, strText);  
![InBlock.gif][]  
![InBlock.gif][]     return   0 ;  
![ExpandedBlockEnd.gif][]\}

![InBlock.gif][]      
![InBlock.gif][]    //绑定端口  
![InBlock.gif][]     if  ( ! aSocket.Bind(nPort))  
![ExpandedSubBlockStart.gif][]![ContractedSubBlock.gif][]     ... \{  
![ExpandedSubBlockStart.gif][]![ContractedSubBlock.gif][]        char szError\[256\] = ...\{ 0\};  
![InBlock.gif][]              
![InBlock.gif][]        sprintf(szError, "Bind Faild: %d", GetLastError());  
![InBlock.gif][]              
![InBlock.gif][]        AfxMessageBox(szError);  
![InBlock.gif][]              
![InBlock.gif][]        return 1;   
![ExpandedSubBlockEnd.gif][]    \}   
![InBlock.gif][]

3) SDK 下的服务器端代码

![None.gif][]         // 子线程函数   
![None.gif][]        unsigned  int  StartServer(LPVOID lParam)  
![ExpandedBlockStart.gif][]![ContractedBlock.gif][]        ... \{  
![InBlock.gif][]          
![InBlock.gif][]       //初始化Winsock, AfxSocketInit() 也是封装了这些语句, 不过 AfxSocketInit() 所做的事比这里多些  
![InBlock.gif][]  
![InBlock.gif][]    WSADATA wsaData;  
![InBlock.gif][]     
![InBlock.gif][]           //Winsock 的版本, 建议用1.1 ,兼容性好  
![InBlock.gif][]    WORD wVersionRequested = MAKEWORD(1, 1);  
![InBlock.gif][]    int nResult = WSAStartup(wVersionRequested, &wsaData);  
![InBlock.gif][]    if (nResult != 0)  
![ExpandedSubBlockStart.gif][]![ContractedSubBlock.gif][]    ...\{  
![InBlock.gif][]  return 1;  
![ExpandedSubBlockEnd.gif][]    \}  
![InBlock.gif][]  
![InBlock.gif][]       //\-----------------------------------------------------   
![InBlock.gif][]  
![InBlock.gif][]           m\_exit = false;  
![InBlock.gif][]  
![InBlock.gif][]    CServerDlg \*aDlg = (CServerDlg \*)lParam;  
![InBlock.gif][]  
![InBlock.gif][]    CString strPort;  
![InBlock.gif][]   
![InBlock.gif][]    aDlg\->GetDlgItemText(IDC\_EDIT\_PORT, strPort);  
![InBlock.gif][]   
![InBlock.gif][]    UINT nPort = atoi(strPort);  
![InBlock.gif][]   
![InBlock.gif][] //socket------------------------------------------------  
![InBlock.gif][]             
![InBlock.gif][]           //接口对象  
![InBlock.gif][]           SOCKET aSocket, serverSocket;  
![InBlock.gif][]  
![InBlock.gif][]           //寻址相关结构  
![InBlock.gif][]    sockaddr\_in serverSockaddr;  
![InBlock.gif][]    memset(&serverSockaddr, 0, sizeof(serverSockaddr));  
![InBlock.gif][]  
![InBlock.gif][]  
![InBlock.gif][]    aSocket = socket(AF\_INET, SOCK\_STREAM, IPPROTO\_TCP);  
![InBlock.gif][]  
![InBlock.gif][]    if (aSocket == INVALID\_SOCKET)  
![ExpandedSubBlockStart.gif][]![ContractedSubBlock.gif][]    ...\{  
![ExpandedSubBlockStart.gif][]![ContractedSubBlock.gif][]  char szError\[256\] = ...\{ 0\};  
![InBlock.gif][]    
![InBlock.gif][]  sprintf(szError, "Create Faild: %d", GetLastError());  
![InBlock.gif][]    
![InBlock.gif][]  AfxMessageBox(szError);  
![InBlock.gif][]    
![InBlock.gif][]  return 1;   
![ExpandedSubBlockEnd.gif][]    \}  
![InBlock.gif][]  
![InBlock.gif][]    //注意，该处非常重要，取值的正确与否决定关闭scoket后端口是否能正常释放  
![InBlock.gif][]    BOOL bOptVal = TRUE;  
![InBlock.gif][]    int bOptLen = sizeof(BOOL);  
![InBlock.gif][]             
![InBlock.gif][]            //设置 socket 选项, SOL\_SOCKET 和 SO\_REUSEADDR 一起使用, 并且后面的参数如上,   
![InBlock.gif][]              关闭scoket后端口便能正常释放  
![InBlock.gif][]     setsockopt(aSocket, SOL\_SOCKET, SO\_REUSEADDR, (char \*)&bOptVal, bOptLen);   
![InBlock.gif][]   
![InBlock.gif][]           //寻址相关结构  
![InBlock.gif][]    sockaddr\_in aSockaddr;  
![InBlock.gif][]    memset(&aSockaddr,0,sizeof(aSockaddr));  
![InBlock.gif][]  
![InBlock.gif][]    aSockaddr.sin\_family = AF\_INET;  
![InBlock.gif][]  
![InBlock.gif][]    aSockaddr.sin\_addr.s\_addr = htonl(INADDR\_ANY);  
![InBlock.gif][]   
![InBlock.gif][]    aSockaddr.sin\_port = htons((u\_short)nPort);  
![InBlock.gif][]   
![InBlock.gif][]           //绑定: 注意参数的类型转换  
![InBlock.gif][]    if(bind(aSocket,(sockaddr \*)&aSockaddr, sizeof(aSockaddr)) == SOCKET\_ERROR)  
![ExpandedSubBlockStart.gif][]![ContractedSubBlock.gif][]    ...\{  
![ExpandedSubBlockStart.gif][]![ContractedSubBlock.gif][]  char szError\[256\] = ...\{ 0\};  
![InBlock.gif][]    
![InBlock.gif][]  sprintf(szError, "Bind Faild: %d", GetLastError());  
![InBlock.gif][]    
![InBlock.gif][]  AfxMessageBox(szError);  
![InBlock.gif][]    
![InBlock.gif][]  return 1;   
![ExpandedSubBlockEnd.gif][]    \}  
![InBlock.gif][]  
![InBlock.gif][]   
![InBlock.gif][]    //监听  
![InBlock.gif][]    if(listen(aSocket, 10) == SOCKET\_ERROR)  
![ExpandedSubBlockStart.gif][]![ContractedSubBlock.gif][]    ...\{   
![ExpandedSubBlockStart.gif][]![ContractedSubBlock.gif][]  char szError\[256\] = ...\{ 0\};  
![InBlock.gif][]    
![InBlock.gif][]  sprintf(szError, "Listen Faild: %d", GetLastError());  
![InBlock.gif][]    
![InBlock.gif][]  AfxMessageBox(szError);  
![InBlock.gif][]    
![InBlock.gif][]  return 1;  
![ExpandedSubBlockEnd.gif][]    \}  
![InBlock.gif][]   
![InBlock.gif][]    CString strText;  
![InBlock.gif][]  
![InBlock.gif][]    aDlg\->GetDlgItemText(IDC\_EDIT\_LOG, strText);  
![InBlock.gif][]  
![InBlock.gif][]    strText \+= "Server Start!  ";  
![InBlock.gif][]  
![InBlock.gif][]    aDlg\->SetDlgItemText(IDC\_EDIT\_LOG, strText);  
![InBlock.gif][]  
![InBlock.gif][]    while(!m\_exit)  
![ExpandedSubBlockStart.gif][]![ContractedSubBlock.gif][]    ...\{  
![InBlock.gif][]  //接收外部连接, 非阻塞  
![InBlock.gif][]  serverSocket = accept(aSocket, (sockaddr \*)&serverSockaddr, 0);  
![InBlock.gif][]     
![InBlock.gif][]  if(serverSocket == INVALID\_SOCKET)  
![ExpandedSubBlockStart.gif][]![ContractedSubBlock.gif][]  ...\{  
![InBlock.gif][]   continue;  
![ExpandedSubBlockEnd.gif][]  \}  
![InBlock.gif][]  else  
![ExpandedSubBlockStart.gif][]![ContractedSubBlock.gif][]  ...\{  
![ExpandedSubBlockStart.gif][]![ContractedSubBlock.gif][]   char szRecvMsg\[256\] = ...\{ 0\};  
![ExpandedSubBlockStart.gif][]![ContractedSubBlock.gif][]   char szOutMsg\[256\] = ...\{ 0\};   
![InBlock.gif][]     
![InBlock.gif][]   //接收客户端内容: 阻塞  
![InBlock.gif][]   recv(serverSocket, szRecvMsg, 256, 0);  
![InBlock.gif][]  
![InBlock.gif][]   sprintf(szOutMsg, "Receive Msg: %s  ", szRecvMsg);  
![InBlock.gif][]     
![InBlock.gif][]   aDlg\->GetDlgItemText(IDC\_EDIT\_LOG, strText);  
![InBlock.gif][]     
![InBlock.gif][]   strText \+= szOutMsg;  
![InBlock.gif][]  
![InBlock.gif][]   aDlg\->SetDlgItemText(IDC\_EDIT\_LOG, strText);  
![InBlock.gif][]  
![InBlock.gif][]                        //发送内容给客户端  
![InBlock.gif][]   send(serverSocket, "Have Receive The Msg", 50, 0);  
![InBlock.gif][]  
![InBlock.gif][]                        //关闭  
![InBlock.gif][]   closesocket(serverSocket);  
![ExpandedSubBlockEnd.gif][]  \}  
![InBlock.gif][]    
![ExpandedSubBlockEnd.gif][]    \}  
![InBlock.gif][]   
![InBlock.gif][]    //关闭  
![InBlock.gif][]    closesocket(aSocket);  
![InBlock.gif][]    closesocket(serverSocket);  
![InBlock.gif][]  
![InBlock.gif][]    aDlg\->GetDlgItemText(IDC\_EDIT\_LOG, strText);  
![InBlock.gif][]   
![InBlock.gif][]    strText \+= "Have Close!";  
![InBlock.gif][]  
![InBlock.gif][]    aDlg\->SetDlgItemText(IDC\_EDIT\_LOG, strText);  
![InBlock.gif][]  
![InBlock.gif][]           //当你使用完Winsock接口后，要调用下面的函数对其占用的资源进行释放  
![InBlock.gif][]    WSACleanup();  
![InBlock.gif][]  
![InBlock.gif][]    return 0;  
![ExpandedBlockEnd.gif][]       \}   
![None.gif][]

3. 总结  
   1) MFC进行编程的确比较简单, 用的代码比较少, 又容易管理。唯一不好的地方在于很多细节上的东西在资料上不容易查出来, 关联性非常紧密, 象 AfxSocketInit() 函数就是,函数的实现里包含着很多不容易理解的类, 并且记录了非常多的环境信息, 比如创建的线程等等, 这样在主线程调用后子线程没有调用执行 CSocket 的操作就会出错。还有就是有些接口的设计非常离奇, 象 CSocket::Create 的接口就是, 实现上还执行了 CSocket::Bind , 非常不容易被发现。并且MSDN上对 CSocket::Bind 的说明又明显的提示需要显示执行 CSocket::Bind 操作。

2) SDK 编程能理解函数的调用顺序和代码的结构就比较容易,省去了MFC下封装了不知道什么东西的部分,使得代码的流程容易控制。但是从上面的例子来看非常明显的并且不是那么容易理解。不仅仅有很多奇怪的结构(微软的命名一直如此, 无所云云), 并且函数相关太过于紧密, 初学者想一下子熟悉使用并不容易, 对开发者来说代码管理起来非常麻烦。

[http_download.csdn.net_source_379597]: http://download.csdn.net/source/379597
[None.gif]: /images/20220406/a873bf88906c47a3b2f8efb094652c9f.png
[ExpandedBlockStart.gif]: http://images.csdn.net/syntaxhighlighting/OutliningIndicators/ExpandedBlockStart.gif
[ContractedBlock.gif]: /images/20220406/170317d1e2c0424aa56b16a5f2e28cfa.png
[ExpandedSubBlockStart.gif]: http://images.csdn.net/syntaxhighlighting/OutliningIndicators/ExpandedSubBlockStart.gif
[ContractedSubBlock.gif]: /images/20220406/1932378269b249d4b2c8ab9edb9af920.png
[InBlock.gif]: /images/20220406/91fb31b228be4e0e91bb116b1b52fc50.png
[ExpandedBlockEnd.gif]: /images/20220406/e4e23c07f39c493ba1e3a46a62b4be59.png
[ExpandedSubBlockEnd.gif]: /images/20220406/feb3b68e239a43eea7a1657a8e6d0c45.png