用java进行复制文件(考虑使用多线程),能系统自带快吗？？ - 黑马程序员技术交流社区

import java.io.IOException;
/*
* 将一个电影文件，拷贝到其他盘。模拟下载，要求使用多线程
* 分析：
* 1，通过File对象关联源文件，并获取其大小。
* 2，通过File对象创建一个和源文件大小相同的（空）文件
* 3，通过随机流RandomAccessFile读取源文件，
* 4，将读取的数据写入到输出管道流PipedOutputStream，
* 5，管道读取流PipedInputStream读取输出流中的数据，并通过随机流写入到目的文件中。
*
*/
public class TestTwo {
public static void main(String[] args) throws IOException {
Copy.copy("C:\\Mon.mp4","C:\\Moncy.mp4");
}
}

复制代码

import java.io.File;
import java.io.IOException;
import java.io.PipedInputStream;
import java.io.PipedOutputStream;
import java.io.RandomAccessFile;
public class Copy {
public static void main(String[] args) {
}
public static boolean copy(String source, String destination) throws IOException {
File socefile = new File(source);
File destfile = new File(destination);
if(socefile.isHidden())
throw new RuntimeException("源文件不可操作");
//目的文件初始化，使其和源文件大小一致。
RandomAccessFile soceRaf = new RandomAccessFile(socefile,"r");
RandomAccessFile destRaf = new RandomAccessFile(destfile,"rwd");
destRaf.setLength(soceRaf.length());
long index = soceRaf.getFilePointer();
soceRaf.close();
destRaf.close();
//把源文件切成4段，每段的最小的（最接近负无穷大）double 值，该值大于等于参数，
//保证数据不丢失。最后一段单独处理，因为数据可能会小于len。
long len = (long) Math.ceil(socefile.length()/4);
for(int x=0 ; x<4 ; x++){
PipedOutputStream pos = new PipedOutputStream();
PipedInputStream pis = new PipedInputStream(pos);
//为了使每个线程都有一个自己独立的指针，为每个对象建立独自的随机流
new Thread(new PipedOut
(pos,new RandomAccessFile(socefile,"r"),index,len)).start();;
new Thread(new PipedIn
(pis,new RandomAccessFile(destfile,"rwd"),index,len)).start();
index = index + len ;
}
return true;
/*无限代码，用于测试的
* PipedOutputStream pos = new PipedOutputStream();
PipedInputStream pis = new PipedInputStream(pos);
long len = soceRaf.length();
new Thread(new PipedOut(pos,soceRaf,index,len)).start();
new Thread(new PipedIn(pis,destRaf,index,len)).start();
*/
}
}

复制代码

import java.io.BufferedOutputStream;
import java.io.IOException;
import java.io.PipedOutputStream;
import java.io.RandomAccessFile;
public class PipedOut implements Runnable{
BufferedOutputStream pos;
RandomAccessFile soceRaf;
long index;
long len;
PipedOut(PipedOutputStream pos, RandomAccessFile soceRaf, long index, long len) {
super();
this.pos = new BufferedOutputStream(pos);
this.soceRaf = soceRaf;
this.index = index;
this.len = len;
}
public void run() {
try {
byte[] buf = new byte[1024*1024*20];
int length = 0 ;
soceRaf.seek(index);//设置指针位置
//如果没有循环超出数据位置，或者在到结尾。
while(soceRaf.getFilePointer()<index+len){
if((length=soceRaf.read(buf))!=-1){
pos.write(buf,0,length);
pos.flush();
}
else
break;
}
//如果是因为循环超出数据位置导致的结束,则计算出有效的数组长度
if(length==buf.length){
length =(int) ((long)length - ( soceRaf.getFilePointer()-(index+len) ));
System.out.println(length);
pos.write(buf,0,length);
}
pos.close();
soceRaf.close();
}
catch (IOException e) {
e.printStackTrace();
}
/*
* 无效代码用于测试的
try {
byte[] buf = new byte[1024*100];
int length = 0 ;
soceRaf.seek(index);//设置指针位置
//如果没有循环超出数据位置，或者在到结尾。
while((length=soceRaf.read(buf))!=-1){
pos.write(buf,0,length);
pos.flush();
}
pos.close();
soceRaf.close();
}
catch (IOException e) {
e.printStackTrace();
}
*/
}
}

复制代码

import java.io.BufferedInputStream;
import java.io.IOException;
import java.io.PipedInputStream;
import java.io.RandomAccessFile;
public class PipedIn implements Runnable {
BufferedInputStream pis;
RandomAccessFile destRaf;
long index;
long len;
PipedIn(PipedInputStream pis, RandomAccessFile destRaf, long index, long len) {
super();
this.pis =new BufferedInputStream(pis);
this.destRaf = destRaf;
this.index = index;
this.len = len;
}
public void run() {
try {
byte[] buf = new byte[1024*1024*20];
int length = 0 ;
destRaf.seek(index);//设置指针位置
//读取管道流中的数据，并写入目的文件中
while((length=pis.read(buf))!=-1){
destRaf.write(buf,0,length);
}
pis.close();
destRaf.close();
System.out.println("over");
} catch (IOException e) {
e.printStackTrace();
}
}
}

复制代码