亚洲精品久久久中文字幕-亚洲精品久久片久久-亚洲精品久久青草-亚洲精品久久婷婷爱久久婷婷-亚洲精品久久午夜香蕉

您的位置:首頁技術文章
文章詳情頁

Java非阻塞I/O模型之NIO相關知識總結

瀏覽:26日期:2022-08-11 18:49:14
組件說明

(1)Channel:NIO模型中的管道,管道是鏈接建立和通信的重要組件,我們可以理解管道是一個容器環境,我們所有的I/O的建立讀取都可以在這個容器中進行

(2)Selector:NIO中的選擇器,NIO是由事件驅動的,當有鏈接事件或者讀取事件發生時,這個事件可以注冊到這個選擇器上,并且最終被我們檢測到。

(3)SelectionKey:我們可以在Selector中進行檢測是否有SelectionKey產生,并且根據這個SelectionKey中的信息判斷時什么事件發生了。

代碼說明

(1)開啟ServerSocketChannel,并開始監聽

//初始化一個網絡地址,并綁定7000端口號InetSocketAddress inetSocketAddress = new InetSocketAddress(7000);//ServerSocketChannel.open() 方法實例化一個ServerSocketChannel對象ServerSocketChannel serverSocketChannel = ServerSocketChannel.open();//serverSocketChannel綁定初始化的網絡地址,并開始監聽serverSocketChannel.socket().bind(inetSocketAddress);//將這個通道設置為非阻塞的serverSocketChannel.configureBlocking(false);

(2)初始化選擇器,并將這個選擇器注冊到上面的網絡通道中

//得到一個Selector對象Selector selector = Selector.open();//在channel上注冊selector,并且告訴這個選擇器初始應該監聽的事件,//SelectionKey.OP_ACCEPT 為監聽鏈接進入的事件,初始化并不監聽數據讀取的事件//SelectionKey.OP_READ 事件讀取事件,需要在有鏈接進入時,配合鏈接一起注冊serverSocketChannel.register(selector, SelectionKey.OP_ACCEPT);

(3)主循環

//循環等待客戶端鏈接while(true){ //等待1秒,1秒內沒有鏈接事件發生,直接返回 if(selector.select(1000)==0){ System.out.println('服務器等待了1秒,無連接進入'); continue; } //有事件發生,拿到集合 //selector.selectedKeys() 關注事件的集合 //通過這個可以反向獲取通道 Set<SelectionKey> selectionKeys = selector.selectedKeys(); //遍歷集合,使用迭代器 Iterator<SelectionKey> keyIterator = selectionKeys.iterator(); while(keyIterator.hasNext()){ //獲取事件key SelectionKey key = keyIterator.next(); //根據key對應的通道發生的事件做相應的處理 if(key.isAcceptable()){ //如果是ACCEPT事件,客戶端鏈接 //傳統的accept()是阻塞的,但是在NIO中,當key.isAcceptable()方法返回true的時候,這個鏈接就已經存在了,所以accept()會立刻執行 SocketChannel socketChannel = serverSocketChannel.accept(); socketChannel.configureBlocking(false); //將當前的socketChannel注冊的selector,關注事件為READ,同時給Channel關聯一個Buffer SelectionKey register = socketChannel.register(selector, SelectionKey.OP_READ, ByteBuffer.allocate(128)); }else if(key.isReadable()){ //發生了READ事件 //通過key反向獲取Channel SocketChannel channel = (SocketChannel)key.channel(); //獲取到該channel關聯的buffer ByteBuffer buffer =(ByteBuffer) key.attachment(); channel.read(buffer); System.out.println('From 客戶端 :'+new String(buffer.array())); } //手動在集合中移除當前的SelectionKey否則可能會出現重復操作 keyIterator.remove(); }}總結

(1)使用一個事件驅動的方式,在沒有事件發生的時候,服務器可以去做一些自己需要做的事。

(2)當有事件發生的時候,通過Selector去關心是什么事件。

(3)甚至不需要使用多線程,就能同時處理更多的鏈接請求。

(4)當然我們也可以配合多線程,來更有效的利用服務器資源,滿足需求更復雜,請求更多的場景。

(5)NIO是Netty的基礎,讀者可以多手動編寫一下NIO的實現,來更深的了解Netty。

到此這篇關于Java非阻塞I/O模型之NIO相關知識總結的文章就介紹到這了,更多相關Java NIO內容請搜索好吧啦網以前的文章或繼續瀏覽下面的相關文章希望大家以后多多支持好吧啦網!

標簽: Java
相關文章:
主站蜘蛛池模板: 国产在线一区二区视频 | 亚洲欧美日产综合在线看 | 亚洲精品不卡久久久久久 | 九九九色视频在线观看免费 | 国产成人在线播放 | 真实做爰对白录音 | 久久婷婷综合中文字幕 | 免费观看欧美精品成人毛片 | 国产99r视频精品免费观看 | 青草青草伊人精品视频 | 1024国产看片在线观看 | 国产精品一区伦免视频播放 | 成人黄色小视频在线观看 | 免费国产黄网站在线观看视频 | 小明永久2015xxx免费看视频 | 国产色产综合色产在线观看视频 | 国产亚洲欧美日韩在线观看不卡 | 国产一级特黄全黄毛片 | 久久香蕉精品成人 | 国产综合色在线视频区色吧图片 | 亚洲国产色图 | 成人精品一级毛片 | 亚洲精品91在线 | 国产黄| 91网址在线观看 | 日韩欧美久久一区二区 | 不卡在线观看 | 黑人好太好长爱不了 | 草草在线影院 | 一级做a爱过程免费视频高清 | 被黑人做的白浆直流在线播放 | 欧美一二区视频 | 毛片大全在线观看 | 国产精品一区二区欧美视频 | 91日韩视频在线观看 | 成人区精品一区二区不卡亚洲 | 91夜夜操| 国产精品yjizz视频网一二区 | 91最新在线| 国产精品lululu在线观看 | 在线视频 一区二区 |