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没有可用的字节写入。


上一篇: Java NIO选择器 下一篇: Java NIO ServerSocketChannel