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…
阅读更多...
敏捷项目管理到底有什么价值？一篇说清楚

敏捷项目管理到底有什么价值？一篇说清楚

敏捷方法是一种理念&#xff0c;采用基于人员、协作和共同价值观的组织模型。它作为新兴的项目管理模式&#xff0c;简化了传统项目管理的繁琐流程和文档。敏捷方法采用波浪式规划&#xff08;rolling wave&#xff09;&#xff1b;迭代递增式交付&#xff1b;对变化做出快速而…
阅读更多...
交叉注意力融合时域、频域特征的FFT + CNN -BiLSTM-CrossAttention电能质量扰动识别模型

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

往期精彩内容&#xff1a; 电能质量扰动信号数据介绍与分类-Python实现-CSDN博客 Python电能质量扰动信号分类(一)基于LSTM模型的一维信号分类-CSDN博客 Python电能质量扰动信号分类(二)基于CNN模型的一维信号分类-CSDN博客 Python电能质量扰动信号分类(三)基于Transformer…
阅读更多...
电商数据分析23——利用数据分析优化电商平台的搜索功能

电商数据分析23——利用数据分析优化电商平台的搜索功能

目录 写在开头1. 电商搜索功能的重要性1.1 搜索功能对用户的购物体验的影响1.2 搜索功能对电商平台销售转化率的影响 2. 数据分析在搜索功能优化中的应用2.1 搜索查询日志分析2.2. 用户行为和偏好分析2.3. 搜索结果相关性和排序优化 3. 搜索功能优化的成功案例3.1 案例分享&…
阅读更多...
【python开发】并发编程和网络编程的结合+并发和并行概念区别+单例模式通过类来实现

【python开发】并发编程和网络编程的结合+并发和并行概念区别+单例模式通过类来实现

知识补充 一、并发编程&网络编程&#xff08;一&#xff09;多线程socket服务端&#xff08;二&#xff09;多进程&socket服务端 二、并发和并行三、单例模式 一、并发编程&网络编程 网络编程&#xff1a;基于网络基础知识、socket模块实现网络的数据传输&#xf…
阅读更多...
AI浸入社交领域,泛娱乐APP如何抓住新风口?

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

2023年是大模型技术蓬勃发展的一年&#xff0c;自ChatGPT以惊艳姿态亮相以来&#xff0c;同年年底多模态大模型技术在国内及全球范围内的全面爆发&#xff0c;即模型能够理解并生成包括文本、图像、视频、音频等多种类型的内容。例如&#xff0c;基于大模型的文本到图像生成工具…
阅读更多...
基于Python的图形用户界面设计及应用

基于Python的图形用户界面设计及应用

基于Python的图形用户界面设计及应用 摘要&#xff1a;随着信息技术的飞速发展&#xff0c;图形用户界面&#xff08;GUI&#xff09;已成为现代软件不可或缺的一部分。Python作为一种简洁、易读且功能强大的编程语言&#xff0c;提供了多种GUI开发工具包&#xff0c;如Tkinte…
阅读更多...
读锁和写锁（共享锁和排他锁）介绍 以及相关类 ReentrantReadWriteLock 学习总结，使用场景

读锁和写锁（共享锁和排他锁）介绍 以及相关类 ReentrantReadWriteLock 学习总结，使用场景

一、读锁和写锁概念 读锁&#xff1a; 也称共享锁&#xff0c;多个线程可以共享资源&#xff0c;同时读取数据和资源&#xff0c;但是不允许出现写操作。多个线程可以同时持有读锁&#xff0c;提高并发性能&#xff0c;因为不会对数据修改。 写锁&#xff1a; 也称排他锁&…
阅读更多...
实战纪实 | 从接口信息泄露到RCE

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

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

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

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

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

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

【Flutter和H5数据传递问题】window.postMessage方法引起的数据问题

Flutter 前言问题双引号问题请求数据问题 总结 前言 距离上一篇博客已经过了很长时间了&#xff0c;这次在做公司项目中又遇到了新的问题&#xff0c;决定还是写出来看看各位大神对此有什么看法&#xff0c;分享一下各位的想法。 问题 首先&#xff0c;公司项目的框架是由Fl…
阅读更多...
2024最新华为OD机试试题库全 -【执行时长】- C卷

2024最新华为OD机试试题库全 -【执行时长】- C卷

1. 🌈题目详情 1.1 ⚠️题目 为了充分发挥GPU算力，需要尽可能多的将任务交给GPU执行，现在有一个任务数组，数组元素表示在这1秒内新增的任务个数且每秒都有新增任务。 假设GPU最多一次执行n个任务，一次执行耗时1秒，在保证GPU不空闲情况下，最少需要多长时间执行完成。…
阅读更多...
Elasticsearch面试系列-01

Elasticsearch面试系列-01

1. 什么是 Elasticsearch？ ES是一种开源、RESTful、可扩展的基于文档的搜索引擎，它构建在Lucene库上。 用户使用Kibana就可以可视化使用数据，同时Kibana也提供交互式的数据状态呈现和数据分析。 Apache Lucene搜索引擎基于JSON文档来进行搜索管理和快速搜索。 Elasticse…
阅读更多...
图像分割在疾病诊断中的应用案例

图像分割在疾病诊断中的应用案例

图像分割在疾病诊断中的应用案例&#xff1a; 乳腺癌检测&#xff1a; 利用MRI图像&#xff0c;通过图像分割技术可以将乳腺组织与正常组织区分开来&#xff0c;进而检测出乳腺癌的早期迹象。 皮肤癌诊断&#xff1a; 对于皮肤镜下的图像&#xff0c;应用图像分割技术可以准确…
阅读更多...
【双指针】算法例题

【双指针】算法例题

目录 二、双指针 25. 验证回文数 ① 26. 判断子序列 ① 27. 两数之和II - 输入有序数组 ② 28. 盛最多水的容器 ② 29. 三数之和 ② 二、双指针 25. 验证回文数 ① 如果在将所有大写字符转换为小写字符、并移除所有非字母数字字符之后&#xff0c;短语正着读和反着读都一…
阅读更多...
Day60 (Golang) 单调栈 84.柱状图中最大的矩形

Day60 (Golang) 单调栈 84.柱状图中最大的矩形

// 84.柱状图中最大的矩形 package mainimport "fmt"func largestRectangleArea(heights []int) int {// 初始化单调栈&#xff08;单调递减栈&#xff09;stack : []int{0}res : 0// 给原数组首位添加0// 数组头部加入0heights append([]int{0}, heights...)// 数组…
阅读更多...
【EXPERIMENT】tmux、SCIP

【EXPERIMENT】tmux、SCIP

【EXPERIMENT】tmux、SCIP 一、TMUX命令&#xff08;一&#xff09;会话操作&#xff08;二&#xff09;窗口操作&#xff08;三&#xff09;窗格操作 二、SCIP安装 一、TMUX命令 &#xff08;一&#xff09;会话操作 新建会话 tmux new -s name退出会话 ctrl B D查看会话…
阅读更多...
C++_第三周做题总结_指针2

C++_第三周做题总结_指针2

id:13 A.月份查询&#xff08;指针数组&#xff09; 题目描述 已知每个月份的英文单词如下&#xff0c;要求创建一个指针数组&#xff0c;数组中的每个指针指向一个月份的英文字符串&#xff0c;要求根据输入的月份数字输出相应的英文单词 1月 January 2月 February 3月 Marc…
阅读更多...
行业回暖？这个行业岗位需求飙升6倍！程序员们提前恭喜了！

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

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

Copyright @ 2022~2023