快捷導(dǎo)航

java nio基礎(chǔ)使用示例

更新時(shí)間：2013年11月19日 14:12:16 作者：

傳統(tǒng)的io技術(shù)為阻塞的，java新nio是非阻塞的，注冊(cè)一個(gè)op_read事件，注冊(cè)到selector對(duì)象上，當(dāng)有數(shù)據(jù)到來(lái)時(shí)候，selector回通知之前注冊(cè)事件的對(duì)象，進(jìn)行read處理，看面我看看它是如何使用的

在jdk1.4中提出的技術(shù)，非阻塞IO，采用的是基于事件處理方式。
傳統(tǒng)的io技術(shù)為阻塞的，比如讀一個(gè)文件，惹read方法是阻塞的，直到有數(shù)據(jù)讀入。
歸納為：
1、java io為阻塞，在打開(kāi)一個(gè)io通道后，read將一直等待在端口一邊讀取字節(jié)內(nèi)容，如果沒(méi)有內(nèi)容進(jìn)來(lái)，read相當(dāng)于阻塞掉了。
2、在1的基礎(chǔ)上改進(jìn)為，開(kāi)設(shè)線程，serversocker.accept()后讓線程去等待，但是當(dāng)并發(fā)量高的時(shí)候，相當(dāng)耗費(fèi)資源的。
3、java nio為非阻塞，采用的是reactor反應(yīng)堆模式，或者說(shuō)observer觀察者模式，監(jiān)察io端口，注冊(cè)事件到selector，當(dāng)事件滿足條件后觸發(fā)行為。
大致流程為：
java nio提供一個(gè)selector，這個(gè)類似一個(gè)觀察者，將需要探知的socketchannel注冊(cè)到selector上
接著我們做別的事情，當(dāng)有事件發(fā)生時(shí)候，selector會(huì)通知我們，傳回一組selectionKey，我們讀取這些key就會(huì)獲得到我們剛剛注冊(cè)過(guò)的socketchannel，然后從這個(gè)channel讀取數(shù)據(jù)、處理業(yè)務(wù)邏輯。
selector內(nèi)部原理，采用輪詢的方式，對(duì)所注冊(cè)的channel進(jìn)行遍歷，判斷channel所注冊(cè)的事件是否發(fā)生。
代碼舉例為：

復(fù)制代碼代碼如下:

// 1.創(chuàng)建一個(gè)selector對(duì)象
Selector selector = Selector.open();
// 2.建立channel對(duì)象，并綁定在8080端口上
ServerSocketChannel ssc = ServerSocketChannel.open();
InetSocketAddress address = new InetSocketAddress(InetAddress.getLocalHost(),8080);
ssc.socket().bind(address);
// 3.將channel設(shè)定為非阻塞方式
ssc.configureBlocking(false);
// 向selector注冊(cè)channel以及我們感興趣的事件
SelectionKey skey = ssc.register(selector,SelectionKey.OP_ACCEPT);// 這邊注冊(cè)了accept，服務(wù)器接受到client連接事件
// 4、簡(jiǎn)單模擬下輪詢過(guò)程
while(true)
{
  // selector通過(guò)select方法，通知我們感興趣的事件發(fā)生了
  int nKeys = selector.select();
  // 當(dāng)nKeys>0表示事件發(fā)生了
  // 這時(shí)候可以通過(guò)selector.selectedKeys();方法拿到key集合
  Set selectKeys = selector.selectedKeys();
  // 5、迭代遍歷keys對(duì)象，分別做適配業(yè)務(wù)邏輯處理
  // 比如：
  s = (SelectionKey)(selectKeys.iterator()).next();
  if(s.isAcceptable())// 判斷為注冊(cè)的OP_ACCEPT事件
  { 
    // 從channel中獲取我們剛才注冊(cè)的channel
    Socket socket = ((ServerSocketChannel)s.channel()).accept().socket();
    SocketChannel sc = socket.getChannel();
    // 設(shè)置為非阻塞
    sc.configureBlocking(false);
　　// 注冊(cè)read/write事件
    sc.register(selector, SelectionKey.OP_READ |SelectionKey.OP_WRITE);
  }
}
// 上邊就是簡(jiǎn)單的java nio演示的偽代碼
// 這時(shí)候，client端可以telnet 主機(jī)名 端口號(hào) 連接到server服務(wù)器。