6. 网络编程-网络io与select、poll，epoll

news2024/11/15 8:06:58

https://0voice.com/uiwebsite/html/courses/v13.7.html

首先看看这个学习计划

  1. 网络、网络编程、网络原理
  2. 基础组件，20个。
  3. 中间件 Redis ,MySQL，Kafka，RPC，Nginx
  4. 开源框架（解决方案）业务开发(工程师开发，写代码)
  5. Docker/K8S，产品角度
  6. 开源代码，写的闭源的。
    火焰图，bpf/ebpf
  7. 分布式，分布式DB，分布式fs。etcd
  8. 项目能与公司业务场景（dkvsstore，图床）

在这里插入图片描述
samba配置可以看这个链接

服务器客户端实现



#include<stdio.h>
#include<string.h>
#include<errno.h>

#include<unistd.h>
#include<sys/socket.h>
#include<netinet/in.h>

int main() {
	//open
	int sockfd = socket(AF_INET, SOCK_STREAM, 0);//io
	
	struct sockaddr_in servaddr;
	memset(&servaddr, 0, sizeof(struct sockaddr_in));//192.168.2.123
	servaddr.sin_family = AF_INET;
	servaddr.sin_addr.s_addr = htonl(INADDR_ANY);//0.0.0.0
	servaddr.sin_port = htons(9999);
	if (-1 == bind(sockfd, (struct sockaddr*)&servaddr, sizeof(struct sockaddr))) {
		printf("bind failed:%s",strerror(errno));
		return -1;
	}
	listen(sockfd, 10);
	getchar();
	
	
}

然后我们运行：

gcc -o multi-io multi-io.c
./multi-io

然后他会阻塞住：
在这里插入图片描述
在这里插入图片描述
然后我们进入一个可视化工具也是可以看的。
在这里插入图片描述
这时候我们已经收到了数据，但是还没有处理。我们上面写的代码就好比一个酒店的服务员。他是可以进去的，但是没有处理。这时候我们要给这个客户端分配一个服务员。



#include<stdio.h>
#include<string.h>
#include<errno.h>

#include<unistd.h>
#include<sys/socket.h>
#include<netinet/in.h>

int main() {
	//open
	int sockfd = socket(AF_INET, SOCK_STREAM, 0);//io
	
	struct sockaddr_in servaddr;
	memset(&servaddr, 0, sizeof(struct sockaddr_in));//192.168.2.123
	servaddr.sin_family = AF_INET;
	servaddr.sin_addr.s_addr = htonl(INADDR_ANY);//0.0.0.0
	servaddr.sin_port = htons(9999);
	if (-1 == bind(sockfd, (struct sockaddr*)&servaddr, sizeof(struct sockaddr))) {
		printf("bind failed:%s",strerror(errno));
		return -1;
	}
	listen(sockfd, 10);
	
#if 1
	struct sockaddr_in clientaddr;
	socklen_t len = sizeof(clientaddr);
	int clientfd = accept(sockfd, (struct sockaddr*)&clientaddr, &len);
	
#endif
	getchar();//block
}

一开始的代码阻塞在getchar()，我们一敲回车他就会退出，但是现在代码阻塞在客户端接收这部分了。
然后这时候我们在这个工具中一点击链接他就退出了。也就是有客户端连接他就往下走了。
在这里插入图片描述
然后这就引出一个概念，阻塞型IO和非阻塞型IO，阻塞型IO就是等待连接，没有连接就是一直等待着，等待条件满足了之后才往下走。
下面是非阻塞IO:



#include<stdio.h>
#include<string.h>
#include<errno.h>

#include<unistd.h>
#include<sys/socket.h>
#include<netinet/in.h>
#include<fcntl.h>

int main() {
	//open
	int sockfd = socket(AF_INET, SOCK_STREAM, 0);//io
	
	struct sockaddr_in servaddr;
	memset(&servaddr, 0, sizeof(struct sockaddr_in));//192.168.2.123
	servaddr.sin_family = AF_INET;
	servaddr.sin_addr.s_addr = htonl(INADDR_ANY);//0.0.0.0
	servaddr.sin_port = htons(9999);
	if (-1 == bind(sockfd, (struct sockaddr*)&servaddr, sizeof(struct sockaddr))) {
		printf("bind failed:%s",strerror(errno));
		return -1;
	}
	listen(sockfd, 10);
	
	sleep(10);
#if 1

	int flags = fcntl(sockfd, F_GETFL, 0);
	flags |= O_NONBLOCK;
	fcntl(sockfd, F_SETFL, flags);

	struct sockaddr_in clientaddr;
	socklen_t len = sizeof(clientaddr);
	int clientfd = accept(sockfd, (struct sockaddr*)&clientaddr, &len);
	
	printf("clientfd：%d", clientfd);
#endif
	getchar();//block
}

在这里插入图片描述
然后我们现在实现代码接收数据并且返回数据。

接发消息



#include<stdio.h>
#include<string.h>
#include<errno.h>

#include<unistd.h>
#include<sys/socket.h>
#include<netinet/in.h>
#include<fcntl.h>


#define BUFFER_LENGTE   1024
int main() {
	//open
	int sockfd = socket(AF_INET, SOCK_STREAM, 0);//io
	
	struct sockaddr_in servaddr;
	memset(&servaddr, 0, sizeof(struct sockaddr_in));//192.168.2.123
	servaddr.sin_family = AF_INET;
	servaddr.sin_addr.s_addr = htonl(INADDR_ANY);//0.0.0.0
	servaddr.sin_port = htons(9999);
	if (-1 == bind(sockfd, (struct sockaddr*)&servaddr, sizeof(struct sockaddr))) {
		printf("bind failed:%s",strerror(errno));
		return -1;
	}
	listen(sockfd, 10);
	
	//sleep(10);
#if 0
	printf("sleep\n");
	int flags = fcntl(sockfd, F_GETFL, 0);
	flags |= O_NONBLOCK;
	fcntl(sockfd, F_SETFL, flags);
#endif

	struct sockaddr_in clientaddr;
	socklen_t len = sizeof(clientaddr);
	int clientfd = accept(sockfd, (struct sockaddr*)&clientaddr, &len);
	

	printf("accept\n");
	char buffer[BUFFER_LENGTE] = { 0 };
	int ret = recv(clientfd,buffer, BUFFER_LENGTE,0);//接收数据
	printf("ret: %d,buffer：%s\n", ret,buffer);


	send(clientfd, buffer,ret,0);//将接收的数据在返回回去

	getchar();//block
}

在这里插入图片描述

这时候发现我们只能发一次。在上面的代码中有两个是阻塞的，一个是accept还要一个是recv,第一个是等待连接，第二个是等待收到消息。

多次接发消息

然后我们在这里引入一个循环，while(1)



#include<stdio.h>
#include<string.h>
#include<errno.h>

#include<unistd.h>
#include<sys/socket.h>
#include<netinet/in.h>
#include<fcntl.h>


#define BUFFER_LENGTE   1024
int main() {
	//open
	int sockfd = socket(AF_INET, SOCK_STREAM, 0);//io
	
	struct sockaddr_in servaddr;
	memset(&servaddr, 0, sizeof(struct sockaddr_in));//192.168.2.123
	servaddr.sin_family = AF_INET;
	servaddr.sin_addr.s_addr = htonl(INADDR_ANY);//0.0.0.0
	servaddr.sin_port = htons(9999);
	if (-1 == bind(sockfd, (struct sockaddr*)&servaddr, sizeof(struct sockaddr))) {
		printf("bind failed:%s",strerror(errno));
		return -1;
	}
	listen(sockfd, 10);
	
	//sleep(10);
#if 0
	printf("sleep\n");
	int flags = fcntl(sockfd, F_GETFL, 0);
	flags |= O_NONBLOCK;
	fcntl(sockfd, F_SETFL, flags);
#endif

	struct sockaddr_in clientaddr;
	socklen_t len = sizeof(clientaddr);
	int clientfd = accept(sockfd, (struct sockaddr*)&clientaddr, &len);
	

	printf("accept\n");

	while (1) {
		char buffer[BUFFER_LENGTE] = { 0 };
		int ret = recv(clientfd,buffer, BUFFER_LENGTE,0);//接收数据
		printf("ret: %d,buffer：%s\n", ret,buffer);
		send(clientfd, buffer,ret,0);//将接收的数据在返回回去
	}
	


	

	getchar();//block
}

然后这里就可以无线的接收和发送了。
在这里插入图片描述
这时候就又出现一个问题，我们这个代码只能有一个客户端。第二个客户端连接不上。然后就引入下面

多客户端

这里我们可以引入多线程



#include<stdio.h>
#include<string.h>
#include<errno.h>

#include<pthread.h>
#include<unistd.h>
#include<sys/socket.h>
#include<netinet/in.h>
#include<fcntl.h>


#define BUFFER_LENGTE   1024

void* client_thread(void* arg) {
	int clientfd = *(int*)arg;

	while (1) {
		char buffer[BUFFER_LENGTE] = { 0 };
		int ret = recv(clientfd, buffer, BUFFER_LENGTE, 0);//接收数据
		printf("ret: %d,buffer：%s\n", ret, buffer);
		send(clientfd, buffer, ret, 0);//将接收的数据在返回回去
	}
}


int main() {
	//open
	int sockfd = socket(AF_INET, SOCK_STREAM, 0);//io
	
	struct sockaddr_in servaddr;
	memset(&servaddr, 0, sizeof(struct sockaddr_in));//192.168.2.123
	servaddr.sin_family = AF_INET;
	servaddr.sin_addr.s_addr = htonl(INADDR_ANY);//0.0.0.0
	servaddr.sin_port = htons(9999);
	if (-1 == bind(sockfd, (struct sockaddr*)&servaddr, sizeof(struct sockaddr))) {
		printf("bind failed:%s",strerror(errno));
		return -1;
	}
	listen(sockfd, 10);
	
	//sleep(10);
#if 0
	printf("sleep\n");
	int flags = fcntl(sockfd, F_GETFL, 0);
	flags |= O_NONBLOCK;
	fcntl(sockfd, F_SETFL, flags);
#endif

	struct sockaddr_in clientaddr;
	socklen_t len = sizeof(clientaddr);
	
	

	printf("accept\n");

	while (1) {
		int clientfd = accept(sockfd, (struct sockaddr*)&clientaddr, &len);
#if 0		
		char buffer[BUFFER_LENGTE] = { 0 };
		int ret = recv(clientfd,buffer, BUFFER_LENGTE,0);//接收数据
		printf("ret: %d,buffer：%s\n", ret,buffer);
		send(clientfd, buffer,ret,0);//将接收的数据在返回回去
#else
		pthread_t threadid;
		pthread_create(&threadid, NULL,client_thread, &clientfd);//线程id,线程属性，线程的入口函数，入口函数的参数


#endif

	
	}
	


	

	getchar();//block
}

在这里插入图片描述
注意这里执行的时候要输入

gcc -o multi-io multi-io.c -lpthread

./multi-io

然后我们现在是1请求1线程。但是如果一个线程一个客户端这样代价很大的。然后下面是IO多路复用

IO多路复用

就是找一个秘书将着一堆的IO进行管理：
在这里插入图片描述
然后这io多路复用有三个东西，

  • select
  • poll
  • epoll
  • io_uring

select实现io多路复用

select(maxfd, rfds, wfds, efds, timeout);

五个参数，
第一个是maxfd，通过这个maxfd检测那些可读可写
第二个是rfds是可读的集合
第三个是wfds是可写的集合
第四个是efds是出错的集合
第五个是多长时间问一次
这个怎么理解呢，就是这里一共有50个io,这个select就像一个秘书一样，看看那些io是需要写的，那些io是需要读的。比如说这里有10个io是需要可读的那么这10个就是rfds集合。20个io是需要可写的，那么这个20就是wfds。

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

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

相关文章

【C语言】5.C语言函数（2）

【C语言】5.C语言函数（2）

文章目录 7.嵌套调⽤和链式访问7.1 嵌套调⽤7.2 链式访问 8.函数的声明和定义8.1 单个⽂件8.2 多个⽂件8.3 static 和 extern8.3.1 static 修饰局部变量8.3.2 static 修饰全局变量8.3.3 static 修饰函数 7.嵌套调⽤和链式访问 7.1 嵌套调⽤ 嵌套调用就是函数之间的互相调用。…
阅读更多...
震撼发布！GPT-4o 上线！

震撼发布！GPT-4o 上线！

5 月 14日凌晨一点&#xff0c;OpenAI 发布了 GPT-4o&#xff01; 新模型的功能简单概括就是&#xff1a;更快、更智能、更像人类。 秉承着持续更新的态度&#xff0c;Hulu AI 快速接入 GPT-4o 啦&#xff01; 继 5 月份上线 Suno 之后&#xff0c;这次是 Hulu AI 的又一重大…
阅读更多...
Android 应用开发-实现将公共存储空间内的文件复制到应用的私用存储空间中

Android 应用开发-实现将公共存储空间内的文件复制到应用的私用存储空间中

一、前言 几个月前&#xff0c;我用Android Studio给公司销售部门的同事开发了一款手机app&#xff0c;让同事们用自己的手机就能进行商品的扫码盘点操作&#xff0c;帮他们提高了工作效率&#xff0c;他们用了一段时间&#xff0c;反映还不错。不过前几天&#xff0c;销售部门…
阅读更多...
Mysql 事务隔离级别

Mysql 事务隔离级别

前言 在数据库管理系统中&#xff0c;事务&#xff08;Transaction&#xff09;是保证数据一致性和完整性的重要机制。在并发环境下&#xff0c;多个事务同时操作相同的数据可能会引发各种问题&#xff0c;如脏读、不可重复读、幻读等。为了解决这些问题&#xff0c;MySQL提供…
阅读更多...
腾讯开源混元DiT文生图模型，消费级单卡可推理

腾讯开源混元DiT文生图模型，消费级单卡可推理

节前&#xff0c;我们组织了一场算法岗技术&面试讨论会&#xff0c;邀请了一些互联网大厂朋友、今年参加社招和校招面试的同学。 针对大模型技术趋势、大模型落地项目经验分享、新手如何入门算法岗、该如何准备面试攻略、面试常考点等热门话题进行了深入的讨论。 总结链接…
阅读更多...
script标签以及defer和async属性

script标签以及defer和async属性

1. <script>标签 将JavaScript代码嵌入到HTML中主要方式是使用<script>元素。 使用<script>的方式有两种&#xff1a; &#xff08;1&#xff09;直接在网页中嵌入JavaScript代码&#xff1a; <script>function sayHi() {console.log("Hi"…
阅读更多...
基于springboot+vue+Mysql的大学生社团活动平台

基于springboot+vue+Mysql的大学生社团活动平台

开发语言&#xff1a;Java框架&#xff1a;springbootJDK版本&#xff1a;JDK1.8服务器&#xff1a;tomcat7数据库&#xff1a;mysql 5.7&#xff08;一定要5.7版本&#xff09;数据库工具&#xff1a;Navicat11开发软件&#xff1a;eclipse/myeclipse/ideaMaven包&#xff1a;…
阅读更多...
PCIE协议-2-事务层规范-Transaction Ordering

PCIE协议-2-事务层规范-Transaction Ordering

2.4.1 事务排序规则 表2-40定义了PCI Express事务的排序要求。此表中定义的规则适用于PCI Express上的所有事务类型&#xff0c;包括内存、I/O、配置和消息事务。在单个流量类别&#xff08;Traffic Class&#xff0c;TC&#xff09;内&#xff0c;这些排序规则适用。不同TC标…
阅读更多...
VUE之旅—day2

VUE之旅—day2

文章目录 Vue生命周期和生命周期的四个阶段created应用—新闻列表渲染mounted应用—进入页面搜索框就获得焦点账单统计&#xff08;Echarts可视化图表渲染&#xff09; Vue生命周期和生命周期的四个阶段 思考&#xff1a; 什么时候可以发送初始化渲染请求&#xff1f;&#xff…
阅读更多...
经验分享智能产品从0到1全流程

经验分享智能产品从0到1全流程

大家好&#xff0c;今天继续分享文章&#xff0c;这篇文章在网络上搜索资料时&#xff0c;有感而发&#xff0c;分享一个智能产品从0到1的整个生命周期中需要经历哪些阶段&#xff0c;我这里以开发一个mini补光灯为例&#xff0c;深入探索各个阶段可能涉及的具体活动和考虑事项…
阅读更多...
记录计全支付切换到RabbitMQ时启动报错的问题

记录计全支付切换到RabbitMQ时启动报错的问题

记录计全支付切换到RabbitMQ时启动报错的问题 首先在application.yml中切换到RabbitMQ配置安装RabbitMQ、Erlang、延时插件 rabbitmq_delayed_message_exchange&#xff0c;延迟插件必装 首先在application.yml中切换到RabbitMQ配置 # 第一处rabbitmq:addresses: 127.0.0.1:56…
阅读更多...
TRL校准和De-embedding的区别以及如何操作？

TRL校准和De-embedding的区别以及如何操作？

Fiture的性能可以在测试前利用TRL校准件移除掉&#xff0c;但是TRL的步骤比较繁琐或者说TRL校准件&#xff08;包含直通、反射、多条Line&#xff09;很难设计(如果做到很高的频率对设计和加工制造的要求都很高)&#xff0c;此时可以选择只做一根2x Through&#xff08;直通件&…
阅读更多...
电脑常用的PDF阅读器-嗨动PDF编辑器！带你详细了解它

电脑常用的PDF阅读器-嗨动PDF编辑器！带你详细了解它

电脑常用的PDF阅读器-嗨动PDF编辑器&#xff01;在数字化信息爆炸的时代&#xff0c;PDF格式的文件因其易于打印和保留原始格式等优点&#xff0c;成为了人们日常工作和学习的常用格式。而对于PDF文件的处理&#xff0c;一款功能强大、操作简便的PDF阅读器是必不可少的。今天&a…
阅读更多...
世界500强企业建设软件开发安全体系，打造DevSecOps示范标杆

世界500强企业建设软件开发安全体系，打造DevSecOps示范标杆

某世界500强企业旗下拥有众多知名汽车品牌&#xff0c;业务涵盖出行服务、科技创新、金融服务、教育等。该集团一直专注于技术创新和人才培养&#xff0c;同时也是国内第一批倡议并践行“数字化转型”的汽车行业企业。 数智化建设转型&#xff0c;研发安全体系建设势在必行 在…
阅读更多...
C#【进阶】委托和事件

C#【进阶】委托和事件

委托和事件 文章目录 1、委托1、委托概念2、基本语法3、定义自定义委托4、使用自定义委托5、委托变量可以存储多个函数6、系统定义好的委托思考 怪物死亡数据更新 2、事件1、事件概念2、事件的使用3、为什么有事件思考 热水器 3、匿名函数1、匿名函数概念2、基本语法3、使用4、…
阅读更多...
27_Scala功能函数

27_Scala功能函数

文章目录 功能函数1.功能函数处理集合数据2.扁平化操作3.按照指定条件将数据集中的数据进行过滤4.集合通过 自定义函数进行分组5.mapValues6.sortBy函数 功能函数 1.功能函数处理集合数据 –集合的功能函数 map List --> map( logical ) --> newList–实现一个不确定的…
阅读更多...
Blender雕刻建模流程

Blender雕刻建模流程

1.构形 先构造一个大致相像的外形 可使用的方法包含 -多边形&#xff1a;表面细分&#xff0c;布尔 -曲线&#xff1a;曲线倒角 -融球&#xff08;使用较少&#xff09; -曲面&#xff08;使用较少&#xff09; 构形之后的准备 -应用缩放 -应用修改器 -曲线转网格 1.1…
阅读更多...
8个迹象表明你需要一台新笔记本电脑，看一下你的笔记本是否有其中一个

8个迹象表明你需要一台新笔记本电脑，看一下你的笔记本是否有其中一个

序言 当你第一次打开你的笔记本电脑的盒子时，它会以最高性能运行，电池寿命更长，过热最小，资源使用效率高。然而，随着笔记本电脑的老化，它将不能满足预期用途。以下几个迹象表明，可能是时候寻找并投资一款新设备了。 你的设备不再具有预期用途 如果你的笔记本电脑不再…
阅读更多...
战网国际服注册教程 暴雪战网国际服账号注册一站式教程分享

战网国际服注册教程 暴雪战网国际服账号注册一站式教程分享

战网国际版&#xff0c;也即Battle.net环球版&#xff0c;是由暴雪娱乐操刀的全球化游戏交流枢纽&#xff0c;它突破地理限制&#xff0c;拥抱全世界的游戏玩家。与仅限特定地区的版本不同&#xff0c;国际版为玩家开辟了无障碍通道&#xff0c;让他们得以自由探索暴雪庞大游戏…
阅读更多...
MacOS docker 安装与配置

MacOS docker 安装与配置

orbstack 安装 官网&#xff1a; https://orbstack.dev 下载链接&#xff1a;Download OrbStack Fast, light, simple Docker Desktop alternative 选择是Apple M系列处理器&#xff0c; 或 Intel系列处理器 到这里就安装好了Orbstack软件&#xff0c;下面开始配置docker 下…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023