?? mfc教程_ 14socket類的設(shè)計和實現(xiàn).htm

?? 一本優(yōu)秀的vc程序?qū)W習(xí)教程,希望能夠幫助大家學(xué)習(xí)
?? HTM
?? 第 1 頁 / 共 3 頁
字號:
上一頁 1 23
    <P align=justify>//阻塞操作。但不能同時進(jìn)行兩個阻塞操作。</P>
    <P align=justify>if (m_pbBlocking != NULL)</P>
    <P align=justify>{</P>
    <P align=justify>WSASetLastError(WSAEINPROGRESS);</P>
    <P align=justify>return FALSE;</P>
    <P align=justify>}</P>
    <P align=justify>//完成數(shù)據(jù)讀取</P>
    <P align=justify>int nResult;</P>
    <P align=justify>while ((nResult = CAsyncSocket::Receive(lpBuf, nBufLen, 
    nFlags)) </P>
    <P align=justify>== SOCKET_ERROR)</P>
    <P align=justify>{</P>
    <P align=justify>if (GetLastError() == WSAEWOULDBLOCK)</P>
    <P align=justify>{</P>
    <P align=justify>//進(jìn)入消息循環(huán)，等待網(wǎng)絡(luò)事件FD_READ</P>
    <P align=justify>if (!PumpMessages(FD_READ))</P>
    <P align=justify>return SOCKET_ERROR;</P>
    <P align=justify>}</P>
    <P align=justify>else</P>
    <P align=justify>return SOCKET_ERROR;</P>
    <P align=justify>}</P>
    <P align=justify>return nResult;</P>
    <P align=justify>}</P>
    <P align=justify>其中：</P>
    <P 
    align=justify>參數(shù)1指定一個緩沖區(qū)保存讀取的數(shù)據(jù)；參數(shù)2指定緩沖區(qū)的大小；參數(shù)3取值MSG_PEEK（數(shù)據(jù)拷貝到緩沖區(qū)，但不從輸入隊列移走），或者M(jìn)SG_OOB（處理帶外數(shù)據(jù)），或者M(jìn)SG_PEEK|MSG_OOB。</P>
    <P 
    align=justify>Receive函數(shù)首先判斷當(dāng)前CSocket對象是否正在處理一個阻塞操作，如果是，則返回錯誤WSAEINPROGRESS；否則，開始數(shù)據(jù)讀取的處理。</P>
    <P 
    align=justify>讀取數(shù)據(jù)時，如果基類CAsyncSocket的Receive讀取到了數(shù)據(jù)，則返回；否則，如果返回一個錯誤，而且錯誤號是WSAEWOULDBLOCK，則表示操作阻塞，于是調(diào)用PumpMessage進(jìn)入消息循環(huán)等待數(shù)據(jù)到達(dá)（網(wǎng)絡(luò)事件FD_READ發(fā)生）。數(shù)據(jù)到達(dá)之后退出消息循環(huán)，再次調(diào)用CAsyncSocket的Receive讀取數(shù)據(jù)，直到?jīng)]有數(shù)據(jù)可讀為止。</P>
    <P align=justify>PumpMessages是CSocket的成員函數(shù)，它完成以下工作：</P>
    <P align=justify>（1）設(shè)置m_pbBlocking，表示進(jìn)入阻塞操作。</P>
    <P 
    align=justify>（2）進(jìn)行消息循環(huán)，如果有以下事件發(fā)生則退出消息循環(huán)：收到指定定時器的定時事件消息WM_TIMER，退出循環(huán)，返回TRUE；收到發(fā)送給本socket的消息WM_SOCKET_NOTIFY，網(wǎng)絡(luò)事件FD_CLOSE或者等待的網(wǎng)絡(luò)事件發(fā)生，退出循環(huán)，返回TRUE；發(fā)送錯誤或者收到WM_QUIT消息，退出循環(huán)，返回FALSE；</P>
    <P 
    align=justify>（3）在消息循環(huán)中，把WM_SOCKET_DEAD消息和發(fā)送給其他socket的通知消息WM_SOCKET_NOFITY放進(jìn)模塊線程狀態(tài)的通知消息列表m_listSocketNotifications，在阻塞操作完成之后處理；對其他消息，則把它們送給目的窗口的窗口過程處理。</P>
    <P align=justify></P>
    <LI><A name=_Toc452641023></A><A name=_Toc457299163></A><B>CSocketFile</B> 
    <P></P></LI></OL></OL>
<P 
align=justify>MFC還提供了一個網(wǎng)絡(luò)編程模式，可以充分利用CSocket的特性。該模式的基礎(chǔ)是CSocketFile類。使用方法如下：</P>
<P align=justify>首先，構(gòu)造一個CSocket對象；調(diào)用Create函數(shù)創(chuàng)建一個socket對象（SOCK_STREAM類型）。</P>
<P 
align=justify>接著，如果是客戶程序，調(diào)用Connect連接到遠(yuǎn)地主機；如果是服務(wù)器程序，先調(diào)用Listen監(jiān)聽socket端口，收到連接請求后調(diào)用Accept接收請求。</P>
<P 
align=justify>然后，創(chuàng)建一個和CSocket對象關(guān)聯(lián)的CSocketFile對象，創(chuàng)建一個和CSocketFile對象關(guān)聯(lián)的CArchive對象，指定CArchive對象是用于讀或者寫。如果既要讀又要寫，則創(chuàng)建兩個CArchive對象。</P>
<P align=justify>創(chuàng)建工作完成之后，使用CArchive對象在客戶和服務(wù)器之間傳送數(shù)據(jù)</P>
<P align=justify>使用完畢，銷毀CArchive對象、CSocketFile對象、CSocket對象。</P>
<P 
align=justify>從前面的章節(jié)可以知道，CArchive可以以一個CFile對象為基礎(chǔ)，通過&lt;&lt;和&gt;&gt;操作符完成對文件的二進(jìn)制流的操作。所以可以從CFile派生一個類，實現(xiàn)CFile的操作界面（Read和Write）。由于CSocket提供了阻塞操作，所以完全可以像讀寫文件一樣讀寫socket數(shù)據(jù)。</P>
<P align=justify>下面，分析CSocketFile的設(shè)計和實現(xiàn)。</P>
<OL>
  <P align=justify>
  <LI>CSocketFile的構(gòu)造函數(shù)和析構(gòu)函數(shù)的實現(xiàn) 
  <P></P></LI></OL>
<UL>
  <P align=justify>
  <LI>構(gòu)造函數(shù)的實現(xiàn) 
  <P></P></LI></UL>
<P align=justify>CSocketFile::CSocketFile(CSocket* pSocket, BOOL 
bArchiveCompatible)</P>
<P align=justify>{</P>
<P align=justify>m_pSocket = pSocket;</P>
<P align=justify>m_bArchiveCompatible = bArchiveCompatible;</P>
<P align=justify></P>
<P align=justify>#ifdef _DEBUG</P>
<P align=justify>ASSERT(m_pSocket != NULL);</P>
<P align=justify>ASSERT(m_pSocket-&gt;m_hSocket != INVALID_SOCKET);</P>
<P align=justify></P>
<P align=justify>int nType = 0;</P>
<P align=justify>int nTypeLen = sizeof(int);</P>
<P 
align=justify>ASSERT(m_pSocket-&gt;GetSockOpt(SO_TYPE,&amp;nType,&amp;nTypeLen));</P>
<P align=justify>ASSERT(nType == SOCK_STREAM);</P>
<P align=justify>#endif // _DEBUG</P>
<P align=justify>}</P>
<P align=justify>其中：</P>
<P align=justify>構(gòu)造函數(shù)的參數(shù)1指向關(guān)聯(lián)的CSocket對象，被保存在成員變量m_pSocket中；</P>
<P 
align=justify>參數(shù)2指定該對象是否和一個CArchive對象關(guān)聯(lián)（不關(guān)聯(lián)則獨立使用），被保存在成員變量bArchiveCompatible中。</P>
<P align=justify>Degug部分用于檢測m_pSocket是否是SOCK_STREAM類型。</P>
<UL>
  <P align=justify>
  <LI>析構(gòu)函數(shù)的實現(xiàn) 
  <P></P></LI></UL>
<P align=justify>CSocketFile::~CSocketFile()</P>
<P align=justify>{</P>
<P align=justify>}</P>
<P align=justify>（2）CSocketFile的讀寫的實現(xiàn)</P>
<P align=justify>分析CSocketFile如何用文件的讀寫實現(xiàn)網(wǎng)絡(luò)I/O。</P>
<UL>
  <P align=justify>
  <LI>文件讀的實現(xiàn) 
  <P></P></LI></UL>
<P align=justify>UINT CSocketFile::Read(void* lpBuf, UINT nCount)</P>
<P align=justify>{</P>
<P align=justify>ASSERT(m_pSocket != NULL);</P>
<P align=justify></P>
<P align=justify>int nRead;</P>
<P align=justify></P>
<P align=justify>//CSocketFile對象獨立使用</P>
<P align=justify>if (!m_bArchiveCompatible)</P>
<P align=justify>{</P>
<DIR>
<P align=justify>int nLeft = nCount;</P>
<P align=justify>PBYTE pBuf = (PBYTE)lpBuf;</P>
<P align=justify></P>
<P align=justify>//讀完nCount個字節(jié)的數(shù)據(jù)</P>
<P align=justify>while(nLeft &gt; 0)</P>
<P align=justify>{</P>
<DIR>
<P align=justify>//CSocket的Receive，阻塞操作，讀取到數(shù)據(jù)才繼續(xù)</P>
<P align=justify>nRead = m_pSocket-&gt;Receive(pBuf, nLeft);</P>
<P align=justify>if (nRead == SOCKET_ERROR)</P>
<P align=justify>{</P>
<DIR>
<DIR>
<P align=justify>int nError = m_pSocket-&gt;GetLastError();</P>
<P align=justify>AfxThrowFileException(CFileException::generic, nError);</P>
<P align=justify>ASSERT(FALSE);</P></DIR></DIR>
<P align=justify>}</P>
<P align=justify>else if (nRead == 0)</P>
<P align=justify>{</P>
<DIR>
<DIR>
<P align=justify>return nCount - nLeft;</P></DIR></DIR>
<P align=justify>}</P>
<P align=justify></P>
<P align=justify>nLeft -= nRead;</P>
<P align=justify>pBuf += nRead;</P></DIR>
<P align=justify>}</P>
<P align=justify>return nCount - nLeft;</P></DIR>
<P align=justify>}</P>
<P align=justify></P>
<P align=justify>//和一個CArchive對象關(guān)聯(lián)使用</P>
<P align=justify>//讀取數(shù)據(jù)，能讀多少是多少</P>
<P align=justify>nRead = m_pSocket-&gt;Receive(lpBuf, nCount, 0);</P>
<P align=justify>if (nRead == SOCKET_ERROR)</P>
<P align=justify>{</P>
<DIR>
<P align=justify>int nError = m_pSocket-&gt;GetLastError();</P>
<P align=justify>AfxThrowFileException(CFileException::generic, nError);</P>
<P align=justify>ASSERT(FALSE);</P></DIR>
<P align=justify>}</P>
<P align=justify>return nRead;</P>
<P align=justify>}</P>
<UL>
  <P align=justify>
  <LI>文件寫的實現(xiàn) 
  <P></P></LI></UL>
<P align=justify>void CSocketFile::Write(const void* lpBuf, UINT nCount)</P>
<P align=justify>{</P>
<P align=justify>ASSERT (m_pSocket!=NULL);</P>
<P align=justify></P>
<P align=justify>//CSocket的函數(shù)Send，阻塞操作，發(fā)送完畢才繼續(xù)</P>
<P align=justify>int nWritten = m_pSocket-&gt;Send(lpBuf, nCount);</P>
<P align=justify>if (nWritten == SOCKET_ERROR)</P>
<P align=justify>{</P>
<DIR>
<P align=justify>int nError = m_pSocket-&gt;GetLastError();</P>
<P align=justify>AfxThrowFileException(CFileException::generic, 
nError);</P></DIR>
<P align=justify>}</P>
<P align=justify>}</P>
<P 
align=justify>從CSockefFile的讀寫實現(xiàn)可以看出，CSocketFile如果獨立使用，在Read操作時可能出現(xiàn)無限等待，因為數(shù)據(jù)是分多個消息多次送達(dá)的，沒有讀取到指定長度的數(shù)據(jù)并不表示數(shù)據(jù)讀取完畢。但是和CArchive配合使用，則僅僅讀取到數(shù)據(jù)就返回。至于數(shù)據(jù)是否讀取完畢，可以使用CArchive的IsBufferEmpty函數(shù)來判斷。</P>
<P align=justify>其他CFile界面，CSocketFile沒有實現(xiàn)。</P>
<P 
align=justify>從CScocketFile的設(shè)計和實現(xiàn)來看，CSocketFile是使用CSocket的一個很好的例子，也是使用CFile的一個例子。</P>
<HR>

<TABLE cellSpacing=0 cellPadding=0 width="100%" align=center border=0>
  <TBODY>
  <TR>
    <TD align=middle><A href="http://www.vczx.com/tutorial/mfc/mfc13.php" 
      target=_self>上一章</A>　<A href="http://www.vczx.com/tutorial/mfc/mfc.php" 
      target=_self>回目錄</A></TD></TR></TBODY></TABLE>
<P>&nbsp;</P>
<P align=justify>　</P></BODY></HTML>
上一頁 1 23
?? 文件大小 499 K
?? 上傳用戶 car_bike2000000
?? 所屬分類 VC書籍
??? 相關(guān)標(biāo)簽

#程序 #教程 #家
?? 快捷鍵說明

復(fù)制代碼 Ctrl + C
搜索代碼 Ctrl + F
全屏模式 F11
切換主題 Ctrl + Shift + D
顯示快捷鍵 ?
增大字號 Ctrl + =
減小字號 Ctrl + -
亚洲欧美第一页_禁久久精品乱码_粉嫩av一区二区三区免费野_久草精品视频

?? mfc教程_ 14socket類的設(shè)計和實現(xiàn).htm

?? 快捷鍵說明
