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