摘要:這里只讀數據,未作任何處理讀完成這里我根據返回值來拋出異常,使得下面的語句塊捕捉并關閉連接,也可以不拋出異常,直接在里處理。
我這篇文章想講的是編程時如何正確關閉tcp連接。
首先給出一個網絡上絕大部分的java nio代碼示例:
服務端:
1首先實例化一個多路I/O復用器Selector
2然后實例化一個ServerSocketChannel
3ServerSocketChannel注冊為非阻塞(channel.configureBlocking(false);)
4ServerSocketChannel注冊到Selector,并監聽連接事件(serverSocketChannel.register(selector, SelectionKey.OP_ACCEPT);)
5Selector開始輪詢,如果監聽到了isAcceptable()事件,就建立一個連接,如果監聽到了isReadable()事件,就讀數據。
6處理完或者在處理每個事件之前將SelectionKey移除出Selector.selectedKeys()
代碼:
package qiuqi.main; import java.io.IOException; import java.net.InetSocketAddress; import java.nio.ByteBuffer; import java.nio.channels.*; import java.util.Iterator; public class NioServer { public static void main(String[] args) throws IOException { startServer(); } static void startServer() throws IOException { Selector selector = Selector.open(); ServerSocketChannel serverSocketChannel = ServerSocketChannel.open(); serverSocketChannel.bind(new InetSocketAddress(999)); serverSocketChannel.configureBlocking(false); serverSocketChannel.register(selector, SelectionKey.OP_ACCEPT); while (selector.select() > 0) { Iteratoriterator = selector.selectedKeys().iterator(); while (iterator.hasNext()) { SelectionKey sk = iterator.next(); iterator.remove(); if (sk.isAcceptable()) { SocketChannel channel = serverSocketChannel.accept(); channel.configureBlocking(false); channel.register(selector, SelectionKey.OP_READ); } else if (sk.isReadable()) { System.out.println("讀事件!!!"); SocketChannel channel = (SocketChannel) sk.channel(); try { ByteBuffer byteBuffer = ByteBuffer.allocate(200); //這里只讀數據,未作任何處理 channel.read(byteBuffer); } catch (IOException e) { //手動關閉channel System.out.println(e.getMessage()); sk.cancel(); if (channel != null) channel.close(); } } } } } }
還有說明一下,為什么在if (sk.isReadable()){}這個里面加上異常捕捉,因為可能讀數據的時候客戶端突然斷掉,如果不捕捉這個異常,將會導致整個程序結束。
而客戶端如果使用NIO編程,那么和服務端很像,然鵝,我們并不需要使用NIO編程,因為這里我想講的問題和NIO或是普通IO無關,在我想講的問題上,他倆是一樣的,那么我就用普通socket編程來講解,因為這個好寫:)。
直接給代碼如下:
package qiuqi.main; import java.io.IOException; import java.net.InetSocketAddress; import java.net.Socket; public class TraditionalSocketClient { public static void main(String[] args) throws IOException { startClient(); } static void startClient() throws IOException { Socket socket = new Socket(); socket.connect(new InetSocketAddress(999)); socket.getOutputStream().write(new byte[100]); //要注意這個close方法,這是正常關閉socket的方法 //也是導致這個錯誤的根源 socket.close(); } }
我們運行客戶端和服務端的代碼,輸出的結果是:
讀事件!!!
讀事件!!!
讀事件!!!
讀事件!!!
讀事件!!!
讀事件!!!
....
讀事件!!!
讀事件!!!
無限個讀事件!!!
why???
客戶端正常關閉,然后顯然客戶端不可能再給服務端發送任何數據了,服務端怎么可能還有讀響應呢?
我們現在把客戶端代碼的最后一行socket.close();這個去掉,再運行一次!輸出結果是:
讀事件!!!
讀事件!!!
遠程主機強迫關閉了一個現有的連接。
然后。。。就正常了(當然代碼里會有異常提示的),這里的正常指的是不會輸出多余的讀事件!!!了。
這又是怎么回事?
我們知道如果去掉socket.close();那么客戶端是非正常關閉,服務端這邊會引發IOException。
引發完IOExpection之后,我們的程序在catch{}語句塊中手動關閉了channel。
既然非正常關閉會引發異常,那么正常關閉呢?什么都不引發?但是這樣服務端怎么知道客戶端已經關閉了呢?
顯然服務端會收到客戶端的關閉信號(可讀數據),而網絡上絕大多數代碼并沒有根據這個關閉信號來結束channel。
那么關閉信號是什么?
channel.read(byteBuffer);
這個語句是有返回值的,大多數情況是返回一個大于等于0的值,表示將多少數據讀入byteBuffer緩沖區。
然鵝,當客戶端正常斷開連接的時候,它就會返回-1。雖然這個斷開連接信號也是可讀數據(會使得isReadable()為true),但是
這個信號無法被讀入byteBuffer,也就是說一旦返回-1,那么無論再繼續讀多少次都是-1,并且會引發可讀事件isReadable()。
因此,這樣寫問題就能得到解決,下面的代碼在try語句塊里。
SocketChannel channel = (SocketChannel) sk.channel(); try { ByteBuffer byteBuffer = ByteBuffer.allocate(200); int num; //這里只讀數據,未作任何處理 num = channel.read(byteBuffer); if(num == -1) throw new IOException("讀完成"); } catch (IOException e) { System.out.println(e.getMessage()); sk.cancel(); if (channel != null) channel.close(); }
這里我根據返回值-1來拋出異常,使得下面的catch語句塊捕捉并關閉連接,也可以不拋出異常,直接在try{}里處理。
還要注意一點的是,假如說bytebuffer已經滿了,也就是channel.read(byteBuffer)返回0,那么即使客戶端正常關閉,也無法收到-1。因此當bytebuffer滿的時候需要及時清空,或者一開始就開一個大一點的bytebuffer。
文章版權歸作者所有,未經允許請勿轉載,若此文章存在違規行為,您可以聯系管理員刪除。
轉載請注明本文地址:http://m.specialneedsforspecialkids.com/yun/73544.html
摘要:采用通信模型的服務端通常由一個獨立的線程負責監聽客戶端的連接它接收到客戶端連接請求之后為每個客戶端創建一個新的線程進行鏈路處理處理完成之后通過輸出流返回應答給客戶端線程銷毀這就是典型的一請求一應答通信模型該模型最大的問題就是缺乏彈性伸縮能力 BIO 采用 BIO 通信模型的服務端, 通常由一個獨立的 Acceptor 線程負責監聽客戶端的連接, 它接收到客戶端連接請求之后為每個客戶端創...
摘要:的異步即是異步的,也是非阻塞的。但是,也可以進行一層稍微薄點的封裝,保留這種多路復用的模型,比如的,是一種同步非阻塞的模型。系統調用操作系統的系統調用提供了多路復用的非阻塞的系統調用,這也是機制實現需要用到的。 異步IO編程在javascript中得到了廣泛的應用,之前也寫過一篇博文進行梳理。js的異步IO即是異步的,也是非阻塞的。非阻塞的IO需要底層操作系統的支持,比如在linux上...
摘要:前言本篇主要講解中的機制和網絡通訊中處理高并發的分為兩塊第一塊講解多線程下的機制第二塊講解如何在機制下優化資源的浪費服務器單線程下的機制就不用我介紹了,不懂得可以去查閱下資料那么多線程下,如果進行套接字的使用呢我們使用最簡單的服務器來幫助大 前言 本篇主要講解Java中的IO機制和網絡通訊中處理高并發的NIO 分為兩塊:第一塊講解多線程下的IO機制第二塊講解如何在IO機制下優化CPU資...
摘要:抽象類有一個方法用于使通道處于阻塞模式或非阻塞模式。注意抽象類的方法是由抽象類實現的,都是直接繼承了抽象類。大家有興趣可以看看的源碼,各種抽象類和抽象類上層的抽象類。 歷史回顧: Java NIO 概覽 Java NIO 之 Buffer(緩沖區) Java NIO 之 Channel(通道) 其他高贊文章: 面試中關于Redis的問題看這篇就夠了 一文輕松搞懂redis集群原理及搭建...
摘要:的出現解決了這尷尬的問題,非阻塞模式下,通過,我們的線程只為已就緒的通道工作,不用盲目的重試了。注意要將注冊到,首先需要將設置為非阻塞模式,否則會拋異常。 showImg(https://segmentfault.com/img/remote/1460000017053374); 背景知識 同步、異步、阻塞、非阻塞 首先,這幾個概念非常容易搞混淆,但NIO中又有涉及,所以總結一下。 ...
閱讀 2088·2021-11-23 10:13
閱讀 2795·2021-11-09 09:47
閱讀 2742·2021-09-22 15:08
閱讀 3322·2021-09-03 10:46
閱讀 2235·2019-08-30 15:54
閱讀 916·2019-08-28 18:09
閱讀 2432·2019-08-26 18:26
閱讀 2346·2019-08-26 13:48