合并文件后删除原来的properties文件出错 - 黑马程序员技术交流社区

import java.io.File;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.SequenceInputStream;
import java.util.ArrayList;
import java.util.Collections;
import java.util.Enumeration;
import java.util.List;
import java.util.Properties;
public class MergeFile {
//定义配置文件后缀名
private static final String PROPERTIES_SUFFIX = ".properties";
//定义碎片文件后缀名
private static final String PART_SUFFIX = ".part";
//取缓冲区:1M
private static final int BUFFERED_SIZE = 1048576;
/**
* 根据文件路径读取properties配置文件，并合并指定路径下的文件
* @param filepath 要合并的的碎片文件的目录
* @param fileMerged 碎片文件合并后文件的存放目录
* @throws IOException
* */
public static void fileMerge(File filepath, File fileMerged) throws IOException {
//检测碎片文件目录是否正确
if(filepath==null || !filepath.isDirectory()){
throw new RuntimeException("提供的碎片文件目录不是一个目录!");
}
//检测碎片文件合并后的存放目录是否正确
if(!fileMerged.isDirectory()){
boolean flag = fileMerged.mkdirs();
if(!flag)
throw new RuntimeException("创建文件存放路径失败，请提供正确的文件存放路径！");
}
//获取properties配置文件
File[] propFiles = getFilesBySuffix(filepath, PROPERTIES_SUFFIX);
if(propFiles.length != 1){
throw new RuntimeException(filepath.getPath()+"下，后缀为.properties的文件不存在或数量不唯一");
}
Properties prop = getPropObject(propFiles[0]);
//从配置文件中读取碎片文件数量
String count = prop.getProperty("count");
String fileName = prop.getProperty("filename");
if(count==null){
throw new RuntimeException("配置文件中的信息有误：count属性对应的值为空");
}
//获取被分割的文件碎片
File[] partFiles = getFilesBySuffix(filepath,PART_SUFFIX);
List<FileInputStream> flist = new ArrayList<FileInputStream>();
if(Integer.parseInt(count) != partFiles.length)
throw new RuntimeException("配置文件中的count属性的值与实际part文件数量不相符");
//将文件碎片添加到一个集合中
for(File f : partFiles){
flist.add(new FileInputStream(f));
}
//将文件集合转化为序列流
SequenceInputStream sis = fileList2SeqInputStream(flist);
//合并文件
write2Disk(sis, fileMerged, fileName);
//关闭序列流
sis.close();
//清除碎片文件
clearDebrisFiles(filepath);
}
//清除碎片文件
private static void clearDebrisFiles(File filepath) {
File[] file = filepath.listFiles();
for(File f : file){
boolean flag = f.delete();
if(!flag)
throw new RuntimeException(filepath.getPath()+"下，"+f.getName()+"删除失败！");
}
}
//将文件集合转化为序列流
private static SequenceInputStream fileList2SeqInputStream(
List<FileInputStream> flist) {
Enumeration<FileInputStream> enumList = Collections.enumeration(flist);
SequenceInputStream sis = new SequenceInputStream(enumList);
return sis;
}
//根据文件后缀获取文件
private static File[] getFilesBySuffix(File filepath, String suffix) {
File[] propFiles = filepath.listFiles(new FilterBySuffix(suffix));
return propFiles;
}
//获取碎片文件数量
private static Properties getPropObject(File propFiles) throws IOException,
FileNotFoundException {
//获取properties配置文件中的信息
Properties prop = new Properties();
prop.load(new FileInputStream(propFiles));
return prop;
}
//合并文件
private static void write2Disk(SequenceInputStream sis, File fileMerged, String filename) throws IOException {
FileOutputStream out = new FileOutputStream(new File(fileMerged, filename));
byte[] buf = new byte[BUFFERED_SIZE];
int len = 0;
while((len=sis.read(buf))!=-1){
out.write(buf, 0, len);
}
out.close();
}
}

复制代码