使用文件通道代码,Java代码库,德仔网

代码语言

代码分类

【Java】使用文件通道

作者:培政 / 发布于2015/4/14/ 417


	package file;
	
	import java.io.BufferedInputStream;
	import java.io.BufferedOutputStream;
	import java.io.File;
	import java.io.FileInputStream;
	import java.io.FileNotFoundException;
	import java.io.FileOutputStream;
	import java.io.IOException;
	import java.io.InputStream;
	import java.io.OutputStream;
	import java.nio.ByteBuffer;
	import java.nio.channels.FileChannel;
	
	/**
	* 提供java IO 操作
	* @author ronaldoGT
	*
	*/
	public class IOfile {
	
	 /**
	 * @param args
	 */
	 private static IOfile ioFile = new IOfile();
	 private static String oldUrl = "E://FunshionMedia/黑客帝国/老梁观世界-20130311.mp4";
	 private static String newUrl = "E://老梁观世界-20130311.mp4";
	
	 public static void main(String[] args) {
	 long star = System.nanoTime();
	 //ioFile.copyFile(new File(oldUrl),new File(newUrl));//601508919
	 //ioFile.copyDirectory(new File("D:/html5"),"E:/");
	 //ioFile.textFileChannel(new File(oldUrl),new File(newUrl));//1511679222
	 ioFile.textFileChannelReadWrite(new File(oldUrl),new File(newUrl));//1333882326
	 long end = System.nanoTime();
	 System.out.println(end-star);
	 }
	
	 /**
	 * 文件通道 测试
	 * @param oldFile
	 * @param newFile
	 */
	 public void textFileChannel(File oldFile,File newFile){
	 FileChannel fis = null ;
	 FileChannel fos = null ;
	 try {
	 fis = new FileInputStream(oldFile).getChannel();
	 fos = new FileOutputStream(newFile).getChannel();
	 fis.transferTo(0, fis.size(), fos);
	 } catch (Exception e) {
	 // TODO Auto-generated catch block
	 e.printStackTrace();
	 }finally{
	 try {
	 fis.close();
	 fos.close();
	 } catch (Exception e) {
	 // TODO Auto-generated catch block
	 e.printStackTrace();
	 }
	 }
	 }
	
	 /**
	 * 测试文件通道 read，write方法
	 * @param oldFile
	 * @param newFile
	 */
	 public void textFileChannelReadWrite(File oldFile,File newFile){
	 FileChannel fis = null ;
	 FileChannel fos = null ;
	 try {
	 fis = new FileInputStream(oldFile).getChannel();
	 fos = new FileOutputStream(newFile).getChannel();
	 ByteBuffer buf = ByteBuffer.allocate(1024*2);
	 while(fis.read(buf) != -1){
	 buf.flip();//准备写入，防止其他读取，锁住文件
	 fos.write(buf);
	 buf.clear();//准备读取。将缓冲区清理完毕，移动文件内部指针
	 }
	 } catch (Exception e) {
	 // TODO Auto-generated catch block
	 e.printStackTrace();
	 }finally{
	 try {
	 fis.close();
	 fos.close();
	 } catch (Exception e) {
	 // TODO Auto-generated catch block
	 e.printStackTrace();
	 }
	 }
	 }
	
	 /**
	 * 复制文件夹，嵌套文件夹，以及包含的文件
	 * @param oldDirectory
	 * @param newUrl
	 */
	 public void copyDirectory(File oldDirectory,String newUrl){
	 File[] f=oldDirectory.listFiles();
	 File file = new File(newUrl);
	 String url;
	 url = oldDirectory.getName();
	 newUrl += "/"+url;
	 file = new File(newUrl);
	 file.mkdir();
	 for(File ff:f){
	 if(ff.isDirectory()){
	 copyDirectory(ff,newUrl);
	 }
	 if(ff.isFile()){
	 copyFile(ff,new File(newUrl+"/"+ff.getName()));
	 }
	 }
	
	 }
	
	
	 /**
	 * 复制文件
	 * @param oldFile
	 * @param newFile
	 */
	 public void copyFile(File oldFile,File newFile){
	 InputStream fis = null;
	 OutputStream fos = null;
	 try {
	 fis = new BufferedInputStream(new FileInputStream(oldFile));
	 fos = new BufferedOutputStream(new FileOutputStream(newFile));
	 byte[] buf = new byte[1024*2];
	 int len ;
	 while((len = fis.read(buf)) != -1){
	 fos.write(buf, 0, len);
	 }
	 fos.flush();
	 } catch (Exception e) {
	 // TODO Auto-generated catch block
	 e.printStackTrace();
	 }finally{
	 try {
	 fis.close();
	 fos.close();
	 } catch (IOException e) {
	 // TODO Auto-generated catch block
	 e.printStackTrace();
	 }
	 }
	 }
	
	}

评论列表

本站所提供的代码，版权归原作者所有，若有侵犯作者版权，请与我们联系，我们将立即删除或修改。谢谢!
本站所有代码发布及提供者。

试试其它关键字

　使用文件通道　

同语言下

可能有用的

培政贡献的其它代码(22)