(1) h檔案中宣告網路事件響應函式

afx_msg void OnNetEvent(WPARAM wParam, LPARAM lParam); 

(2)cpp檔案中把NETWORK_EVENT事件對映到OnNetEvent()函式

BEGIN_MESSAGE_MAP(CInstrumentStatusView, CFormView) ON_MESSAGE(NETWORK_EVENT,OnNetEvent) END_MESSAGE_MAP() 

(3)OnNetEvent()函式體, 對FD_CONNECT, FD_CLOSE, FD_READ事件進行響應處理

void CInstrumentStatusView::OnNetEvent(WPARAM wParam, LPARAM lParam) { int iEvent = WSAGETSELECTEVENT(lParam); int error = WSAGETSELECTERROR(lParam); //if error!=0, it means failure SOCKET CurSock= (SOCKET)wParam; if(error) { AfxMessageBox("OnNetEvent()接收到錯誤訊息"); closesocket(wParam); return; } switch(iEvent){ case FD_CONNECT: OnSockConnect(error); //void CInstrumentStatusView::OnSockConnect(int error); break; case FD_CLOSE: CloseCurrSockHandle();//void CInstrumentStatusView::CloseCurrSockHandle(); break; case FD_READ: OnSockReceive(); //recv buffer and copy to m_pCurCommand->m_CommandBuffer break; } }

(4)建立套接字, 並使用WSAAsyncSelect()為套接字m_sockClient註冊事件

if(WSAAsyncSelect(m_sockClient,m_hWnd,NETWORK_EVENT,FD_CLOSE | FD_READ | FD_CONNECT) == SOCKET_ERROR) { closesocket(m_sockClient); //MessageBox("CComWnd註冊網路非同步事件失敗!"); //WSACleanup(); return 0; } 

(5)OnSockReceive()函式體, 收到FD_READ訊息後, 執行此函式

void CInstrumentStatusView::OnSockReceive(){ int ReadResults=0; BOOL Ready=FALSE; char tempChar; WSAAsyncSelect(m_sockClient,m_hWnd,NETWORK_EVENT,0); //關閉套接字事件m_sockClient上的事件 //迴圈讀,每次讀一個位元組 //while(total!=m_pCurCommand->m_nExpectedBytes) while(!Ready) //當讀到結束符時,Ready=TRUE { ReadResults=recv(m_sockClient,&tempChar,1,0); if(ReadResults == SOCKET_ERROR)//recv返回異常處理 { if (WSAEWOULDBLOCK == WSAGetLastError()) { continue; //如果異常是"阻塞異常", 繼續下次迴圈 } else //非WSAEWOULDBLOCK 異常的處理,可能是網路斷開等 { m_bConnected=FALSE; break; } } else if(ReadResults==0) { AfxMessageBox(_T("對端關閉了連線")); } else if(ReadResults==1) { if(m_pCurCommand->AddToReceiveBuffer(tempChar)) Ready=TRUE; //AddToReceiveBuffer中判斷tempChar是否是結束字元,如果是,返回TRUE, while迴圈條件Ready置為TRUE,退出迴圈 } } WSAAsyncSelect(m_sockClient,m_hWnd,NETWORK_EVENT,FD_CLOSE | FD_READ | FD_CONNECT);//資料接收完成,恢復套接字m_sockClient的網路事件 }