程序師世界是廣大編程愛好者互助、分享、學習的平台,程序師世界有你更精彩!
首頁
編程語言
C語言|JAVA編程
Python編程
網頁編程
ASP編程|PHP編程
JSP編程
數據庫知識
MYSQL數據庫|SqlServer數據庫
Oracle數據庫|DB2數據庫
 程式師世界 >> 編程語言 >> JAVA編程 >> JAVA編程入門知識 >> java nio基礎使用示例

java nio基礎使用示例

編輯:JAVA編程入門知識

在jdk1.4中提出的技術,非阻塞IO,采用的是基於事件處理方式。
傳統的io技術為阻塞的,比如讀一個文件,惹read方法是阻塞的,直到有數據讀入。
歸納為:
1、java io為阻塞,在打開一個io通道後,read將一直等待在端口一邊讀取字節內容,如果沒有內容進來,read相當於阻塞掉了。
2、在1的基礎上改進為,開設線程,serversocker.accept()後讓線程去等待,但是當並發量高的時候,相當耗費資源的。
3、java nio為非阻塞,采用的是reactor反應堆模式,或者說observer觀察者模式,監察io端口,注冊事件到selector,當事件滿足條件後觸發行為。
大致流程為:
java nio提供一個selector,這個類似一個觀察者,將需要探知的socketchannel注冊到selector上
接著我們做別的事情,當有事件發生時候,selector會通知我們,傳回一組selectionKey,我們讀取這些key就會獲得到我們剛剛注冊過的socketchannel,然後從這個channel讀取數據、處理業務邏輯。
selector內部原理,采用輪詢的方式,對所注冊的channel進行遍歷,判斷channel所注冊的事件是否發生。
代碼舉例為:

代碼如下:

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

  1. 上一頁:
  2. 下一頁:
Copyright © 程式師世界 All Rights Reserved