Java NIO 由以下几个核心部分组成:
在传统IO中,流是基于字节的方式进行读写的。
在NIO中,使用通道(Channel)基于缓冲区数据块的读写。
Java NIO的通道类似IO中的流,但又有些不同:
下面是JAVA NIO中的一些主要Channel的实现:
FileChannel 是基于文件的Channel。
DatagramChannel、SocketChannel、ServerSocketChannel 都是基于网络流的Channel。
下面我们主要介绍关于基于网络流的SocketChannel 和 ServerSocketChannel 。
基于网络流的Channel中提供了register方法。
使用示例:
channel.register(selector, Selectionkey.OP_READ, ByteBuffer.allocate(64));
代码的写法感觉是要将selector对象注册到channel中。其实正好相反,应该是将channel注册到selector中。
下面通过代码分析:
undefined
channel 的 register 方法
1.首先判断 selector 中是否已经注册此 channel ,如果注册过就更新注册的事件和attach附件信息。
public final SelectableChannel configureBlocking(boolean block)
Channel 默认使用阻塞模式,通过 configureBlocking 方法可以将该 Channel 设置成非阻塞模式。
//设置成非阻塞模式
channel.configureBlocking(false);
ServerSocketChannel只支持入站连接请求。不提供读取、写入数据功能。
public abstract SocketChannel accept()
accept()可以在阻塞或非阻塞模式下操作。
示例:
public static void blockMode(){
try {
ServerSocketChannel serverChannel = ServerSocketChannel.open();
//绑定要监控的端口
serverChannel.bind(new InetSocketAddress(9000));
//获取入站请求socketChannel
SocketChannel clientChannel = serverChannel.accept();
...
} catch (Exception e) {
}
}
示例:
public static void nonBlockMode(){
try {
//创建一个selector
Selector selector = Selector.open();
//创建一个ServerSocketChannel
ServerSocketChannel serverChannel = ServerSocketChannel.open();
//设置成非阻塞模式
serverChannel.configureBlocking(false);
//绑定要监控的端口
serverChannel.bind(new InetSocketAddress(9000));
//接受入站请求
serverChannel.accept();
//将 serverChannel 注册到 selector 上
serverChannel.register(selector, SelectionKey.OP_READ);
} catch (Exception e) {
}
}
SocketChannel 类可以读写TCP Socket。数据必须编码到ByteBuffer对象中来完成读写。
示例:
public static void nonSocketChannel() throws Exception {
SocketChannel client = SocketChannel.open();
client.configureBlocking(false);
client.connet(new InetSocketAddress("192.168.1.10", 9000));
}
public abstract boolean connect(SocketAddress remote)
非阻塞模式下,如果要连接远程服务器必须使用 connect 方法进行连接。
public abstract boolean finishConnect()
阻塞模式:直接返回true,因为在构造SocketChannel的时候已经建立连接了。
非阻塞模式下:必须调用此方法来判断该方法是否已经建立网络连接,只有建立网络连接后才能进行读写操作。
public abstract boolean isConnected()
判断是否已经连接。
public abstract boolean isConnectionPending()
判断连接是否正在连接状态