java NIO原理及实例

java NIO原理及实例

一、reactor（反应器）模式

　　使用单线程模拟多线程，提升资源利用率和程序的效率，增长系统吞吐量。下面例子比较形象的说明了什么是反应器模式：

　　一个老板经营一个饭店，

　　传统模式 - 来一个客人安排一个服务员招呼，客人很满意；（至关于一个链接一个线程）

　　后来客人愈来愈多，须要的服务员愈来愈多，资源条件不足以再请更多的服务员了，传统模式已经不能知足需求。老板之因此为老板天然有过人之处，老板发现，服务员在为客人服务时，当客人点菜的时候，服务员基本处于等待状态，（阻塞线程，不作事）。

　　因而乎就让服务员在客人点菜的时候，去为其余客人服务，当客人菜点好后再招呼服务员便可。 --反应器（reactor）模式诞生了

　　饭店的生意红红火火，几个服务员就足以支撑大量的客流量，老板用有限的资源赚了更多的money~~~~^_^

 

二、NIO中的重要概念 通道、缓冲区、选择器

　　通道：相似于流，可是能够异步读写数据（流只能同步读写），通道是双向的，（流是单向的），通道的数据老是要先读到一个buffer 或者 从一个buffer写入，即通道与buffer进行数据交互。

　　通道类型：　　

• • FileChannel：从文件中读写数据。　　
  • DatagramChannel：能经过UDP读写网络中的数据。　　
  • SocketChannel：能经过TCP读写网络中的数据。　　
  • ServerSocketChannel：能够监听新进来的TCP链接，像Web服务器那样。对每个新进来的链接都会建立一个SocketChannel。　　

　　FileChannel比较特殊，它能够与通道进行数据交互， 不能切换到非阻塞模式，套接字通道能够切换到非阻塞模式；

　　缓冲区 - 本质上是一块能够存储数据的内存，被封装成了buffer对象而已！

　　缓冲区类型：

• • ByteBuffer　　
  • MappedByteBuffer　　
  • CharBuffer　　
  • DoubleBuffer　　
  • FloatBuffer　　
  • IntBuffer　　
  • LongBuffer　　
  • ShortBuffer　　

　　经常使用方法：

• 　　allocate() - 分配一块缓冲区　　
• 　　put() -  向缓冲区写数据
• 　　get() - 向缓冲区读数据　　
• 　　filp() - 将缓冲区从写模式切换到读模式　　
•  　  clear() - 从读模式切换到写模式，不会清空数据，但后续写数据会覆盖原来的数据，即便有部分数据没有读，也会被遗忘；　　
•       compact() - 从读数据切换到写模式，数据不会被清空，会将全部未读的数据copy到缓冲区头部，后续写数据不会覆盖，而是在这些数据以后写数据
• 　　mark() - 对position作出标记，配合reset使用
• •       reset() - 将position置为标记值　　　　

缓冲区的一些属性：

• • 　　　　capacity - 缓冲区大小，不管是读模式仍是写模式，此属性值不会变；
  • 　　　　position - 写数据时，position表示当前写的位置，每写一个数据，会向下移动一个数据单元，初始为0；最大为capacity - 1

　　　　　　　　切换到读模式时，position会被置为0，表示当前读的位置

• • 　　　　limit - 写模式下，limit 至关于capacity 表示最多能够写多少数据，切换到读模式时，limit 等于原先的position，表示最多能够读多少数据。

　　选择器：至关于一个观察者，用来监听通道感兴趣的事件，一个选择器能够绑定多个通道；

 　　通道向选择器注册时，须要指定感兴趣的事件，选择器支持如下事件：

• • SelectionKey.OP_CONNECT
  • SelectionKey.OP_ACCEPT
  • SelectionKey.OP_READ
  • SelectionKey.OP_WRITE　　

 　　若是你对不止一种事件感兴趣，那么能够用“位或”操做符将常量链接起来，以下：

　　　　 int interestSet = SelectionKey.OP_READ | SelectionKey.OP_WRITE; 

 　　通道向选择器注册时，会返回一个 SelectionKey对象，具备以下属性

• • interest集合
  • ready集合　　
  • Channel　　
  • Selector
  • 附加的对象（可选）　　

　　用“位与”操做interest 集合和给定的SelectionKey常量，能够肯定某个肯定的事件是否在interest 集合中。

int interestSet = selectionKey.interestOps();  
 
boolean isInterestedInAccept  = interestSet & SelectionKey.OP_ACCEPT;
boolean isInterestedInConnect = interestSet & SelectionKey.OP_CONNECT;  
boolean isInterestedInRead    = interestSet & SelectionKey.OP_READ;  
boolean isInterestedInWrite   = interestSet & SelectionKey.OP_WRITE;  

　　ready 集合是通道已经准备就绪的操做的集合。在一次选择(Selection)以后，你会首先访问这个ready set。Selection将在下一小节进行解释。能够这样访问ready集合： 
　　int readySet = selectionKey.readyOps();

 　　也可使用如下四个方法获取已就绪事件，返回值为boolean：

selectionKey.isAcceptable();  
selectionKey.isConnectable();  
selectionKey.isReadable();  
selectionKey.isWritable();  

 　　能够将一个对象或者更多信息附着到SelectionKey上，即记录在附加对象上，方法以下：

selectionKey.attach(theObject);  
Object attachedObj = selectionKey.attachment();  

 　　能够经过选择器的select方法获取是否有就绪的通道；

• int select()　　
• int select(long timeout)　　
• int selectNow()

　　返回值表示上次执行select以后，就绪通道的个数。　

　　能够经过selectedKeySet获取已就绪的通道。返回值是SelectionKey 的集合，处理完相应的通道以后，须要removed 由于Selector不会本身removed

 

　　select阻塞后，能够用wakeup唤醒；执行wakeup时，若是没有阻塞的select  那么执行完wakeup后下一个执行select就会当即返回。

　　调用close() 方法关闭selector

 下面是一个简单的实例代码，帮助理解上面的内容：

  NIO服务器端

  BIO服务器端

  BIO客户端及测试类

其中 testNioServer()方法，是启动NIO服务器端；

testBioServer()方法是启动BIO服务器端

testConnect()是BIO的一个链接

基于NIO实现的时钟服务器：http://www.cnblogs.com/tengpan-cn/p/6529628.html

 

 

一篇写的比较详细的JAVA NIO的文章：http://www.iteye.com/magazines/132-Java-NIO