当前位置: 首页 > news >正文

做中文网站的公司/福州seo网站推广优化

做中文网站的公司,福州seo网站推广优化,聊城做网站的,住房和城乡建设部机关服务中心Linux 网络 IO 模型 同步和异步,阻塞和非阻塞 同步和异步 关注的是调用方是否主动获取结果 同步:同步的意思就是调用方需要主动等待结果的返回 异步:异步的意思就是不需要主动等待结果的返回,而是通过其他手段比如,状态通知&#xff0…

Linux 网络 IO 模型

同步和异步,阻塞和非阻塞

同步和异步
关注的是调用方是否主动获取结果
         同步:同步的意思就是调用方需要主动等待结果的返回
        异步:异步的意思就是不需要主动等待结果的返回,而是通过其他手段比如,状态通知,
回调函数等。
阻塞和非阻塞
主要关注的是等待结果返回调用方的状态
         阻塞:是指结果返回之前,当前线程被挂起,不做任何事
        非阻塞:是指结果在返回之前,线程可以做一些其他事,不会被挂起。
两者的组合
        1 .同步阻塞: 同步阻塞基本也是编程中最常见的模型,打个比方你去商店买衣服,你去了
之后发现衣服卖完了,那你就在店里面一直等,期间不做任何事(包括看手机),等着商家进
货,直到有货为止,这个效率很低。
        2.同步非阻塞: 同步非阻塞在编程中可以抽象为一个轮询模式,你去了商店之后,发现衣
服卖完了,这个时候不需要傻傻的等着,你可以去其他地方比如奶茶店,买杯水,但是你还
是需要时不时的去商店问老板新衣服到了吗。
        3.异步阻塞: 异步阻塞这个编程里面用的较少,有点类似你写了个线程池,submit 然后马
上 future.get(),这样线程其实还是挂起的。有点像你去商店买衣服,这个时候发现衣服没有
了,这个时候你就给老板留给电话,说衣服到了就给我打电话,然后你就守着这个电话,一
直等着他响什么事也不做。这样感觉的确有点傻,所以这个模式用得比较少。
        4.异步非阻塞: 异步非阻塞。好比你去商店买衣服,衣服没了,你只需要给老板说这是我
的电话,衣服到了就打。然后你就随心所欲的去玩,也不用操心衣服什么时候到,衣服一到,
电话一响就可以去买衣服了

Linux 下的五种 I/O 模型

        总的来说, 阻塞 IO 就是 JDK 里的 BIO 编程,IO 复用就是 JDK 里的 NIO 编程,Linux 下异
步 IO 的实现建立在 epoll 之上,是个伪异步实现,而且相比 IO 复用,没有体现出性能优势,
使用不广。 非阻塞 IO 使用轮询模式,会不断检测是否有数据到达,大量的占用 CPU 的时间,
是绝不被推荐的模型。 信号驱动 IO 需要在网络通信时额外安装信号处理函数,使用也不广
 阻塞 IO 模型

 I/O 复用模型

        比较上面两张图,IO 复用需要使用两个系统调用 (select recvfrom) ,而 blocking IO
调用了一个系统调用 (recvfrom) 。但是,用 select 的优势在于它可以同时处理多个 connection
所以,如果处理的连接数不是很高的话,使用 select/epoll web server 不一定比使用
multi-threading + blocking IO web server 性能更好,可能延迟还更大。 select/epoll 的优势
并不是对于单个连接能处理得更快,而是在于能处理更多的连接。
Linux 代码结构看网络通信

         Linux 内核的源码包含的东西很多,在 Linux 的源代码中,网络设备驱动对应的逻辑位于
driver/net/ethernet, 其中 intel 系列网卡的驱动在 driver/net/ethernet/intel 目录下。 协议栈模
块代码位于 kernel net 目录。
        其中 net 目录中包含 Linux 内核的网络协议栈的代码。子目录 ipv4 ipv6 TCP/IP 协议
栈的 IPv4 IPv6 的实现,主要包含了 TCP UDP IP 协议的代码,还有 ARP 协议、 ICMP
议、 IGMP 协议代码实现,以及如 proc ioctl 等控制相关的代码。
        站在网络通信的角度,源代码组织的表现形式如下:
         网络协议栈是由若干个层组成的,网络数据的流程主要是指在协议栈的各个层之间的传递
一个 TCP 服务器的流程按照建立 socket()函数绑定地址端口 bind()函数侦听端口 listen()
函数接收连接 accept()函数发送数据 send()函数接收数据 recv()函数关闭 socket()函
的顺序来进行。
        与此对应内核的处理过程也是按照此顺序进行的,网络数据内核中的处理过程 主要是在
网卡 协议栈 之间进行 : 从网卡接收数据,交给协议栈处理;协议栈将需要发送的数据通过网络发出去。
        由下图中可以看出,数据的流向主要有两种。应用层输出数据时,数据按照自上而下的顺
序,依次通过应用 API 层、协议层和接口层 ; 当有数据到达的时候,自下而上依次通过接口
层、协议层和应用 API 层的方式,在内核层传递。
        应用层 Socket 的初始化、绑定 (bind) 和销毁是通过调用内核层的 socket() 函数进行资源的申
请和销毁的。
        发送数据的时候,将数据由应用 API 层传递给协议层,协议层在 UDP 层添加 UDP 的首部、
TCP 层添加 TCP 的首部、 IP 层添加 IP 的首部,接口层的网卡则添加以太网相关的信息后,
通过网卡的发送程序发送到网络上。
        接收数据的过程是一个相反的过程,当有数据到来的时候,网卡的中断处理程序将数据从
以太网网卡的 FIFO 对列中接收到内核 , 传递给协议层 , 协议层在 IP 层剥离 IP 的首部、 UDP
剥离 UDP 的首部、 TCP 层剥离 TCP 的首部后传递给应用 API 层,应用 API 层查询 socket
标识后,将数据送给用户层匹配的 socket
        在 Linux 内核实现中,链路层协议靠网卡驱动来实现,内核协议栈来实现网络层和传输层。
内核对更上层的应用层提供 socket 接口来供用户进程访问。

Linux 下的 IO 复用编程

        select, poll epoll 都是 IO 多路复用的机制。 I/O 多路复用就是通过一种机制,一个进
程可以监视多个描述符,一旦某个描述符就绪(一般是读就绪或者写就绪),能够通知程序
进行相应的读写操作。但 select poll epoll 本质上都是同步 I/O ,因为他们都需要在读写事
件就绪后自己负责进行读写,并等待读写完成。
文件描述符 FD
        在 Linux 操作系统中,可以将一切都看作是文件,包括普通文件,目录文件,字符设备
文件(如键盘,鼠标…),块设备文件(如硬盘,光驱…),套接字等等,所有一切均抽象
成文件,提供了统一的接口,方便应用程序调用。
既然在 Linux 操作系统中,你将一切都抽象为了文件,那么对于一个打开的文件,我应
用程序怎么对应上呢?文件描述符应运而生。
         文件描述符 File descriptor,简称 fd,当应用程序请求内核打开/新建一个文件时,内核
会返回一个文件描述符用于对应这个打开/新建的文件,其 fd 本质上就是一个非负整数。
际上,它是一个索引值,指向内核为每一个进程所维护的该进程打开文件的记录表。当程序
打开一个现有文件或者创建一个新文件时,内核向进程返回一个文件描述符。在程序设计中,
一些涉及底层的程序编写往往会围绕着文件描述符展开。但是文件描述符这一概念往往只适
用于 UNIX Linux 这样的操作系统。
        系统为了维护文件描述符建立了 3 个表:进程级的文件描述符表、系统级的文件描述符
表、文件系统的 i-node 表 。所谓进程级的文件描述符表,指操作系统为每一个进程维护了
一个文件描述符表,该表的索引值都从从 0 开始的,所以在不同的进程中可以看到相同的文
件描述符,这种情况下相同的文件描述符可能指向同一个实际文件,也可能指向不同的实际
文件
select
int select (int n, fd_set *readfds, fd_set *writefds, fd_set *exceptfds, struct timeval
*timeout);
        select 函数监视的文件描述符分 3 类, 分别是 writefds、readfds、和 exceptfds 。调用后
select 函数会阻塞,直到有描述副就绪(有数据 可读、可写、或者有 except ),或者超时
timeout 指定等待时间,如果立即返回设为 null 即可),函数返回。当 select 函数返回后,
可以 通过遍历 fdset ,来找到就绪的描述符。
        select 目前几乎在所有的平台上支持,其良好跨平台支持也是它的一个优点。 select
一 个缺点在于单个进程能够监视的文件描述符的数量存在最大限制,在 Linux 上一般为 1024
可以通过修改宏定义甚至重新编译内核的方式提升这一限制,但是这样也会造成效率的降低。
poll
int poll (struct pollfd *fds, unsigned int nfds, int timeout);
         不同与 select 使用三个位图来表示三个 fdset 的方式,poll 使用一个 pollfd 的指针实现。
pollfd 结构包含了要监视的 event 和发生的 event,不再使用 select“参数-值”传递的方
。同时, pollfd 并没有最大数量限制(但是数量过大后性能也是会下降)。 和 select 函数
一样, poll 返回后,需要轮询 pollfd 来获取就绪的描述符。
epoll
         epoll 是在 2.6 内核中提出的,是之前的 select 和 poll 的增强版本 。相对于 select poll
来说,可以看到 epoll 做了更细致的分解,包含了三个方法,使用上更加灵活。
int epoll_create(int size)
int epoll_ctl(int epfd, int op, int fd, struct epoll_event *event)
int epoll_wait(int epfd, struct epoll_event * events, int maxevents, int timeout);
int epoll_create(int size);
        创建一个 epoll 的句柄, size 用来告诉内核这个监听的数目一共有多大,这个参数不同
select() 中的第一个参数,给出最大监听的 fd+1 的值,参数 size 并不是限制了 epoll 所能
监听的描述符最大个数,只是对内核初始分配内部数据结构的一个建议。当创建好 epoll
柄后,它就会占用一个 fd 值,在 linux 下如果查看 /proc/ 进程 id/fd/ ,是能够看到这个 fd 的,
所以在使用完 epoll 后,必须调用 close() 关闭,否则可能导致 fd 被耗尽。
作为类比,可以理解为对应于 JDK NIO 编程里的 selector = Selector.open();
int epoll_ctl(int epfd, int op, int fd, struct epoll_event *event)
函数是对指定描述符 fd 执行 op 操作。
         epfd: 是 epoll_create()的返回值。
         op: 表示 op 操作,用三个宏来表示:添加 EPOLL_CTL_ADD,删除 EPOLL_CTL_DEL,修改 EPOLL_CTL_MOD。分别添加、删除和修改对 fd 的监听事件。
         fd: 是需要监听的 fd(文件描述符)
         epoll_event: 是告诉内核需要监听什么事,有具体的宏可以使用,比如 EPOLLIN :表示
对应的文件描述符可以读(包括对端 SOCKET 正常关闭);EPOLLOUT:表示对应的文件描述
符可以写;
        作为类比,可以理解为对应于 JDK NIO 编程里的 socketChannel.register();
int epoll_wait(int epfd, struct epoll_event * events, int maxevents, int timeout);
        等待 epfd 上的 io 事件,最多返回 maxevents 个事件。
        参数 events 用来从内核得到事件的集合, maxevents 告之内核这个 events 有多大,这 个 maxevents 的值不能大于创建 epoll_create() 时的 size ,参数 timeout 是超时时间(毫秒, 0
会立即返回, -1 将不确定,也有说法说是永久阻塞)。该函数返回需要处理的事件数目,
如返回 0 表示已超时。
        作为类比,可以理解为对应于 JDK NIO 编程里的 selector.select();

selectpollepoll 的比较

         select,poll,epoll 都是 操作系统实现 IO 多路复用的机制。 我们知道, I/O 多路复用
就通过一种机制,可以监视多个描述符,一旦某个描述符就绪(一般是读就绪或者写就绪),
能够通知程序进行相应的读写操作。那么这三种机制有什么区别呢。
1、支持一个进程所能打开的最大连接数.

 2FD 剧增后带来的 IO 效率问题

 3、 消息传递方式

总结:
        综上,在选择 select poll epoll 时要根据具体的使用场合以及这三种方式的自身特点。
         1、表面上看 epoll 的性能最好,但是在连接数少并且连接都十分活跃的情况下,select
和 poll 的性能可能比 epoll 好,毕竟 epoll 的通知机制需要很多函数回调。
        2、select 低效是因为每次它都需要轮询。但低效也是相对的,视情况而定,也可通过
良好的设计改善。

epoll 高效原理和底层机制分析

从网卡接收数据说起

        一个典型的计算机结构图,计算机由 CPU 、存储器(内存)、网络接口等部件组成。了
epoll 本质的第一步,要从硬件的角度看计算机怎样接收网络数据.
         网卡收到网线传来的数据;经过硬件电路的传输;最终将数据写入到内存中的某个地址
。这个过程涉及到 DMA 传输、 IO 通路选择等硬件有关的知识,但我们只需知道:网卡会
把接收到的数据写入内存。操作系统就可以去读取它们。

如何知道接收了数据?

        CPU 和操作系统如何知道网络上有数据要接收?很简单,使用中断机制。

中断、上半部、下半部

         内核和设备驱动是通过中断的方式来处理的 。所谓中断,可以理解为当设备上有数据到达
的时候,会给 CPU 的相关引脚上触发一个电压变化,以通知 CPU 来处理数据。
         计算机执行程序时,会有优先级的需求 。比如,当计算机收到断电信号时(电容可以保
存少许电量,供 CPU 运行很短的一小段时间),它应立即去保存数据,保存数据的程序具
有较高的优先级。
        一般而言,由硬件产生的信号需要 cpu 立马做出回应(不然数据可能就丢失),所以它
的优先级很高。 cpu 理应中断掉正在执行的程序,去做出响应;当 cpu 完成对硬件的响应后,
再重新执行用户程序。中断的过程如下图,和函数调用差不多。只不过函数调用是事先定好
位置,而中断的位置由“信号”决定。

         以键盘为例,当用户按下键盘某个按键时,键盘会给 cpu 的中断引脚发出一个高电平。
cpu 能够捕获这个信号,然后执行键盘中断程序。
         同样,当网卡把数据写入到内存后,网卡向 cpu 发出一个中断信号,操作系统便能得知有
新数据到来,再通过网卡中断程序去处理数据。
        对于网络模块来说,由于处理过程比较复杂和耗时,如果在中断函数中完成所有的处理,
将会导致中断处理函数(优先级过高)将过度占据 CPU,将导致 CPU 无法响应其它设备,
例如鼠标和键盘的消息。
        因此 Linux 中断处理函数是分上半部和下半部的。上半部是只进行最简单的工作,快速处
理然后释放 CPU,接着 CPU 就可以允许其它中断进来。剩下将绝大部分的工作都放到下半
部中,可以慢慢从容处理。2.4 以后的内核版本采用的下半部实现方式是软中断,由 ksoftirqd
内核线程全权处理。和硬中断不同的是,硬中断是通过给 CPU 物理引脚施加电压变化,而
软中断是通过给内存中的一个变量的二进制值以通知软中断处理程序。

内核收包的概览

        当网卡上收到数据以后,Linux 中第一个工作的模块是网络驱动。 网络驱动会以 DMA 的
方式把网卡上收到的帧写到内存里。再向 CPU 发起一个中断,以通知 CPU 有数据到达。
二,当 CPU 收到中断请求后,会去调用网络驱动注册的中断处理函数。 网卡的中断处理函
数并不做过多工作,发出软中断请求,然后尽快释放 CPU ksoftirqd 检测到有软中断请求到
达,调用 poll 开始轮询收包,收到后交由各级协议栈处理。 最后会被放到用户 socket 的接
收队列中。

进程阻塞

        了解 epoll 本质,要从操作系统进程调度的角度来看数据接收。阻塞是进程调度的关键
一环,指的是进程在等待某事件(如接收到网络数据)发生之前的等待状态, recv select
epoll 都是阻塞方法。了解“进程阻塞为什么不占用 cpu 资源?”,也就能够了解这一步。
        为简单起见,我们从普通的 recv 接收开始分析,先看看下面代码:
        //创建 socket
        int s = socket(AF_INET, SOCK_STREAM, 0);
        //绑定
        bind(s, ...)
        //监听
        listen(s, ...)
        //接受客户端连接

        int c = accept(s, ...)
        //接收客户端数据
        recv(c, ...);
        //将数据打印出来
        printf(...)
        这是一段最基础的网络编程代码,先新建 socket 对象,依次调用 bind listen accept
最后调用 recv 接收数据。 recv 是个阻塞方法,当程序运行到 recv 时,它会一直等待,直到
接收到数据才往下执行。
         那么阻塞的原理是什么?
         操作系统为了支持多任务,实现了进程调度的功能,会把进程分为“运行”和“等待”
等几种状态。运行状态是进程获得 cpu 使用权,正在执行代码的状态;等待状态是阻塞状态,
比如上述程序运行到 recv 时,程序会从运行状态变为等待状态,接收到数据后又变回运行
状态。操作系统会分时执行各个运行状态的进程,由于速度很快,看上去就像是同时执行多
个任务。
        下图中的计算机中运行着 A B C 三个进程,其中进程 A 执行着上述基础网络程序,
一开始,这 3 个进程都被操作系统的工作队列所引用,处于运行状态,会分时执行。

        当进程 A 执行到创建 socket 的语句时,操作系统会创建一个由文件系统管理的 socket
对象。这个 socket 对象包含了发送缓冲区、接收缓冲区、等待队列等成员。等待队列是个
非常重要的结构,它指向所有需要等待该 socket 事件的进程。
        当程序执行到 recv 时,操作系统会将进程 A 从工作队列移动到该 socket 的等待队列中
(如下图)。由于工作队列只剩下了进程 B C ,依据进程调度, cpu 会轮流执行这两个进
程的程序,不会执行进程 A 的程序。所以进程 A 被阻塞,不会往下执行代码,也不会占用
cpu 资源。
         操作系统添加等待队列只是添加了对这个“等待中”进程的引用,以便在接收到数据时
获取进程对象、将其唤醒,而非直接将进程管理纳入自己之下 。上图为了方便说明,直接将
进程挂到等待队列之下。
         当 socket 接收到数据后,操作系统将该 socket 等待队列上的进程重新放回到工作队列,
该进程变成运行状态,继续执行代码。 也由于 socket 的接收缓冲区已经有了数据, recv
以返回接收到的数据。

内核接收网络数据

        进程在 recv 阻塞期间,计算机收到了对端传送的数据(步骤①)。数据经由网卡传送
到内存(步骤②),然后网卡通过中断信号通知 cpu 有数据到达, cpu 执行中断程序(步骤
③)。此处的中断程序主要有两项功能,先将网络数据写入到对应 socket 的接收缓冲区里
面(步骤④),再唤醒进程 A (步骤⑤),重新将进程 A 放入工作队列中。

        思考下,操作系统如何知道网络数据对应于哪个 socket
        因为一个 socket 对应着一个端口号,而网络数据包中包含了 ip 和端口的信息,内核可 以通过端口号找到对应的 socket 。当然,为了提高处理速度,操作系统会维护端口号到 socket 的索引结构,以快速读取。
        思考下,如何同时监视多个 socket 的数据?

同时监视多个 socket 的简单方法

         服务端需要管理多个客户端连接,而 recv 只能监视单个 socket,这种矛盾下,人们开
始寻找监视多个 socket 的方法。epoll 的要义是高效的监视多个 socket。 从历史发展角度看,
必然先出现一种不太高效的方法,人们再加以改进。只有先理解了不太高效的方法,才能够
理解 epoll 的本质。
        假如能够预先传入一个 socket 列表,如果列表中的 socket 都没有数据,挂起进程,直
到有一个 socket 收到数据,唤醒进程。这种方法很直接,也是 select 的设计思想。
        为方便理解,我们先看看 Linux select 的用法。在如下的代码中,先准备一个数组(下
面代码中的 fds ),让 fds 存放着所有需要监视的 socket 。然后调用 select ,如果 fds 中的所
socket 都没有数据, select 会阻塞,直到有一个 socket 接收到数据, select 返回,唤醒进
程。用户可以遍历 fds ,通过 FD_ISSET 判断具体哪个 socket 收到数据,然后做出处理。
int fds[] = 存放需要监听的 socket
while(1){int n = select(..., fds, ...)for(int i=0; i < fds.count; i++){if(FD_ISSET(fds[i], ...)){//fds[i]的数据处理}} }
        select 的实现思路很直接。假如程序同时监视 sock1 sock2 sock3 三个 socket ,那么
在调用 select 之后,操作系统把进程 A 分别加入这三个 socket 的等待队列中。
         当任何一个 socket 收到数据后,中断程序将唤起进程。所谓唤起进程,就是将进程从
所有的等待队列中移除,加入到工作队列里面。
        经由这些步骤,当进程 A 被唤醒后,它知道至少有一个 socket 接收了数据。程序只需
遍历一遍 socket 列表,就可以得到就绪的 socket。
        这种简单方式行之有效,在几乎所有操作系统都有对应的实现。
        但是简单的方法往往有缺点,主要是:
        其一,每次调用 select 都需要将进程加入到所有被监视 socket 的等待队列,每次唤醒都
需要从每个队列中移除,都必须要进行遍历。而且每次都要将整个 fds 列表传递给内核,有
一定的开销。正是因为遍历操作开销大,出于效率的考量,才会规定 select 的最大监视数量,
默认只能监视 1024 socket
        其二,进程被唤醒后,程序并不知道哪些 socket 收到数据,还需要遍历一次。
        那么,有没有减少遍历的方法?有没有保存就绪 socket 的方法?这两个问题便是 epoll
技术要解决的。
        当然,当程序调用 select 时,内核会先遍历一遍 socket ,如果有一个以上的 socket 接收
缓冲区有数据,那么 select 直接返回,不会阻塞。这也是为什么 select 的返回值有可能大于
1 的原因之一。如果没有 socket 有数据,进程才会阻塞。
 

epoll 的设计思路

        epoll 是在 select 出现 N 多年后才被发明的,是 select poll 的增强版本。 epoll 通过以
下一些措施来改进效率。
        措施一: 功能分离
         select 低效的原因之一是将“维护等待队列”和“阻塞进程”两个步骤合二为一。每次
调用 select 都需要这两步操作,然而大多数应用场景中,需要监视的 socket 相对固定,并不
需要每次都修改。epoll 将这两个操作分开,先用 epoll_ctl 维护等待队列,再调用 epoll_wait
阻塞进程。显而易见的,效率就能得到提升。
        相比 select,epoll 拆分了功能
        为方便理解后续的内容,我们再来看看 epoll 的用法。如下的代码中,先用 epoll_create
创建一个 epoll 对象 epfd ,再通过 epoll_ctl 将需要监视的 socket 添加到 epfd 中,最后调用
epoll_wait 等待数据。
int epfd = epoll_create(...);
epoll_ctl(epfd, ...); //将所有需要监听的 socket 添加到 epfd 中
while(1){int n = epoll_wait(...)for(接收到数据的 socket){//处理} }
功能分离,使得 epoll 有了优化的可能。
措施二: 就绪列表
        select 低效的另一个原因在于程序不知道哪些 socket 收到数据,只能一个个遍历。如果
内核维护一个“就绪列表”,引用收到数据的 socket ,就能避免遍历。

epoll 的原理和流程

        当某个进程调用 epoll_create 方法时,内核会创建一个 eventpoll 对象(也就是程序中
epfd 所代表的对象)。 eventpoll 对象也是文件系统中的一员,和 socket 一样,它也会有等
待队列。
        创建 epoll 对象后,可以用 epoll_ctl 添加或删除所要监听的 socket 。以添加 socket 为例,
如下图,如果通过 epoll_ctl 添加 sock1 sock2 sock3 的监视,内核会将 eventpoll 添加到
这三个 socket 的等待队列中。
        当 socket 收到数据后,中断程序会操作 eventpoll 对象,而不是直接操作进程。中断程
序会给 eventpoll 的“就绪列表”添加 socket 引用。如下图展示的是 sock2 sock3 收到数
据后,中断程序让 rdlist 引用这两个 socket
        eventpoll 对象相当于是 socket 和进程之间的中介, socket 的数据接收并不直接影响进
程,而是通过改变 eventpoll 的就绪列表来改变进程状态。
        当程序执行到 epoll_wait 时,如果 rdlist 已经引用了 socket ,那么 epoll_wait 直接返回,
如果 rdlist 为空,阻塞进程。
        假设计算机中正在运行进程 A 和进程 B ,在某时刻进程 A 运行到了 epoll_wait 语句。如
下图所示,内核会将进程 A 放入 eventpoll 的等待队列中,阻塞进程。
        当 socket 接收到数据,中断程序一方面修改 rdlist ,另一方面唤醒 eventpoll 等待队列中
的进程,进程 A 再次进入运行状态。也因为 rdlist 的存在,进程 A 可以知道哪些 socket 发生
了变化。

epoll 的实现细节

        现在对 epoll 的本质已经有一定的了解。但我们还留有一个问题, eventpoll 的数据结构
是什么样子?
        思考两个问题,就绪队列应该应使用什么数据结构?eventpoll 应使用什么数据结构来
管理通过 epoll_ctl 添加或删除的 socket

        就绪列表引用着就绪的 socket,所以它应能够快速的插入数据。

        程序可能随时调用 epoll_ctl 添加监视 socket ,也可能随时删除。当删除时,若该 socket
已经存放在就绪列表中,它也应该被移除。
        所以就绪列表应是一种能够快速插入和删除的数据结构。双向链表就是这样一种数据结
构, epoll 使用双向链表来实现就绪队列,也就是 Linux 源码中的
        既然 epoll 将“维护监视队列”和“进程阻塞”分离,也意味着需要有个数据结构来保
存监视的 socket。至少要方便的添加和移除,还要便于搜索,以避免重复添加。红黑树是一
种自平衡二叉查找树,搜索、插入和删除时间复杂度都是 O(log(N)) ,效率较好。 epoll 使用
了红黑树作为索引结构,也就是 Linux 源码中的

 总结

        当某一进程调用 epoll_create 方法时, Linux 内核会创建一个 eventpoll 结构体,在内核
cache 里建了个红黑树用于存储以后 epoll_ctl 传来的 socket 外,还会再建立一个 rdllist 双向
链表,用于存储准备就绪的事件,当 epoll_wait 调用时,仅仅观察这个 rdllist 双向链表里有
没有数据即可。有数据就返回,没有数据就 sleep ,等到 timeout 时间到后即使链表没数据
也返回。
        同时,所有添加到 epoll 中的事件都会与设备 ( 如网卡 ) 驱动程序建立回调关系,也就是
说相应事件的发生时会调用这里的回调方法。这个回调方法在内核中叫做 ep_poll_callback
它会把这样的事件放到上面的 rdllist 双向链表中。
        当调用 epoll_wait 检查是否有发生事件的连接时,只是检查 eventpoll 对象中的 rdllist
双向链表是否有 epitem 元素而已,如果 rdllist 链表不为空,则这里的事件复制到用户态内
存(使用共享内存提高效率)中,同时将事件数量返回给用户。因此 epoll_waitx 效率非常
高,可以轻易地处理百万级别的并发连接。

相关文章:

网络通信-Linux 对网络通信的实现

Linux 网络 IO 模型 同步和异步&#xff0c;阻塞和非阻塞 同步和异步 关注的是调用方是否主动获取结果 同步:同步的意思就是调用方需要主动等待结果的返回 异步:异步的意思就是不需要主动等待结果的返回&#xff0c;而是通过其他手段比如&#xff0c;状态通知&#xff0…...

mysql修改密码

mysql -u root -p ALTER USER USER() IDENTIFIED BY root; FLUSH PRIVILEGES; 其它cmd&#xff1a; ①查看端口&#xff0c;找到占用3306端口的进程&#xff1a;命令行输入 netstat -aon &#xff0c;找到端口号为3306的对应的PID ②结束占用端口3306的进程&#xff1a;命令…...

深入解析C语言中void (*signal(int ,void(*)(int) ) ) (int)

目录 深入解析C语言中的signal函数声明 1. signal函数声明 1.1 signal是一个函数 1.2 返回类型是一个函数指针 2. 函数指针的理解 3. 简化声明使用typedef 为啥不这么写typedef void (*)(int) acc&#xff1f; 代码&#xff1a; 结论 深入解析C语言中的signal函数声明…...

网站显示不安全警告怎么办?消除网站不安全警告超全指南

网站显示不安全警告怎么办&#xff1f;当用户访问你的网站&#xff0c;而您的网站没有部署SSL证书实现HTTPS加密时&#xff0c;网站就会显示不安全警告&#xff0c;这种警告&#xff0c;不仅有可能阻止用户继续浏览网站&#xff0c;影响网站声誉&#xff0c;还有可能影响网站在…...

[SWPUCTF 2021 新生赛]finalrce

[SWPUCTF 2021 新生赛]finalrce wp 注&#xff1a;本文参考了 NSSCTF Leaderchen 师傅的题解&#xff0c;并修补了其中些许不足。 此外&#xff0c;参考了 命令执行(RCE)面对各种过滤&#xff0c;骚姿势绕过总结 题目代码&#xff1a; <?php highlight_file(__FILE__); …...

如何底层调用最快地复制OPC数据到关系数据库

计算机上的二大应用&#xff0c;一是从WEB服务器上获得数据&#xff0c;另一种是向关系数据库中写入数据。在上集我已提出了一个从WEB上获得OPC数据的独创方法&#xff0c;现在谈谈第二种如何快速地把OPC数据写进到数据库中&#xff0c;这也是Calssic OPC最典型的一个应用场景。…...

接口测试工具——ApiFox使用初体验 postman导出和ApiFox导入

目录 ApiFox使用初体验初步使用从postman导出到apifox导入 IDEA简单测试Postman测试工具post请求 接口测试工具swaggerKnife4j1.引入依赖2.配置3.常用注解4.接口测试 JMeter什么是JMeter?JMeter安装配置1.官网下载2.下载后解压3.汉语设置 JMeter的使用方法1.新建线程组2.设置参…...

搜维尔科技:经脉腧穴虚拟针灸VR虚拟教学平台AcuMap软件案例分享

北京中医药大学经脉腧穴VR虚拟教学平台案例 主要产品 HTCvive &#xff0c;AcuMap&#xff1b; 实施内容 一、项目说明 &#xff08;1&#xff09;穴位取穴与体表解剖标志关系&#xff1b;&#xff08;2&#xff09;穴下层次解剖及周围解剖结构展示&#xff1b; &#xf…...

Jenkins的shared library相关

Jenkins的shared library是一种用于在多个Jenkins流水线项目中共享和重用代码的机制。它可以将常用的构建逻辑、工具函数或自定义步骤封装为可复用的库&#xff0c;并以插件的形式提供给Jenkins。 Shared library的作用主要包括以下几个方面&#xff1a; 代码复用&#xff1a…...

文件IO

文章目录 文章目录 前言 一 . 文件 文件路径 文件类型 Java中操作文件 File 概述 属性 构造方法 方法 createNewFile mkdir 二 . 文件内容的读写 - IO InputStream 概述 FileInputStream 概述 利用 Scanner 进行字符读取 OutputStream 概述 PrintWriter封装O…...

【日常聊聊】编程语言的未来:趋势、多样性、人工智能融合、教育与生态系统

&#x1f34e;个人博客&#xff1a;个人主页 &#x1f3c6;个人专栏&#xff1a; 日常聊聊 ⛳️ 功不唐捐&#xff0c;玉汝于成 目录 前言&#xff1a; 正文 1. 编程语言的发展趋势 1.1 新语言和编程范式的涌现 1.2 影响和挑战 2. 编程语言的多样性 2.1 互操作性和可移…...

无需手动搜索!轻松创建IntelliJ IDEA快捷方式的Linux教程

轻松创建IntelliJ IDEA快捷方式的Linux教程 一、IntelliJ IDEA简介二、在Linux系统中创建快捷方式的好处三、命令行创建IntelliJ IDEA快捷方式四、图形界面创建IntelliJ IDEA快捷方式五、常见问题总结 一、IntelliJ IDEA简介 IntelliJ IDEA是一个由JetBrains搞的IDE&#xff0…...

如何去掉微博水印?用它一键去除三秒出图

微博是一款非常流行的社交媒体平台&#xff0c;许多人都在上面分享自己的生活点滴和心得体会。但是&#xff0c;有时候我们会发现&#xff0c;在上传图片时&#xff0c;微博会自动添加水印&#xff0c;这会影响到图片的美观度。那么&#xff0c;如何去掉微博水印呢&#xff1f;…...

Golang 泛型实现原理

文章目录 1.什么是泛型&#xff1f;2.有 interface{} 为什么还要有泛型&#xff1f;3.泛型有哪些特性?3.1 类型参数泛型函数泛型类型 3.2 类型约束3.3 类型集3.4 约束元素任意类型约束元素近似约束元素联合约束元素约束中的可比类型 3.5 类型推断 4.实现原理4.1 类型擦除虚方法…...

[玩转AIGC]LLaMA2之如何微调模型

目录 1、下载训练脚本2、 下载模型2.1、申请下载权限2.2、模型下载 3、模型微调3.1、使用单卡微调3.2、使用多卡训练&#xff1a; 1、下载训练脚本 首先我们从github上下载Llama 2的微调代码&#xff1a;GitHub - facebookresearch/llama-recipes: Examples and recipes for L…...

使用克魔助手进行iOS数据抓包和HTTP抓包的方法详解

摘要 本文博客将介绍如何在iOS环境下使用克魔助手进行数据抓包和HTTP抓包。通过抓包&#xff0c;开发者可以分析移动应用程序的网络请求发送和接收过程&#xff0c;识别潜在的性能和安全问题&#xff0c;提高应用的质量和安全性。 引言 在移动应用程序的开发和测试过程中&am…...

【递归 回溯】LeetCode-301. 删除无效的括号

301. 删除无效的括号。 给你一个由若干括号和字母组成的字符串 s &#xff0c;删除最小数量的无效括号&#xff0c;使得输入的字符串有效。 返回所有可能的结果。答案可以按 任意顺序 返回。 示例 1&#xff1a; 输入&#xff1a;s "()())()" 输出&#xff1a;[…...

C++ 基本的输入输出

C 标准库提供了一组丰富的输入/输出功能&#xff0c;我们将在后续的章节进行介绍。本章将讨论 C 编程中最基本和最常见的 I/O 操作。 C 的 I/O 发生在流中&#xff0c;流是字节序列。如果字节流是从设备&#xff08;如键盘、磁盘驱动器、网络连接等&#xff09;流向内存&#…...

vue3老项目如何引入vite

vue3老项目如何引入vite 安装 npm install vite vitejs/plugin-vue --save-dev Vite官方中文文档修改package.json文件 在 npm scripts 中使用 vite 执行文件 "scripts": {"serve": "vite","build": "vite build","pr…...

javaEE -19(9000 字 JavaScript入门 - 4)

一&#xff1a; jQuery jQuery是一个快速、小巧且功能丰富的JavaScript库。它旨在简化HTML文档遍历、事件处理、动画效果以及与后端服务器的交互等操作。通过使用jQuery&#xff0c;开发者可以以更简洁、更高效的方式来编写JavaScript代码。 jQuery提供了许多易于使用的方法和…...

二叉树的非递归遍历|前中后序遍历

二叉树的非递归遍历 文章目录 二叉树的非递归遍历前序遍历-栈层序遍历-队列中序遍历-栈后序遍历-栈 前序遍历-栈 首先我们应该创建一个Stack 用来存放节点&#xff0c;首先我们想要打印根节点的数据&#xff0c;此时Stack里面的内容为空&#xff0c;所以我们优先将头结点加入S…...

开源minio-AWS-S3存储的部署及go操作详细

介绍 MinIO是一个开源的分布式对象存储服务&#xff0c;它允许用户在私有云或公有云环境中构建自己的对象存储基础设施。MinIO旨在提供高性能、高可用性的对象存储&#xff0c;并且与Amazon S3兼容&#xff0c;这意味着可以使用S3客户端工具和库直接与MinIO交互&#xff0c;而…...

【Web2D/3D】Canvas(第三篇)

1. 前言 <canvas>是HTML5新增元素&#xff0c;它是一个画板&#xff0c;开发人员基于它的2D上下文或webgl上下文&#xff0c;使用JS脚本绘制简单的动画、可交互画面&#xff0c;甚至进行视频渲染。 本篇介绍基于canvas的2D上下文绘制2D画面的一些方法和属性。 2. canvas…...

紫光展锐T820与飞桨完成I级兼容性测试 助推端侧AI融合创新

近日&#xff0c;紫光展锐高性能5G SoC T820与百度飞桨完成I级兼容性测试&#xff08;基于Paddle Lite工具&#xff09;。测试结果显示&#xff0c;双方兼容性表现良好&#xff0c;整体运行稳定。这是紫光展锐加入百度“硬件生态共创计划”后的阶段性成果。 本次I级兼容性测试完…...

3DV 2024 Oral | SlimmeRF:可动态压缩辐射场,实现模型大小和建模精度的灵活权衡

目前大多数NeRF模型要么通过使用大型模型来实现高精度&#xff0c;要么通过牺牲精度来节省内存资源。这使得任何单一模型的适用范围受到局限&#xff0c;因为高精度模型可能无法适应低内存设备&#xff0c;而内存高效模型可能无法满足高质量要求。为此&#xff0c;本文研究者提…...

【unity学习笔记】4.场景切换

创建空物体→创建脚本挂载在空物体上→打开脚本 1.创建所需要的场景 assets中点击创建场景 2.文件→生成设置 3.将需要的场景拖入 4.场景跳转 创建空对象&#xff0c;将脚本放在空对象上。 注意两个类&#xff1a;场景类、场景管理类 void Start(){//场景跳转SceneManager.Lo…...

LeetCode75| 滑动窗口

目录 643 子数组最大平均数 | 1456 定长子串中元音的最大数目 1004 最大连续1的个数 ||| 1493 删掉一个元素以后全为1的最长子数组 643 子数组最大平均数 | class Solution { public:double findMaxAverage(vector<int>& nums, int k) {double sum 0;double re…...

gulimall-002 分布式基础概念

1、微服务概念 微服务是一种非常流行的架构风格。 拒绝大型单体应用&#xff0c;基于业务边界进行服务微化拆分&#xff0c;各个服务独立部署运行。 每个服务运行在自己的单个进程使用轻量级机制通信可以使用不同的编程语言编写以及不同的数据存储技术 2、集群&分布式&…...

K8s之声明式APIs

大家好&#xff0c;我是升仔 引言 Kubernetes&#xff08;K8s&#xff09;是一个开源的容器编排系统&#xff0c;用于自动化部署、扩展和管理容器化应用。在K8s中&#xff0c;声明式APIs&#xff08;Application Programming Interfaces&#xff09;是一种核心概念&#xff0…...

Hive执行计划

Hive提供了explain命令来展示一个查询的执行计划&#xff0c;这个执行计划对于我们了解底层原理&#xff0c;Hive 调优&#xff0c;排查数据倾斜等很有帮助。 使用语法如下&#xff1a; explain query;在 hive cli 中输入以下命令(hive 2.3.7)&#xff1a; explain select s…...