首页 > 代码库 > java NIO
java NIO
Java NIO提供了与标准IO不同的IO工作方式:
- Channels and Buffers(通道和缓冲区):标准的IO基于字节流和字符流进行操作的,而NIO是基于通道(Channel)和缓冲区(Buffer)进行操作,数据总是从通道读取到缓冲区中,或者从缓冲区写入到通道中。
- Asynchronous IO(异步IO):Java NIO可以让你异步的使用IO,例如:当线程从通道读取数据到缓冲区时,线程还是可以进行其他事情。当数据被写入到缓冲区时,线程可以继续处理它。从缓冲区写入通道也类似。
- Selectors(选择器):Java NIO引入了选择器的概念,选择器用于监听多个通道的事件(比如:连接打开,数据到达)。因此,单个的线程可以监听多个数据通道。
1. Channel的实现
Java NIO中最重要的通道的实现:
- FileChannel:从文件中读写数据。
- DatagramChannel:能通过UDP读写网络中的数据。
- SocketChannel:能通过TCP读写网络中的数据。
- ServerSocketChannel:可以监听新进来的TCP连接,像Web服务器那样。对每一个新进来的连接都会创建一个SocketChannel。
2. Buffer的类型
Java NIO 有以下Buffer类型:
- ByteBuffer
- MappedByteBuffer
- CharBuffer
- DoubleBuffer
- FloatBuffer
- IntBuffer
- LongBuffer
- ShortBuffer
2. Selector(选择器)
Selector(选择器)是Java NIO中能够检测一到多个NIO通道,并能够知晓通道是否为诸如读写事件做好准备的组件。这样,一个单独的线程可以管理多个channel,从而管理多个网络连接。
Selector监听Channel时间类型:
- SelectionKey.OP_CONNECT connect事件 socketChannel 通过连接事件连接
- SelectionKey.OP_ACCEPT accept 事件 serverSocketChannel 通过accept方法接收SocketChannel
- SelectionKey.OP_READ Read 事件 Channel通过read方法将数据写到buffer中
- SelectionKey.OP_WRITE Write 事件 Channel通过write方法将buffer中的数据写到通道中
eg:
监听端口888得到的数据
ServerSocketChannel serverSocketChannel1 = ServerSocketChannel.open();
serverSocketChannel1.socket().bind(new InetSocketAddress(888)); // 监听888端口
SocketChannel channel = serverSocketChannel.accept();
SocketChannel socketChannel = SocketChannel.open();
socketChannel.connect(new InetSocketAddress("http://jenkov.com", 80));
Selector selector = Selector.open();
channel.configureBlocking(false);
channel.register(selector, SelectionKey.OP_ACCEPT); // socket接收
socketChannel.register(selector, SelectionKey.OP_READ); // 读
while(true) {
int readyChannels = selector.select();
if(readyChannels == 0) continue;
Set selectedKeys = selector.selectedKeys();
Iterator keyIterator = selectedKeys.iterator();
while(keyIterator.hasNext()) {
SelectionKey key = keyIterator.next();
if(key.isAcceptable()) {
// a connection was accepted by a ServerSocketChannel.
ServerSocketChannel serverSocketChannel = SelectionKey.channel();
SocketChannel socketChannel = serverSocketChannel.accept();
ByteBuffer buf = ByteBuffer.allocate(48);
socketChannel.read(buf);
} else if (key.isConnectable()) {
// a connection was established with a remote server.
} else if (key.isReadable()) {
// a channel is ready for reading
} else if (key.isWritable()) {
SocketChannel socketChannel = SelectionKey.channel();
String newData = "New String to write to file..." + System.currentTimeMillis();
ByteBuffer buf = ByteBuffer.allocate(48);
buf.clear();
buf.put(newData.getBytes());
buf.flip(); // 将Buffer从写模式切换到读模式
socketChannel.write(buf);
// a channel is ready for writing
}
keyIterator.remove();
}
}
参考:http://www.iteye.com/magazines/132-Java-NIO#590
java NIO