SocketChannel是一个连接到TCP网络socket上的channel。它等同于java网络连接的Socket。有两种方式创建一个SocketChannel:
1.打开一个SocketChannel并且连接到互联网的某个服务器上。
2.当一个网络连接到达ServerSocketChannel上时,也会创建一个SocketChannel。
1.打开一个SocketChannel
打开一个SocketChannel:
SocketChannel socketChannel = SocketChannel.open();
socketChannel.connect(new InetSocketAddress("http://jenkov.com", 80));
2.关闭一个SocketChannel
在使用完一个SocketChannel之后,你可以调用SocketChannel.close()方法来关闭它。
这里有一个例子:
socketChannel.close();
3.从SocketChannel中读
如果想从SocketChannel中读取数据的话,你可以调用read()方法。下面有一个例子:
ByteBuffer buf = ByteBuffer.allocate(48);
int bytesRead = socketChannel.read(buf);
第一步,先开辟一个buffer,SocketChannel中的数据被读到Buffer中。
第二步,调用SocketChannel.read()方法把数据从SocketChannel中读取到Buffer中。read()方法返回的int值,在告诉我们已经向
Buffer中写入了多少字节的数据。如果返回的是-1,就到达了流的末尾(连接被关闭)。
4.向SocketChannel中写
使用SocketChannel.write()方法可以把数据写入到SocketChannel中,write()方法会接收一个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);
}
请注意:SocketChannel.write()方法是在while-loop循环中调用的。我们并没有办法保证write()方法向SocketChannel中写入多少字节的数据。
因此,我们重复调用write()方法直到Buffer中没有更多的数据要写入。
5.非阻塞模式Non-blocking Mode
你可以把SocketChannel设置为非阻塞模式,一旦你把SocketChannel设置为非阻塞模式之后,你就能以异步的模式调用connect(), read()以及write()方法。
5.1 connect()
如果SocketChannel处于非阻塞模式并且你调用了connect()方法的话,该方法会在一个链接建立之前就返回。你可以调用finishConnect()方法去判断一个链接有没有建立。例如:
socketChannel.configureBlocking(false);
socketChannel.connect(new InetSocketAddress("http://jenkov.com", 80));
while(! socketChannel.finishConnect() ){
//wait, or do something else...
}
5.2 write()
在非阻塞模式中,write()方法可能在没有任何写入的情况下就返回。因此,你需要在一个循环中调用write()方法。 但是,由于这在之前的例子中已经做过了,这里就不再重复啦。
5.3 read()
在非阻塞模式下,read()方法可能在没有读取任何数据的情况下就返回。因此,你需要关系返回的int值,这个值会告诉你已经读取了多少字节啦。
5.4 在非阻塞模式下使用Selector
SocketChannel的非阻塞模式能够更好地和Selector配合工作。通过向Selector注册多个SocketChannel,你可以从Selector中获取到已做好读/写准备的channel。我们将在下面的文章中,讲述如何让Selector和SocketChannel配合使用。