【在Linux世界中追寻伟大的One Piece】多路转接select

news2024/11/25 0:21:45

目录

1 -> I/O多路转接之select

1.1 -> 初识select

1.2 -> select函数原型

1.3 -> 关于fd_set结构

1.4 -> 关于timeval结构

2 -> 理解select执行过程

2.1 -> Socket就绪条件

2.2 -> select特点

2.3 -> select缺点

3 -> select使用示例

3.1 -> 只检测标准输入

3.2 -> 实现字典服务器

1 -> I/O多路转接之select

1.1 -> 初识select

系统提供select函数来实现多路复用输入/输出模型。

  • select系统调用是用来让我们的程序监视多个文件描述符的状态变化的。
  • 程序会停在select这里等待，直到被监视的文件描述符有一个或多个发生了状态改变。

1.2 -> select函数原型

select函数原型如下：

#include <sys/select.h>

int select(int nfds, fd_set* readfds, fd_set* writefds, fd_set
	* exceptfds, struct timeval* timeout);

参数解释：

  • 参数nfds是需要监视的最大的文件描述符值+1。
  • rdset，wrset，exset分别对应于需要检测的可读文件描述符的集合，可写文件描述符的集合及异常文件描述符的集合。
  • 参数timeout为结构timeval，用来设置select()的等待时间。

参数timeout取值：

  • NULL：则表示 select()没有timeout，select将一直被阻塞，直到某个文件描述符上发生了事件。
  • 0：仅检测描述符集合的状态，然后立即返回，并不等待外部事件的发生。
  • 特定的时间值：如果在指定的时间段里没有事件发生，select将超时返回。

1.3 -> 关于fd_set结构

其实这个结构就是一个整数数组，更严格的说，是一个"位图"。使用位图中对应的位来表示要监视的文件描述符。

提供了一组操作fd_set的接口，来比较方便的操作位图。

void FD_CLR(int fd, fd_set* set); // 用来清除描述词组 set 中相关fd的位
int FD_ISSET(int fd, fd_set* set); // 用来测试描述词组 set 中相关fd的位是否为真
void FD_SET(int fd, fd_set* set); // 用来设置描述词组 set 中相关fd的位
void FD_ZERO(fd_set* set); // 用来清除描述词组 set 的全部位

1.4 -> 关于timeval结构

timeval结构用于描述一段时间长度，如果在这个时间内，需要监视的描述符没有事件发生则函数返回，返回值为0。

函数返回值：

  • 执行成功则返回文件描述词状态已改变的个数。
  • 如果返回0代表在描述词状态改变前已超过timeout时间，没有返回。
  • 当有错误发生时则返回-1，错误原因存于errno，此时参数readfds，writefds，exceptfds和timeout的值变成不可预测。

错误值可能为：

  • EBADF文件描述词为无效的或该文件已关闭。
  • EINTR此调用被信号所中断。
  • EINVAL参数n为负值。
  • ENOMEM核心内存不足。

常见的程序片段如下：

fs_set readset；
FD_SET(fd, &readset);
select(fd + 1, &readset, NULL, NULL, NULL);
if (FD_ISSET(fd, readset)) { …… }

2 -> 理解select执行过程

理解select模型的关键在于理解fd_set，为说明方便，取fd_set长度为1字节，fd_set中的每一bit可以对应一个文件描述符fd。则1字节长的fd_set最大可以对应8个fd。

  1. 执行fd_set set，FD_ZERO(&set)；则set用位表示是0000,0000。
  2. 若fd＝5，执行 FD_SET(fd,&set)；后set变为 0001,0000(第5位置为1) 。
  3. 若再加入fd＝2，fd=1，则set变为0001,0011。
  4. 执行select(6,&set,0,0,0)阻塞等待。
  5. 若fd=1，fd=2上都发生可读事件，则select返回，此时set变为0000,0011。注意：没有事件发生的fd=5被清空。

2.1 -> Socket就绪条件

读就绪

  • socket内核中，接收缓冲区中的字节数，大于等于低水位标记SO_RCVLOWAT。此时可以无阻塞的读该文件描述符，并且返回值大于0。
  • socket TCP通信中，对端关闭连接，此时对该socket读，则返回0。
  • 监听的socket上有新的连接请求。
  • socket上有未处理的错误。

写就绪

  • socket内核中，发送缓冲区中的可用字节数(发送缓冲区的空闲位置大小)，大于等于低水位标记SO_SNDLOWAT，此时可以无阻塞的写，并且返回值大于0。
  • socket的写操作被关闭(close或者shutdown)。对一个写操作被关闭的socket进行写操作，会触发SIGPIPE信号。
  • socket使用非阻塞connect连接成功或失败之后。
  • socket上有未读取的错误。

2.2 -> select特点

  • 可监控的文件描述符个数取决于sizeof(fd_set)的值。我这边服务器上sizeof(fd_set)＝512，每bit表示一个文件描述符，则我服务器上支持的最大文件描述符是512*8=4096。
  • 将fd加入select监控集的同时，还要再使用一个数据结构array保存放到select监控集中的fd。
    • 一是用于再select返回后，array作为源数据和fd_set进行FD_ISSET判断。
    • 二是select返回后会把以前加入的但并无事件发生的fd清空，则每次开始select前都要重新从array取得fd逐一加入(FD_ZERO最先)，扫描array的同时取得fd最大值maxfd，用于select的第一个参数。

2.3 -> select缺点

  • 每次调用select，都需要手动设置fd集合，从接口使用角度来说也非常不便。
  • 每次调用select，都需要把fd集合从用户态拷贝到内核态，这个开销在fd很多时会很大。
  • 同时每次调用select都需要在内核遍历传递进来的所有fd，这个开销在fd很多时也很大。
  • select支持的文件描述符数量太小。

3 -> select使用示例

3.1 -> 只检测标准输入

#include <stdio.h>
#include <unistd.h>
#include <sys/select.h>

int main() 
{
	fd_set read_fds;
	FD_ZERO(&read_fds);
	FD_SET(0, &read_fds);
	for (;;) 
	{
		printf("> ");
		fflush(stdout);
		int ret = select(1, &read_fds, NULL, NULL, NULL);
		if (ret < 0) 
		{
			perror("select");

			continue;
		}

		if (FD_ISSET(0, &read_fds)) 
		{
			char buf[1024] = { 0 };
			read(0, buf, sizeof(buf) - 1);

			printf("input: %s", buf);
		}
		else 
		{
			printf("error! invaild fd\n");

			continue;
		}

		FD_ZERO(&read_fds);
		FD_SET(0, &read_fds);
	}

	return 0;
}

说明：

当只检测文件描述符0(标准输入)时，因为输入条件只有在你有输入信息的时候，才成立，所以如果一直不输入，就会产生超时信息。

3.2 -> 实现字典服务器

tcp_select_server.hpp

#pragma once

#include <vector>
#include <unordered_map>
#include <functional>
#include <sys/select.h>
#include "tcp_socket.hpp"

// 必要的调试函数
inline void PrintFdSet(fd_set* fds, int max_fd) 
{
	printf("select fds: ");
	for (int i = 0; i < max_fd + 1; ++i) 
	{
		if (!FD_ISSET(i, fds)) 
		{
			continue;
		}

		printf("%d ", i);
	}

	printf("\n");
}

typedef std::function<void(const std::string& req, std::string*
	resp)> Handler;

// 把 Select 封装成一个类. 这个类虽然保存很多 TcpSocket 对象指针, 但是不管理内存
class Selector 
{
public:
	Selector() 
	{
		// [注意!] 初始化千万别忘了!!
		max_fd_ = 0;
		FD_ZERO(&read_fds_);
	}

	bool Add(const TcpSocket& sock) 
	{
		int fd = sock.GetFd();
		printf("[Selector::Add] %d\n", fd);
		if (fd_map_.find(fd) != fd_map_.end()) 
		{
			printf("Add failed! fd has in Selector!\n");

			return false;
		}

		fd_map_[fd] = sock;
		FD_SET(fd, &read_fds_);
		if (fd > max_fd_) 
		{
			max_fd_ = fd;
		}

		return true;
	}

	bool Del(const TcpSocket& sock) 
	{
		int fd = sock.GetFd();
		printf("[Selector::Del] %d\n", fd);
		if (fd_map_.find(fd) == fd_map_.end()) 
		{
			printf("Del failed! fd has not in Selector!\n");

			return false;
		}

		fd_map_.erase(fd);
		FD_CLR(fd, &read_fds_);

		// 重新找到最大的文件描述符, 从右往左找比较快
		for (int i = max_fd_; i >= 0; --i) 
		{
			if (!FD_ISSET(i, &read_fds_)) 
			{
				continue;
			}
			max_fd_ = i;

			break;
		}

		return true;
	}

	// 返回读就绪的文件描述符集
	bool Wait(std::vector<TcpSocket>* output) 
	{
		output->clear();

		// [注意] 此处必须要创建一个临时变量, 否则原来的结果会被覆盖掉
		fd_set tmp = read_fds_;

		// DEBUG
		PrintFdSet(&tmp, max_fd_);
		int nfds = select(max_fd_ + 1, &tmp, NULL, NULL, NULL);
		if (nfds < 0) 
		{
			perror("select");

			return false;
		}

		// [注意!] 此处的循环条件必须是 i < max_fd_ + 1
		for (int i = 0; i < max_fd_ + 1; ++i) 
		{
			if (!FD_ISSET(i, &tmp)) 
			{
				continue;
			}

			output->push_back(fd_map_[i]);
		}

		return true;
	}

private:
	fd_set read_fds_;
	int max_fd_;

	// 文件描述符和 socket 对象的映射关系
	std::unordered_map<int, TcpSocket> fd_map_;
};

class TcpSelectServer 
{
public:
	TcpSelectServer(const std::string& ip, uint16_t port) : ip_(ip),
		port_(port) 
	{
	}

	bool Start(Handler handler) const 
	{
		// 1. 创建 socket
		TcpSocket listen_sock;
		bool ret = listen_sock.Socket();
		if (!ret) 
		{
			return false;
		}

		// 2. 绑定端口号
		ret = listen_sock.Bind(ip_, port_);
		if (!ret) 
		{
			return false;
		}

		// 3. 进行监听
		ret = listen_sock.Listen(5);
		if (!ret) 
		{
			return false;
		}

		// 4. 创建 Selector 对象
		Selector selector;
		selector.Add(listen_sock);

		// 5. 进入事件循环
		for (;;) 
		{
			std::vector<TcpSocket> output;
			bool ret = selector.Wait(&output);
			if (!ret) 
			{
				continue;
			}

			// 6. 根据就绪的文件描述符的差别, 决定后续的处理逻辑
			for (size_t i = 0; i < output.size(); ++i) 
			{
				if (output[i].GetFd() == listen_sock.GetFd()) 
				{
					// 如果就绪的文件描述符是 listen_sock, 就执行 accept, 并加入到 select 中
					TcpSocket new_sock;
					listen_sock.Accept(&new_sock, NULL, NULL);
					selector.Add(new_sock);
				}
				else 
				{
					// 如果就绪的文件描述符是 new_sock, 就进行一次请求的处理
					std::string req, resp;
					bool ret = output[i].Recv(&req);
					if (!ret) 
					{
						selector.Del(output[i]);

						// [注意!] 需要关闭 socket
						output[i].Close();
						continue;
					}

					// 调用业务函数计算响应
					handler(req, &resp);

					// 将结果写回到客户端
					output[i].Send(resp);
				}

			} // end for
		} // end for (;;)

		return true;
	}

private:
	std::string ip_;
	uint16_t port_;
};

感谢各位大佬支持！！！

互三啦！！！

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

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

相关文章

小语言模型介绍与LLM的比较

小语言模型介绍与LLM的比较

小模型介绍 小语言模型&#xff08;SLM&#xff09;与大语言模型&#xff08;LLM&#xff09;相比&#xff0c;具有不同的特点和应用场景。大语言模型通常拥有大量的参数&#xff08;如 GPT-3 拥有 1750 亿个参数&#xff09;&#xff0c;能够处理复杂的自然语言任务&#xff…
阅读更多...
双11花了“一部手机钱”买手机壳的年轻人，究竟在买什么？

双11花了“一部手机钱”买手机壳的年轻人，究竟在买什么？

【潮汐商业评论/原创】 这个双十一&#xff0c;Elsa在天猫多了一笔新支出——手机壳。和大家都熟悉的“义乌制造”不同的是&#xff0c;她的手机壳支出单件就已经到了500块&#xff0c;加上配套的手机链、支架、卡包、耳机壳&#xff0c;总共1000多元&#xff0c;足够买一部学…
阅读更多...
03WIFI与蓝牙1——基于全志V3S的Linux开发板教程笔记

03WIFI与蓝牙1——基于全志V3S的Linux开发板教程笔记

1. Kernel支持 1&#xff09;配置 终端输入&#xff1a; make menuconfig使能如下部分&#xff1a; 2&#xff09;编译 保存并退出后编译内核&#xff1a; make licheepi_zero_defconfig make menuconfig #配置内核&#xff0c;有需要的话配置 make -j16 make -j16 modu…
阅读更多...
02系统跑起来——基于全志V3S的Linux开发板教程笔记

02系统跑起来——基于全志V3S的Linux开发板教程笔记

开发环境&#xff1a;Linux系统为Ubuntu 18.04.6 LTS&#xff0c;如在下面操作中提示部分环境/工具缺失未安装&#xff0c;请单独安装。 硬件基本介绍请参考第一篇文章&#xff1a;基于全志V3S的Linux开发板学习笔记01——简介 1. 环境准备 推荐直接下载完整资源包&#xff0c;…
阅读更多...
用户思维，才是银行理财的杀手锏

用户思维，才是银行理财的杀手锏

近些年&#xff0c;伴随着居民理财需求的迸发&#xff0c;银行理财市场规模逐步扩大。 在前不久的2024Inclusion外滩大会上&#xff0c;麦肯锡发布了《银行理财六大趋势》&#xff0c;其中提到在财富管理客户风险偏好普遍下移的大背景下&#xff0c;银行理财将是客户财富管理配…
阅读更多...
信息安全工程师（79）网络安全测评概况

信息安全工程师（79）网络安全测评概况

一、定义与目的 网络安全测评是指参照一定的标准规范要求&#xff0c;通过一系列的技术、管理方法&#xff0c;获取评估对象的网络安全状况信息&#xff0c;并对其给出相应的网络安全情况综合判定。其对象主要为信息系统的组成要素或信息系统自身。网络安全测评的目的是为了提高…
阅读更多...
学习笔记：微服务技术栈（一）服务治理框架SpringCloud

学习笔记：微服务技术栈（一）服务治理框架SpringCloud

教学视频链接&#xff1a; 【SpringCloudRabbitMQDockerRedis搜索分布式&#xff0c;系统详解springcloud微服务技术栈课程|黑马程序员Java微服务】 目录 前言一、认识微服务1.1 服务架构1.2 微服务架构1.3 SpringCloud 二、服务拆分及远程调用2.1 服务拆分细节2.2 服务间调用 …
阅读更多...
医院数字影像信息系统源码，拥有完整知识产权，能够同HIS、电子病历、体检系统无缝对接

医院数字影像信息系统源码，拥有完整知识产权，能够同HIS、电子病历、体检系统无缝对接

数字医学影像系统源码&#xff0c;RIS/PACS系统源码&#xff0c;医院数字影像信息系统源码。 开发技术&#xff1a;基于C/S架构&#xff0c;C#开发语言&#xff0c;数据库服务器采用Oracle数据库。三甲以下的医院都能满足 医学影像系统PACS系统是应用在医院影像科室的系统&…
阅读更多...
LabVIEW for Linux 介绍

LabVIEW for Linux 介绍

LabVIEW for Linux 介绍 1. 兼容性 LabVIEW for Linux 设计用于多种 Linux 发行版&#xff0c;包括 CentOS、Ubuntu 等。在安装之前&#xff0c;务必检查与您特定发行版版本的兼容性。 2. 程序移植 可移植性&#xff1a;在许多情况下&#xff0c;LabVIEW 程序&#xff08;VI…
阅读更多...
使用NVM自由切换nodejs版本

使用NVM自由切换nodejs版本

一、NVM介绍 在日常开发中&#xff0c;我们可能需要同时进行多个不同NodeJS版本的项目开发&#xff0c;每个项目所依赖的nodejs版本可能不一致&#xff0c;我们如果只安装一个版本的nodejs&#xff0c;就可能出现node版本冲突问题&#xff0c;导致项目无法启动。这种情况下&am…
阅读更多...
职场日常：多年的测试工程师如何继续在测试行业中砥砺前行

职场日常：多年的测试工程师如何继续在测试行业中砥砺前行

大家好&#xff0c;今天我们一起聊聊测试工程师在职业、在团队、在家庭中如何更好的做好角色。 作为一个工作了多年测试工作的大牛来说&#xff0c;从今天开始或许未来会因为各个方面的原因可能不在从事软件测试了&#xff0c;但是会继续总结过往的经验&#xff0c;从事这么多…
阅读更多...
文件操作：Xml转Excel

文件操作：Xml转Excel

1 添加依赖 Spire.Xls.jar <dependency><groupId>e-iceblue</groupId><artifactId>spire.xls</artifactId><version>5.3.3</version></dependency>2 代码使用 package cctd.controller;import com.spire.xls.FileFormat; im…
阅读更多...
【Homework】【1--3】Learning resources for DQ Robotics in MATLAB

【Homework】【1--3】Learning resources for DQ Robotics in MATLAB

Learning resources for DQ Robotics in MATLAB Lesson 1 代码 % Step 2: Define the real numbers a1 and a2 a1 123; a2 321;% Step 3: Calculate and display a3 a1 a2 a3 a1 a2; disp([a3 (a1 a2) , num2str(a3)])% Step 4: Calculate and display a3 a1 * a2 a3…
阅读更多...
「Mac畅玩鸿蒙与硬件24」UI互动应用篇1 - 灯光控制小项目

「Mac畅玩鸿蒙与硬件24」UI互动应用篇1 - 灯光控制小项目

本篇将带领你实现一个互动性十足的灯光控制小项目&#xff0c;用户可以通过点击按钮来控制灯光的开关。该项目将涉及状态管理、动态图片加载以及按钮交互&#xff0c;是学习鸿蒙应用开发的重要基础。 关键词 UI互动应用状态管理动态图片加载用户交互 一、功能说明 在这个灯光…
阅读更多...
雷池社区版 7.1.0 LTS 发布了

雷池社区版 7.1.0 LTS 发布了

LTS&#xff08;Long Term Support&#xff0c;长期支持版本&#xff09;是软件开发中的一个概念&#xff0c;表示该版本将获得较长时间的支持和更新&#xff0c;通常包含稳定性、性能改进和安全修复&#xff0c;但不包含频繁的新特性更新。 作为最受欢迎的社区waf&#xff0c…
阅读更多...
七.numpy模块

七.numpy模块

NumPy(Numerical Python) 是 Python 语言的一个扩展程序库&#xff0c;支持大量的维度数组与矩阵运算&#xff0c;此外也针对数组运算提供大量的数学函数库。 NumPy 的前身 Numeric 最早是由 Jim Hugunin 与其它协作者共同开发&#xff0c;2005 年&#xff0c;Travis Oliphant…
阅读更多...
RK3568平台开发系列讲解（内存篇）Linux 内存优化

RK3568平台开发系列讲解（内存篇）Linux 内存优化

🚀返回专栏总目录 文章目录 一、如何正确采集 Linux 内存可用空间二、系统内存优化参考步骤2.1、优化 Linux Kernel module 所占用的内存空间2.3、将 Wi-Fi built-in kernel2.4、优化 Linux 文件系统所占用的内存空间2.5、上层优化2.6、客户定制优化2.6.1、对具体客户的具体产…
阅读更多...
Caffeine 手动策略缓存 put() 方法源码解析

Caffeine 手动策略缓存 put() 方法源码解析

BoundedLocalManualCache put() 方法源码解析 先看一下BoundedLocalManualCache的类图 com.github.benmanes.caffeine.cache.BoundedLocalCache中定义的BoundedLocalManualCache静态内部类。 static class BoundedLocalManualCache<K, V> implements LocalManualCache&…
阅读更多...
猎板PCB2到10层数的科技进阶与应用解析

猎板PCB2到10层数的科技进阶与应用解析

1. 单层板&#xff08;Single-sided PCB&#xff09; 定义&#xff1a;单层板是最基本的PCB类型&#xff0c;导线只出现在其中一面&#xff0c;因此被称为单面板。限制&#xff1a;由于只有一面可以布线&#xff0c;设计线路上有许多限制&#xff0c;不适合复杂电路。应用&…
阅读更多...
Dinky中配置Flink集群

Dinky中配置Flink集群

需要启动yarn-session 进程&#xff0c;在集群服务器 cd /pwd//flink/bin yarn-session -d 启动成功后可以在yarn的资源管理队列进行查看 启动成功后会给出&#xff1a;JobManager Web Interface 在dinky中进行配置&#xff1a; 集群配置 Hadoop 配置&#xff1a; H…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023