Java IO复用_动力节点Java学院整理

发布时间 - 2026-01-11 01:25:48    点击率:

对于服务器的并发处理能力,我们需要的是:每一毫秒服务器都能及时处理这一毫秒内收到的数百个不同TCP连接上的报文,与此同时,可能服务器上还有数以十万计的最近几秒没有收发任何报文的相对不活跃连接。同时处理多个并行发生事件的连接,简称为并发;同时处理万计、十万计的连接,则是高并发。服务器的并发编程所追求的就是处理的并发连接数目无限大,同时维持着高效率使用CPU等资源,直至物理资源首先耗尽。

并发编程有很多种实现模型,最简单的就是与“线程”捆绑,1个线程处理1个连接的全部生命周期。优点:这个模型足够简单,它可以实现复杂的业务场景,同时,线程个数是可以远大于CPU个数的。然而,线程个数又不是可以无限增大的,为什么呢?因为线程什么时候执行是由操作系统内核调度算法决定的,调度算法并不会考虑某个线程可能只是为了一个连接服务的,它会做大一统的玩法:时间片到了就执行一下,哪怕这个线程一执行就会不得不继续睡眠。这样来回的唤醒、睡眠线程在次数不多的情况下,是廉价的,但如果操作系统的线程总数很多时,它就是昂贵的(被放大了),因为这种技术性的调度损耗会影响到线程上执行的业务代码的时间。举个例子,这时大部分拥有不活跃连接的线程就像我们的国企,它们执行效率太低了,它总是唤醒就睡眠在做无用功,而它唤醒争到CPU资源的同时,就意味着处理活跃连接的民企线程减少获得了CPU的机会,CPU是核心竞争力,它的无效率进而影响了GDP总吞吐量。我们所追求的是并发处理数十万连接,当几千个线程出现时,系统的执行效率就已经无法满足高并发了。

对高并发编程,目前只有一种模型,也是本质上唯一有效的玩法。连接上的消息处理,可以分为两个阶段:等待消息准备好、消息处理。当使用默认的阻塞套接字时(例如上面提到的1个线程捆绑处理1个连接),往往是把这两个阶段合而为一,这样操作套接字的代码所在的线程就得睡眠来等待消息准备好,这导致了高并发下线程会频繁的睡眠、唤醒,从而影响了CPU的使用效率。

高并发编程方法当然就是把两个阶段分开处理。即,等待消息准备好的代码段,与处理消息的代码段是分离的。当然,这也要求套接字必须是非阻塞的,否则,处理消息的代码段很容易导致条件不满足时,所在线程又进入了睡眠等待阶段。那么问题来了,等待消息准备好这个阶段怎么实现?它毕竟还是等待,这意味着线程还是要睡眠的!解决办法就是,主动查询,或者让1个线程为所有连接而等待!这就是IO多路复用了。多路复用就是处理等待消息准备好这件事的,但它可以同时处理多个连接!它也可以“等待”,所以它也可能导致线程睡眠,然而这不要紧,因为它一对多、它可以监控所有连接。这样,当我们的线程被唤醒执行时,就一定是有一些连接准备好被我们的代码执行了,这是有效率的!没有那么多个线程都在争抢处理“等待消息准备好”阶段,整个世界终于清净了!
多路复用有很多种实现,在linux上,2.4内核前主要是select和poll,现在主流是epoll,它们的使用方法似乎很不同,但本质是一样的。

效率却也不同,这也是epoll完全替代了select的原因。

简单的谈下epoll为何会替代select。

前面提到过,高并发的核心解决方案是1个线程处理所有连接的“等待消息准备好”,这一点上epoll和select是无争议的。但select预估错误了一件事,就像我们开篇所说,当数十万并发连接存在时,可能每一毫秒只有数百个活跃的连接,同时其余数十万连接在这一毫秒是非活跃的。select的使用方法是这样的:
返回的活跃连接 ==select(全部待监控的连接)

什么时候会调用select方法呢?在你认为需要找出有报文到达的活跃连接时,就应该调用。所以,调用select在高并发时是会被频繁调用的。这样,这个频繁调用的方法就很有必要看看它是否有效率,因为,它的轻微效率损失都会被“频繁”二字所放大。它有效率损失吗?显而易见,全部待监控连接是数以十万计的,返回的只是数百个活跃连接,这本身就是无效率的表现。被放大后就会发现,处理并发上万个连接时,select就完全力不从心了。
看几个图。当并发连接为一千以下,select的执行次数不算频繁,与epoll似乎并无多少差距: 

然而,并发数一旦上去,select的缺点被“执行频繁”无限放大了,且并发数越多越明显:

再来说说epoll是如何解决的。它很聪明的用了3个方法来实现select方法要做的事:

新建的epoll描述符==epoll_create()

epoll_ctrl(epoll描述符,添加或者删除所有待监控的连接)

返回的活跃连接 ==epoll_wait( epoll描述符 )

这么做的好处主要是:分清了频繁调用和不频繁调用的操作。例如,epoll_ctrl是不太频繁调用的,而epoll_wait是非常频繁调用的。这时,epoll_wait却几乎没有入参,这比select的效率高出一大截,而且,它也不会随着并发连接的增加使得入参越发多起来,导致内核执行效率下降。

epoll是怎么实现的呢?其实很简单,从这3个方法就可以看出,它比select聪明的避免了每次频繁调用“哪些连接已经处在消息准备好阶段”的 epoll_wait时,是不需要把所有待监控连接传入的。这意味着,它在内核态维护了一个数据结构保存着所有待监控的连接。这个数据结构就是一棵红黑树,它的结点的增加、减少是通过epoll_ctrl来完成的。它是非常简单的: 

图中左下方的红黑树由所有待监控的连接构成。左上方的链表,同是目前所有活跃的连接。于是,epoll_wait执行时只是检查左上方的链表,并返回左上方链表中的连接给用户。这样,epoll_wait的执行效率能不高吗?

最后,再看看epoll提供的2种玩法ET和LT,即翻译过来的边缘触发和水平触发。其实这两个中文名字倒也有些贴切。这2种使用方式针对的仍然是效率问题,只不过变成了epoll_wait返回的连接如何能够更准确些。

例如,我们需要监控一个连接的写缓冲区是否空闲,满足“可写”时我们就可以从用户态将响应调用write发送给客户端 。但是,或者连接可写时,我们的“响应”内容还在磁盘上呢,此时若是磁盘读取还未完成呢?肯定不能使线程阻塞的,那么就不发送响应了。但是,下一次epoll_wait时可能又把这个连接返回给你了,你还得检查下是否要处理。可能,我们的程序有另一个模块专门处理磁盘IO,它会在磁盘IO完成时再发送响应。那么,每次epoll_wait都返回这个“可写”的、却无法立刻处理的连接,是否符合用户预期呢?

于是,ET和LT模式就应运而生了。LT是每次满足期待状态的连接,都得在epoll_wait中返回,所以它一视同仁,都在一条水平线上。ET则不然,它倾向更精确的返回连接。在上面的例子中,连接第一次变为可写后,若是程序未向连接上写入任何数据,那么下一次epoll_wait是不会返回这个连接的。ET叫做 边缘触发,就是指,只有连接从一个状态转到另一个状态时,才会触发epoll_wait返回它。可见,ET的编程要复杂不少,至少应用程序要小心的防止epoll_wait的返回的连接出现:可写时未写数据后却期待下一次“可写”、可读时未读尽数据却期待下一次“可读”。

当然,从一般应用场景上它们性能是不会有什么大的差距的,ET可能的优点是,epoll_wait的调用次数会减少一些,某些场景下连接在不必要唤醒时不会被唤醒(此唤醒指epoll_wait返回)。但如果像我上面举例所说的,有时它不单纯是一个网络问题,跟应用场景相关。当然,大部分开源框架都是基于ET写的,框架嘛,它追求的是纯技术问题,当然力求尽善尽美


# java  # io  # 复用  # JavaWeb Session失效时间设置方法  # Java 使用IO流实现大文件的分割与合并实例详解  # java中Collections.sort排序函数用法详解  # java IO流 之 输出流 OutputString()的使用  # java IO流 之 输入流 InputString()的使用  # SVN出现提示org.apache.subversion.javahl.ClientExceptio  # 的是  # 多个  # 它也  # 这一  # 就会  # 数十万  # 就像  # 都在  # 多路  # 什么时候  # 百个  # 这两个  # 数据结构  # 链表  # 大了  # 它可以  # 数以  # 就可以  # 主要是 


相关栏目: 【 网站优化151355 】 【 网络推广146373 】 【 网络技术251813 】 【 AI营销90571


相关推荐: Thinkphp 中 distinct 的用法解析  Laravel Seeder怎么填充数据_Laravel数据库填充器的使用方法与技巧  EditPlus中的正则表达式实战(6)  网站页面设计需要考虑到这些问题  黑客如何利用漏洞与弱口令入侵网站服务器?  如何在不使用负向后查找的情况下匹配特定条件前的换行符  如何快速搭建安全的FTP站点?  Laravel模型事件有哪些_Laravel Model Event生命周期详解  如何在HTML表单中获取用户输入并结合JavaScript动态控制复利计算循环  网站制作壁纸教程视频,电脑壁纸网站?  如何在万网利用已有域名快速建站?  Swift中switch语句区间和元组模式匹配  ChatGPT常用指令模板大全 新手快速上手的万能Prompt合集  Laravel如何实现API版本控制_Laravel API版本化路由设计策略  如何用AI帮你把自己的生活经历写成一个有趣的故事?  香港服务器网站搭建教程-电商部署、配置优化与安全稳定指南  教你用AI将一段旋律扩展成一首完整的曲子  如何在建站主机中优化服务器配置?  西安市网站制作公司,哪个相亲网站比较好?西安比较好的相亲网站?  如何正确下载安装西数主机建站助手?  iOS UIView常见属性方法小结  Win11搜索不到蓝牙耳机怎么办 Win11蓝牙驱动更新修复【详解】  小视频制作网站有哪些,有什么看国内小视频的网站,求推荐?  如何自定义建站之星模板颜色并下载新样式?  文字头像制作网站推荐软件,醒图能自动配文字吗?  html5源代码发行怎么设置权限_访问权限控制方法与实践【指南】  Claude怎样写约束型提示词_Claude约束提示词写法【教程】  瓜子二手车官方网站在线入口 瓜子二手车网页版官网通道入口  Laravel Eloquent:优雅地将关联模型字段扁平化到主模型中  Laravel如何生成和使用数据填充?(Seeder和Factory示例)  Laravel如何处理和验证JSON类型的数据库字段  免费网站制作appp,免费制作app哪个平台好?  html5的keygen标签为什么废弃_替代方案说明【解答】  东莞市网站制作公司有哪些,东莞找工作用什么网站好?  矢量图网站制作软件,用千图网的一张矢量图做公司app首页,该网站并未说明版权等问题,这样做算不算侵权?应该如何解决?  CSS3怎么给轮播图加过渡动画_transition加transform实现【技巧】  浅谈redis在项目中的应用  如何在橙子建站中快速调整背景颜色?  js实现点击每个li节点,都弹出其文本值及修改  Python自动化办公教程_ExcelWordPDF批量处理案例  高端企业智能建站程序:SEO优化与响应式模板定制开发  微信小程序 scroll-view组件实现列表页实例代码  进行网站优化必须要坚持的四大原则  详解一款开源免费的.NET文档操作组件DocX(.NET组件介绍之一)  bootstrap日历插件datetimepicker使用方法  Windows10如何删除恢复分区_Win10 Diskpart命令强制删除分区  Gemini手机端怎么发图片_Gemini手机端发图方法【步骤】  Laravel Eloquent性能优化技巧_Laravel N+1查询问题解决  JavaScript Ajax实现异步通信  Laravel如何记录自定义日志?(Log频道配置)