随着计算机网络化的深入,计算机网络编程在程序设计的过程中变得日益重要。由于 C++语言对底层操作的优越性,许多文章都曾经介绍过用 VC++进行 Socket 编程的方法。但由于都是直接利用动态连接库 wsock32.dll进行操作,实现比较繁琐。其实,VC++的 MFC 类库中提供了 CAsyncSocket 这样一个套接字类,用他来实现 Socket 编程,是非常方便的。
---- 本文将用一个 Echo 例程来介绍 CAsyncSocket 类的用法。
----
一. 客户端 ---- 1. 创建一个 Dialog Based 项目:CSockClient。
---- 2. 设计对话框
---- 去掉 Ok 和 Cancle 两个按钮,增加 ID_Connect(连接)、ID_Send(发送)、ID_Exit(关闭)按钮,增加 ListBox 控件 IDC_LISTMSG 和 Edit 控件 IDC_EDITMSG,并按下表在 ClassWizard 中为 CCSockClientDlg 类添加变量。
Control ID
Type Member
IDC_EDITMSG
CEdit m_MSGIDC_LISTMSG
ClistBox
m_MSGS
---- 3. CAsyncSocket 类用 DoCallBack 函数处理 MFC 消息,当一个网络事件发生时,DoCallBack 函数按网络事件类型:FD_READ、FD_WRITE、FD_ACCEPT、FD_CONNECT 分别调用 OnReceive、OnSend、OnAccept、OnConnect 函数。由于 MFC 把这些事件处理函数定义为虚函数,所以要生成一个新的 C++类,以重载这些函数,做法如下:
---- 以 Public 方式继承 CAsyncSocket 类,生成新类 MySock;
---- 为 MySock 类添加虚函数 OnReceive、OnConnect、OnSend
---- 4. 在 MySock.ccp 中添加以下代码 #include "CSockClient.h"#include "CSockClientDlg.h"
---- 5. 在 MySock.h 中添加以下代码 public: BOOL m_bConnected;
//是否连接 UINT m_nLength;
//消息长度 char m_szBuffer[4096];
//消息缓冲区
---- 6. 在 MySock.ccp 中重载各函数 MySock::MySock(){ m_nLength=0;
memset(m_szBuffer,0,sizeof(m_szBuffer));
m_bConnected=FALSE;}MySock::~MySock(){
//关闭套接字 if(m_hSocket!=INVALID_SOCKET)
Close();}
void MySock::OnReceive(int nErrorCode) {
m_nLength=Receive(m_szBuffer,sizeof(m_szBuffer),0);
//下面两行代码用来获取对话框指针 CCSockClientApp* pApp=(CCSockClientApp*)AfxGetApp();
CCSockClientDlg* pDlg=(CCSockClientDlg*)pApp- >m_pMainWnd;
pDlg- >m_MSGS.InsertString(0,m_szBuffer); memset(m_szBuffer,0,sizeof(m_szBuffer));
CAsyncSocket::OnReceive(nErrorCode);}void MySock::OnSend(int nErrorCode) {
Send(m_szBuffer,m_nLength,0); m_nLength=0;
memset(m_szBuffer,0,sizeof(m_szBuffer));
//继续提请一个“读”的网络事件,接收 Server 消息 AsyncSelect(FD_READ);
CAsyncSocket::OnSend(nErrorCode);}void MySock::OnConnect(int nErrorCode) {
if (nErrorCode==0) {
m_bConnected=TRUE;
CCSockClientApp* pApp=(CCSockClientApp*)AfxGetApp();
CCSockClientDlg* pDlg=(CCSockClientDlg*)pApp- >m_pMainWnd;
memcpy(m_szBuffer,"Connected to ",13);
strncat(m_szBuffer,pDlg- >m_szServerAdr,
sizeof(pDlg- >m_szServerAdr));
pDlg- >m_MSGS.InsertString(0,m_szBuffer);
AsyncSelect(FD_READ);
////提请一个“读”的网络事件,准备接收 }
CAsyncSocket::OnConnect(nErrorCode);}
---- 7. 新建对话框 IDD_Addr,用来输入 IP 地址和 Port;生成新类 CAddrDlg。增加两个 Edit 控件:IDC_Addr、IDC_Port 按下表在 ClassWizard 中为 CAddrDlg 类添加变量。 Control ID Type MemberIDC_Addr CString m_AddrIDC_Port Int m_Port
---- 8. 在 CSockClientDlg.ccp 中添加代码 #include "AddrDlg.h"protected: int TryCount;
MySock m_clientSocket;
UINT m_szPort;public: char m_szServerAdr[256];
---- 9. 双击 IDD_CSOCKCLIENT_DIALOG 对话框中的“连接”按钮,添加以下代码 void CCSockClientDlg::OnConnect() {
m_clientSocket.ShutDown(2);
m_clientSocket.m_hSocket=INVALID_SOCKET;
m_clientSocket.m_bConnected=FALSE;
CAddrDlg m_Dlg; //默认端口1088m_Dlg.m_Port=1088;
if (m_Dlg.DoModal()==IDOK && !m_Dlg.m_Addr.IsEmpty()) {
memcpy(m_szServerAdr,m_Dlg.m_Addr,sizeof(m_szServerAdr));
m_szPort=m_Dlg.m_Port; //建立计时器,每1秒尝试连接一次,直到连上或 TryCount>10SetTimer(1,1000,NULL);
TryCount=0; }}
---- 10. 添加 Windows 消息 WM_TIMER 响应函数 OnTimer void CCSockClientDlg::OnTimer(UINT nIDEvent) {
if (m_clientSocket.m_hSocket==INVALID_SOCKET) {
BOOL bFlag=m_clientSocket.Create(0,SOCK_STREAM,FD_CONNECT);
if(!bFlag) { AfxMessageBox("Socket Error!");
m_clientSocket.Close();
PostQuitMessage(0);
return;
} }
m_clientSocket.Connect(m_szServerAdr,m_szPort);
TryCount++;
if (TryCount >=10 || m_clientSocket.m_bConnected) {
KillTimer(1);
if (TryCount >=10) AfxMessageBox("Connect Failed!");
return; }
CDialog::OnTimer(nIDEvent);}
考试大-全国最大教育类网站(www.Examda。com) ---- 11. 双击 IDD_CSOCKCLIENT_DIALOG 对话框中的“发送”按钮,添加以下代码 void CCSockClientDlg::OnSend() {
if (m_clientSocket.m_bConnected)
{m_clientSocket.m_nLength=m_MSG.GetWindowText(m_clientSocket.m_szBuffer, sizeof(m_clientSocket.m_szBuffer));
m_clientSocket.AsyncSelect(FD_WRITE);
m_MSG.SetWindowText(""); }}
---- 12. 双击 IDD_CSOCKCLIENT_DIALOG 对话框中的“关闭”按钮,添加以下代码 void CCSockClientDlg::OnExit() {
//关闭 Socketm_clientSocket.ShutDown(2); //关闭对话框 EndDialog(0); }
----12.运行此项目,连接时输入主机名或 IP 均可,CAsyncSocket 类会自动处理。