用WSAsyncSelect创建一个聊天室实验过程

1、用WSAsyncSelect创建一个聊天室服务器端程序1.创建基于对话框的MFC应用程序，巹 添加一个EDIT控件，界面效果如图示。在xxxDlg.cpp中引入Socket动态链接库，并定义Socket消息 /引y入?Socket动态?连?接库a #include winsock2.h#pragma comment(lib,WS2_32.lib)/定义?Socket消?息 #define WM_SOCKET (WM_USER+1)在应用程序胡初始化部分初始化Socket。在 :OnInitDialog() 中添加初始化代码。/初始化SocketWSADATA wsaData;WORD sock

2、etVersion=MAKEWORD(2,2);if(WSAStartup(socketVersion,&wsaData)!=0)MessageBox(LSOCKET初始化失败！);return 0;USHORT nPort=3000;SOCKET s=socket(AF_INET,SOCK_STREAM,0);sockaddr_in sin;sin.sin_family=AF_INET;sin.sin_port=ntohs(nPort);sin.sin_addr.S_un.S_addr=INADDR_ANY;if(bind(s,(sockaddr*)&sin,sizeof(sin)=SOCK

3、ET_ERROR)DWORD error=GetLastError();return TRUE;/注册Socket关心的事件WSAAsyncSelect(s,m_hWnd,WM_SOCKET,FD_ACCEPT|FD_CLOSE);listen(s,10);编写Socket的消息响应函数在xxxDlg.h文件中添加Socket消息响应函数afx_msg LRESULT OnSocketMsg(WPARAM wParam,LPARAM lParam);在xxxDlg.cpp实现消息响应函数LRESULT CASynsIODlg:OnSocketMsg(WPARAM wParam,LPARAM l

4、Param)SOCKET s=wParam;CString strContent;if(WSAGETSELECTERROR(lParam)closesocket(s);return false;switch(WSAGETSELECTEVENT(lParam)case FD_ACCEPT: /检测到有套接字连接SOCKET client=accept(s,NULL,NULL);WSAAsyncSelect(client,m_hWnd,WM_SOCKET,FD_READ|FD_WRITE|FD_CLOSE);CString strContent;GetDlgItemText(IDC_EDIT1,s

5、trContent);if(!strContent.IsEmpty()strContent+=rn;strContent+=有客户端连接上来了！;SetDlgItemText(IDC_EDIT1,strContent);/显示内容break;case FD_WRITE:break;case FD_READ:char szText1024=0;if(recv(s,szText,1024,0)=-1)closesocket(s);elseGetDlgItemText(IDC_EDIT1,strContent);if(!strContent.IsEmpty() strContent+=rn; CSt

6、ring strTemp;strTemp.Format(-T(%s),szText);strContent+=strTemp;SetDlgItemText(IDC_EDIT1,strContent);/显示内容break;case FD_CLOSE:closesocket(s);GetDlgItemText(IDC_EDIT1,strContent);if(!strContent.IsEmpty()strContent+=rn;strContent+=有客户断开连接了！;SetDlgItemText(IDC_EDIT1,strContent);/显示内容break;return true;定义

7、WM_SOCKET带OnOnSocketMsg()函数的映射关系。BEGIN_MESSAGE_MAP(CWSAsyncSelectDlg, CDialogEx)ON_WM_SYSCOMMAND()ON_WM_PAINT()ON_WM_QUERYDRAGICON()ON_BN_CLICKED(IDOK, &CWSAsyncSelectDlg:OnBnClickedOk)/定义WM_SOCKET消息到OnSocketMsg()函数胡映射ON_MESSAGE(WM_SOCKET,OnSocketMsg)END_MESSAGE_MAP()在窗口销毁事件中释放Socket资源。客户端程序制作一、创建MF

8、C应用程序并布局控件，其界面如下：二、初始化“IP地址“及”端口号“控件的值。三、添加全局变量在XXXDlg.h文件中添加#define WM_NETWORK WM_USER+100 SOCKET sock; 四、编写“连接”按钮响应事件函数/初始化Socket WSADATA wsa; if(WSAStartup(MAKEWORD(2,2),&wsa)!=0) MessageBox(L套接字初始化失败!); return; /创建Socket if(sock=socket(AF_INET,SOCK_STREAM,IPPROTO_TCP)=INVALID_SOCKET) MessageBox(

9、L创建套接字失败！); WSACleanup(); return; /获取服务器地址及端口号 CString strip; GetDlgItemText(IDC_IPADDRESS1,strip); const char *cip; cip=(const char *)strip.GetBuffer(strip.GetLength(); CString strPort; GetDlgItemText(IDC_EDIT2,strPort); int port=_ttoi(strPort);/ msg.Format(%c,&cip);MessageBox(msg+ +strPort);/绑定地址

10、struct sockaddr_in serverAddr; ZeroMemory(&serverAddr,sizeof(serverAddr); serverAddr.sin_family = AF_INET; serverAddr.sin_addr.S_un.S_addr = inet_addr(127.0.0.1); serverAddr.sin_port = htons(3000); /注册SOcket关注的事件/请求谅链接 if(connect(sock, (struct sockaddr*)&serverAddr, sizeof(serverAddr)=SOCKET_ERROR)

11、int err = WSAGetLastError(); if(err=WSAEWOULDBLOCK) msg.Format(_T(Waiting./n); else MessageBox(_T(无法连接到服务器！); closesocket(sock); WSACleanup(); 五、编写“发送”按钮响应事件函数 / TODO: 在此添加控件通知处理程序代码/读取庶发送的数据CString m_message;GetDlgItemText(IDC_EDIT3,m_message);/发送数据 int bytes = send(sock,(const char *)m_message.GetBuffer(m_message.GetLength(),m_message.GetLength()*2,0); if(bytes=SOCKET_ERROR) int error = WSAGetLastError(); if(error=WSAEWOULDBLOCK) msg = Send failed for message: ; msg+=m_message; else msg.Format(