非阻塞套接字(Nonblocking Sockets) 概述

2019-11-18 12:13:04

字體：大中小

來源：轉載

供稿：網友

　　非阻塞套接字（Nonblocking sockets）,自J2SE 1.4版引入，它答應網絡通信在應用程序和沒有阻塞的進程中使用套接字。在這篇文章中，將具體介紹什么是Nonblocking sockets，怎樣工作及其用途。
　　
　　由于JSR 51的面世，從java 1.4起，程序員便能用一組新的API來進行I/O操作。自2000年一月的Java 1.4 beta版，程序員便可以使用JSR 51了。在Java 1.4中用一些最重要的新特征來處理諸如在文件和套接字上高性能的讀/寫操作，正規表達式，譯碼/編碼字符集，內存映射和文件鎖定。在這篇文章中，我們將討論一個非凡的新概念――New I/O API: Nonblocking sockets。
　　非阻塞套接字答應在通道上做輸入/輸出操作而不用阻塞使用該通道的進程。我正在討論異步的高性能的讀/寫操作，同樣，你將看到，翻轉上下設計和開發基于接口的應用程序技巧。
　　
　　Java開發者也許會問，為什么介紹一種新的技術來處理套接字？Java 1.3.x的套接字又有哪些問題？假設實現服務器端接受不同的客戶端的連接；同樣，假設客戶端能支持處理同步的多請求；那么，使用Java 1.3.x,開發這樣的服務器端有兩種不同的選擇：
　　●實現多線程服務為每個連接用戶處理線程。
　　●使用外部第三方模塊。
　　
　　這兩種方法都可以實現，但是假如適用第一種方法――整個線程治理方案，包括相關并發性和沖突問題――都需要靠程序員來處理。第二個方案也許花費更大，且使應用程序依靠“non－JDK”的外部模塊。依靠非阻塞套接字，你能實現非阻塞的服務無需直接治理線程或者采用外部模塊。
　　
　　Buffer
　　在我們考慮非阻塞套接字以前，不得不花費一些字句在一個新的Java 1.4的類：java.nio.Buffer上。一個Buffer實例只是原始數據的一個有限的容器。稱其有限是因為它只能包含有限數量的字節；換句話說，它不是一個像Vector或是ArrayList一樣的容器，后兩者從理論上說是沒有限度的。另外，一個Buffer實例僅能包含屬于Java的基本數據類型。例如：int,char,double,Boolean,等等。
　　
　　Buffer類是一個抽象類，它有7個子類分別對應于七種基本的數據類型：
　　●ByteBuffer
　　●CharBuffer
　　●DoubleBuffer
　　●FloatBuffer
　　●IntBuffer
　　●LongBuffer
　　●ShortBuffer
　　
　　在非阻塞化套接字編程中，通常所有新 I/O系統能工作的環境中，解決Buffer對象如何工作是要害。這是因為新套接字通道使用Buffer對象通過網絡來傳送數據。
　　你可以使用以下靜態方法（即類方法）來創建一個新的Buffer實例：allocate,allocateDirect,wrap。在下面的例子中，三個Buffer對象將用三種不同的方法來實例化。
　　ByteBuffer buffer1 = ByteBuffer.allocate(1024);
　　ByteBuffer buffer2 = ByteBuffer.allocateDirect(1024);
　　ByteBuffer buffer3 = ByteBuffer.wrap(new String("hello").getBytes());
　　
　　
　　這段代碼的前兩行創建了兩個ByteBuffer對象，它們都包含1024個字節。allocate和allocateDirect方法都做了相同的工作，不同的是第二個方法直接使用操作系統來分配Buffer。因而它將提供更快的訪問速度。不幸的是，并非所有的虛擬機都支持這種直接分配的方法。第三行使用wrap方法。它創建了一個ByteBuffer對象，包含的字節由字符串“hello”組成。
　　
　　Buffer對象的作用或多或少的與流的作用相似?！爱斍拔恢茫╟urrent position）”是一個極其重要的概念，它計算出你將要處理的Buffer對象的適當的位置。在任何時候，一個Buffer對象都有一個當前位置指向某一項。之后，每一次讀或寫操作都會自動的將當前位置指向Buffer中的下一項。
　　你可以用put方法寫入一些數據到Buffer中：
　　// Writing on a buffer
　　IntBuffer buffer = IntBuffer.allocate(10);
　　for (int i=0; i < buffer.capacity(); i++) {
　　buffer.put(i);
　　}
　　
　　這段代碼創建了一個包含10個整型值的Buffer，然后將數字0到9放入到Buffer中。同時你可以看到，我使用了capacity方法來獲得Buffer的容量。
　　要想讀取Buffer的內容，你可以用如下方法來處理：
　　
　　// Reading from a buffer
　　buffer.position(0);
　　while (buffer.hasRemaining()) {
　　int i = buffer.get();
　　System.out.　　}
　　
　　調用position方法，你能設置當前位置為0；即Bufferr的起始位置。當在當前位置和limit值之間有元素時，hasRemaining方法返回true；直到超出這個范圍，此方法將返回flase。while循環中的代碼調用get方法讀取各項，并同時顯示在控制臺上。
　　
　　理解Buffer的limit和capacity這兩個值之間的區別是十分重要的。Capacity是某個Buffer對象所能包含的項數的最大值。Limit是在0到capacity之間的一個值，它表示一個限度，可以使用limit或者fl ip方法來設置它。我們來看下面的例子：
　　// Sample of using flip
　　buffer.position(5);
　　buffer.flip();
　　while (buffer.hasRemaining()) {
　　int i = buffer.get();
　　System.out.println("i="+i);
　　}
　　
　　
　　當前位置被position方法設置成5。Flip方法進行如下操作：先將設置limit為當前位置的值，即5；然后再設置當前位置的值為0。因此，此后的while循環就只能掃描到前5個元素了，因為flip方法設置了新的limit值，即為5。從而，數字0，1，2，3，4將被顯示出來。
　　
　　另一個重要的Buffer類的方法是clear，它將設置position為0并設置limit為Buffer的容量值?；旧?，clear方法消除這之前flip（或limit）方法產生的影響?？紤]下例：
　　// Sample of using clear
　　buffer.clear();
　　while (buffer.hasRemaining()) {
　　int i = buffer.get();
　　System.out.println("i="+i);
　　}
　　
　　這段代碼將顯示數字0到9，而與Buffer的當前位置和limit值無關。
　　
　　非阻塞（Nonblocking）體系結構
　　在這一部分，我將從理論的角度來解釋非阻塞體系的結構及其工作原理。這部“喜劇”（當然，假如你喜歡的話也可以稱做戲劇）的“人物”如下：
　　●服務器端：接收請求的應用程序。
　　●客戶端：向服務器端發出請求的應用程序。
　　●套接字通道：客戶端與服務器端之間的通信通道。它能識別服務器端的ＩＰ地址和端口號。數據以Buffer中元素的形式通過套接字通道傳送。
　　●選擇器：所有非阻塞技術的主要對象。它監視著已注冊的套接字通道，并序列化服務器需要應答的請求。
　　●要害字：選擇器用來對對象的請求進行排序。每個要害字代表一個單獨的客戶端子請求并包含識別客戶端和請求類型的信息。
　　圖一：使用非阻塞套接字體系的結構圖。
　　非阻塞套接字(Nonblocking Sockets) 概述

　　圖1：非阻塞套接字結構
　　你可能注重到，客戶端應用程序同時執行對服務器端的請求，接著選擇器將其集中起來，創建要害字，然后將其發送至服務器端。這看起來像是阻塞（Blocking）體系，因為在一定時間內只處理一個請求，但事實并非如此。實際上，每個要害字不代表從客戶端發至服務器端的整個信息流，僅僅只是一部分。我們不要忘了選擇器能分割那些被要害字標識的子請求里的數據。因此，假如有更多連續地數據發送至服務器端，那么選擇器就會創建更多的根據時間共享策略（Time-sharing policy）來進行處理的要害字。強調一下，在圖一中要害字的顏色與客戶端的顏色相對應。
　　
　　服務器端非阻塞（Server Nonblocking）
　　我以前的部分介紹過的實體都有與其相當的Java實體?？蛻舳撕头掌鞫耸莾蓚€Java應用程序。套接字通道是SocketChannel類的實例，這個類答應通過網絡傳送數據。它們能被Java程序員看作是一個新的套接字。SocketChannel類被定義在java.nio.channel包中。
　　選擇器是一個Selector類的對象。該類的每個實例均能監視更多的套接字通道，進而建立更多的連接。當一些有意義的事發生在通道上（如客戶端試圖連接服務器端或進行讀/寫操作），選擇器便會通知應用程序處理請求。選擇器會創建一個要害字，這個要害字是SelectionKey類的一個實例。每個要害字都保存著應用程序的標識及請求的類型。其中，請求的類型可以是如下之一：
　　●嘗試連接(客戶端)
　　●嘗試連接(服務器端)
　　●讀取操作
　　●寫入操作
　　一個通用的實現非阻塞服務器的算法如下：
　　create SocketChannel;
　　create Selector
　　associate the SocketChannel to the Selector
　　for(;;) {
　　waiting events from the Selector;
　　event arrived; create keys;
　　for each key created by Selector {
　　check the type of request;
　　isAcceptable:
　　get the client SocketChannel;
　　associate that SocketChannel　to the Selector;
　　record it for read/write Operations
　　continue;
　　isReadable:
　　get the client SocketChannel;
　　read from the socket;
　　continue;
　　isWriteable:
　　get the client SocketChannel;
　　write on the socket;
　　continue;
　　}
　　}
　　
　　基本上，服務器端的實現是由選擇器等待事件和創建要害字的無限循環組成的。根據要害字的類型，及時的執行操作。要害字存在以下4種可能的類型。
　　Acceptable: 相應的客戶端要求連接。
　　Connectable:服務器端接受連接。
　　Readable:服務器端可讀。
　　Writeable:服務器端可寫。
　　
　　通常一個表示接受的要害

上一篇：一個完整的Socket例子

下一篇：一個基于UDP數據廣播的局域網絡會議程序