加入收藏 | 设为首页 | 会员中心 | 我要投稿 萍乡站长网 (https://www.0799zz.com/)- 科技、建站、经验、云计算、5G、大数据,站长网!
当前位置: 首页 > 业界 > 正文

NIO与BIO的区别、NIO的运行原理和并发使用场景

发布时间:2018-09-21 17:18:46 所属栏目:业界 来源:今日头条
导读:副标题#e# 【新品产上线啦】51CTO播客,随时随地,碎片化学习 NIO(Non-blocking I/O,在Java领域,也称为New I/O),是一种同步非阻塞的I/O模型,也是I/O多路复用的基础,已经被越来越多地应用到大型应用服务器,成为解决高并发与大量连接、I/O处理问题的有

我们首先需要注册当这几个事件到来的时候所对应的处理器。然后在合适的时机告诉事件选择器:我对这个事件感兴趣。对于写操作,就是写不出去的时候对写事件感兴趣;对于读操作,就是完成连接和系统没有办法承载新读入的数据的时;对于accept,一般是服务器刚启动的时候;而对于connect,一般是connect失败需要重连或者直接异步调用connect的时候。

其次,用一个死循环选择就绪的事件,会执行系统调用(Linux 2.6之前是select、poll,2.6之后是epoll,Windows是IOCP),还会阻塞的等待新事件的到来。新事件到来的时候,会在selector上注册标记位,标示可读、可写或者有连接到来。

注意,select是阻塞的,无论是通过操作系统的通知(epoll)还是不停的轮询(select,poll),这个函数是阻塞的。所以你可以放心大胆地在一个while(true)里面调用这个函数而不用担心CPU空转。

所以我们的程序大概的模样是:

  1. interface ChannelHandler{ 
  2. void channelReadable(Channel channel); 
  3. void channelWritable(Channel channel); 
  4. class Channel{ 
  5. Socket socket; 
  6. Event event;//读,写或者连接 
  7. //IO线程主循环: 
  8. class IoThread extends Thread{ 
  9. public void run(){ 
  10. Channel channel; 
  11. while(channel=Selector.select()){//选择就绪的事件和对应的连接 
  12. if(channel.event==accept){ 
  13. registerNewChannelHandler(channel);//如果是新连接,则注册一个新的读写处理器 
  14. if(channel.event==write){ 
  15. getChannelHandler(channel).channelWritable(channel);//如果可以写,则执行写事件 
  16. if(channel.event==read){ 
  17. getChannelHandler(channel).channelReadable(channel);//如果可以读,则执行读事件 
  18. Map<Channel,ChannelHandler> handlerMap;//所有channel的对应事件处理器 

这个程序很简短,也是最简单的Reactor模式:注册所有感兴趣的事件处理器,单线程轮询选择就绪事件,执行事件处理器。

3.优化线程模型

由上面的示例我们大概可以总结出NIO是怎么解决掉线程的瓶颈并处理海量连接的:

NIO由原来的阻塞读写(占用线程)变成了单线程轮询事件,找到可以进行读写的网络描述符进行读写。除了事件的轮询是阻塞的(没有可干的事情必须要阻塞),剩余的I/O操作都是纯CPU操作,没有必要开启多线程。

并且由于线程的节约,连接数大的时候因为线程切换带来的问题也随之解决,进而为处理海量连接提供了可能。

单线程处理I/O的效率确实非常高,没有线程切换,只是拼命的读、写、选择事件。但现在的服务器,一般都是多核处理器,如果能够利用多核心进行I/O,无疑对效率会有更大的提高。

(编辑:萍乡站长网)

【声明】本站内容均来自网络,其相关言论仅代表作者个人观点,不代表本站立场。若无意侵犯到您的权利,请及时与联系站长删除相关内容!

推荐文章
    热点阅读