天天看点

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

¥ 我要打赏

纠错/补充

收藏

加QQ群啦,易百教程官方技术学习群

注意:建议每个人选自己的技术方向加群,同一个QQ最多限加 3 个群。