IO多分复用

#include<myhead.h>
#define SER_PORT 8888           //服务器端口号
#define SER_IP "192.168.65.131"  //服务器IPint main(int argc, const char *argv[])
{//1、创建一个套接字int sfd = -1;sfd = socket(AF_INET, SOCK_STREAM, 0);    //参数1：表示创建的是网络通信的套接字//参数2：表示使用的是TCP通信协议//参数3：参数2指定了协议，参数3填0即可if(sfd == -1){perror("socket error");return -1;}printf("%d success sfd = %d\n", __LINE__, sfd);   //3//设置端口号快速重用int reuse = 1;if(setsockopt(sfd, SOL_SOCKET, SO_REUSEADDR, &reuse, sizeof(reuse)) ==-1){perror("setsockopt error");return -1;}printf("端口号快速重用成功\n");//2、绑定IP地址和端口号//2.1填充地址信息结构体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地址//2.2 绑定if(bind(sfd, (struct sockaddr *)&sin, sizeof(sin)) ==-1){perror("bind error");return -1;}printf("%d  bind success\n", __LINE__);//3、将套接字设置成被动监听状态if(listen(sfd, 128) == -1){perror("listen error");return -1;}printf("%d  listen success\n", __LINE__);//4、阻塞等待客户端的链接请求int newfd = -1;//定义结构体变量接收对方地址信息结构体struct sockaddr_in cin; //用于接收客户端地址信息结构体socklen_t addrlen = sizeof(cin);  //用于接收客户端结构体的大小char sbuf[128] = "";   //服务器输入数据内容//11、定义一个文件描述符集合fd_set readfds,tempfds;//22、将集合清空FD_ZERO(&readfds);//33、将要被检测的文件描述符放入集合FD_SET(0, &readfds);FD_SET(sfd, &readfds);int maxfd = sfd; //记录容器中的最大文件描述符struct sockaddr_in cin_arr[1024];  //存储客户端地址信息结构体的数组while(1){tempfds = readfds;int 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, &tempfds)){continue;}//判断sfd是否触发事件//程序运行至此代表i文件描述符触发了事件if(i == sfd){if((newfd = accept(sfd, (struct sockaddr*)&cin, &addrlen)) == -1){perror("accept error");return -1;}printf("[%s  %d]:发来连接请求\n", inet_ntoa(cin.sin_addr), ntohs(cin.sin_port));//将客户端地址信息结构体放入数组容器中cin_arr[newfd] = cin;//将newfd放入容器中检测FD_SET(newfd,&readfds);//可能需要更新maxfdif(newfd > maxfd){maxfd = newfd;}   }//判断0号描述符是否为触发事件else if(0 == i){fgets(sbuf,sizeof(sbuf),stdin);sbuf[strlen(sbuf)-1] = 0;printf("触发了键盘输入事件:%s\n",sbuf);//将消息发送给所有客户端for(int i=4;i<=maxfd;i++){send(i,sbuf,sizeof(sbuf),0);}printf("发送成功\n");}else{//说明有客户端发来消息了，遍历所有客户端，看是哪一个发来的消息//5收发数据char rbuf[128] = "";       //用于接收客户发发来的数据//将容器清空bzero(rbuf, sizeof(rbuf));     //memset(rbuf, 0, sizeof(rbuf));//从套接字中读取数据‘int res = recv(i, rbuf, sizeof(rbuf)-1, 0);   if(res == 0){printf("客户端已经下线\n");//关闭套接字close(i);//将当前文件描述符移除容器FD_CLR(i,&readfds);//可能需要更新maxfdfor(int k=maxfd;k>=sfd;k--){if(FD_ISSET(k,&readfds)){maxfd = k;break;}}continue;}printf("[%s  %d]: %s\n", inet_ntoa(cin.sin_addr), ntohs(cin.sin_port), rbuf);//加个笑脸再回回去strcat(rbuf,"*_*");send(newfd, rbuf, strlen(rbuf), 0);printf("发送成功\n");}}}//6、关闭服务器close(sfd);return 0;
}

#include<myhead.h>
#define SER_PORT 8888
#define SER_IP "192.168.117.74"
#define CLI_PORT 9999
#define CLI_IP "192.168.117.74"int main(int argc, const char *argv[])
{//1、创建用于连接的客户端套接字int cfd = socket(AF_INET, SOCK_STREAM, 0);if(cfd == -1){perror("socket error");return -1;}printf("socket success cfd = %d\n", cfd);        //3//设置端口号快速重用int reuse = 1;if(setsockopt(cfd, SOL_SOCKET, SO_REUSEADDR, &reuse, sizeof(reuse)) ==-1){perror("setsockopt error");return -1;}printf("端口号快速重用成功\n");//2、绑定端口号和ip地址(非必须)//2.1 填充客户端地址信息结构体struct sockaddr_in cin;cin.sin_family = AF_INET;cin.sin_port = htons(CLI_PORT);cin.sin_addr.s_addr = inet_addr(CLI_IP);//2.2 绑定端口号和IPif(bind(cfd, (struct sockaddr*)&cin, sizeof(cin)) == -1){perror("bind error");return -1;}printf("bind success\n");//3、连接服务器//3.1 填充要连接服务器的地址信息结构体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地址//3.2 连接服务器if(connect(cfd, (struct sockaddr*)&sin, sizeof(sin)) == -1){perror("connect error");return -1;}printf("连接成功!\n");//使用poll完成0号文件描述符和cfd文件描述符的多路复用//11、准备文件描述符容器struct pollfd pfds[2];pfds[0].fd = 0; //文件描述符pfds[0].events = POLLIN;    //检测读事件pfds[1].fd = cfd;       //文件描述符pfds[1].events = POLLIN;    //检测读事件//4、收发数据char wbuf[128] = "";while(1){int res = poll(pfds, 2, -1);        //阻塞检测集合中是否有事件产生if(res == -1){perror("poll error");return -1;}else if(res == 0){printf("time out\n");return -1;}//程序执行至此，说明检测的文件描述符集合中有事件产生//判断是否为0号文件描述符产生事件if(pfds[0].revents == POLLIN){fgets(wbuf, sizeof(wbuf), stdin);    //从终端上获取一个字符串wbuf[strlen(wbuf)-1] = '\0';      //将换行换成 '\0'//判断输入的字符串值if(strcmp(wbuf, "quit") ==0){break;}//将数据发送给服务器send(cfd, wbuf, strlen(wbuf), 0);}//判断释放为cfd文件描述符中产生事件if(pfds[1].revents == POLLIN){//将字符数组清空bzero(wbuf, sizeof(wbuf));recv(cfd, wbuf, sizeof(wbuf)-1, 0);printf("收到服务器消息为：%s\n", wbuf);}}//5、关闭套接字close(cfd);return 0;
}

模拟面试总结:

TCP通信中的三次握手和四次挥手？
三次握手：服务器向客户端发送连接请求-->客户端回应服务器的连接请求-->二者建立联系成功
四次挥手：服务器向客户端发送断开连接请求-->客户端回应服务器的断开请求，回应知道要断开链接了 -->客户端向服务器发送断开连接请求-->断开连接成功
并发和并行的区别？
并发：单核CPU中多个任务交叉执行是并发。
并行：多核CPU同时处理多个任务称为并行。
阻塞IO和非阻塞IO的区别？
阻塞IO会等待阻塞事件的产生，如果没有发生会一直阻塞后面函数的执行 。
非阻塞IO如果没有等到事件发生，会立刻返回 ，执行后续的任务。
同步和异步的区别？
同步表示任务有顺序的执行，而异步表示任务没有顺序的执行。
广播的相关内容？
一对多UDP的通信方式实现，广播地址为网络号+255的主机号，发送端类似与UDP的客户端，接收端类似于UDP的服务器端。
组播的相关内容？
D类网络地址，需要对接收端加入多播组属性，发送端类似与UDP的客户端，接收端类似于UDP的服务器端，同样也是使用一对多的UDP通信。
在使用套接字通信时，客户端一定不需要绑定操作吗？
不一定。如果不绑定套接字，系统不会自动绑定IP地址和端口号，服务器无法向客户端发送消息。
目前进程间的通信方式有哪些？
信号，信号灯集，共享内存，消息队列，套接字，有无名管道。
线程的同步互斥机制？
引入同步互斥机制是为了对临界区进行保护。
互斥机制：当多个线程拥有临界资源的临界区时，只要有一个线程在操作这个临界区，那么其他的线程均不可以拥有临界资源的临界区。

同步机制：通过互斥的手段安排好每一个线程的运行顺序，相当于有规律的互斥。

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

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

相关文章

MyBatis是纸老虎吗？（四）

MyBatis是纸老虎吗？（四）

在《MyBatis是纸老虎吗&#xff1f;&#xff08;三&#xff09;》这篇文章中我们一起梳理了MyBatis配置文件的解析流程&#xff0c;并详细介绍了其中的一些常见节点的解析步骤。通过梳理&#xff0c;我们弄清楚了MyBatis配置文件中的一些常用配置项与Java Bean之间的对应关系&a…
阅读更多...
交叉注意力融合时域、频域特征的FFT + CNN -BiLSTM-CrossAttention电能质量扰动识别模型

交叉注意力融合时域、频域特征的FFT + CNN -BiLSTM-CrossAttention电能质量扰动识别模型

往期精彩内容&#xff1a; 电能质量扰动信号数据介绍与分类-Python实现-CSDN博客 Python电能质量扰动信号分类(一)基于LSTM模型的一维信号分类-CSDN博客 Python电能质量扰动信号分类(二)基于CNN模型的一维信号分类-CSDN博客 Python电能质量扰动信号分类(三)基于Transformer…
阅读更多...
AI浸入社交领域,泛娱乐APP如何抓住新风口?

AI浸入社交领域,泛娱乐APP如何抓住新风口?

2023年是大模型技术蓬勃发展的一年&#xff0c;自ChatGPT以惊艳姿态亮相以来&#xff0c;同年年底多模态大模型技术在国内及全球范围内的全面爆发&#xff0c;即模型能够理解并生成包括文本、图像、视频、音频等多种类型的内容。例如&#xff0c;基于大模型的文本到图像生成工具…
阅读更多...
实战纪实 | 从接口信息泄露到RCE

实战纪实 | 从接口信息泄露到RCE

打点 开局一个登录框 信息收集 发现了一处接口泄露了部分信息 不过只有支付宝密钥的信息无法扩大危害&#xff0c;此时尝试寻找了一下其他同类型系统同样的接口&#xff0c;查看一下是否泄露的信息相同 因为如果相同就说明是静态的&#xff0c;没有价值 横向收集 此时访问其…
阅读更多...
后端系统开发之——接口参数校验

后端系统开发之——接口参数校验

今天难得双更&#xff0c;大家点个关注捧个场 原文地址&#xff1a;后端系统开发之——接口参数校验 - Pleasure的博客 下面是正文内容&#xff1a; 前言 在上一篇文章中提到了接口的开发&#xff0c;虽然是完成了&#xff0c;但还是缺少一些细节——传入参数的校验。 即用户…
阅读更多...
JMeter 并发测试和持续性压测详解

JMeter 并发测试和持续性压测详解

并发测试和持续性压测都是评估系统性能的常用方法&#xff0c;它们可以帮助开发人员发现并解决系统中的性能问题。本文来详细介绍下。 概念 并发测试&#xff1a; 旨在评估系统在同时处理多个用户请求时的性能。在这种 测试 中&#xff0c;系统会暴露于一定数量的用户负载下&…
阅读更多...
【双指针】算法例题

【双指针】算法例题

目录 二、双指针 25. 验证回文数 ① 26. 判断子序列 ① 27. 两数之和II - 输入有序数组 ② 28. 盛最多水的容器 ② 29. 三数之和 ② 二、双指针 25. 验证回文数 ① 如果在将所有大写字符转换为小写字符、并移除所有非字母数字字符之后&#xff0c;短语正着读和反着读都一…
阅读更多...
行业回暖？这个行业岗位需求飙升6倍！程序员们提前恭喜了！

行业回暖？这个行业岗位需求飙升6倍！程序员们提前恭喜了！

前言 随着今年史上最长春节假期正式收官&#xff0c;各行各业相继进入开工节奏&#xff0c;就业市场开启持续升温模式。 今年开工首周&#xff0c;人才需求增长明显&#xff0c;求职者活跃度大大增多&#xff0c;就业市场进入了繁忙有序的节奏&#xff0c;呈现出春招市场的勃…
阅读更多...
QT网络编程之获取本机网络信息

QT网络编程之获取本机网络信息

一.概述 查询一个主机的MAC地址或者IP地址是网络应用中常用到的功能&#xff0c;Qt提供了QHostInfo和QNetworkInterface 类可以用于此类信息的查询 1.QHostInfo 类&#xff08;显示和查找本地的信息&#xff09; 2.QNetworkInterface 类&#xff08;获得应用程序上所在主机的…
阅读更多...
在window命令行中，使用conda创建新的虚拟环境时出现的问题以及解决办法

在window命令行中，使用conda创建新的虚拟环境时出现的问题以及解决办法

一.出现的问题 C:\Users\zhu>conda create -n ML python3.8 Collecting package metadata (current_repodata.json): failedCondaHTTPError: HTTP 000 CONNECTION FAILED for url <https://mirrors.tuna.tsinghua.edu.cn/anaconda/pkgs/main/win-64/current_repodata.js…
阅读更多...
南京大学AI考研，宣布改考408！

南京大学AI考研，宣布改考408！

官网还没通知 附上南大与同层次学校近四年的分数线对比&#xff0c;整体很难 添加图片注释&#xff0c;不超过 140 字&#xff08;可选&#xff09; 添加图片注释&#xff0c;不超过 140 字&#xff08;可选&#xff09; 如果确定要冲南大的话建议提早调整自己的复习路线&…
阅读更多...
Combining external-latent attention for medical image segmentation

Combining external-latent attention for medical image segmentation

结合外部潜在注意的医学图像分割 摘要 注意机制是提高医学图像分割性能的新切入点。如何合理分配权重是注意力机制的关键，目前流行的方法包括全局压缩和使用自注意操作的非局部信息交互。然而，这些方法过于关注外部特征，缺乏对潜在特征的开发。全局压缩方法通过全局均值或…
阅读更多...
介绍5款 世界范围内比较广的 5款 mysql Database Management Tool

介绍5款 世界范围内比较广的 5款 mysql Database Management Tool

介绍5款 世界范围内比较广的 5款 Mysql Database Management Tool 文章目录 介绍5款 世界范围内比较广的 5款 Mysql Database Management Tool前言MySQL Workbench&#xff1a;Navicat Premium&#xff1a;DBeaver Community&#xff1a;HeidiSQL&#xff1a;SQLyog&#xff1a…
阅读更多...
如何解决node-sass下载用的还是过期的淘宝源？

如何解决node-sass下载用的还是过期的淘宝源？

下载node-sass发现报错过期的证书 把npm的淘宝源换成最新的https://registry.npmmirror.com后发现还是指向了以前的淘宝源&#xff0c;看到一位博主说&#xff0c;单改npm源不够还要改下载node-sass的源&#xff0c;再次搜索另外一位博主提供了命令npm config ls可以使用它来查…
阅读更多...
文件包含漏洞之包含NGINX日志文件（常用）

文件包含漏洞之包含NGINX日志文件（常用）

条件&#xff1a;知道目标服务器的日志文件存贮路径&#xff0c;并且存在文件包含漏洞 首先对目标服务器发送一次含有木马的请求&#xff0c;目的是让目标服务器日志中生成含有木马的日志记录。因为发送过程中&#xff0c;使用了url编码&#xff0c;我们抓包进行更改成能够执行…
阅读更多...
图文详解io_uring高性能异步IO架构

图文详解io_uring高性能异步IO架构

说到高性能网络编程&#xff0c;我们第一时间想到的是epoll机制&#xff0c;epoll很长一段时间统治着整个网络编程江湖&#xff0c;然而io_uring的出现&#xff0c;似乎在撼动epoll的统治地位&#xff0c;今天我们来揭开io_uring的神秘面纱。 1.io_uring简介 io_uring是一个L…
阅读更多...
竞赛 - 基于机器视觉的图像拼接算法

竞赛 - 基于机器视觉的图像拼接算法

前言 图像拼接在实际的应用场景很广&#xff0c;比如无人机航拍&#xff0c;遥感图像等等&#xff0c;图像拼接是进一步做图像理解基础步骤&#xff0c;拼接效果的好坏直接影响接下来的工作&#xff0c;所以一个好的图像拼接算法非常重要。 再举一个身边的例子吧&#xff0c;…
阅读更多...
express+mysql+vue,从零搭建一个商城管理系统16--收货地址（全国省市县名称和code列表）

express+mysql+vue,从零搭建一个商城管理系统16--收货地址（全国省市县名称和code列表）

提示&#xff1a;学习express&#xff0c;搭建管理系统 文章目录 前言一、新建config/area.js二、新建models/address.js三、新建dao/address.js四、新建routes/address.js五、添加地址六、查询用户地址列表总结 前言 需求&#xff1a;主要学习express&#xff0c;所以先写serv…
阅读更多...
浅谈大模型“幻觉”问题

浅谈大模型“幻觉”问题

大模型的幻觉大概来源于算法对于数据处理的混乱&#xff0c;它不像人类一样可以by the book&#xff0c;它没有一个权威的对照数据源。 什么是大模型幻觉 大模型的幻觉&#xff08;Hallucination&#xff09;是指当人工智能模型生成的内容与提供的源内容不符或没有意义的现象。…
阅读更多...
SpringCloud Gateway工作流程

SpringCloud Gateway工作流程

Spring Cloud Gateway的工作流程 具体的流程&#xff1a; 用户发送请求到网关 请求断言&#xff0c;用户请求到达网关后&#xff0c;由Gateway Handler Mapping&#xff08;网关处理器映射&#xff09;进行Predicates&#xff08;断言&#xff09;&#xff0c;看一下哪一个符合…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023