xnio java_java基础篇---新I/O技术(NIO)

在JDK1.4以前，I/O输入输出处理，我们把它称为旧I/O处理，在JDK1.4开始，java提供了一系列改进的输入/输出新特性，这些功能被称为新I/O(NEW I/O)，新添了许多用于处理输入/输出的类，这些类都被放在java.nio包及子包下，并且对原java.io包中的很多类以NIO为基础进行了改写，新添了满足新I/O的功能。

Java NIO和IO的主要区别

NIO

面向流

面向缓冲

阻塞IO

非阻塞IO

无

选择器

面向缓冲(Buffer)

在整个Java的心I/O中，所以操作都是以缓冲区进行的，使操作的性能大大提高。

操作

在Buffer中存在一系列的状态变量，这状态变量随着写入或读取都可能会被概念，在缓冲区开元使用是三个值表示缓冲区的状态。

position：表示下个缓冲区读取或写入的操作指针，没向缓冲区中华写入数据的时候此指针就会改变，指针永远放在写入的最后一个元素之后。即：如果写入了4个位置的数据，则posotion会指向第5个位置。

Limit：表示还有多少数据可以存储或读取，position<=limit

capacity：表示缓冲区的最大容量，limit<=capacity,此值在分配缓冲区时被设置。一般不改变。

创建缓冲区：

importjava.nio.IntBuffer ;public classIntBufferDemo{public static voidmain(String args[]){

IntBuffer buf= IntBuffer.allocate(10) ; //准备出10个大小的缓冲区

System.out.print("1、写入数据之前的position、limit和capacity：") ;

System.out.println("position = " + buf.position() + "，limit = " + buf.limit() + "，capacty = " +buf.capacity()) ;int temp[] = {5,7,9} ;//定义一个int数组

buf.put(3) ; //设置一个数据

buf.put(temp) ; //此时已经存放了四个记录

System.out.print("2、写入数据之后的position、limit和capacity：") ;

System.out.println("position = " + buf.position() + "，limit = " + buf.limit() + "，capacty = " +buf.capacity()) ;

buf.flip() ;//重设缓冲区//postion = 0 ,limit = 原本position

System.out.print("3、准备输出数据时的position、limit和capacity：") ;

System.out.println("position = " + buf.position() + "，limit = " + buf.limit() + "，capacty = " +buf.capacity()) ;

System.out.print("缓冲区中的内容：") ;while(buf.hasRemaining()){int x =buf.get() ;

System.out.print(x+ "、") ;

}

如果创建了缓冲区，则JVM可直接对其执行本机的IO操作

importjava.nio.ByteBuffer ;public classByteBufferDemo{public static voidmain(String args[]){

ByteBuffer buf= ByteBuffer.allocateDirect(10) ; //准备出10个大小的缓冲区

byte temp[] = {1,3,5,7,9} ; //设置内容

buf.put(temp) ; //设置一组内容

buf.flip() ;

System.out.print("主缓冲区中的内容：") ;while(buf.hasRemaining()){int x =buf.get() ;

System.out.print(x+ "、") ;

}

通道(Channel)

Java NIO的非阻塞模式，使一个线程从某通道发送请求读取数据，但是它仅能得到目前可用的数据，如果目前没有数据可用时，就什么都不会获取。而不是保持线程阻塞，所以直至数据变的可以读取之前，该线程可以继续做其他的事情。非阻塞写也是如此。一个线程请求写入一些数据到某通道，但不需要等待它完全写入，这个线程同时可以去做别的事情。线程通常将非阻塞IO的空闲时间用于在其它通道上执行IO操作，所以一个单独的线程现在可以管理多个输入和输出通道(channel)。

Java NIO的通道类似流，但又有些不同：

既可以从通道中读取数据，又可以写数据到通道。但流的读写通常是单向的。

通道可以异步地读写。

通道中的数据总是要先读到一个Buffer，或者总是要从一个Buffer中写入。

正如上面所说，从通道读取数据到缓冲区，从缓冲区写入数据到通道。

Channel的实现

这些是Java NIO中最重要的通道的实现：

FileChannel

DatagramChannel

SocketChannel

ServerSocketChannel

FileChannel 从文件中读写数据。

DatagramChannel 能通过UDP读写网络中的数据。

SocketChannel 能通过TCP读写网络中的数据。

ServerSocketChannel可以监听新进来的TCP连接，像Web服务器那样。对每一个新进来的连接都会创建一个SocketChannel。

通过通道可以完成双向的输入和输出操作。在通道还有一种方式称为内存映射

几种读入的方式的比较

RandomAccessFile 较慢

FileInputStream 较慢

缓冲读取　　　　　速度较快

内存映射　　　　　速度最快

FileChannel内存映射实例

importjava.nio.ByteBuffer ;importjava.nio.MappedByteBuffer ;importjava.nio.channels.FileChannel ;importjava.io.File ;importjava.io.FileOutputStream ;importjava.io.FileInputStream ;public classFileChannelDemo03{public static void main(String args[]) throwsException{

File file= new File("d:" + File.separator + "oumyye.txt") ;

FileInputStream input= null;

input= newFileInputStream(file) ;

FileChannel fin= null ; //定义输入的通道

fin = input.getChannel() ; //得到输入的通道

MappedByteBuffer mbb = null;

mbb= fin.map(FileChannel.MapMode.READ_ONLY,0,file.length()) ;byte data[] = new byte[(int)file.length()] ; //开辟空间接收内容

int foot = 0;while(mbb.hasRemaining()){

data[foot++] = mbb.get() ; //读取数据

}

System.out.println(new String(data)) ; //输出内容

fin.close() ;

input.close() ;

}

操作以上代码的时候，执行的是写入操作则可能是非常危险的，因为仅仅只是改变数组中的单个元素这种简单的操作，就可能直接修改磁盘上的文件，因为修改数据与数据保存在磁盘上是一样的。

选择器(Selectors)

Selector(选择器)是Java NIO中能够检测一到多个NIO通道，并能够知晓通道是否为诸如读写事件做好准备的组件。这样，一个单独的线程可以管理多个channel，从而管理多个网络连接。

为什么使用Selector?

仅用单个线程来处理多个Channels的好处是，只需要更少的线程来处理通道。事实上，可以只用一个线程处理所有的通道。对于操作系统来说，线程之间上下文切换的开销很大，而且每个线程都要占用系统的一些资源(如内存)。因此，使用的线程越少越好。

但是，需要记住，现代的操作系统和CPU在多任务方面表现的越来越好，所以多线程的开销随着时间的推移，变得越来越小了。实际上，如果一个CPU有多个内核，不使用多任务可能是在浪费CPU能力。不管怎么说，关于那种设计的讨论应该放在另一篇不同的文章中。在这里，只要知道使用Selector能够处理多个通道就足够了。

要点

使用Selector可以构建一个非阻塞的网络服务。

在新IO实现网络程序需要依靠ServerSocketChannel类与SocketChannel

Selector实例

下面使用Selector完成一个简单的服务器的操作，服务器可以同时在多个端口进行监听，此服务器的主要功能是返回当前时间。

importjava.net.InetSocketAddress ;importjava.net.ServerSocket ;importjava.util.Set ;importjava.util.Iterator ;importjava.util.Date ;importjava.nio.channels.ServerSocketChannel ;importjava.nio.ByteBuffer ;importjava.nio.channels.SocketChannel ;importjava.nio.channels.Selector ;importjava.nio.channels.SelectionKey ;public classDateServer{public static void main(String args[]) throwsException {int ports[] = {8000,8001,8002,8003,8005,8006} ; //表示五个监听端口

Selector selector = Selector.open() ; //通过open()方法找到Selector

for(int i=0;i

ServerSocketChannel initSer= null;

initSer= ServerSocketChannel.open() ; //打开服务器的通道

initSer.configureBlocking(false) ; //服务器配置为非阻塞

ServerSocket initSock =initSer.socket() ;

InetSocketAddress address= null;

address= new InetSocketAddress(ports[i]) ; //实例化绑定地址

initSock.bind(address) ; //进行服务的绑定

initSer.register(selector,SelectionKey.OP_ACCEPT) ; //等待连接

System.out.println("服务器运行，在" + ports[i] + "端口监听。") ;

}//要接收全部生成的key，并通过连接进行判断是否获取客户端的输出