Java NIO的SocketChannel
是连接到一个TCP网络套接字的Channel
。它相当于Java NIO的Java网络套接字。有两种方法可以创建SocketChannel
:
- 打开一个
SocketChannel
并连接到因特网的某个地方; - 当有连接连到
ServerSocketChannel
的时候,会自动创建一个SocketChannel
。
Opening a SocketChannel
以下是如何打开一个SocketChannel
的例子:
SocketChannel socketChannel = SocketChannel.open();
socketChannel.connect(new InetSocketAddress("http://jenkov.com", 80));
Closing a SocketChannel
调用SocketChannel.close()
方法可以关闭SocketChannel
。如下:
socketChannel.close();
Reading from a SocketChannel
调用read()
方法可以从SocketChannel
读取数据。如下:
ByteBuffer buf = ByteBuffer.allocate(48);
int bytesRead = socketChannel.read(buf);
首先,分配一个Buffer
。来自SocketChannel
的数据会被读入这个Buffer
。
然后调用SocketChannel.read()
方法。这个方法会从SocketChannel
读取数据进入Buffer
。read()
方法返回的int
代表着有多少数据被读入了Buffer
。如果返回-1,代表已经读到流的末尾(即连接关闭了)。
Writing to a SocketChannel
调用SocketChannel.write()
方法可以往SocketChannel
中写入数据,它接收一个Buffer
类型的参数。如下:
String newData = "New String to write to file..." + System.currentTimeMillis();
ByteBuffer buf = ByteBuffer.allocate(48);
buf.clear();
buf.put(newData.getBytes());
buf.flip();
while (buf.hasRemaining()) {
channel.write(buf);
}
注意在while-循环里面调用的SocketChannel.write()
方法。我们无法保证每次write()
方法向Channel
写了多少字节。因此我们重复调用write()
直至没有数据可写为止。
Non-blocking Mode
你可以将SocketChannel
设置为非阻塞模式。这样,你就可以以异步的方式调用connect()
、read()
以及write()
方法了。
connect()
在非阻塞模式下,如果你调用了SocketChannel
的connect()
方法,它会在连接真正建立之前返回。为了确定连接是否真的已经建立,你可以调用finishConnect()
方法,就像这样:
socketChannel.configureBlocking(false);
socketChannel.connect(new InetAddress("http://jenkov.com", 80));
while (!(socketChannel.finishConect())) {
// 等待,或者干点其他事
}
write()
在非阻塞模式下,write()
方法可能在还没有写入任何数据的情况下直接返回。因此,你需要循环调用write()
。但是,我们之前的例子已经是循环调用了,所以这里就不需要做什么改动了。
read()
在非阻塞模式下,read()
方法可能在还没有读入任何数据的清下直接返回。因此你需要特别注意该方法返回的int
,它代表着到底已经读入了多少数据。
Non-blocking Mode with Selectors
SocketChannel
的非阻塞模式和Selector
一起使用会更好。通过向Selector
注册一个或多个SocketChannel
,你可以向Selector
询问已经准备好读、写等的Channel
。后面我们会详细介绍怎么将SocketChannel
和Selector
结合起来使用。
说明
发现貌似有人在看这个系列文章了,有必要说明下,这个Java NIO系列来源于jenkov.com,本文只是翻译,希望大家千万不要误会,本文不是原创。原文地址:Java NIO。
网友评论