wordpress音乐网站主题,个人网站icp,台州网站制作推广,响应式网站要多久作业#xff1a;
运行1个服务器和2个客户端 实现效果#xff1a; 服务器和2个客户端互相聊天#xff0c;服务器和客户端都需要使用select模型去实现 服务器要监视2个客户端是否连接#xff0c;2个客户端是否发来消息以及服务器自己的标准输入流 客户端要监视服务器是否发来…作业
运行1个服务器和2个客户端 实现效果 服务器和2个客户端互相聊天服务器和客户端都需要使用select模型去实现 服务器要监视2个客户端是否连接2个客户端是否发来消息以及服务器自己的标准输入流 客户端要监视服务器是否发来消息以及客户端自己的标准输入流 在不开线程的情况下实现互相聊天
#includemyhead.hvoid intsert_newfd(int* newfd_arr,int* len,int newfd)
{newfd_arr[*len] newfd;(*len);
}int find_newfd(int* newfd_arr,int len,int newfd)
{for(int i0;ilen;i){if(newfd_arr[i] newfd){return i;}}return -1;
}void remove_newfd(int* newfd_arr,int* len,int newfd)
{int tar find_newfd(newfd_arr,*len,newfd);if(tar -1){return ;}for(int itar;i*len-1;i){newfd_arr[tar] newfd_arr[tar1];}(*len)--;
}int main(int argc,const char *argv[])
{if(argc ! 2){printf(请输入正确的端口号\n);return 1;}//存放客户端的套接字int newfd_arr[100] {0};//存放客户端的数量int newfd_count 0;int port atoi(argv[1]);int sfd socket(AF_INET,SOCK_STREAM,0);struct sockaddr_in sin;sin.sin_family AF_INET;sin.sin_port htons(port);sin.sin_addr.s_addr inet_addr(192.168.2.53);int reuse setsockopt(sfd,SOL_SOCKET,SO_REUSEADDR,reuse,sizeof(reuse));bind(sfd,(struct sockaddr*)sin,sizeof(sin));listen(sfd,128);fd_set readfds;FD_ZERO(readfds);FD_SET(sfd,readfds);FD_SET(0,readfds);while(1){fd_set temp readfds;//监视服务器套接字select(FD_SETSIZE,temp,0,0,0);//如果 0 激活if(FD_ISSET(0,temp) 1){printf(标准输入流激活\n);char buf[32] ;scanf(%s,buf);getchar();for(int i0;inewfd_count;i){int fd newfd_arr[i];write(fd,buf,strlen(buf));}}if(FD_ISSET(sfd,temp)){//接收链接int newfd accept(sfd,0,0);printf(有客户端连接\n);//将接收到的客户端的套接字放入监视列表FD_SET(newfd,readfds);//将连接的客户端的套接字存入数组中进行统一管理intsert_newfd(newfd_arr,newfd_count,newfd);}else{//判断每一个客户端是否激活如果激活了调用read来读取for(int i0;inewfd_count;i){int newfd newfd_arr[i];if(FD_ISSET(newfd,temp)){//客户端套接字激活有两种情况1、发来了信息 2、断开链接char buf[128] ;int res read(newfd,buf,sizeof(buf));//如果read阻塞客户端断开连接read返回0//如果read非阻塞客户端断开连接read返回-1if(res 0){//说明客户端断开了连接//1、从监视列表中删除FD_CLR(newfd,readfds);//2、从客户端数据中删除remove_newfd(newfd_arr,newfd_count,newfd);//3、关闭客户端套接字close(newfd);printf(客户端已下线\n);break;}printf(客户端发来的消息为%s\n,buf);}}}}close(sfd);return 0;
}
#includemyhead.h
#define SER_PORT 6000
#define SER_IP 192.168.2.53int main(int argc,char *argv[])
{if(argc ! 2){printf(请输入正确的端口号\n);return 1;}int port atoi(argv[1]);int cfd socket(AF_INET,SOCK_STREAM,0);struct sockaddr_in cin;cin.sin_family AF_INET; //通信域cin.sin_port htons(port); //端口号cin.sin_addr.s_addr inet_addr(192.168.2.53); //IP地址bind(cfd,(struct sockaddr*)cin,sizeof(cin));struct sockaddr_in sin;sin.sin_family AF_INET; //通信域sin.sin_port htons(SER_PORT); //服务器口号sin.sin_addr.s_addr inet_addr(SER_IP); //服务器IP地址connect(cfd,(struct sockaddr*)sin,sizeof(sin));//准备描述符集合fd_set readfds;//初始化FD_ZERO(readfds);//将管道读段描述符添加进入描述符集合FD_SET(cfd,readfds);//将标准输入流添加进入描述符集合FD_SET(0,readfds);while(1){fd_set temp readfds;//监视readfds,此时readfds里面只有 0 和 cfdselect(FD_SETSIZE,temp,0,0,0);//如果 0 激活if(FD_ISSET(0,temp) 1){printf(标准输入流激活\n);char buf[32] ;scanf(%s,buf);getchar();write(cfd,buf,strlen(buf));if(strcmp(buf,quit) 0){break;}}if(FD_ISSET(cfd,temp) 1){printf(管道读端激活\n);char buf[32] ;read(cfd,buf,sizeof(buf));printf(管道读取到的数据为%s\n,buf);}}//5、关闭套接字close(cfd);return 0;
}
