Java NIO 系列学习 09 - SocketChannel

Java NIO SocketChannel 是一个连接TCP网络socket的channel。与标准库的网络Socket是等效的。有两个办法可以来建立SocketChannel

1. 打开了 SocketChannel 连接到了网络上的一个服务
2. 传入了 ServerSocketChannel 连接

打开 SocketChannel

SocketChannel socketChannel = SocketChannel.open();
socketChannel.connect(new InetSocketAddress("http://tutorials.jenkov.com", 80));

关闭 SocketChannel

使用完毕后需要关闭Channel

socketChannel.close();

从SocketChannel读取数据

通过调用read()方法来读取数据

ByteBuffer buf = ByteBuffer.allocate(48);
int bytesRead = socketChannel.read(buf);

首先，分配Buffer，数据将从SocketChannel读到Buffer。 然后，调用read()方法，从SocketChannel读数据到Buffer。返回值来表示有多少字节的数据写入到来Buffer。如果返回-1则表示已经写完了。

写数据到SocketChannel

通过调用write()方法了来写入数据

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);
}

与 FileChannel类似，write() 方法在循环内部被调用。

非阻塞模式

我们可以把SocketChannel置为非阻塞模式，然后就可以在异步调用connect(), read(), write()方法

connet()

在非阻塞模式下，建立连接可以调用connect() 方法，此方法可能在连接建立前返回(因为是非阻塞的)。可以通过调用finishConnect()方法来确认连接是否已建立。

socketChannel.configureBlocking(false);
socketChannel.connect(new InetSocketAddress("http://jenkov.com", 80));

while(! socketChannel.finishConnect() ){
    //wait, or do something else...    
}

write()

在非阻塞模式下，write()方法可能在未写入数据前返回。因此同样在循环内调用，例子与之前的一致。

read()

在非阻塞模式下，read()方法可能没有返回真正读取到的数据，因此需要注意其出参，也就是’读取’了多少字节的数据.

非阻塞模式下的 Selectors

非阻塞模式下的SocketChannel 与 Selectors配合的很好，注册一个或多个SocketChannel到Selector，可以向Selector查询有多少个channel是可读或可写的。

参考

1. Java NIO SocketChannel