java的nio的使用示例分享

在jdk1.4中提出的技術，非阻塞IO，採用的是基於事件處理方式。

傳統的io技術為阻塞的`，比如讀一個文件，惹read方法是阻塞的，直到有數據讀入。

　歸納為：

1、java io為阻塞，在打開一個io通道後，read將一直等待在端口一邊讀取字節內容，如果沒有內容進來，read相當於阻塞掉了。

2、在1的基礎上改進為，開設線程，pt()後讓線程去等待，但是當併發量高的時候，相當耗費資源的。

3、java nio為非阻塞，採用的是reactor反應堆模式，或者説observer觀察者模式，監察io端口，註冊事件到selector，當事件滿足條件後觸發行為。

　大致流程為：

java nio提供一個selector，這個類似一個觀察者，將需要探知的socketchannel註冊到selector上

接着我們做別的事情，當有事件發生時候，selector會通知我們，傳回一組selectionKey，我們讀取這些key就會獲得到我們剛剛註冊過的socketchannel，然後從這個channel讀取數據、處理業務邏輯。

selector內部原理，採用輪詢的方式，對所註冊的channel進行遍歷，判斷channel所註冊的事件是否發生。

　代碼舉例為：

複製代碼 代碼如下:

// 1.創建一個selector對象

Selector selector = ();

// 2.建立channel對象，並綁定在8080端口上

ServerSocketChannel ssc = ();

InetSocketAddress address = new InetSocketAddress(ocalHost(),8080);

et()(address);

// 3.將channel設定為非阻塞方式

igureBlocking(false);

// 向selector註冊channel以及我們感興趣的事件

SelectionKey skey = ster(selector,_ACCEPT);// 這邊註冊了accept，服務器接受到client連接事件

// 4、簡單模擬下輪詢過程

while(true)

{

// selector通過select方法，通知我們感興趣的事件發生了

int nKeys = ct();

// 當nKeys>0表示事件發生了

// 這時候可以通過ctedKeys();方法拿到key集合

Set selectKeys = ctedKeys();

// 5、迭代遍歷keys對象，分別做適配業務邏輯處理

// 比如：

s = (SelectionKey)(ator())();

if(ceptable())// 判斷為註冊的OP_ACCEPT事件

{

// 從channel中獲取我們剛才註冊的channel

Socket socket = ((ServerSocketChannel)nel())pt()et();

SocketChannel sc = hannel();

// 設置為非阻塞

igureBlocking(false);

// 註冊read/write事件

ster(selector, _READ |_WRITE);

}

}

// 上邊就是簡單的java nio演示的偽代碼

// 這時候，client端可以telnet 主機名 端口號 連接到server服務器。