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

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。

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

如若内容造成侵权/违法违规/事实不符，请联系我们进行投诉反馈qq邮箱809451989@qq.com，一经查实，立即删除！

相关文章

YOLOv9训练自己的数据集：最新最详细教程

YOLOv9训练自己的数据集：最新最详细教程

一、代码及论文链接&#xff1a; 代码链接&#xff1a;https://github.com/WongKinYiu/yolov9/tree/main 论文链接&#xff1a;https://arxiv.org/abs/2402.13616 二、使用步骤 1.1 虚拟环境配置 创建一个虚拟环境用于单独对yolov9的环境进行配置&#xff1a; conda crea…
阅读更多...
Java中的数组、Set、List、Map类型的互相转换总结

Java中的数组、Set、List、Map类型的互相转换总结

序言 数组、Set、List、Map是Java语言非常常用的几种数据类型&#xff0c;他们之间存在着千丝万缕的联系。关于底层的数据结构我这里就不再多说啦&#xff0c;直接从应用出发&#xff0c;总结他们之间的转换方法&#xff0c;并给出推荐方法。 大家可以点赞收藏等到需要的时候…
阅读更多...
传说中的运维门户设计

传说中的运维门户设计

在IT服务管理这片广阔天地中&#xff0c;运维门户如同一位技艺高超的魔术师&#xff0c;轻轻一挥手&#xff0c;便将纷繁复杂的运维世界化繁为简&#xff0c;编织成一张便捷高效、触手可及的网络。它不仅是ITSM系统中不可或缺的一环&#xff0c;更是连接用户与技术世界的桥梁&a…
阅读更多...
【打字】打字训练之针对性键盘区域练习

【打字】打字训练之针对性键盘区域练习

本文章的核心点是&#xff1a;使用代码生成自己想要训练的键位的词汇&#xff0c;然后导入到打字软件针对性练习 一个程序员突然想纠正打字习惯源于腱鞘炎&#xff0c;虽然使用双拼打字已经不慢了&#xff0c;但是姿势不是很正确&#xff0c;导致了腱鞘炎。 所以想着好好纠正指…
阅读更多...
就这？轻轻松松在RK356X Android11适配ML307R Cat.1模组

就这？轻轻松松在RK356X Android11适配ML307R Cat.1模组

开源鸿蒙硬件方案领跑者 触觉智能 Industio 本文基于IDO-SXB3568主板&#xff0c;介绍Android11平台上适配中移物联ML307R Cat.1 4G模组的方法。该方法适用于触觉所有RK356X的主板。 IDO-SXB3568是触觉智能推出的RK3568行业主板&#xff0c;预计6月上旬正式上架售卖。该行业主…
阅读更多...
Docker安装Mosquitto

Docker安装Mosquitto

在物联网项目中&#xff0c;我们经常用到MQTT协议&#xff0c;用MQTT协议做交互就需要部署一个MQTT服务&#xff0c;而mosquitto是一个常用的MQTT应用服务&#xff0c; Mosquitto是一个实现了消息推送协议MQTT v3.1的开源消息代理软件。MQTT&#xff08;Message Queuing Teleme…
阅读更多...
【淘宝超高价女装】电商最好项目：一单赚1000多

【淘宝超高价女装】电商最好项目：一单赚1000多

课程目录 01.【超高价女装】项目介绍实操案例 02.【超高价女装】找款&#xff1a;配得上1000多的款式 03.【超高价女装】软件上款&#xff1a;600个款为底 04.【超高价女装】标题&#xff1a;能卖1000多的标题 05.【超高价女装】销量布局&#xff1a;主推款做销量评价 06…
阅读更多...
【python量化交易】—— Alpha选股策略 - Qteasy自定义交易策略【附源码】

【python量化交易】—— Alpha选股策略 - Qteasy自定义交易策略【附源码】

使用qteasy创建并回测Alpha选股交易策略 使用qteasy创建并回测Alpha选股交易策略策略思想第一种自定义策略设置方法&#xff0c;使用持仓数据和选股数据直接生成比例交易信号PS信号&#xff1a;第二种自定义策略设置方法&#xff0c;使用PT交易信号设置持仓目标&#xff1a;第三…
阅读更多...
代码审计--变量覆盖

代码审计--变量覆盖

漏洞原理 变量覆盖(Dynamic Variable Evaluation) 是指变量未被初始化&#xff0c; 而我们自定义的变量可以替换程序原有的变量值。 相关函数 $$ &#xff0c; extract &#xff0c; parse_str &#xff0c; import_request_variables 等等 这里涉及到一个安全函数&#xf…
阅读更多...
嬴政只比刘邦大三岁，项羽竟是比刘邦小24岁的小老弟？

嬴政只比刘邦大三岁，项羽竟是比刘邦小24岁的小老弟？

大秦始皇帝祖龙嬴政、汉太祖高皇帝刘邦、西楚霸王项羽他们的出生顺序怎样&#xff1f; 细看正史我们就知道&#xff0c;项羽嬴政刘邦这三个人&#xff0c;说他们是兄弟可以&#xff0c;说他们有代差也不错&#xff1a;公元前259年&#xff0c;秦始皇降生&#xff0c;三年后的…
阅读更多...
Blender 导入资源包的例子

Blender 导入资源包的例子

先到清华源下载资源包&#xff1a; Index of /blender/ | 清华大学开源软件镜像站 | Tsinghua Open Source Mirror 具体地址&#xff1a;https://mirrors.tuna.tsinghua.edu.cn/blender/demo/asset-bundles/human-base-meshes/human-base-meshes-bundle-v1.1.0.zip 解压/hum…
阅读更多...
【数据结构】C++语言实现二叉树的介绍及堆的实现(详细解读)

【数据结构】C++语言实现二叉树的介绍及堆的实现(详细解读)

c语言中的小小白-CSDN博客c语言中的小小白关注算法,c,c语言,贪心算法,链表,mysql,动态规划,后端,线性回归,数据结构,排序算法领域.https://blog.csdn.net/bhbcdxb123?spm1001.2014.3001.5343 给大家分享一句我很喜欢我话&#xff1a; 知不足而奋进&#xff0c;望远山而前行&am…
阅读更多...
【Leetcode每日一题】 动态规划 - 简单多状态 dp 问题 - 删除并获得点数（难度⭐⭐）（76）

【Leetcode每日一题】 动态规划 - 简单多状态 dp 问题 - 删除并获得点数（难度⭐⭐）（76）

1. 题目解析 题目链接&#xff1a;LCR 091. 粉刷房子 这个问题的理解其实相当简单&#xff0c;只需看一下示例&#xff0c;基本就能明白其含义了。 2.算法原理 1. 状态定义 在解决这类问题时&#xff0c;我们首先需要根据题目的具体要求来定义状态。针对房屋粉刷问题&#…
阅读更多...
malloc_consolidate

malloc_consolidate

此文章用于详细介绍malloc_consolidate。 众所周知&#xff0c;fastbin一般是不能合并&#xff0c;但在malloc_consolidate中是个例外。 1.触发机制 首先构造这样的堆块结构 一个0x40的堆块在fastbin中&#xff0c;一个0x110的堆块在unbin中 随后我们尝试分配一个0x300的堆…
阅读更多...
智能BI（后端）-- 系统异步化

智能BI（后端）-- 系统异步化

文章目录 系统问题分析什么是异步化&#xff1f;业务流程分析标准异步化的业务流程系统业务流程 线程池为什么需要线程池&#xff1f;线程池两种实现方式线程池的参数线程池的开发 项目异步化改造 系统问题分析 问题场景&#xff1a;调用的服务能力有限&#xff0c;或者接口的…
阅读更多...
strcpy函数详解

strcpy函数详解

strcpy函数详解 1.函数简介2.strcpy函数的使用2.1使用方法一2.1使用方法二 3.strcpy在使用过程中的注意事项3.1被复制字符必须以\0结尾3.2目标空间必须能够大于源字符串长度3.3目标空间必须可变 1.函数简介 strcpy函数包含在<string.h>库函数中&#xff0c;是将一个字符…
阅读更多...
共享文件夹（以及问题解决方法）

共享文件夹（以及问题解决方法）

目录 文件夹共享 第一步&#xff0c;将文件夹共享 第二步&#xff0c;设置用户权限 第三步&#xff0c;打开网络发现 第四步&#xff0c;访问 网络中没有设备问题 控制面板&#xff0c;启动 重启 还是不行&#xff1f;计算机管理&#xff0c;启动 FDResPub服务&#x…
阅读更多...
波搜索算法(WSA)-2024年SCI新算法-公式原理详解与性能测评 Matlab代码免费获取

波搜索算法(WSA)-2024年SCI新算法-公式原理详解与性能测评 Matlab代码免费获取

​ 声明&#xff1a;文章是从本人公众号中复制而来&#xff0c;因此&#xff0c;想最新最快了解各类智能优化算法及其改进的朋友&#xff0c;可关注我的公众号&#xff1a;强盛机器学习&#xff0c;不定期会有很多免费代码分享~ 目录 原理简介 一、初始化阶段 二、全…
阅读更多...
JumpServer堡垒机应用(v3.10.8) 下

JumpServer堡垒机应用(v3.10.8) 下

目录 JumpServer堡垒机简单式部署与管理(v3.10.8) 上-CSDN博客 一. 资产管理 1.1创建资产 1.2 给资产主机创建用户 1.2.1 普通账户&#xff1a; 1.2.2 特权账户&#xff1a; 1.2.3 创建用户 二. 命令过滤 2.1 创建命令组 2.2 创建命令过滤 ​编辑 三. 创建资产授权 …
阅读更多...
大模型算法(一)：从Transformer到ViT再到LLaMA

大模型算法(一)：从Transformer到ViT再到LLaMA

单任务/单领域模型 深度学习最早的研究集中在针对单个领域或者单个任务设计相应的模型。 对于CV计算机视觉领域&#xff0c;最常用的模型是CNN卷积模型。其中针对计算机视觉中的不同具体任务例如分类任务&#xff0c;目标检测任务&#xff0c;图像分割任务&#xff0c;以CNN作…
阅读更多...
最新文章

Copyright @ 2022~2023