Java非阻塞I/O模型之NIO说明
在了解NIO (Non-Block I/O) 非阻塞I/O模型之前,我们可以先了解一下原始的BIO(Block I/O) 阻塞I/O模型,NIO模型能够以非阻塞的方式更好的利用服务器资源,需要的朋友可以参考下 |
组件说明
(1)Channel:NIO模型中的管道,管道是链接建立和通信的重要组件,我们可以理解管道是一个容器环境,我们所有的I/O的建立读取都可以在这个容器中进行
(2)Selector:NIO中的选择器,NIO是由事件驱动的,当有链接事件或者读取事件发生时,这个事件可以注册到这个选择器上,并且最终被我们检测到。
(3)SelectionKey:我们可以在Selector中进行检测是否有SelectionKey产生,并且根据这个SelectionKey中的信息判断时什么事件发生了。
代码说明
(1)开启ServerSocketChannel,并开始监听
//初始化一个网络地址,并绑定7000端口号 InetSocketAddress inetSocketAddress = new InetSocketAddress(7000); //ServerSocketChannel.open() 方法实例化一个ServerSocketChannel对象 ServerSocketChannel serverSocketChannel = ServerSocketChannel.open(); //serverSocketChannel绑定初始化的网络地址,并开始监听 serverSocketChannel.socket().bind(inetSocketAddress); //将这个通道设置为非阻塞的 serverSocketChannel.configureBlocking(false);
(2)初始化选择器,并将这个选择器注册到上面的网络通道中
//得到一个Selector对象 Selector selector = Selector.open(); //在channel上注册selector,并且告诉这个选择器初始应该监听的事件, //SelectionKey.OP_ACCEPT 为监听链接进入的事件,初始化并不监听数据读取的事件 //SelectionKey.OP_READ 事件读取事件,需要在有链接进入时,配合链接一起注册 serverSocketChannel.register(selector, SelectionKey.OP_ACCEPT);
(3)主循环
//循环等待客户端链接 while(true){//等待1秒,1秒内没有链接事件发生,直接返回if(selector.select(1000)==0){System.out.println("服务器等待了1秒,无连接进入");continue;}//有事件发生,拿到集合//selector.selectedKeys() 关注事件的集合//通过这个可以反向获取通道Set selectionKeys = selector.selectedKeys();//遍历集合,使用迭代器Iterator keyIterator = selectionKeys.iterator();while(keyIterator.hasNext()){//获取事件keySelectionKey key = keyIterator.next();//根据key对应的通道发生的事件做相应的处理if(key.isAcceptable()){//如果是ACCEPT事件,客户端链接//传统的accept()是阻塞的,但是在NIO中,当key.isAcceptable()方法返回true的时候,这个链接就已经存在了,所以accept()会立刻执行SocketChannel socketChannel = serverSocketChannel.accept();socketChannel.configureBlocking(false);//将当前的socketChannel注册的selector,关注事件为READ,同时给Channel关联一个BufferSelectionKey register = socketChannel.register(selector, SelectionKey.OP_READ, ByteBuffer.allocate(128));}else if(key.isReadable()){//发生了READ事件//通过key反向获取ChannelSocketChannel channel = (SocketChannel)key.channel();//获取到该channel关联的bufferByteBuffer buffer =(ByteBuffer) key.attachment();channel.read(buffer);System.out.println("From 客户端 :"+new String(buffer.array()));}//手动在集合中移除当前的SelectionKey否则可能会出现重复操作keyIterator.remove();}}
总结
(1)使用一个事件驱动的方式,在没有事件发生的时候,服务器可以去做一些自己需要做的事。
(2)当有事件发生的时候,通过Selector去关心是什么事件。
(3)甚至不需要使用多线程,就能同时处理更多的链接请求。
(4)当然我们也可以配合多线程,来更有效的利用服务器资源,满足需求更复杂,请求更多的场景。
(5)NIO是Netty的基础,读者可以多手动编写一下NIO的实现,来更深的了解Netty。
Java非阻塞I/O模型之NIO说明相关推荐
- java 非阻塞_Java之NIO(非阻塞IO)
[1]NIO的与IO的区别: 总的来说java 中的IO 和NIO的区别主要有3点: 1)IO是面向流的,NIO是面向缓冲的: 2)IO是阻塞的,NIO是非阻塞的: 3)IO是单线程的,NIO 是通过 ...
- Java 非阻塞 IO 和异步 IO
转载自 Java 非阻塞 IO 和异步 IO 上一篇文章介绍了 Java NIO 中 Buffer.Channel 和 Selector 的基本操作,主要是一些接口操作,比较简单. 本文将介绍非阻塞 ...
- java非阻塞io流_阻塞式和非阻塞io流初认识
1 什么是阻塞式和非阻塞式? 阻塞式IO:IO即input/output,阻塞式IO指的是"一旦输入/输出工作没有完成,则程序阻塞,直到输入/输出工作完成".在目前,我们从书本上 ...
- 深入学习java非阻塞IO
深入学习java非阻塞IO 三大组件: 1. Channel:数据通道双向通道 (1)常见的channel: FileChannel:文件传输通道 DatagramChannel:UDP传输通道 So ...
- node.js事件驱动的非阻塞 I/O模型理解
都说Node.js是一个基于chrome V8引擎的js运行环境,用于方便地搭建响应速度快.易于扩展的网络应用,它有非阻塞.事件驱动模型的特性,有轻量高效的特点,适用于分布式设备上运行数据密集型的实时 ...
- 理解Node.js的异步非阻塞I/O模型
对后台服务器编程不清楚,通过在网上查资料也就大概有写了解. Apache对并发请求的处理方式是,对每个请求就创建一个线程处理,这个线程是堵塞的.因为线程的是占用内存的,所以一台服务器能支持的并发线程量 ...
- java非阻塞锁_Java并发问题的非阻塞解决方案
转自http://blog.csdn.net/u011277203/article/details/9223545 在并发环境中,对于共享资源通常会采用显式的锁机制(比如synchronized或Re ...
- java 非阻塞队列_java并发之非阻塞队列
非阻塞队列有:ArrayDeque.PriorityQueue.ConcurrentLinkedQueue 之前都说过阻塞队列了,其实差别都不大,阻塞和非阻塞的区别在于阻塞队列有put和take方法进 ...
- java非阻塞 串口读数据_串口阻塞与非阻塞
VTIME定义要求等待的时间量(取值不能大于cc_t). VMIN定义了要求等待的最小字节数. options.c_cc[VTIME] = X; //设置从获取到1个字节后开始计时的超时时间(单位为分 ...
最新文章
- xubuntu 19.10安装tensorflow-gpu-2.0(本文很乱,供自己参考)
- 20155226 2016-2017-2 《Java程序设计》第一周学习总结
- track文件 什么是git_git常用命令
- AndroidStudio Refreshing Gradle Project编译更新Gradle卡住问题
- SAP Commerce Cloud OAuth 实现介绍
- java中的动态代理----自己手动实现
- python is beautiful_Python list 和 str 互转
- 项目中记录影响性能的缓慢数据库查询
- javascript实现下拉条联动_JavaScript gt;gt;gt; 003
- Kaggle 年度报告出炉:数据科学家年轻高学历,薪资近百万
- php与mysql事物处理
- js 的arguments的一些理解资料
- 测试用rtmp直播源
- IDT oligo使用说明
- 六个机械原理,动图形象直观、解读通俗易懂
- 程序员必上的20大网站
- 关于手机端ios手机自带safari浏览器网页缩放问题
- 我就不信了,spring基础知识这么总结整理还拿不下大厂offer(一)
- 关于如何通过Swap函数交换两个变量的值
- zz: 胡适:赠与今年的大学毕业生