java NIO 入门学习

Channel(通道)和Buffer(缓冲)是新IO中的两个核心对象，Channel是对传统的输入/输出系统的模拟，在新IO系统中，所有的数据都需要通过通道传输：Channel与传统的InputStream,OutputStream最大的区别在于它提供了一个map()方法，通过该map()方法可以直接将“一块数据”映射到内存中。如果说传统的输入/输出系统是面向流的处理，则新IO则是面向块的处理。

 

Buffer可以被理解成一个容器，它的本质是一个数组，发送到Channel中的所有对象都必须首先发到Buffer中，而从Channel中读取的数据也必须先放到Buffer中。

 

 

ByteBuffer类还有一个子类：MappedByteBuffer，它用于表示Channel将磁盘文件的部分或全部内容映射到内存中后得到的结果，通常MappedByteBuffer对象由Channel的map()方法返回。

 

 

容量(capacity)：缓冲区的容量(capacity)表示该Buffer的最大数据容量，即最多可以存储多少数据。缓冲区的容量不可能为负值，创建后不能改变

 

界限(limit)：第一个不应该被读出或者写入的缓冲区位置索引。也就是说，位于limit后的数据既不可以被读，也不可被写。

 

位置(position)：用于指明下一个可以被读出的或者写入的缓冲区位置索引(类似于IO流中的记录指针)。当刚刚新建一个Buffer对象时，其position为0；如果从Channel中读取了2个数据到该Buffer中，则position为2，指向Buffer中第3个位置。

 

当Buffer装入数据结束后，调用Buffer的flip()方法，该方法将limit设置为position所在的位置，并将position设为0，这就使得Buffer的读写指针又移到了开始位置。也就是说，Buffer调用flip()方法之后，Buffer为输出数据做好准备；当 Buffer输出数据结束后，Buffer调用clear()方法，clear()方法不是清空Buffer的数据，它仅仅将position置为0，将limit置为capacity，这样为再次向Buffer中装入数据做好准备。

 

flip()为从Buffer中取出数据做好准备。

clear()为再次向Buffer中装入谁做好准备。

 

package hb.nio;

import java.nio.CharBuffer;

public class BufferTest {

	public static void main(String[] args) {
		
		CharBuffer buff = CharBuffer.allocate(8);
		//容量为8
		System.out.println("capacity ：" + buff.capacity());
		//在没有加入数据的时候，可以读写长度为8
		System.out.println("limit ：" + buff.limit());
		//在没有加入数据的时候，position当前位置为0
		System.out.println("position ：" + buff.position());
		
		buff.put("a");
		buff.put("b");
		buff.put("c");
		
		//加入数据之后position会向后移动，位置为3
		System.out.println("加入三个元素之后，position ：" + buff.position());
		
		//调用flip()方法
		buff.flip();
		//可读写的长度是3
		System.out.println("执行flip()方法，limit：" + buff.limit());
		
		//取出第一个元素
		System.out.println("第一个元素（position=0）: " + buff.get());
		System.out.println("取出第一个元素后，position："+buff.position());
		
		//调用clear()方法
		buff.clear();
		System.out.println("执行clear()后,limit="+buff.limit());
		System.out.println("执行clear()后,position="+buff.position());
		System.out.println("执行clear()后,缓冲区域的数据没有被清除:"+buff.get(2));
		System.out.println("执行绝对读取后，position="+buff.position());
	}

}

 

打印结果：

capacity ：8

limit ：8

position ：0

加入三个元素之后，position ：3

执行flip()方法，limit：3

第一个元素（position=0）: a

取出第一个元素后，position：1

执行clear()后,limit=8

执行clear()后,position=0

执行clear()后,缓冲区域的数据没有被清除:c

执行绝对读取后，position=0

 

使用Channel

package hb.nio;

import java.io.File;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.IOException;
import java.io.RandomAccessFile;
import java.nio.ByteBuffer;
import java.nio.CharBuffer;
import java.nio.channels.FileChannel;
import java.nio.charset.Charset;
import java.nio.charset.CharsetDecoder;

public class RandomFileChannelTest {

	public static void main(String[] args) {

		File f = new File("c:\\MyClient.java");

		try {
			FileInputStream fis = new FileInputStream(f);
			FileChannel fileChannel = fis.getChannel();
			ByteBuffer bb = fileChannel.map(FileChannel.MapMode.READ_ONLY, 0, f.length());
			while (bb.hasRemaining()) {
				System.out.print((char) bb.get());
			}
		} catch (FileNotFoundException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		} catch (IOException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}

//		try {
//			RandomAccessFile fis = new RandomAccessFile(f, "rw");
//			// FileInputStream fis = new FileInputStream(f);
//			FileChannel fileChannel = fis.getChannel();
//
//			ByteBuffer bb = ByteBuffer.allocate(1024);
//
//			while (fileChannel.read(bb) != -1) {
//				bb.flip();
//				Charset charset = Charset.forName("GBK");
//				CharsetDecoder decoder = charset.newDecoder();
//				CharBuffer charBuffer = decoder.decode(bb);
//				System.out.print(charBuffer);
//				// System.out.println(bb);
//				bb.clear();
//			}
//
//		} catch (FileNotFoundException e) {
//			// TODO Auto-generated catch block
//			e.printStackTrace();
//		} catch (Exception e) {
//			// TODO Auto-generated catch block
//			e.printStackTrace();
//		}
		

	}

}