华清远见嵌入式学习——网络编程——作业4

作业要求:①使用IO多路复用中的select函数实现TCP并发服务器客户端

                  ②使用IO多路复用中的poll函数实现TCP并发服务器的服务器端

一、

代码

#include <myhead.h>#define SERPORT 8888              //服务器端口号
#define SERIP "192.168.114.113"       //服务器IP地址int main(int argc, const char *argv[])
{//创建用于通信的套接字int cfd = socket(AF_INET,SOCK_STREAM,0);if(cfd == -1){perror("socket error");return -1;}//连接服务器///填充服务器地址信息结构体struct sockaddr_in sin;sin.sin_family = AF_INET;sin.sin_port = htons(SERPORT);sin.sin_addr.s_addr = inet_addr(SERIP);///连接服务器if(connect(cfd,(struct sockaddr *)&sin,sizeof(sin)) == -1){perror("connect error");return -1;}//创建用于检测文件描述符的集合fd_set readfds,tempfds;//清空集合FD_ZERO(&readfds);//将要检测的文件描述符放入集合中FD_SET(cfd,&readfds);FD_SET(0,&readfds);int res = 0;    //接收select的返回值int maxfd = cfd;  //集合中值最大的文件描述符//向服务器进行数据的收发char buf[128] = "";int ret = 0;    //接收recv的返回值while(1){tempfds = readfds;res = select(maxfd+1,&tempfds,NULL,NULL,NULL);if(res == -1){perror("select error");return -1;}else if(res == 0){printf("time out\n");return -1;			}//遍历集合中所有的文件描述符for(int i = 0;i <= maxfd;i++){//判断当前文件描述符是否在集合中if(!FD_ISSET(i,&readfds)){continue;}//判断0号文件描述符是否还在集合中if(0 == i){//从标准输入中读取数据fgets(buf,sizeof(buf),stdin);buf[strlen(buf)-1] == 0;//将数据发送到服务器if(send(cfd,buf,sizeof(buf),0) == -1){perror("send error");return -1;}}else if(cfd == i)     //判断cfd是否还在集合中{//接收来自服务器的消息ret = recv(cfd,buf,sizeof(buf),0);if(ret == -1){perror("recv error");return -1;}else if(ret == 0){printf("服务器已关闭\n");return -1;}printf("服务器消息:%s\n",buf);}}}//关闭文件描述符close(cfd);return 0; 
}

效果图

二、

代码

#include <myhead.h>#define IP "192.168.114.118"
#define PORT 8888int main(int argc, const char *argv[])
{//创建用于连接的套接字int sfd = socket(AF_INET,SOCK_STREAM,0);if(sfd == -1){perror("socket error");return -1;}//设置端口号快速重用int reuse = 1;if(setsockopt(sfd, SOL_SOCKET, SO_REUSEADDR, &reuse, sizeof(reuse)) == -1){perror("setsockopt error");return -1;}//绑定服务器IP和端口号///填充服务器地址信息结构体struct sockaddr_in sin;sin.sin_family = AF_INET;sin.sin_port = htons(PORT);sin.sin_addr.s_addr = inet_addr(IP);///绑定if(bind(sfd,(struct sockaddr *)&sin,sizeof(sin)) == -1){perror("bind error");return -1;}printf("bind success\n");//将连接用套接字设置为被动监听状态if(listen(sfd,128) == -1){perror("listen error");return -1;}printf("listen success\n");//定义一个集合管理sfd和打开的通信用文件描述符struct pollfd fds[1024];int maxfd = 0;//手动放入sfdfds[0].fd = sfd;fds[0].events = POLLIN;     //表明为读事件//将fds中其余元素初始化为-1for(int i = 4;i <= 1024;i++){fds[i].fd = -1;}//填充客户端地址信息结构体struct sockaddr_in cin;cin.sin_family = AF_INET;socklen_t socklen = sizeof(cin);char cbuf[128] = "";  //给客户端用的容器int nfd;int res = 0;  //接收poll返回的结果while(1){res = poll(fds,maxfd+1,-1);if(res == -1){perror("select");return -1;}else if(res == 0){continue;;}else if(res > 0)                //说明检测到了有文件描述符对应的缓冲区的数据发生了改变{if(fds[0].revents ==  POLLIN)    //表明有新的客户连接进来了{int nfd = accept(sfd,(struct sockaddr*)&cin,&socklen);  //阻塞在此处,直到有客户端连接上来if(nfd == -1)   //增加这些错误的判断非常重要,可以帮助找到出现问题的地方{perror("accept");return -1;}//将新的文件描述符加入到集合中for(int i = 1;i < 1024;i++){if( fds[i].fd == -1){fds[i].fd = nfd;fds[i].events = POLLIN;break;}}//更新最大的文件描述符if(nfd > maxfd){maxfd = nfd;}}for(int i = 1;i <= maxfd;i++)     //轮询客户端对应的文件描述符{if(fds[i].revents == POLLIN)  //说明此文件描述符对应的客户端发送来了数据{int ret = read(fds[i].fd,cbuf,sizeof(cbuf));if(ret == -1){perror("read");exit(-1);}else if(ret == 0){printf("client closed\n");close(fds[i].fd);   //关闭对应的文件描述符fds[i].fd = -1;   //在fds中清空对应的文件描述符}else if(ret > 0){printf("read buf = %s\n",cbuf);write(fds[i].fd,cbuf,strlen(cbuf)+1);}}}}}//关闭所有套接字close(sfd);return 0;}

效果图

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.hqwc.cn/news/210073.html

如若内容造成侵权/违法违规/事实不符,请联系编程知识网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

曲率半径的推导

参考文章 参考文章

ABB机 器 人 操 作 培 训

目 录 1 培训手册介绍 ---------------------------------------------2 2 系统安全与环境保护 ---------------------------------------------3 3 机器人综述 ---------------------------------------------5 4 机器人示教 --------------------------------------------12…

强化学习------贝尔曼方程

目录 前言基础知识马尔可夫决策过程 (Markov decision process, MDP)回报(Return)折扣回报(Discounted Return) State Value&#xff08;状态价值函数&#xff09;贝尔曼方程的推导贝尔曼方程的矩阵形式Action Value&#xff08;动作价值函数&#xff09;贝尔曼最优公式 前言 …

pip安装python包到指定python版本下

python -m pip install 包名1.命令行进入到指定python安装目录。比如我电脑上有python3.8也有python3.9。准备给python3.9安装指定的包

gitee推荐-PHP面试准备的资料

该内容为giee项目。PHP-Interview: 这个项目是自己准备PHP面试整理的资料。包括PHP、MySQL、Linux、计算机网络等资料。方便自己以后查阅&#xff0c;会不定期更新&#xff0c;欢迎提交pr&#xff0c;如果错误&#xff0c;请指出&#xff0c;谢谢 在线预览地址&#xff1a;Intr…

Android7.1 高通平台 修改系统默认语言

客户需求&#xff1a;修改系统默认语言为英文&#xff08;美国&#xff09; 源码位置&#xff1a;/build/tools/buildinfo.sh 只需修改 ro.product.locale的值即可&#xff0c;如下图&#xff1a;

【大数据】Docker部署HMS(Hive Metastore Service)并使用Trino访问Minio

本文参考链接置顶&#xff1a; Presto使用Docker独立运行Hive Standalone Metastore管理MinIO&#xff08;S3&#xff09;_hive minio_BigDataToAI的博客-CSDN博客 一. 背景 团队要升级大数据架构&#xff0c;需要摒弃hadoop&#xff0c;底层使用Minio做存储&#xff0c;应用…

k8s部署的java服务查看连接nacos缓存的配置文件

一、问题描述 k8s部署的java服务&#xff0c;使用nacos中的配置文件&#xff0c;需要在缓存中查看该服务具体是使用到了哪些配置文件 二、解决 参考文档: https://nacos.io/zh-cn/docs/system-configurations.html 文档描述如下: 进入java服务容器进入用户目录下的nacos&a…

一体化大气环境监测设备实时守护我们的空气质量

WX-CSQX12 随着空气污染问题的日益严重&#xff0c;大气环境监测设备成为了我们生活中不可或缺的一部分。而一体化的大气环境监测设备&#xff0c;更是为我们的环境保护工作带来了更多的便利和效益。 一体化大气环境监测设备是一种集成了多种功能于一体的环保设备&#xff0c;…

使用JVS低代码表单引擎高效管理文件,实现个性化需求

在数字化、信息化的时代&#xff0c;文件上传与管理功能已经成为了各类应用系统的标配。无论是在办公自动化、项目管理还是内容管理系统中&#xff0c;我们都希望能轻松、高效地完成文件的上传、查看和管理。JVS低代码表单引擎提供了文件类组件。无论是文件类型、大小的限制&am…

景区智慧旅游智能化系统方案:PPT全文58页,附下载

关键词&#xff1a;智慧景区解决方案&#xff0c;智慧文旅解决方案&#xff0c;智慧旅游解决方案&#xff0c;智慧文旅综合运营平台 一、景区智慧旅游智能化系统建设背景 近年来&#xff0c;随着信息技术的快速发展和普及&#xff0c;以及旅游市场的不断扩大和升级&#xff0…

非遗数字保护的崭新篇章:十八数藏柏松的文化守护

在数字时代&#xff0c;非遗数字保护崭新的篇章由十八数藏柏松书写。这个数字保护的使者不仅仅是文化的守护者&#xff0c;更是文化传承的崭新篇章的开创者。 首先&#xff0c;十八数藏柏松以数字技术作为媒介&#xff0c;将传统非物质文化遗产数字化&#xff0c;为其创造了一个…