準(zhǔn)備工作
定義一個(gè)定時(shí)器琅锻，監(jiān)聽(tīng)分割文件和合并文件的耗時(shí)。
public class Times {
@FunctionalInterface
public interface Block{
abstract void execute();
}
public static void timeConsuming(Block block) {
System.out.println("開(kāi)始-------------------");
long startTime = System.currentTimeMillis();
block.execute();
long endTime = System.currentTimeMillis();
System.out.println("結(jié)束-------------------");
long second = (endTime - startTime) / 1000;
System.out.println("共耗時(shí)：" + second + "秒");
}
}
分割文件
- 獲取需要分割文件的存儲(chǔ)路徑
String separator = File.separator; String userHomePath = System.getProperty("user.home"); String originalDirectoryPath = userHomePath + separator + "Downloads"; String fileNameString = "GMA71.zip"; - 進(jìn)行文件的分割
/** * 文件分割 * @param targetFilePath 目標(biāo)文件路勁 * @throws Exception * 默認(rèn)分割后每個(gè)文件最大為1MB */ private static void fileSplit(String targetFilePath) throws Exception { fileSplit(targetFilePath, ".part", 1024 * 1024); } /** * 文件分割 * @param targetFilePath 目標(biāo)文件路勁 * @param eachFileMaxSize 分割后每個(gè)文件的最大大小哲戚，默認(rèn)是1MB * @throws Exception */ private static void fileSplit(String targetFilePath, String fileExtensionNameString,int eachFileMaxSize) throws Exception { assert(eachFileMaxSize > 0) : "eachFileMaxSize不能小于等于0"; if (targetFilePath == null || targetFilePath.length() == 0) { throw new Exception("目標(biāo)路徑不能為空"); } // 創(chuàng)建目標(biāo)文件 File targetFile = new File(targetFilePath); if (targetFile.exists()) { try ( /* * 初始化輸入流 * 先初始化一個(gè)文件輸入流 * 為節(jié)省性能損耗蘸鲸，再初始化緩存輸入流 */ BufferedInputStream bIS = new BufferedInputStream( new FileInputStream(targetFile));){ String separator = File.separator; // 分割后的文件存儲(chǔ)目錄 String splitFolderPath = targetFile.getParent() + separator + "分割"; // 從緩存輸入流中噪伊，一次性最多讀取多少個(gè)字節(jié) byte[] b = new byte[eachFileMaxSize]; // 讀取的字節(jié)長(zhǎng)度 int len = 0; //循環(huán)個(gè)數(shù) int count = 0; //獲取文件的名字榨婆，包含擴(kuò)展名 String name = targetFile.getName(); int index = name.lastIndexOf("."); name = name.substring(0, index) + fileExtensionNameString; //從緩存輸入流中讀取數(shù)據(jù) while ((len = bIS.read(b)) != -1) { // 初始化分割后的文件 File splitFile = new File(splitFolderPath + separator + ++count + "_" + name); // 獲取分割后的文件所在的目錄 File parentFile = splitFile.getParentFile(); // 判斷目錄是否存在 if (!parentFile.exists()) { // 創(chuàng)建所有目錄 if (parentFile.mkdirs()) { System.out.println(parentFile.getName() + "文件夾創(chuàng)建成功"); } } // 判斷分割后的文件是否存在 if (!splitFile.exists()) { // 創(chuàng)建分割后的文件 if (splitFile.createNewFile()) { System.out.println(splitFile.getName() + "文件創(chuàng)建成功"); } } try ( // 初始化文件輸出流 BufferedOutputStream bOS = new BufferedOutputStream(new FileOutputStream(splitFile));){ // 往分割后的文件中寫(xiě)入數(shù)據(jù) bOS.write(b, 0, len); bOS.flush(); } catch (Exception e) { // TODO: handle exception e.printStackTrace(); } } } catch (Exception e) { // TODO: handle exception e.printStackTrace(); } }else { throw new Exception("目標(biāo)文件不存在"); } } -
打印結(jié)果如下：image.png
合并文件
- 獲取需要合并的文件所在的目錄
String separator = File.separator; String userHomePath = System.getProperty("user.home"); String originalDirectoryPath = userHomePath + separator + "Downloads"; String fileNameString = "RPReplay_Final1602630844.mp4"; String parentFileNameString = "分割"; - 進(jìn)行文件合并
/** * 文件合并 * @param targetParentFilePath 合并文件所在目錄 * @param fileNameString 合并后的文件名 * @throws Exception */ private static void fileMerge(String targetParentFilePath, String fileNameString) throws Exception { if (targetParentFilePath == null || targetParentFilePath.length() == 0) { throw new Exception("目標(biāo)路徑不能為空"); } File parentFile = new File(targetParentFilePath); if (!parentFile.exists()) { throw new Exception("目錄不存在"); } File[] listFiles = parentFile.listFiles(); // 目錄中是否有文件 if (listFiles.length == 0) { return; } // 進(jìn)行排序 Arrays.sort(listFiles, (File o1, File o2) -> { // TODO Auto-generated method stub String name1 = o1.getName().split("_")[0]; String name2 = o2.getName().split("_")[0]; int num1 = Integer.parseInt(name1); int num2 = Integer.parseInt(name2); return num1 - num2; }); String mergePathString = parentFile.getParent() + File.separator + "合并" + File.separator + fileNameString; File mergeFile = new File(mergePathString); if (!mergeFile.getParentFile().exists()) { if (mergeFile.getParentFile().mkdirs()) { System.out.println(mergeFile.getParentFile().getName() + "文件夾創(chuàng)建成功"); } } if (!mergeFile.exists()) { if (!mergeFile.createNewFile()) { System.out.println(mergeFile.getName() + "文件創(chuàng)建成功"); } } // 初始化輸入流集合 Vector<InputStream> vector = new Vector<InputStream>(); for (File file : listFiles) { vector.add(new FileInputStream(file)); } try ( // 初始化集合輸入流 SequenceInputStream sequenceInputStream = new SequenceInputStream(vector.elements()); BufferedOutputStream boStream = new BufferedOutputStream(new FileOutputStream(mergeFile));){ byte[] b = new byte[1024 * 1024]; int len = -1; while ((len = sequenceInputStream.read(b)) != -1) { boStream.write(b, 0, len);; } boStream.flush(); } catch (Exception e) { // TODO: handle exception e.printStackTrace(); } } - 在main函數(shù)中調(diào)用該靜態(tài)方法
Times.timeConsuming(() -> { try { fileMerge(originalDirectoryPath + separator + parentFileNameString, fileNameString); } catch (Exception e) { // TODO Auto-generated catch block e.printStackTrace(); } }); -
打印結(jié)果如下：image.png
