使用select实现服务器并发

select函数介绍: 

select 函数是一个用于在一组文件描述符上进行异步I/O多路复用的系统调用。它可以同时监视多个文件描述符,等待其中任何一个文件描述符准备就绪,然后进行相应的操作。

以下是select函数的原型:

#include <sys/select.h>int select(int nfds, fd_set *readfds, fd_set *writefds, fd_set *exceptfds, struct timeval *timeout);

参数:

nfds:待监视的最大文件描述符加1。
readfds:指向一个可读文件描述符集合的指针,用于指定要监视读事件的文件描述符。
writefds:指向一个可写文件描述符集合的指针,用于指定要监视写事件的文件描述符。
exceptfds:指向一个异常文件描述符集合的指针,用于指定要监视异常事件的文件描述符。
timeout:指向一个表示超时时间的结构体指针,用于设置select的超时时间。如果为NULL,select将一直阻塞,直到有事件发生。

返回值:

如果超时时间内有文件描述符就绪或有错误发生,select函数返回就绪文件描述符的总数。
如果超时时间到达而没有文件描述符就绪,select函数返回0。
如果出现错误,select函数返回-1,并设置errno来指示具体的错误类型。
select函数主要用于实现多路复用的I/O操作,它允许同时监视多个文件描述符,以避免使用阻塞式I/O时每个文件描述符都需要单独的线程。通过select函数,可以有效地管理并发连接、处理I/O事件和提高系统性能。
 

服务器代码:

#include <myhead.h>#define PORT 9999               //端口号
#define IP "192.168.125.39"     //本机IPint main(int argc, const char *argv[])
{//创建流式套接字 socketint sfd=socket(AF_INET,SOCK_STREAM,0);if(sfd<0){ERR_MSG("socket create");return -1;}//允许端口快速的被复用int reuse = 1;                                                            if(setsockopt(sfd, SOL_SOCKET, SO_REUSEADDR, &reuse, sizeof(reuse)) < 0){ERR_MSG("setsockopt");return -1;}printf("允许端口快速的被复用成功\n");//填充地址信息结构体给bind函数绑定//真实的地址信息结构体根据地址族指定 AF_INET:man 7 ipstruct sockaddr_in sin;sin.sin_family = AF_INET; //必须填AF_INETsin.sin_port = htons(PORT); //端口号的网络字节序sin.sin_addr.s_addr = inet_addr(IP);//本机ip//绑定服务器的地址信息 必须绑定bindif(bind(sfd,(struct sockaddr*)&sin,sizeof(sin))<0){ERR_MSG("bind");return -1;}//将套接字设置为被动监听状态listenif(listen(sfd,128)<0){ERR_MSG("listen");return -1;}//创建一个读集合fd_set readfds,tempfds;//fd_set 本质上是一个结构体,结构体中有一个整形数组//清空集合,存在随机值,可能会随机到有用的但是不需要监测的文件描述符//清空集合FD_ZERO(&readfds);//将要监测的文件描述符添加到集合中FD_SET(0,&readfds);FD_SET(sfd,&readfds);int maxfd = sfd;      //储存最大文件描述符char buff[128] = "";int s_res = -1;char buf[128] = "";ssize_t res = -1;struct sockaddr_in saveCin[1024];   //备份连接成功的客户端的地址信息,用下标对应文件描述符while(1){tempfds = readfds;//执行IO多路复用函数s_res = select(maxfd+1,&tempfds,NULL,NULL,NULL);if(s_res <0){ERR_MSG("select");return -1;}else if(s_res == 0){printf("time out,, \n");break;}//此时集合中会只剩下产生事件的文件描述符//只需要判断集合中剩下哪个文件描述符,走对应处理函数for(int i=0;i<=maxfd;i++ ){if(FD_ISSET(i,&tempfds)==0)continue;//能运行到这里,说明i代表的文件描述符在集合中if(0 == i){int sendfd = -1;printf("触发键盘事件\n");bzero(buff,sizeof(buff));int res=scanf("%d %s",&sendfd,buff);while(getchar()!=10);if(2!=res){printf("输入格式错误\n");return -1;}if(2>=sendfd || FD_ISSET(sendfd,&readfds)==0){printf("输入有误\n");return -1;}if(send(sendfd,buff,sizeof(buff),0)<0){ERR_MSG("send");return -1;}}else if(sfd == i){printf("触发客户端连接事件\n");//连接到客户端//获取一个已经完成的客户端信息,生成一个新的文件描述符int newfd = -1;struct sockaddr_in cin;//存储客户端的地址信息socklen_t addrlen = sizeof(cin);//真实的结构体信息地址大小newfd = accept(sfd,(struct sockaddr*)&cin,&addrlen);if(newfd<0){ERR_MSG("newfd");return -1;}printf("[%s %d]:%d\n",inet_ntoa(cin.sin_addr),ntohs(cin.sin_port),newfd);saveCin[newfd] = cin;//将newfd添加到集合中FD_SET(newfd,&readfds);//更新最大文件描述符maxfd = maxfd>newfd?maxfd:newfd;}else{printf("触发客户端交互事件\n");bzero(buf,sizeof(buf));res = recv(i,buf,sizeof(buf),0);if(res<0){ERR_MSG("recv");return -1;}if(0 == res){printf("[%s %d]客户端下线:%d",inet_ntoa(saveCin[i].sin_addr),ntohs(saveCin[i].sin_port),i);//关闭文件描述符	close(i);//剔除文件描述符FD_CLR(i, &readfds);while(!FD_ISSET(maxfd, &readfds)&& (maxfd--) > 0);continue;}printf("[%s %d]%d:%s\n",inet_ntoa(saveCin[i].sin_addr),ntohs(saveCin[i].sin_port),i,buf);}}}//关闭if(close(sfd)<0){ERR_MSG("close");return -1;}return 0;
}

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

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

相关文章

使用Visual Studio调试排查Windows系统程序audiodg.exe频繁弹出报错

VC常用功能开发汇总&#xff08;专栏文章列表&#xff0c;欢迎订阅&#xff0c;持续更新...&#xff09;https://blog.csdn.net/chenlycly/article/details/124272585C软件异常排查从入门到精通系列教程&#xff08;专栏文章列表&#xff0c;欢迎订阅&#xff0c;持续更新...&a…

lv7 嵌入式开发-网络编程开发 03 TCP/IP与五层体系结构

目录 1 TCP/IP协议族体系结构 1.1 OSI与TCP/IP 1.2 TCP/IP 的体系结构 1.3 TCP/IP 体系结构的另一种表示方法 1.4 沙漏计时器形状的 TCP/IP 协议族 2 五层协议的体系结构 2.1 各层的主要功能 2.2 互联网中客户-服务器工作方式 2.3 同时为多个客户进程提供服务 3 练…

vertx的学习总结三

一、event bus是什么 各个verticle的通信 二、point-to-point, request-reply, publish/subscribe 通过 the event bus 例题一&#xff1a;点对点 package eventBus;import io.vertx.core.AbstractVerticle; import io.vertx.core.Vertx;public class EventBusExample exte…

Go-Python-Java-C-LeetCode高分解法-第八周合集

前言 本题解Go语言部分基于 LeetCode-Go 其他部分基于本人实践学习 个人题解GitHub连接&#xff1a;LeetCode-Go-Python-Java-C 欢迎订阅CSDN专栏&#xff0c;每日一题&#xff0c;和博主一起进步 LeetCode专栏 我搜集到了50道精选题&#xff0c;适合速成概览大部分常用算法 突…

快速选择排序

"你经过我每个灿烂时刻&#xff0c;我才真正学会如你般自由" 前些天有些无聊&#xff0c;想试试自己写的快排能否过leetcode上的排序算法题。结果是&#xff0c;不用截图可想而知&#xff0c;肯定是没过的&#xff0c;否则也不会有这篇文章的产出。 这份快排算法代码…

“链圈”十年反思

2013 年 11 月&#xff0c;Vitalik Buterin 发表了以太坊白皮书的第一个版本。事后人们经常把这视为“区块链 2.0” 时代开启的标志&#xff0c;但在当时&#xff0c;其实是以太坊的出现才使得“区块链”作为一项单独的技术从“数字货币”当中分离出来。换句话说&#xff0c;比…

软件工程与计算总结(一)软件工程基础

国庆快乐&#xff0c;今天开始更新《软件工程与计算&#xff08;卷二&#xff09;》的重要知识点内容~ 一.软件 1.软件独立于硬件 早期的软件是为了计算机硬件在研究型项目中而开发制造的&#xff0c;人们使用专门针对于硬件的指令码和汇编语言编写&#xff0c;这也是最早软件…

C++ opencv设置视频的捕获方式为 MJPG设置失败

我有一款4k摄像头&#xff0c;在设置分辨率为4k的时候总是出现帧率不够的情况&#xff0c; 使用命令查看 v4l2-ctl --device/dev/video0 --list-formats-ext发现 v4l2-ctl --device/dev/video0 --list-formats-ext ioctl: VIDIOC_ENUM_FMTType: Video Capture[0]: MJPG (Moti…

c++-vector

文章目录 前言一、vector介绍二、vector使用1、构造函数2、vector 元素访问3、vector iterator 的使用4、vector 空间增长问题5、vector 增删查改6、理解vector<vector< int >>7、电话号码的字母组合练习题 三、模拟实现vector1、查看STL库源码中怎样实现的vector2…

利用norm.ppfnorm.interval分别计算正态置信区间[实例]

scipy.stats.norm.ppf用于计算正态分布的累积分布函数CDF的逆函数&#xff0c;也称为百分位点函数。它的作用是根据给定的概率值&#xff0c;计算对应的随机变量值。scipy.stats.norm.interval是用于计算正态分布的置信区间的函数。这个函数的主要目的是根据给定的置信水平、均…

算法 接雨水问题-(双指针)

牛客网: BM94 题目: 把数组看成柱子高度图&#xff0c;计算最多能接多少雨水 思路: 初始化左右双指针left, right 0, n-1, 初始化高度maxL, maxR&#xff0c;比较maxL与maxR&#xff0c;较小的往对面移动&#xff0c;更新maxL或maxR, 同时统计柱子高度差即为可接雨水数&…

Leetcode.965 单值二叉树

本专栏内容为&#xff1a;leetcode刷题专栏&#xff0c;记录了leetcode热门题目以及重难点题目的详细记录 &#x1f493;博主csdn个人主页&#xff1a;小小unicorn ⏩专栏分类&#xff1a;八大排序汇总 &#x1f69a;代码仓库&#xff1a;小小unicorn的代码仓库&#x1f69a; &…

Page Cache难以回收产生之直接内存回收引起 load 飙高或者业务时延抖动

相信你在平时的工作中&#xff0c;应该会或多或少遇到过这些情形&#xff1a;系统很卡顿&#xff0c;敲命令响应非常慢&#xff1b;应用程序的 RT 变得很高&#xff0c;或者抖动得很厉害。在发生这些问题时&#xff0c;很有可能也伴随着系统 load 飙得很高。 据我观察&#xf…

Android逆向学习(五)app进行动态调试

Android逆向学习&#xff08;五&#xff09;app进行动态调试 一、写在前面 非常抱歉鸽了那么久&#xff0c;前一段时间一直在忙&#xff0c;现在终于结束了&#xff0c;可以继续更新android逆向系列的&#xff0c;这个系列我会尽力做下去&#xff0c;然后如果可以的话我看看能…

vued中图片路径与主机路径相关联,例如img:‘http://127.0.0.1:8000/media/data/els.jpg‘

1.在Django项目的settings.py文件中&#xff0c;确保已指定正确的MEDIA_URL和MEDIA_ROOT。MEDIA_URL定义了图片的URL前缀&#xff0c;MEDIA_ROOT定义了本地文件系统中存储图片的路径。 2.在 Django 项目的主 urls.py 文件中&#xff0c;确保包含了适当的 URL 配置&#xff0c;以…

flask-sqlalchemy结合Blueprint遇到循环引入问题的解决方案

想要用flask_sqlalchemy结合Blueprint分模块写一下SQL的增删改查接口&#xff0c;结果发现有循环引入问题。 一开始&#xff0c;我在app.py中使用db SQLAlchemy(app)创建数据库对象&#xff1b;并且使用app.register_blueprint(db_bp, url_prefix/db)注册蓝图。 这使得我的依…

国庆中秋特辑(六)大学生常见30道宝藏编程面试题

以下是 30 道大学生 Java 面试常见编程面试题和答案&#xff0c;包含完整代码&#xff1a; 什么是 Java 中的 main 方法&#xff1f; 答&#xff1a;main 方法是 Java 程序的入口点。它是一个特殊的方法&#xff0c;不需要被声明。当 Java 运行时系统执行一个 Java 程序时&…

uboot启动流程-涉及lowlevel_init汇编函数

一. uboot启动流程涉及函数 之前文章简单分析了 uboot启动流程的开始&#xff0c;从链接脚本文件 u-boot.lds 中&#xff0c;我们已经知道了入口点是 arch/arm/lib/vectors.S 文件中的 _start函数。 _start函数&#xff1a;调用了 reset 函数&#xff0c;reset 函数内部&…

大屏自适应容器组件-Vue3+TS

1.引言 在做数字大屏时&#xff0c;图表能跟着浏览器的尺寸自动变化&#xff0c;本文采用Vue3前端框架&#xff0c;采用TypeScript语言&#xff0c;封装了一个大屏自适应组件&#xff0c;将需要显示的图表放入组件的插槽中&#xff0c;就能实现自适应屏幕大小的效果。 2.实际…

Flutter笔记 - 用于描述Align的Alignment、AlignmentDirectional、AlignmentTween类

Flutter笔记 用于描述Align的Alignment、AlignmentDirectional、AlignmentTween类 作者&#xff1a;李俊才 &#xff08;jcLee95&#xff09;&#xff1a;https://blog.csdn.net/qq_28550263 邮箱 &#xff1a;291148484163.com 本文地址&#xff1a;https://blog.csdn.net/qq_…