来点实用的Java NIO（五）_JAVA_编程开发_程序员俱乐部

class="java">package com.qin.sanxian.newio;

import java.nio.CharBuffer;

/**
 * @author 三劫散仙
 * 测试Java 新IO的buffer
 * 
 * */
public class TestBuffer {
	
	public static void main(String[] args)throws Exception {
	
		
		//创建一个Buffer对象，allcote分配的容量为8
		CharBuffer buff=CharBuffer.allocate(8);
		
		System.out.println("容量："+buff.capacity());
		System.out.println("限制大小,limit: "+buff.limit());
		System.out.println("位置: position: "+buff.position());
		//放入三个元素
		buff.put("a");
		buff.put("b");
		buff.put("c");
		System.out.println("加入三个元素后位置 :  "+buff.position());
		//此方法是会将limit设置为position的位置，将position的位置为0
		buff.flip();
		System.out.println("执行filp后，limit的位置:"+buff.limit());
		System.out.println("执行filp后,position的位置:"+buff.position());
		
		//取出，第一个元素后
		System.out.println(buff.get(0));
		System.out.println("position: "+buff.position());
		
		//调用clear方法后 ,将position置为0，limit置为capacity
		buff.clear();
		
	 
		 
		 
	 
		System.out.println("执行clean后，limit ="+buff.limit());
		System.out.println("执行clean后，position = "+buff.position());
		
		System.out.println("执行clear后，缓冲区的内容没有被清除： "+buff.get(0));
		System.out.println("执行绝对读取后,position= "+buff.position());
		
		
	}

}

容量：8
限制大小,limit: 8
位置: position: 0
加入三个元素后位置 :  3
执行filp后，limit的位置:3
执行filp后,position的位置:0
a
position: 0
执行clean后，limit =8
执行clean后，position = 0
执行clear后，缓冲区的内容没有被清除： a
执行绝对读取后,position= 0

package com.qin.sanxian.newio;

import java.io.BufferedReader;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.RandomAccessFile;
import java.nio.ByteBuffer;
import java.nio.CharBuffer;
import java.nio.MappedByteBuffer;
import java.nio.channels.FileChannel;
import java.nio.charset.Charset;
import java.nio.charset.CharsetDecoder;

 

/**
 * 
 * Channel测试
 * **/
public class TestChannel {
	
	public static void main(String[] args) throws Exception{
		
		//read();
	//	write();
		moreRead();
	}
	
	
	
	/**
	 * 
	 * 读取一个文件的数据
	 * 写入到另一个文件里
	 * **/
	public static  void read()throws Exception{
		
		File f=new File("F:\\1\\text.txt");
		//创建流获取channel对象
		FileChannel inChannel=new FileInputStream(f).getChannel();
		
		FileChannel outChannel=new FileOutputStream("abc.txt").getChannel();
		
		//将FileChannel里的数据全部映射成ByteBuffer;
		MappedByteBuffer buffer=inChannel.map(FileChannel.MapMode.READ_ONLY, 0, f.length());
		//将f的数据全部输出
		outChannel.write(buffer);
		
		buffer.clear();//复原位置
		Charset c=Charset.forName("UTF-8");
		CharsetDecoder decoder=c.newDecoder();//创建解码器
		
		//解码buffer
		CharBuffer  charBuffer=decoder.decode(buffer);
		System.out.println(charBuffer);
		
		outChannel.close();//关闭流
		inChannel.close();//关闭流
		
		
	}
	
	/**
	 * 
	 * 写入测试
	 * */
public static  void write()throws Exception{
		
		File f=new File("F:\\1\\text.txt");
		 
		//获取一个RandomAccessFile对象
		RandomAccessFile raf=new RandomAccessFile(f, "rw");
		 
		
		//获取FileChannel
		FileChannel channel=raf.getChannel();
		//将文件全部映射到内存中
		ByteBuffer buffer=channel.map(FileChannel.MapMode.READ_WRITE, 0, f.length());
	//控制原来的的指针到最后一步
         
		channel.position(f.length()); 
		
		channel.write(buffer);//拷贝已有数据
		channel.close();//释放资源
		raf.close();//关闭流
		
		
		
	}
	
	
/**
 * 多次读取数据
 * 
 * **/
	public static void moreRead()throws Exception{
		
		FileInputStream f=new FileInputStream(new File("F:\\1\\text.txt"));
		
		//创建一个fileChannel
		FileChannel channel=f.getChannel();
		//定义一个ByteBuffer对象
		ByteBuffer buff=ByteBuffer.allocate(103);
		//将FileChannel的数据放入ByteBuffer中
		 
		while(channel.read(buff)!=-1){
			
			buff.flip();//封印未读取的空间
			//创建Charset对象
			Charset charset=Charset.forName("UTF-8");
			//创建解码器对象
			CharsetDecoder decoder=charset.newDecoder();
			//将字节内容转码
			CharBuffer cbuff=decoder.decode(buff);
			System.out.println(cbuff);
			//为下一次，读取数据做准备，注意其并不会清空缓存内容
			buff.clear();
		}
		channel.close();
		f.close();
		
	}
	
}