CAsyncSocket

刺骨的言语ヽ痛彻心扉 2022-04-06 08:37 228阅读 0赞

**[http://www.cnblogs.com/wqj1212/archive/2009/03/18/1415786.html][http_www.cnblogs.com_wqj1212_archive_2009_03_18_1415786.html]**

**一、        一些网络的基本概念**

1.       **同步**：指的是发送方不等接收方响应，便接着发下个数据包的通信方式；

2.       **异步：**指发送方发出数据后，等收到接收方发回的响应，才发下一个数据包的通信方式

3.       **阻塞：**指调用某函数时，直到该函数完成操作，才返回；否则一直阻塞在该调用上

4.       **非阻塞：**指调用某操作时，不管操作是否成功都立即返回，而不会挂在该操作上

CAsyncSocket属于异步非阻塞类；

CSocket是MFC在CAsyncSocket基础上派生的一个同步阻塞Socket的封装类

**二、       CAsyncSocket的使用(伪码)**

**服务器端：**

![None.gif][] m\_pListSocket    =     new     CAsyncSocket();  
![None.gif][]m\_pListSocket \->  Create( 端口，地址);                    //  创建   
![None.gif][]   
![None.gif][]m\_pListSocket \-> Listen();                             //  开始监听   
![None.gif][]   
![None.gif][]  
![None.gif][]  
![None.gif][]m\_pListSocket::OnAccept( )                        //  有客户端请求连接时响应   
![None.gif][]   
![ExpandedBlockStart.gif][]![ContractedBlock.gif][] \{  
![InBlock.gif][]  
![InBlock.gif][]m\_pSocket   =   new    CAsyncSocket();  
![InBlock.gif][]m\_pListSocket\-> Accept(m\_pSocket);       // 建立通信,成功后m\_pSocket就用于发送和接受.  
![InBlock.gif][]  
![InBlock.gif][]  
![InBlock.gif][]  
![InBlock.gif][]// m\_pSocket 就相当于连接的那个客户端了  
![InBlock.gif][]  
![ExpandedBlockEnd.gif][]\}   
![None.gif][]  
![None.gif][]  
![None.gif][]  
![None.gif][]m\_pSocket::OnRecive(  int  nErrorCode)  
![None.gif][]  
![ExpandedBlockStart.gif][]![ContractedBlock.gif][] \{  
![InBlock.gif][]  
![InBlock.gif][]         if( nErrorCode == 0)  
![InBlock.gif][]  
![ExpandedSubBlockStart.gif][]![ContractedSubBlock.gif][]\{  
![InBlock.gif][]  
![InBlock.gif][]          Recevie();                            // 接受客户端发送来的信息  
![InBlock.gif][]  
![ExpandedSubBlockEnd.gif][]\}  
![InBlock.gif][]  
![InBlock.gif][]          CAsyncSocket::OnRecive( nErrorCode)  
![InBlock.gif][]  
![ExpandedBlockEnd.gif][]\}   
![None.gif][]  
![None.gif][]  
![None.gif][]  
![None.gif][]m\_pSocket::OnSend()  
![None.gif][]  
![ExpandedBlockStart.gif][]![ContractedBlock.gif][] \{  
![InBlock.gif][]  
![InBlock.gif][]          Send();                        // 发送信息，该事件触发条件见下节  
![InBlock.gif][]  
![ExpandedBlockEnd.gif][]\}   
![None.gif][]  
![None.gif][]  
![None.gif][]  
![None.gif][]m\_pListSocket \-> Close();  
![None.gif][]  
![None.gif][]  
![None.gif][]  
![None.gif][]delete m\_pListSocket;  
![None.gif][]  
![None.gif][]delete m\_pSocket;  
![None.gif][]  
![None.gif][]

**客户端：**

![None.gif][] m\_pClientSocket    =     new     CAsyncSocket();  
![None.gif][]m\_pClientSocket  \->  Create( 端口，地址);                       //  创建   
![None.gif][]   
![None.gif][]m\_pClientSocket \-> Connect();                                          //  连接服务器，最终将触发服务器的OnAccept();   
![None.gif][]   
![None.gif][]m\_ pClientSocket::OnConnect()                                             //  当连接上服务器   
![None.gif][]   
![ExpandedBlockStart.gif][]![ContractedBlock.gif][] \{  
![InBlock.gif][]  
![InBlock.gif][]           
![InBlock.gif][]  
![ExpandedBlockEnd.gif][]\}   
![None.gif][]  
![None.gif][]  
![None.gif][]  
![None.gif][]m\_ pClientSocket::OnRecive(  int  nErrorCode)  
![None.gif][]  
![ExpandedBlockStart.gif][]![ContractedBlock.gif][] \{  
![InBlock.gif][]  
![InBlock.gif][]         if( nErrorCode == 0)  
![InBlock.gif][]  
![ExpandedSubBlockStart.gif][]![ContractedSubBlock.gif][]\{  
![InBlock.gif][]  
![InBlock.gif][]          Recevie();                            // 接受客户端发送来的信息  
![InBlock.gif][]  
![ExpandedSubBlockEnd.gif][]\}  
![InBlock.gif][]  
![InBlock.gif][]          CAsyncSocket::OnRecive( nErrorCode)  
![InBlock.gif][]  
![ExpandedBlockEnd.gif][]\}   
![None.gif][]  
![None.gif][]  
![None.gif][]  
![None.gif][]m\_pClientSocket::OnSend(  int  nErrorCode)  
![None.gif][]  
![ExpandedBlockStart.gif][]![ContractedBlock.gif][] \{  
![InBlock.gif][]  
![InBlock.gif][]          Send();                                  // 发送信息  
![InBlock.gif][]  
![ExpandedBlockEnd.gif][]\}   
![None.gif][]  
![None.gif][]  
![None.gif][]  
![None.gif][]m\_pClientSocket \-> Close();  
![None.gif][]

**三、       CAsyncSocket异步机制**

由于CAsyncSocket采用的是异步非阻塞机制，所以你随时可以发包，也随时可能收到包。

发送、接收函数都是异步非阻塞的，顷刻就能完成，所以收发交错进行着。也正因为如此，仅调用它们并不能保障发送或接收的完成。

例如发送函数Send，调用它可能有3种结果：**错误、部分完成、全部完成**。其中错误又分两种情况：一种是由各种网络问题导致的失败，你需要马上决定是放弃本次操作，还是启用某种对策；另一种是“忙”，你实际上不用马上理睬。你需要调用GetLastError来判断是哪种情况，GetLastError返回WSAEWOULDBLOCK，代表“忙”，为什么当你Send得  
到WSAEWOULDBLOCK却不用理睬呢？因为CAsyncSocket会记得你的SendWSAEWOULDBLOCK了，待发送的数据会写入CAsyncSocket内部的发送缓冲区，并会在不忙的时候自动调用OnSend，发送内部缓冲区里的数据。同样，如果Send只完成了一部分，你也不需要理睬，尚未发送的数据同样会写入CAsyncSocket内部的发送缓冲区，并在不“忙”的时候自动调用OnSend完成发送。

与OnSend协助Send完成工作一样，OnRecieve、OnConnect、OnAccept也会分别协助Recieve、Connect、Accept完成工作。这一切都通过消息机制完成。

在你使用CAsyncSocket之前，必须调用AfxSocketInit初始化WinSock环境，而AfxSocketInit会创建一个隐藏的CSocketWnd对象，由于这个对象由Cwnd派生，因此它能够接收Windows消息。一方面它会接受各个CAsyncSocket的状态报告，另一方面它能捕捉系统发出的各种SOCKET事件。所以它能够成为高层CAsyncSocket对象与WinSock底层之间的桥梁：例如某CAsyncSocket在Send时WSAEWOULDBLOCK了，它就会发送一条消息给CSocketWnd作为报告，CSocketWnd会维护一个报告登记表，当它收到底层WinSock发出的空闲消息时，就会检索报告登记表，然后直接调用报告者的OnSend函数。所以前文所说的CAsyncSocket会自动调用OnXxx，实际上是不对的，真正的调用者是CSocketWnd——它是一个CWnd对象，运行在独立的线程中。

**四、       网络事件处理流程**

在理解了上面的机制后， 让我们了解下CAsyncSocket的通信流程；

![liucheng.JPG][]

OnSend,除了在对方发送消息来的时候响应外，还会在缓冲区有空闲的时候自动触发；

如果每次发送的数据比较简单，不会造成WASEWOULDBLOCK(阻塞)，不会触发OnSend;

因此小数据直接Send就行了，大数据就需要在OnSend判断数据发送是否正确；

如何手动触发OnSend()呢，采用AsyncSelect( FD\_WRITE),通知CsocketWnd窗口处理写

数据操作； 同样AsyncSelect(FD\_READ)将通知CsocketWnd窗口当有消息传来的时候触发OnRecevie();

**五、       消息为何只接收一次**

编程中遇到这个问题，发现很多人都遇到过这个问题。

症状如下：Socket连接后只能发送一次消息，发送第二次消息的时候，另一方就接收不到；

原因是：没有让Socket改变响应事件的发式

解决方法：在OnReceive()中，Receive()后调用AsyncSelect(FD\_READ);

![None.gif][] Void CMyAsyncSocket::OnReceive( int  nErrorCode)  
![None.gif][]  
![ExpandedBlockStart.gif][]![ContractedBlock.gif][] \{  
![InBlock.gif][]  
![InBlock.gif][]         Receive();  
![InBlock.gif][]  
![InBlock.gif][]         AsyncSelect(FD\_READ);  
![InBlock.gif][]  
![ExpandedBlockEnd.gif][]\}   
![None.gif][]

或则  调用父类的OnReceive()

![None.gif][] Void CMyAsyncSocket::OnReceive(  int  nErrorCode)  
![None.gif][]  
![ExpandedBlockStart.gif][]![ContractedBlock.gif][] \{  
![InBlock.gif][]  
![InBlock.gif][]         Receive();  
![InBlock.gif][]  
![InBlock.gif][]   
![InBlock.gif][]  
![InBlock.gif][]         CAsyncSocket::OnReceive( nErrorCode);  
![InBlock.gif][]  
![ExpandedBlockEnd.gif][]\}   
![None.gif][]  
![None.gif][]

**六、   为何服务器Socket不监听**

在创建服务器Socket的时候，只有采用SOCK\_STREAM(字符流),Listen才能成功；

采用SOCK\_DGRAM(数据报文)创建的Socket是面向无连接发式(UDP)，所以Listen不成功(有待验证)

[http_www.cnblogs.com_wqj1212_archive_2009_03_18_1415786.html]: http://www.cnblogs.com/wqj1212/archive/2009/03/18/1415786.html
[None.gif]: /images/20220406/7b31a3a0ff804f35ae8efa5d2f544314.png
[ExpandedBlockStart.gif]: http://images.csdn.net/syntaxhighlighting/OutliningIndicators/ExpandedBlockStart.gif
[ContractedBlock.gif]: /images/20220406/e33772cfc234438096cd51f79abcae21.png
[InBlock.gif]: /images/20220406/3d565f04dc0343168c95133410f6bc03.png
[ExpandedBlockEnd.gif]: /images/20220406/2281aa66f7ef46bd968a23b3619e34fb.png
[ExpandedSubBlockStart.gif]: http://images.csdn.net/syntaxhighlighting/OutliningIndicators/ExpandedSubBlockStart.gif
[ContractedSubBlock.gif]: /images/20220406/fa0d449495b84628af31734a4c13c3e3.png
[ExpandedSubBlockEnd.gif]: /images/20220406/d42a4a9780f24bfea8a99bc20d2b8281.png
[liucheng.JPG]: /images/20220406/5293de47b5e449e5be2c18b6632f7d12.png