Java NIO SocketChannel
Java NIO SocketChannel用於將通道與TCP(傳輸控制協議)網絡套接字連接。它相當於網絡編程中使用的Java網絡套接字(Socket)。
Java NIO中有兩種可用於創建SocketChannel的方法:
- 當傳入連接到達
ServerSocketChannel時,可以創建它。 - 打開一個
SocketChannel,並在網絡上與服務器連接。
我們來看看使用選擇器的SocketChannel客戶端 - 服務器通信的框圖:
打開套接字通道 - SocketChannel
可以通過調用SocketChannel.Open()方法打開一個SocketChannel。
打開套接字通道(SocketChannel)的語法是:
SocketChannel sc = SocketChannel.open();
sc.connect(new InetSocketAddress("localhost", 9099));
關閉套接字通道 - SocketChannel
通過調用SocketChannel.close()方法執行所有操作後,可以關閉SocketChannel。
關閉套接字通道(SocketChannel)的語法是:
SocketChannel.close();
從SocketChannel讀取
要從SocketChannel讀取數據,調用read()方法之一。
下面來看如何從SocketChannel讀取數據的例子:
ByteBuffer bb = ByteBuffer.allocate(84);
int bytesRead = SocketChannel.read(bb);
首先分配緩衝區。 從SocketChannel讀取的數據存儲在緩衝區中。
其次,調用SocketChannel.read()方法,並將數據從SocketChannel讀入緩衝區。 read()方法返回寫入緩衝區字節數的整數值。
寫入套接字通道-SocketChannel
要將數據寫入SocketChannel,可使用SocketChannel.write()方法並將緩衝(buffer)作爲參數。
下面來看看一下將數據寫入SocketChannel的例子:
String newData = "The new String is writing in a file ..." + System.currentTimeMillis();
ByteBuffer bb= ByteBuffer.allocate(48);
bb.clear();
bb.put(newData.getBytes());
bb.flip();
while(bb.hasRemaining()) {
SocketChannel.write(bb);
}
SocketChannel.write()方法在while循環中使用,因爲write()方法寫入SocketChannel的字節數目是未知的,因此需要重複使用write()方法,直到Buffer沒有可用的字節寫入。