- 1、本文档共5页,可阅读全部内容。
- 2、有哪些信誉好的足球投注网站(book118)网站文档一经付费(服务费),不意味着购买了该文档的版权,仅供个人/单位学习、研究之用,不得用于商业用途,未经授权,严禁复制、发行、汇编、翻译或者网络传播等,侵权必究。
- 3、本站所有内容均由合作方或网友上传,本站不对文档的完整性、权威性及其观点立场正确性做任何保证或承诺!文档内容仅供研究参考,付费前请自行鉴别。如您付费,意味着您自己接受本站规则且自行承担风险,本站不退款、不进行额外附加服务;查看《如何避免下载的几个坑》。如果您已付费下载过本站文档,您可以点击 这里二次下载。
- 4、如文档侵犯商业秘密、侵犯著作权、侵犯人身权等,请点击“版权申诉”(推荐),也可以打举报电话:400-050-0827(电话支持时间:9:00-18:30)。
查看更多
实验六_selet服务器
实验六 基于套接口复用的聊天室系统
内容:
建立一个容纳63个客户的聊天室。
流程:
1. 客户端连接上聊天室服务器;
2. 服务器把从一个客户端收到的数据转发给其它所有的客户端;
3. 客户端显示从服务器接收的数据
服务器的流程如下
BEGIN
While(1)
{
把监听套接口和所有已连接套接口放入到查询集合rset中;
调用select()函数对rset中的套接口进行可读性查询;
if(监听套接口有数据可读)
{
调用accept()函数来接受新客户的连接;
把新建立的已连接套接口放入到下一次查询的rset中;
}
对每一个(for each)有数据可读的已连接套接口
{
调用recv()函数来接收数据;
if(客户端断开连接)
{
把该套接口从下一次查询的rset中清除掉;
跳转到下一个有数据可读的已连接套接口继续处理(continue);
}
把该套接口上接收到的数据,转发给其它已连接套接口;
} // for each end
}//while(1) end
END
客户端的框架如下:
/* 使用多线程的TCP聊天客户端程序逻辑结构 */
void __cdecl get_keyboard_input(void * param)
{
SOCKET sock = (SOCKET) param;
While(1)
{
char info[1024];
gets(info);
send(sock, info, strlen(info), 0);
}
}
int main()
{
SOCKET sock=socket(…);
connect(sock,…);
_beginthread(get_keyboard_input, 0, (void *)sock); //启动线程处理键盘输入
while(1)
{
recv(sock, …); //主线程负责处理接收服务器的数据
printf();
}
}
要求:
服务器的固定端口号为27015;
TCP用套接口的复用来实现,有兴趣的同学可以考虑实现基于UDP的程序;
客户端使用多线程来处理键盘的输入和服务器数据的接收。
服务器
// C1.cpp : 定义控制台应用程序的入口点。
//
// C1.cpp : 定义控制台应用程序的入口点。
//
#include stdafx.h
#includewinsock2.h
#pragma comment(lib,ws2_32.lib)
int _tmain(int argc, _TCHAR* argv[])
{
int i;
WSADATA wsaData;
int err = WSAStartup(MAKEWORD(2,2),wsaData);
if(0 != err)
return -1;
SOCKET sock;
sock = socket(AF_INET,SOCK_STREAM,0);
if(sock == INVALID_SOCKET)
{
WSACleanup();
return -1;
}
sockaddr_in server;
server.sin_family = AF_INET;
server.sin_port = htons(27015);
server.sin_addr.s_addr=htonl(INADDR_ANY);
if(bind(sock,(SOCKADDR*)server,sizeof(server)) == SOCKET_ERROR)
{
closesocket(sock);
WSACleanup();
return -1;
}
if(listen(sock,1) == SOCKET_ERROR)
{
closesocket(sock);
WSACleanup();
return -1;
}
#define MAXC 63
SOCKET client[MAXC];
for( i=0;iMAXC;i++)
client[i] = INVALID_SOCKET;
fd_set rset,allset;
FD_ZERO(allset);
FD_SET(sock,allset);
#define MAXS 1024
char buf[MAXC][MAXS];
for(;;)
{
rset = allset;
int ret = select(0,rset,NULL,NULL,NULL);
if(ret == SO
文档评论(0)