IO多路复用实现并发服务器

一.select函数

select 的调用注意事项
在使用 select 函数时，需要注意以下几个关键点：

1. 参数的修改与拷贝
   readfds 等参数是结果参数 ：
   select 函数会直接修改传入的 fd_set（如 readfds、writefds 和 exceptfds）。
   为了保留原始监听集合，通常会定义一个备份集合（如 allread_fdset），并将它的拷贝传递给 select。
    示例：
    fd_set allread_fdset, readfds;
    FD_ZERO(&allread_fdset);
    FD_SET(fd1, &allread_fdset);
    FD_SET(fd2, &allread_fdset);

    readfds = allread_fdset; // 拷贝到临时集合
    select(..., &readfds, ...);
2. 计算 nfds

    nfds 是最大文件描述符值 + 1 ：
    在新增监听句柄时，更新 nfds 较为简单。
    在减少监听句柄时，更新 nfds 较为复杂：
    如果需要精确计算，可以通过遍历或维护一个最大堆等数据结构来找到第二大的文件描述符。
    或者，可以选择忽略 nfds 的更新，但可能导致性能下降。
    
    
3. 超时参数 timeout
    timeout 的含义 ：
    如果为 NULL，表示阻塞等待，直到有事件发生。
    如果指向的时间为 0，表示非阻塞模式。
    如果指定超时时间，则 select 会在超时后返回。
    注意：Linux 实现中，select 返回时会修改 timeout 为剩余时间 ：
    如果需要重复使用 timeout，需要重新初始化。
    
4. 返回值的处理
    返回值的意义 ：
    -1：表示错误。
    0：表示超时时间到，没有事件发生。
    正数：表示监听到的事件总数（包括可读、可写和异常事件）。
    优化事件处理 ：
    可以利用返回值避免不必要的检查。例如，如果返回值为 1，并且已经在可读集合中处理了一个事件，则无需再检查可写和异常集合。

select 的缺点
    尽管 select 是一种经典的 I/O 多路复用机制，但它存在以下显著缺点：

    1. 文件描述符数量限制
        FD_SETSIZE 的限制 ：
        每个 fd_set 最多只能监听 FD_SETSIZE 个文件描述符（在 Linux 上通常是 1024）。
        这一限制使得 select 不适合高并发场景。
        
    2. 遍历效率低
        需要逐一检查文件描述符 ：
        返回的 fd_set 是一个位图，应用程序需要对所有监听的文件描述符逐一调用 FD_ISSET 来判断是否就绪。
        示例：

        for (int i = 0; i < nfds; i++) {
            if (FD_ISSET(i, &readfds)) {
                // 处理可读事件
            }
        }
3. nfds 的效率问题
    select 的实现方式 ：
    select 内部会遍历从 0 到 nfds-1 的所有文件描述符，判断每个描述符是否是关心的，并检查是否有事件发生。
    即使只监听少数几个文件描述符（如 0 和 1000），select 仍然需要遍历 1001 个描述符，导致效率低下。


总结
优点
    简单易用，跨平台支持广泛。
缺点
    文件描述符数量受限 ：最多只能监听 FD_SETSIZE 个文件描述符。
    遍历效率低         ：需要逐一检查文件描述符，增加了开销。
    nfds 的问题        ：即使监听的文件描述符稀疏分布，select 仍需遍历所有小于 nfds 的描述符。
这些缺点促使了更高效的 I/O 多路复用机制（如 poll 和 epoll）的出现，尤其是在高并发场景下，epoll 成为了更优的选择。

【1】管道select

【2】tcp服务器select

二.poll函数

poll 
   针对select 做了改进 
   底层实现 --- 用的是数组 
   poll --- 链表 
   poll 引入了事件机制 
   
   1. 遍历?
   2. poll 需要在 用户空间 和 内核空间 来回拷贝 

epoll 
   三种多路IO操作中最高效


   
 

三.epoll函数

3. epoll
int epoll_create(int size);
int epoll_ctl(int epfd, int op, int fd, struct epoll_event *event);

typedef union epoll_data {
    void *ptr;
    int fd;
    __uint32_t u32;
    __uint64_t u64;
} epoll_data_t;

struct epoll_event {
    __uint32_t events;      /* Epoll events */
    epoll_data_t data;      /* User data variable */
};
int epoll_wait(int epfd, struct epoll_event * events, int maxevents, int timeout);


epoll 解决了select和poll的几个性能上的缺陷：
① 不限制监听的描述符个数（poll也是），只受进程打开描述符总数的限制；
② 监听性能不随着监听描述 符数的增加而增加，是O(1) 的，
  不再是轮询描述符来探测事件，而是由描述符主动上报事件； //事件机制的 
③ 使用共享内存的方式，不在用户和内核之间反复传递监听的描述 符信息；
④ 返回参数中就是触发事件的列表，不用再遍历输入事件表查询各个事件是否被触发

------------------------------------------

epoll显著提高性能的前提是：
监听大量描述符，
并且每次触发事件的描述符文件非常少。
epoll的另外区别是：
①epoll创建了描述符，记得close；
②支持水平触发和边沿触发。

epoll使用注意事项：
//epoll_create
① int epoll_create(int size)；    //创建epoll文件描述符
参数size并不是限制了epoll所能监听的描述符最大个数，
只是对内核初始分配内部数据结构的一个建议。
返回是epoll描述符。-1表示创建失败。


//epoll_ctl
② int epoll_ctl(int epfd, int op, int fd, struct epoll_event *event)；    //epoll文件描述符的控制接口
功能:
     epoll_ctl控制对指定描述符fd执行op操作，event是与fd关联的监听事件。
参数:
   @epfd --- epoll对象 
   @op 
        op操作有三种：
        
        添加EPOLL_CTL_ADD，
        
        删除EPOLL_CTL_DEL，
        
        修改EPOLL_CTL_MOD。
        
    分别添加、删除和修改对fd的监听事件。
    重复添加fd会怎样（event相同或不相同）：
    添加失败（errno：17， File exists）
    删除和修改不存在的fd会怎样：
    删除或修改失败（errno：9，Bad file descriptor）

  @fd -- 关心的fd 
  
  
event是与监听的fd相关联的事件信息，event->events描述了要监听的事件类型，有以下类型：
//事件类型:
EPOLLIN        可读
EPOLLOUT       可写
EPOLLRDHUP     套接口对端close或shutdown写，在ET模式下比较有用
EPOLLPRI       紧急数据可读
EPOLLERR       异常条件
EPOLLHUP       挂起，EPOLLERR和EPOLLHUP始终由epoll_wait监听，不需要用户设置
EPOLLET        边沿触发模式，在描述符状态跳变时才上报监听事件。（监听默认都是LT模式）(ET+非阻塞模式)
EPOLLONESHOT   只一次有效，设置oneshot标记，描述符在触发一次事件之后自动失效（fd还被监听），
               不会再上报任何事件，直到使用EPOLL_CTL_MOD重新激活，
               设置新的监听事件为止（可不可以和之前的事件一样？）。

event->data是个共用体，可以存放和fd绑定的描述符信息，
比如就存放描述符本身fd，或者一个结构体信息，包括fd，ip，port等等。

在epoll_wait返回时，只会返回一个event列表，需要从列表元素中获取fd等信息。
返回值:
        返回0表示控制成功，
        返回-1表示失败。

③ int epoll_wait(int epfd, struct epoll_event * events, int maxevents, int timeout);
//等待epfd上的io事件，最多返回maxevents个事件
timeout = -1 的行为是block；
timeout =  0 是立即返回

④ epoll监听ET事件时，fd必须是非阻塞套接口。
比如监听可读事件，当ET上报可读后，需要一直读fd直到遇到EAGAIN错误为止，以免遗留数据在缓冲区中。
如果fd是阻塞的，则会读到阻塞了。
EAGAIN错误对于非阻塞套接口来说不是错误，只是说没有数据可读或者没有空间可写。
EWOULDBLOCK就是EAGAIN，值都是11。
selset/poll/epoll的LT模式监听的fd可以是阻塞模式的。

⑤ 多路复用监听io事件时，如果对某个套接口监听可写事件，总是会返回可写而事实上可能没有数据要写。
处理方法：
①只有在有数据要写时才把要写的套接口加入 监听列表中，数据全部写完之后从监听列表中删除它；
②在有数据写时，首先尝试直接写，当直接写没有把数据全部写入发送缓冲区时再把这个套接口加入可写事件 监听列表。
（这种方式效率较高，需要套接口是非阻塞的，前一种方式可以是阻塞的吗？）
可以是阻塞的。

四. 特点和区别

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

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

相关文章

解决火绒启动时，报安全服务异常，无法保障计算机安全

解决火绒启动时，报安全服务异常，无法保障计算机安全

1.找到控制面板-安全和维护-更改用户账户控制设置 重启启动电脑解决。
阅读更多...
【Docker】容器安全之非root用户运行

【Docker】容器安全之非root用户运行

【Docker】容器安全之非root用户运行 1. 场景2. 原 Dockerfile 内容3. 整改结果4. 非 root 用户带来的潜在问题4.1 文件夹读写权限异常4.2 验证文件夹权限 1. 场景 最近有个项目要交付&#xff0c;第三方测试对项目源码扫描后发现一个问题&#xff0c;服务的 Dockerfile 都未指…
阅读更多...
3.9[A]csd

3.9[A]csd

在传统CPU中心架构中&#xff0c;中央处理器通过内存访问外部存储器&#xff0c;而数据必须经过网络接口卡才能到达外部存储器。这种架构存在集中式计算、DRAM带宽和容量挑战、大量数据移动&#xff08;服务器内和网络&#xff09;以及固定计算导致工作负载容量增长等问题。 而…
阅读更多...
嵌入式开发：傅里叶变换（5）：基于STM32，实现CMSIS中的DSP库

嵌入式开发：傅里叶变换（5）：基于STM32，实现CMSIS中的DSP库

目录 步骤 1&#xff1a;准备工作 步骤 2&#xff1a;创建 Keil 项目&#xff0c;并配置工程 步骤 3&#xff1a;在MDK工程上添加 CMSIS-DSP 库 步骤 5&#xff1a;编写代码 步骤 6&#xff1a;配置时钟和优化 步骤 7&#xff1a;调试与验证 步骤 8&#xff1a;优化和调…
阅读更多...
个人学习编程(3-06) 搜索

个人学习编程(3-06) 搜索

树的高度&#xff1a; 题目&#xff1a; PS G:\vscodetest> .\ab.exe 5 5 1 2 1 4 1 5 2 3 3 #include <stdio.h> #include <vector> #include <queue> using namespace std; int main() {int n,m;scanf("%d %d",&n,&m);vector<vec…
阅读更多...
QwQ-32B 开源！本地部署+微调教程来了

QwQ-32B 开源！本地部署+微调教程来了

今天&#xff0c;通义千问开源了推理模型QwQ-32B QwQ-32B 在一系列基准测试中进行了评估&#xff0c;测试了数学推理、编程能力和通用能力。以下结果展示了 QwQ-32B 与其他领先模型的性能对比&#xff0c;包括 DeepSeek-R1-Distilled-Qwen-32B、DeepSeek-R1-Distilled-Llama-7…
阅读更多...
【鸿蒙开发】Windows平台MQTT服务器搭建教程

【鸿蒙开发】Windows平台MQTT服务器搭建教程

00. 目录 文章目录 00. 目录01. MQTT概述02. MQTT服务器下载03. MQTT服务器安装04. MQTT服务器配置05. MQTT服务器启动06. 附录 01. MQTT概述 MQTT&#xff08;Message Queuing Telemetry Transport&#xff0c;消息队列遥测传输协议&#xff09;&#xff0c;是一种基于发布/订…
阅读更多...
007-Property在C++中的实现与应用

007-Property在C++中的实现与应用

Property在C中的实现与应用 以下是在C中实现属性(Property)的完整实现方案&#xff0c;结合模板技术和运算符重载实现类型安全的属性访问&#xff0c;支持独立模块化封装&#xff1a; #include <iostream> #include <functional>template<typename HostType, t…
阅读更多...
自然语言处理：最大期望值算法

自然语言处理：最大期望值算法

介绍 大家好&#xff0c;博主又来给大家分享知识了&#xff0c;今天给大家分享的内容是自然语言处理中的最大期望值算法。那么什么是最大期望值算法呢&#xff1f; 最大期望值算法&#xff0c;英文简称为EM算法&#xff0c;它的核心思想非常巧妙。它把求解模型参数的过程分成…
阅读更多...
javascrip网页设计案例，SuperSlide+bootstrap+html经典组合

javascrip网页设计案例，SuperSlide+bootstrap+html经典组合

概述 JavaScript作为一种强大的脚本语言&#xff0c;在网页设计领域发挥着举足轻重的作用&#xff0c;能够为网页赋予丰富的交互性与动态功能。以下通过具体案例来深入理解其应用。​ 假设要打造一个旅游网站&#xff0c;该网站具备诸多实用功能。在响应式设计方面&#xff0…
阅读更多...
C#控制台应用程序学习——3.8

C#控制台应用程序学习——3.8

一、语言概述 1、平台相关性 C# 主要运行在.NET 平台上。.NET 提供了一个庞大的类库&#xff0c;C# 程序可以方便地调用这些类库来实现各种功能&#xff0c;如文件操作、数据库访问、网络通信等。 2、语法风格 C# 的语法与 C、C 和 Java 有一定的相似性。例如&#xff0c;它使用…
阅读更多...
【A2DP】SBC 编解码器互操作性要求详解

【A2DP】SBC 编解码器互操作性要求详解

目录 一、SBC编解码器互操作性概述 二、编解码器特定信息元素（Codec Specific Information Elements） 2.1 采样频率（Sampling Frequency） 2.2 声道模式（Channel Mode） 2.3 块长度（Block Length） 2.4 子带数量（Subbands） 2.5 分配方法（Allocation Method） 2…
阅读更多...
MySQL创建数据库和表，插入四大名著中的人物

MySQL创建数据库和表，插入四大名著中的人物

一、登录数据库并创建数据库db_ck 二、创建表t_hero 表属性包括&#xff08;id&#xff0c;name&#xff0c;nickname&#xff0c;age&#xff0c;gender&#xff0c;address&#xff0c;weapon&#xff0c;types&#xff09; mysql> create table t_hero(-> id int,-…
阅读更多...
C++修炼之路：初识C++

C++修炼之路：初识C++

Hello大家好&#xff01;很高兴我们又见面啦&#xff01;给生活添点passion&#xff0c;开始今天的编程之路&#xff01; 我的博客&#xff1a;<但凡. 我的专栏&#xff1a;《编程之路》、《数据结构与算法之美》、《题海拾贝》 欢迎点赞&#xff0c;关注&#xff01; 引言 …
阅读更多...
Python项目在 Cursor 编辑器中 Conda 环境配置问题

Python项目在 Cursor 编辑器中 Conda 环境配置问题

在开发使用 FastApi 框架的 Python 某项目时&#xff0c;我遇到了一个因为 Conda 环境配置没有起作用的问题。 我是用 Cursor 编辑器开发 FastApi 项目的&#xff0c;项目运行在 Conda 环境blog中&#xff0c; 由于使用了 opencc-python-reimplemented&#xff0c;Python 版本…
阅读更多...
Redis客户端

Redis客户端

1.前言 前面学习的Redis的基本操作和命令都是在redis命令行手动执行的&#xff0c;更多的时候&#xff0c;是使用redis的API来实现定制化的redis客户端操作redis服务器。接下来我们要了解Redis服务端和客户端的通信协议&#xff0c;以及Java语言的Redis客户端使用方法 Redis服…
阅读更多...
Git基础之分支

Git基础之分支

常用指令 git branch 列出本地所有分支 git branch -r 列出所有远程分支 git branch [branch-name] 新建一个分支&#xff0c;但依然停留在当前分支 git checkout -b [branch] 新建一个分支&#xff0c;并切换到该分支 git merge [branch] 合并指定分支当前分支 git branch -d …
阅读更多...
Java多线程与高并发专题——什么是阻塞队列？

Java多线程与高并发专题——什么是阻塞队列？

引入 阻塞队列&#xff08;Blocking Queue&#xff09;是一种线程安全的队列数据结构&#xff0c;它的主要特点是&#xff1a; 线程安全&#xff1a;多个线程可以安全地同时访问队列。阻塞操作&#xff1a;当队列为空时&#xff0c;从队列中获取元素的操作会被阻塞&#xff0…
阅读更多...
电路常用常用的定理/定律/计算方法

电路常用常用的定理/定律/计算方法

1、欧姆定理 在恒定温度下&#xff0c;导体中的电流I与导体两端的电压U成正比&#xff0c;与导体的电阻R成反比。 2、基尔霍夫定律 2.1基尔霍夫电流定律&#xff08;KCL&#xff09; 在电路中任何一个节点上&#xff0c;任意时刻&#xff0c;流入节点的电流之和等于流出节点…
阅读更多...
unity 让两个物体相遇时候刚体互不影响

unity 让两个物体相遇时候刚体互不影响

解决方案是设定好层级不同&#xff0c;在PlayerSetting中找到物理&#xff0c;有一个图层碰撞矩阵 取消对应 勾选即可 如图
阅读更多...
最新文章
推荐文章

Copyright @ 2022~2023