编写TCP客户端和服务端程序,客户端通过多路IO复用同时处理标准输入(文件描述符为0)和套接字。当输入为quit时程序结束;当通过套接字收到对方消息时把收到的消息再次转发给对方,服务器端需通过select()监控listenfd和accept()后建立的新的套接字newfd, 可只写select()相关的主要代码。
perror("listen");
return -1;
}
//接受连接--accept阻塞
//接收客户端数据--recv阻塞
//select多路复用
fd_set readfds;
//定义读文件描述符集合
int cfds[50]={0};
//保存所有客户端的套接字
while(1)
{
int maxfd = sockfd;
//清空集合
FD_ZERO(&readfds);
FD_SET(sockfd,&readfds);
//把sockfd添加到readfds集合中
//把客户端的套接字也添加到集合中
for(int i=0; i<50; i++)
{
if(cfds[i] != 0)//如果不等于0就说明这个空间存储了套接字
{
FD_SET(cfds[i],&readfds);
maxfd = maxfd>cfds[i]?maxfd:cfds[i];
}
} //select用监听readfds里面的所有文件描述符,
//如果某一个或多个描述符有响应就跳出select函数
ret = select(maxfd+1,&readfds,NULL, NULL, NULL);
if(ret < 0)
{
perror("select");
}
//判断是否是sockfd有数据---说明有客户端连接
if(FD_ISSET(sockfd, &readfds))
{
//接受连接
int clientfd = accept(sockfd, NULL,NULL);
if(clientfd < 0)
{
perror("accept");
} //把客户端套接字保存到cfds数组中
for(int i=0; i<50; i++)
{
if(cfds[i] == 0)//判断放在没有使用的空间中
{
cfds[i] = clientfd;
break;
}
}
} //判断是否是客户端有数据
for(int i=0; i<50; i++)
{
//判断套接字是否存在,并且是否有数据到达
if(cfds[i] != 0 && FD_ISSET(cfds[i], &readfds))
{
//接收客户端数据
char buffer[128]={0};
int size = recv(cfds[i], buffer, 128, 0);
if(size<=0)
{
printf("有客户端掉线\n");
close(cfds[i]);
cfds[i] = 0;
}
//把接收到的信息转发给客户端自己
size = send(cfds[i],buffer,size,0);
}
}
}
printf("有客户端连接\n");
close(sockfd);
}
标签:int,readfds,API,sockfd,接字,select,客户端
From: https://www.cnblogs.com/hhail08/p/18246795