基于WinSocket的网络通信实现

发表于:2007-07-14来源:作者:点击数: 标签:
陈广奕 VC++中,MFC编程支持两种利用 Windows Sockets进行 网络 通信的编程模式,这两种模式即为用CAsyncSocket类和派生于CAsyncSocket 的CSocket类。 * CAsyncSocket类封装了Windows Sockets API函数,提供了较低层的与Windows Sockets对话接口,一般适
陈广奕

  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::OnAclearcase/" target="_blank" >ccept(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; 

原文转自:http://www.ltesting.net