VC＋＋中，MFC编程支持两种利用Windows Sockets进行网络通信的编程模式，这两种模式即为用CAsyncSocket类和派生于CAsyncSocket 的CSocket类。 ＊ CAsyncSocket类封装了Windows Sockets API函数，提供了较低层的与Windows Sockets对话接口，一般适合于有相当水平的网络编程基础者使用，可方便地进行底层的网络事件通知及信息回叫控制等操作。 ＊ CSocket派生于CAsyncSocket，它继承了父类中一些常用易懂得的Windows Sockets API函数，并对CAsyncSocket中底层的较难控制的一些API函数或成员函数进行了处理，它通过MFC CArchive 对象进行信息的接发操作，使得网络传输如同使用MFC的文档连载协议(Serialization protocol)，简捷易用。同时它支持模块化的后台信息处理，解决了CAsyncSocket中较难克服的多线程处理。 Socket的建立与使用操作 作为服务器，需要有一专用于接听的Socket，以便于随时接收从客户发送来的信息，CSocket类的Listen本身支持多线程，故而不必为其开辟新的线程。建立Windows Sockets的操作步骤见表1。服务器Socket的建立与使用 ＊ 在服务器应用程序中声名Socket全局变量，并使其处于听等状态以等待客户端与其建立连接： CListeningSocket m—pSocket； m—pSocket = new CListeningSocket(this);if (m—pSocket－〉Create(Dialog.m—nPort＋700)){ if (m—pSocket－〉Listen())return TRUE;} ＊ 当接到客户端的主动连接时或接到数据时，调用文档类接收新客户的处理函数： void CListeningSocket::OnAccept(int nErrorCode) { CSocket::OnAccept(nErrorCode); m—pDoc－〉ProcessPendingAccept(); //调用文档类成员函数，以生成新的对话线程 } ＊ 服务器Socket的网上数据发送与接收操作： void CClientSocket::SendMsg(CMsg pMsg) { if (m—pArchiveOut != NULL){ pMsg－〉Serialize(m—pArchiveOut); //调用按协议自定义信息类(CMsg)的函数m—pArchiveOut－〉Flush(); //Serialize进行网上信息发送操作} } void CClientSocket::ReceiveMsg(CMsg pMsg) { pMsg－〉Serialize(m—pArchiveIn); } //调用按协议自定义信息类(CMsg)的函数 //Serialize进行网上信息接收操作 客户端建立连接与通信实现 ＊ 新客户与服务器端建立连接： BOOL CChatDoc::ConnectSocket(LPCTSTR lpszHandle, LPCTSTR lpszAddress, UINT nPort) { m—strHandle = lpszHandle;m—pSocket = new CChatSocket(this);if (!m—pSocket－〉Create()){...} // 创建新Socket失败处理 while (!m—pSocket－〉Connect(lpszAddress, nPort ＋ 700)) {...} //与服务器建立连接失败后的处理m—pFile = new CSocketFile(m—pSocket);m—pArchiveIn = new CArchive(m—pFile,CArchive::load);m—pArchiveOut = new CArchive(m—pFile,CArchive::store);// 建立通信流对象return TRUE; } ＊ 客户端从流中读入网上信息： void CChatDoc::ReceiveMsg() { CMsg msg;TRY { msg.Serialize(m—pArchiveIn); //调用按协议自定义信息类(CMsg)的函数while(!msg.m—msgList.IsEmpty()) //Serialize进行网上信息接收操作{...CATCH(CFileException, e) {... } END—CATCH // 出错处理if (msg.m—bClose){...} // 关闭连接的善后处理 } ＊ 客户端通过流进行网上发送信息： void CChatDoc::SendMsg(CString＆ strText,int index,int i) { if (m—pArchiveOut != NULL){ CMsg msg; msg=AssembleMsg(index,i); // 装配信息TRY { msg－〉Serialize(m—pArchiveOut); //调用按协议自定义信息类(CMsg)的函数m—pArchiveOut－〉Flush(); // Serialize进行网上信息发送操作}CATCH(CFileException, e){ ...... } // 出错处理END—CATCH} } 表1
| | 服务器端 | 注释 | 客户端 | | 1 | csocket socksrvr; | 构造一个socket对象 | csocket sockclient; | | 2 | socksrvr.create(nport); | 创建socket | sockclient.create(nport); | | 3 | socksrvr.listen(); | 听等连接 | 与服务器建立连接 | sockclient.connect(straddr,nport); | | 4 | csocket sockrecv;socksrvr.accept(sockrecv); | 构造新的socket对象用以接收客户端的连接 | | | 5 | csocketfile file(&sockrecv); | 构造一文件对象 | csocketfile file(&sockrecv); | | 6 | carchive arin(&file,carchive::load);carchive arout(&file,carchive::store); | 构造流对象 | carchive arin(&file,carchive::load);carchive arout(&file,carchive::store); | | 7 | arin〉〉dwvalue;arout〈〈dwvalue; | 用流进行数据的传输 | arin〉〉dwvalue;arout〈〈dwvalue; |
|
