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没有可用的字节写入。
¥ 我要打赏
纠错/补充
收藏
加QQ群啦,易百教程官方技术学习群
注意:建议每个人选自己的技术方向加群,同一个QQ最多限加 3 个群。