将客户端地址赋给这个 Socket。然后登客户端的用户就可以在服务器上聊天了。
(2)客户端工作流程。客户端程序相对简单,只需要建立一个 Socket与服务器端连接,成功后通过这个 Socket来发送第 37 卷第 4 期和接收数据就可以了。
三、 关键技术
(一)Windows Sockets
Windows Sockets 是一套开放的、支持多种协议的 Windows 下的网络编程接口. Socket 实际在计算机中提供了一个通信端口,可以通过这个端口与任何一个具有Socket 接口的计算机通信 . 应用程序在网络上传输,接收的信息都通过这个 Socket 接口来实现(图 1).
(二)多线程编程技术
进程是应用程序的执行实例,每个进程是由私有的虚拟地址空间、代码、数据和其他各种系统资源组成,进程在运行过程中创建的资源随着进程的终止而被销毁,所使用的系统资源在进程终止时被释放或关闭. 线程是进程内部的一个执行单元系统创建好进程后,实际上就启动执行了该进程的主执行线程,主执行线程以函数地址形式,将程序的启动点提供给 Windows 系统. 主执行线程终止了,进程也就随之终止. 一个进程中的所有线程都在该进程的虚拟地址空间中,共同使用这些虚拟地址空间、全局变量和系统资源,所以线程间的通讯非常方便,多线程技术的应用也较为广泛。
.
图 1 面向相连接的套接字的系统调用图
四、功能分析
本系统是建立局域网通信模型,设计一个聊天系统,根据网络应用程序的特点,局域网聊天系统有即时、高效的特点. 服务器端和客户端有不同的功能与需求。
(一)服务器端功能
1)能够正确地、无冲突地启动服务器; 2)监听指定的端口,等待用户的连接; 3)接收到用户连接请求时,验证用户身份; 4)接收处理用户注册信息;
5)建立与客户端的连接,并能通知已在线用户; 6)向新登陆的用户发送已上线的用户信息; 7)接收客户端的消息请求,并能正确无误地处理消息,并能发出消息到客户端; 8)当用户断开与服务器端的连接时,服务器能够正确的断开连接,并通知其他在线用户;
9)当服务器关闭时,应通知所有在线用户.
(二)客户端功能
1)能够正确启动应用程序,并能向服务器发出连接请求; 2)能够向服务器发送注册请求; 3)显示在线用户列表;
4)能够向指定聊天对象发送消息; 5)能够及时接收其他用户发出的消息; 6)能够正确断开与服务器的连接;
7)当服务器关闭时,所有用户自动下线.
五、详细设计
我们利用 WinSocket实现一个网络聊天室。需要一个聊天服务器,它可以和很多客户端进行通信,从而把来自不同的客户的聊天信息转交到所有其他的客户端。这样就形成了一个采用 Client/Server结构的并可以多人同时在线的聊天室。
(一)服务器端的实现
服务器端主要用于接收客户端的连接,并转发客户端的信息。服务器端的具体实现过程如下:
(1)利用“MFC AppWizard”创建一个基于对话框的应用程序,在对话框中添加 List Box、Edit Box等控件。服务器端对话框界面如 2 所示。
图 2 服务器端界面运行图
(2)在对话框中类的头文件中引用 winsock2.h 头文件,并 导入 ws2_32.lib库文件。 #include“winsock2.h”
#pragma comment(lib“,ws2_32.lib”) (3)在对话框类中定义成员变量,记录服务器套接字和与之连接的客户端套接字信息。
SOCKET m_server,m_client; SOCKET m_Clients[MAXNUM];// 客户端套接字
int m_CurClient; // 当前连接的客户数量
(4)在对话框的 OninitDailog 函数中创建套接字,并初始化数据。 // 创建套接字
m_server = socke(tAF_INET,SOCK_STREAM,0);
// 将网络中的事件关联到窗口的消息函数中
WSAAsyncSelect (m_server,m_hWnd,20000,
FD_WRITE|FD_
READ|FD_ACCEPT);
m_client = 0; m_serverIP = \;
for(int i = 0;i< MAXNUM;i++)
m_Clients[i]= 0; m_CurClient = 0;
(5)处理“监听”按钮的单击事件,将套接字绑定到本机地址,并开始监听套接字。
void CSocketChatFWQDDlg::OnOK() {
// 服务器端地址
sockaddr_in serveraddr;
serveraddr.sin_family = AF_INET; m_IP.GetWindowTex(tm_serverIP); // 设置本机地址
serveraddr.sin_addr.S_un.S_addr = inet_add(rm_serverIP); UpdateData(TRUE); // 设置端口号
serveraddr.sin_port = htons(m_port); // 绑定地址
if (bind (m_server,(sockaddr*)&serveraddr,sizeof(serveraddr))) {
MessageBox(“绑定地址失败.”); return; }
// 开始监听
listen(m_server,50);
(6)向对话框中添加 HeadleData函数,用于接收客户端的连接,并获得客户端传来的数据,将其转发给其他客户端。
void CSocketChatFWQDDlg::HandleData() {
sockaddr_in serveraddr; char buffe[r1024];
int len =sizeo(fserveraddr); // 接收客户端的数据 int curlink =- 1; int num =- 1;
for(int p = 0;p< MAXNUM;p++) {
num= recv(m_Clients[p],buffer,1024,0); if(num !=- 1) {
curlink = p; break; }
}
buffe[rnum]= 0;
if(num==- 1) // 接受客户端的连接 {
if(m_CurClient < MAXNUM) {
m_Clients [m_CurClient] = accept(m_server,
(struct sockaddr*)&serveraddr,&len);
相关推荐: