java的nio的使用示例分享
在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服務器。
【java的nio的使用示例分享】相關文章：
1.java使用反射技術示例
2.java system類使用方法示例
3.java運行異常的示例
4.Java數組的使用
5.關于循環的java代碼示例
6.JAVA中If語句的使用
7.Java編程學習示例
8.java.exe和javaw.exe的區別和使用方法示例
这里有更多你想看的|
|
