10.1 今日任务：select实现服务器并发

#include <myhead.h>#define ERR_MSG(msg)  do{\fprintf(stderr, "__%d__:", __LINE__); \perror(msg);\
}while(0)#define PORT 8888               //端口号，范围1024~49151
#define IP  "192.168.112.115"   //本机IP，ifconfigint keybord_events(fd_set readfds);
int cliConnect_events(int, struct sockaddr_in*, fd_set *, int *);
int cliRcvSnd_events(int, struct sockaddr_in*, fd_set *, int* );int main(int argc, const char *argv[])
{//创建流式套接字 socketint sfd = socket(AF_INET, SOCK_STREAM, 0);if(sfd < 0){ERR_MSG("socket");return -1;}printf("socket create success sfd=%d\n", sfd);//允许端口快速的被复用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_INET;sin.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;}printf("bind success\n");//将套接字设置为被动监听状态 listenif(listen(sfd, 128) < 0){ERR_MSG("listen");return -1;}printf("listen success\n");//创建一个读集合fd_set readfds, tempfds;//fd_set 本质上是一个结构体，结构体中有一个整形数组。//若不清空，则会存有随机值，可能会随机到有效的，但是不需要监测的文件描述符//清空集合FD_ZERO(&readfds);//将需要监测的文件描述符添加到集合中FD_SET(0, &readfds);FD_SET(sfd, &readfds);int maxfd = sfd;                    //存储最大的文件描述符int s_res = -1;ssize_t res = -1;char buf[128] = "";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(0 == s_res){printf("time out,,\n");break;}printf("__%d__\n", __LINE__);//能运行到当前位置，则代表select函数解除阻塞，即代表集合中有文件描述符准备就绪//此时集合中会只剩下产生事件的文件描述符，例如：//0号准备就绪，则集合中会只剩下0号//sfd准备就绪，则集合中会只剩下sfd//0和sfd均准备就绪，则集合中会剩下0和sfd;//只需要判断集合中剩下哪个文件描述符，走对应处理函数即可;for(int i=0; i<=maxfd; i++){if(FD_ISSET(i, &tempfds) == 0)continue;//能运行到当前位置，则说明i所代表的文件描述符在集合中if(0 == i)          //0在集合中{printf("触发键盘输入事件\n");keybord_events(readfds);}else if(sfd == i)       //sfd在集合中{printf("触发客户端连接事件\n");cliConnect_events(sfd, saveCin, &readfds, &maxfd);}else{printf("触发客户端交互事件\n");cliRcvSnd_events(i, saveCin, &readfds, &maxfd);}}}if(close(sfd) < 0){ERR_MSG("close");return -1;}return 0;
}//键盘输入事件
int keybord_events(fd_set readfds)
{char buf[128] = "";int sndfd = -1;             //从终端获取一个文件描述符，发送数据给该文件描述符对应的客户端bzero(buf, sizeof(buf));int res = scanf("%d %s", &sndfd, buf);while(getchar() != 10);if(res != 2)                //终端输入的数据格式错误{printf("输入数据的格式错误，：fd string\n");return -1;                                                                                                          }if(sndfd<=2 || FD_ISSET(sndfd, &readfds)==0)        //判断文件描述符的合法性{printf("非法的文件描述符：sndfd=%d\n", sndfd);return -1;}if(send(sndfd, buf, sizeof(buf), 0) < 0){ERR_MSG("send");return -1;}printf("send success\n");return 0;
}//客户端连接事件
int cliConnect_events(int sfd, struct sockaddr_in saveCin[], fd_set *preadfds, int *pmaxfd)
{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]客户端连接成功 newfd=%d\n", \inet_ntoa(cin.sin_addr), ntohs(cin.sin_port), newfd);saveCin[newfd] = cin;                       //将cin另存到newfd对应的下标位置去FD_SET(newfd, preadfds);                    //将newfd添加到集合中*pmaxfd = *pmaxfd>newfd ? *pmaxfd:newfd;    //更新maxfdreturn 0;
}//客户端交互事件
int cliRcvSnd_events(int fd, struct sockaddr_in* saveCin, fd_set *preadfds, int* pmaxfd)
{char buf[128] = "";//清空字符串bzero(buf, sizeof(buf));    //memset//接收ssize_t res = recv(fd, buf, sizeof(buf), 0);if(res < 0){ERR_MSG("recv");return -1;}else if(0 == res){printf("[%s:%d]客户端下线 newfd=%d\n", \inet_ntoa(saveCin[fd].sin_addr), ntohs(saveCin[fd].sin_port), fd);close(fd);              //关闭文件描述符FD_CLR(fd, preadfds);   //将文件描述符从集合中剔除//由于剔除的文件描述符可能是最大文件描述符，所以要更新maxfd //从大往小判断，若在集合中，则该文件描述符就是最大的文件描述符/*for(; *pmaxfd>=0; *pmaxfd--){if(FD_ISSET(*pmaxfd, preadfds))break;}*/while(FD_ISSET(*pmaxfd, preadfds)==0 && (*pmaxfd)-->=0);return 0;}printf("[%s:%d] newfd=%d : %s\n", \inet_ntoa(saveCin[fd].sin_addr), ntohs(saveCin[fd].sin_port), fd, buf);//发送strcat(buf, "*_*");if(send(fd, buf, sizeof(buf), 0) < 0){ERR_MSG("send");return -1;}printf("send success\n");return 0;
}

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

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

相关文章

Qt自定义菜单

Qt自定义菜单

Qt开发过程中&#xff0c;弹出菜单时我们一般使用QMenu,但是QMenu都是一条项固定的格式&#xff0c;如查想要自己的设计界面就没法使用默认的Action项了&#xff0c;因此我们得用自定义的QMenu。 本篇介绍使用自定义的QMenu设计出UI。我们使用QWidget QWidgetAction来实现。Q…
阅读更多...
Spring注册Bean系列--方法1：@Component

Spring注册Bean系列--方法1：@Component

原文网址&#xff1a;Spring注册Bean系列--方法1&#xff1a;Component_IT利刃出鞘的博客-CSDN博客 简介 本文介绍Spring注册Bean的方法&#xff1a;Component。 注册Bean的方法我写了一个系列&#xff0c;见&#xff1a;Spring注册Bean(提供Bean)系列--方法大全_IT利刃出鞘…
阅读更多...
前期开发用最内聚环境，最直观简单的方法管理代码

前期开发用最内聚环境，最直观简单的方法管理代码

代码稍微一多我们就会思考代码如何去规划和管理&#xff0c;首先想到MVN等管理工具去帮助我们&#xff0c;结果配置了好长时间感觉不是很方便。首先因为没有系统去了解这个工具的使用方法&#xff0c;另外发现IDEA在原本松散的工具之间以插件的形式做了一定的配置&#xff0c;将…
阅读更多...
数据分析三剑客之一：Numpy详解及实战

数据分析三剑客之一：Numpy详解及实战

1 NumPy介绍 NumPy 软件包是Python生态系统中数据分析、机器学习和科学计算的主力军。它极大地简化了向量和矩阵的操作处理。Python的一些主要软件包&#xff08;如 scikit-learn、SciPy、pandas 和 tensorflow&#xff09;都以 NumPy 作为其架构的基础部分。除了能对数值数据…
阅读更多...
基于Java的城市天然气费管理系统的设计与实现(源码+lw+部署文档+讲解等)

基于Java的城市天然气费管理系统的设计与实现(源码+lw+部署文档+讲解等)

文章目录 前言具体实现截图论文参考详细视频演示为什么选择我自己的网站自己的小程序&#xff08;小蔡coding&#xff09;有保障的售后福利 代码参考源码获取 前言 &#x1f497;博主介绍&#xff1a;✌全网粉丝10W,CSDN特邀作者、博客专家、CSDN新星计划导师、全栈领域优质创作…
阅读更多...
QT：鼠标画线(双画布)

QT：鼠标画线(双画布)

widget.h #ifndef WIDGET_H #define WIDGET_H#include <QWidget> #include <QPoint> //点 #include <QMouseEvent> //鼠标事件 #include <QPaintEvent> //绘图事件class Widget : public QWidget {Q_OBJECTpublic:Widget(QWidget *parent 0);~Wi…
阅读更多...
大模型 Decoder 的生成策略

大模型 Decoder 的生成策略

本文将介绍以下内容&#xff1a; IntroductionGreedy Searchbeam searchSamplingTop-K SamplingTop-p (nucleus) sampling总结 一、Introduction 1、简介 近年来&#xff0c;由于在数百万个网页数据上训练的大型基于 Transformer 的语言模型的兴起&#xff0c;开放式语言生…
阅读更多...
[题]修剪草坪 #单调队列优化

[题]修剪草坪 #单调队列优化

题目 洛谷上的题目 Acwing上的题目 根据y总的一波分析&#xff0c;我们得出……公式就是一切…… 所以&#xff0c;我要学会推公式…… 推公式…… 公式…… #include<bits/stdc.h> using namespace std; typedef long long ll; const int N 1e5 10; int n, m; ll s[N…
阅读更多...
Matlab随机数的产生

Matlab随机数的产生

目录 1、常见分布随机数的产生 1.1 二项分布 1.2 泊松分布 1.3 几何分布 1.4 均匀分布&#xff08;离散&#xff0c;等可能分布&#xff09; 1.5 均匀分布&#xff08;连续型等可能&#xff09; 1.6 指数分布&#xff08;描述“寿命”问题&#xff09; 1.7 正态分布 1.8…
阅读更多...
支持向量机SVM：从数学原理到实际应用

支持向量机SVM：从数学原理到实际应用

目录 一、引言背景SVM算法的重要性 二、SVM基础线性分类器简介什么是支持向量&#xff1f;超平面和决策边界SVM的目标函数 三、数学背景和优化拉格朗日乘子法&#xff08;Lagrange Multipliers&#xff09;KKT条件核技巧&#xff08;Kernel Trick&#xff09;双重问题和主问题&…
阅读更多...
[JAVAee]MyBatis

[JAVAee]MyBatis

目录 MyBatis简介 MyBatis的准备工作 框架的添加 连接数据库字符串的配置 MyBatis中XML路径的配置 ​编辑 MyBatis的使用 各层的实现 进行数据库操作 增加操作 拓展 修改操作 删除操作 查询操作 结果映射 单表查询 多表查询 like模糊查询 动态SQL / MyBa…
阅读更多...
传输层协议—UDP协议

传输层协议—UDP协议

传输层协议—UDP协议 文章目录 传输层协议—UDP协议传输层再谈端口号端口号范围划分pidofnetstat UDP协议端格式UDP报文UDP特点UDP缓冲区基于UDP的应用层协议 传输层 在学习HTTP/HTTPS等应用层协议时&#xff0c;为了方便理解&#xff0c;可以简单认为HTTP将请求和响应直接发送…
阅读更多...
【算法优选】双指针专题——贰

【算法优选】双指针专题——贰

文章目录 &#x1f60e;前言&#x1f332;[快乐数](https://leetcode.cn/problems/happy-number/)&#x1f6a9;题目描述&#x1f6a9;题⽬分析&#xff1a;&#x1f6a9;算法思路&#xff1a;&#x1f6a9;代码实现&#xff1a; &#x1f38b;[盛水最多的容器](https://leetco…
阅读更多...
CocosCreator3.8研究笔记（二十二）CocosCreator 动画系统-动画剪辑和动画组件介绍

CocosCreator3.8研究笔记（二十二）CocosCreator 动画系统-动画剪辑和动画组件介绍

国庆假期&#xff0c;闲着没事&#xff0c;在家研究技术~ 大家都知道在Cocos Creator3.x 的版本的动画编辑器中&#xff0c;可以实现不用写一行代码就能实现各种动态效果。 Cocos Creator动画编辑器中主要实现关键帧动画&#xff0c;不仅支持位移、旋转、缩放、帧动画&#xff…
阅读更多...
【算法】算法基础课模板大全

【算法】算法基础课模板大全

一、基础算法 快速排序算法模板 void quick_sort(int q[], int l, int r) {//递归的终止情况if (l > r) return;//选取分界线。这里选数组中间那个数int i l - 1, j r 1, x q[l r >> 1];//划分成左右两个部分while (i < j){do i ; while (q[i] < x);do …
阅读更多...
正点原子嵌入式linux驱动开发——TF-A初探

正点原子嵌入式linux驱动开发——TF-A初探

上一篇笔记中&#xff0c;正点原子的文档简单讲解了一下什么是TF-A&#xff0c;并且也学习了如何编译TF-A。但是TF-A是如何运行的&#xff0c;它的一个运行流程并未涉及。TF-A的详细运行过程是很复杂的&#xff0c;涉及到很多ARM处理器底层知识&#xff0c;所以这一篇笔记的内容…
阅读更多...
PHP 反序列化漏洞：__PHP_Incomplete_Class 与 serialize(unserialize($x)) !== $x；

PHP 反序列化漏洞：__PHP_Incomplete_Class 与 serialize(unserialize($x)) !== $x；

文章目录 参考环境声明__PHP_Incomplete_Class灵显为什么需要 __PHP_Incomplete_Class&#xff1f;不可访问的属性 serialize(unserialize($x)) $x;serialize(unserialize($x)) ! $x;雾现__PHP_Incomplete_Class 对象与其序列化文本的差异试构造 __PHP__Incomplete_Class 对象…
阅读更多...
UE5.1编辑器拓展【二、脚本化资产行为，快速更改资产名字,1.直接添加前缀或后缀2.通过资产类判断添加修改前缀】

UE5.1编辑器拓展【二、脚本化资产行为，快速更改资产名字,1.直接添加前缀或后缀2.通过资产类判断添加修改前缀】

目录 了解相关的函数 第一种做法&#xff1a;自定义添加选择资产的前缀或后缀 代码 效果 第二种做法&#xff1a;通过映射来获取资产类型添加前缀和修改前缀 映射代码 代码 效果 在之前一章中&#xff0c;我们创建了插件&#xff0c;用来扩展编辑器的使用&#xff1a; …
阅读更多...
VS Code 如何搭建 C/C++开发环境

VS Code 如何搭建 C/C++开发环境

目录 VScode是什么? VScode的下载和安装? 2.1 下载和安装 安装&#xff1a; 2.2 环境的介绍 环境介绍&#xff1a;​编辑 安装中文插件&#xff1a; VScode配置 C/C 开发环境 3.1 下载和配置MinGW-w64 编译器套件 下载&#xff1a; 配置MinGW64&#xff1a; 3.2 安…
阅读更多...
加入PreAuthorize注解鉴权之后NullPointerException报错

加入PreAuthorize注解鉴权之后NullPointerException报错

记录一次很坑的bug&#xff0c;加入PreAuthorize注解鉴权之后NullPointerException报错&#xff0c;按理来说没有权限应该403报错&#xff0c;但是这个是500报错&#xff0c;原因是因为controller层的service注入失败&#xff0c;然而我去掉注解后service注入成功&#xff0c;并…
阅读更多...
最新文章
推荐文章

Copyright @ 2022~2023