感觉这个应该是毕老师视频中关于流操作的比较复杂的一个了，涉及流，文件，集合，异常处理。

1. package com.itheima;
   
2. 
   
3. import java.io.BufferedInputStream;
   
4. import java.io.BufferedOutputStream;
   
5. import java.io.File;
   
6. import java.io.FileInputStream;
   
7. import java.io.FileNotFoundException;
   
8. import java.io.FileOutputStream;
   
9. import java.io.FilenameFilter;
   
10. import java.io.IOException;
    
11. import java.io.SequenceInputStream;
    
12. import java.util.ArrayList;
    
13. import java.util.Collections;
    
14. import java.util.Enumeration;
    
15. import java.util.Properties;
    
16. import java.util.Set;
    
17. 
    
18. 
    
19. /**
    
20. * 文件的切割与合并
    
21. * @author wfq
    
22. */
    
23. public class Test9 {
    
24. 
    
25.         public static void main(String[] args) {
    
26. //                File file = new File("tempfile\\那片海.mp3");
    
27.                 File targfFile = new File("tempfile\\targfile");
    
28. //                split(file,targfFile);
    
29.                 merger(targfFile);
    
30.         }
    
31.         //合并文件方法
    
32.         public static void merger(File targfFile) {
    
33.                
    
34.                 //判断该文件是否存在且为目录
    
35.                 if(!(targfFile.exists()&&targfFile.isDirectory()))
    
36.                         throw new RuntimeException("该文件不存在或不是目录...");
    
37.                
    
38.                 //判断配置文件是否存在且唯一
    
39.                 File[] filesProp = targfFile.listFiles(new FilenameFilter() {
    
40.                         @Override
    
41.                         public boolean accept(File dir, String name) {
    
42.                                 return name.endsWith(".properties");
    
43.                         }
    
44.                 });
    
45.                 if(!(filesProp.length==1))
    
46.                         throw new RuntimeException("配置文件不存在或不唯一...");
    
47.                 //创建属性集读取配置文件
    
48.                 Properties prop = new Properties();
    
49.                 BufferedInputStream propIn = null;
    
50.                
    
51.                 String fileName = null;
    
52.                 int fileCount = 0;
    
53.                 try {
    
54.                         propIn = new BufferedInputStream(new FileInputStream(filesProp[0]));
    
55.                         prop.load(propIn);
    
56.                         Set<String > propSet = prop.stringPropertyNames();
    
57.                         for (String string : propSet) {
    
58.                                 fileName = string;
    
59.                                 fileCount = Integer.parseInt(prop.getProperty(fileName));
    
60.                         }
    
61.                 } catch (IOException e) {
    
62.                         System.out.println("异常啦..");
    
63.                 } finally {
    
64.                         if(propIn!=null)
    
65.                         try {
    
66.                                 propIn.close();
    
67.                         } catch (IOException e) {
    
68.                                 e.printStackTrace();
    
69.                         }
    
70.                 }
    
71.                 //判断碎片文件是否缺失或不连续
    
72.                 File[] filesPart = targfFile.listFiles(new FilenameFilter() {
    
73.                         @Override
    
74.                         public boolean accept(File dir, String name) {
    
75.                                 return name.endsWith(".part");
    
76.                         }
    
77.                 });
    
78.                 //判断碎片数异常
    
79.                 if(fileCount!=filesPart.length)
    
80.                        throw new RuntimeException("碎片数异常...");
    
81.                 //判断是否有碎片缺失
    
82.                 for (int i = 1; i <= fileCount; i++) {
    
83.                         File partFile = new File(targfFile, i+".part");
    
84.                         if(!partFile.exists())
    
85.                                 throw new RuntimeException(partFile.getName()+"碎片缺失..");
    
86.                 }
    
87.                 //合并文件
    
88.                 mergerFile(targfFile,filesPart,fileName);
    
89.         }
    
90.        
    
91.         private static void mergerFile(File targfFile, File[] filesPart,
    
92.                         String fileName) {
    
93.                 //创建存储流的集合
    
94.                 ArrayList<FileInputStream> list = new ArrayList<FileInputStream>();
    
95.                 //存入关联每一个碎片文件的流对象
    
96.                 for (File file : filesPart) {
    
97.                         try {
    
98.                                 list.add(new FileInputStream(file));
    
99.                         } catch (FileNotFoundException e) {
    
100.                                 e.printStackTrace();
     
101.                         }
     
102.                 }
     
103.                 //获取输入流的枚举
     
104.                 Enumeration<FileInputStream> en = Collections.enumeration(list);
     
105.                 //创建序列读取流
     
106.                 SequenceInputStream in = new SequenceInputStream(en);
     
107.                 //创建输出流
     
108.                 BufferedOutputStream out = null;
     
109.                
     
110.                 try {
     
111.                         out = new BufferedOutputStream(new FileOutputStream(new File(targfFile, fileName)));
     
112.                         byte[] buf = new byte[1024];
     
113.                         int len = 0;
     
114.                         while ((len=in.read(buf))!=-1) {
     
115.                                 out.write(buf, 0, len);
     
116.                                 out.flush();
     
117.                         }
     
118.                 } catch (IOException e) {
     
119.                         System.out.println("异常啦..");
     
120.                 } finally {
     
121.                         //关闭资源
     
122.                         if(in!=null)
     
123.                         try {
     
124.                                 in.close();
     
125.                         } catch (IOException e) {
     
126.                                 e.printStackTrace();
     
127.                         }
     
128.                         if(out!=null)
     
129.                                 try {
     
130.                                         out.close();
     
131.                                 } catch (IOException e) {
     
132.                                         e.printStackTrace();
     
133.                                 }
     
134.                 }
     
135.         }
     
136.         //切割文件方法
     
137.         public static void split(File file, File targfFile){
     
138.                 //判断被切割的文件是否是是文件并存在
     
139.                 if(!(file.isFile()&&file.exists()))
     
140.                         throw new RuntimeException("被切割的文件不存在或不是文件...");
     
141.                 //判断目标目录是否存在，不存在创建
     
142.                 if(!targfFile.exists())
     
143.                         targfFile.mkdir();
     
144.                 //创建属性集，持久化存储配置文件
     
145.                 Properties prop = new Properties();
     
146.                 //创建以该大小为单位的切割文件的缓冲数组
     
147.                 byte[] buf = new byte[1024*1024];
     
148.                 //创建读写流
     
149.                 BufferedInputStream bfi = null;
     
150.                 BufferedOutputStream bfo = null;
     
151.                 //记录生成文件编号
     
152.                 int fileNum = 0;
     
153.                 //完成切割
     
154.                 try {
     
155.                         bfi = new BufferedInputStream(new FileInputStream(file));
     
156.                        
     
157.                         int len = 0;
     
158.                         while ((len=bfi.read(buf))!=-1) {
     
159.                                 bfo = new BufferedOutputStream(new FileOutputStream(new File(targfFile, (++fileNum)+".part")));
     
160.                                 bfo.write(buf, 0, len);
     
161.                                 bfo.flush();
     
162.                         }
     
163.                         //记录配置数据
     
164.                         prop.setProperty(file.getName(), String.valueOf(fileNum));
     
165.                        
     
166.                         bfo = new BufferedOutputStream(new FileOutputStream(new File(targfFile, (++fileNum)+".properties")));
     
167.                         //写出数据到配置文件
     
168.                         prop.store(bfo, "wfq");
     
169.                        
     
170.                 } catch (IOException e) {
     
171.                         System.out.println("出错啦...");
     
172.                 } finally {
     
173.                         //关闭资源
     
174.                         if(bfi!=null)
     
175.                         try {
     
176.                                 bfi.close();
     
177.                         } catch (IOException e) {
     
178.                                 e.printStackTrace();
     
179.                         }
     
180.                         if(bfo!=null)
     
181.                                 try {
     
182.                                         bfo.close();
     
183.                                 } catch (IOException e) {
     
184.                                         e.printStackTrace();
     
185.                                 }
     
186.                 }
     
187.                
     
188.         }
     
189. 
     
190. }
     

复制代码

感觉这个应该是毕老师视频中关于流操作的比较复杂的一个了，涉及流，文件，集合，异常处理。

1. package com.itheima;
   
2. 
   
3. import java.io.BufferedInputStream;
   
4. import java.io.BufferedOutputStream;
   
5. import java.io.File;
   
6. import java.io.FileInputStream;
   
7. import java.io.FileNotFoundException;
   
8. import java.io.FileOutputStream;
   
9. import java.io.FilenameFilter;
   
10. import java.io.IOException;
    
11. import java.io.SequenceInputStream;
    
12. import java.util.ArrayList;
    
13. import java.util.Collections;
    
14. import java.util.Enumeration;
    
15. import java.util.Properties;
    
16. import java.util.Set;
    
17. 
    
18. 
    
19. /**
    
20. * 文件的切割与合并
    
21. * @author wfq
    
22. */
    
23. public class Test9 {
    
24. 
    
25.         public static void main(String[] args) {
    
26. //                File file = new File("tempfile\\那片海.mp3");
    
27.                 File targfFile = new File("tempfile\\targfile");
    
28. //                split(file,targfFile);
    
29.                 merger(targfFile);
    
30.         }
    
31.         //合并文件方法
    
32.         public static void merger(File targfFile) {
    
33.                
    
34.                 //判断该文件是否存在且为目录
    
35.                 if(!(targfFile.exists()&&targfFile.isDirectory()))
    
36.                         throw new RuntimeException("该文件不存在或不是目录...");
    
37.                
    
38.                 //判断配置文件是否存在且唯一
    
39.                 File[] filesProp = targfFile.listFiles(new FilenameFilter() {
    
40.                         @Override
    
41.                         public boolean accept(File dir, String name) {
    
42.                                 return name.endsWith(".properties");
    
43.                         }
    
44.                 });
    
45.                 if(!(filesProp.length==1))
    
46.                         throw new RuntimeException("配置文件不存在或不唯一...");
    
47.                 //创建属性集读取配置文件
    
48.                 Properties prop = new Properties();
    
49.                 BufferedInputStream propIn = null;
    
50.                
    
51.                 String fileName = null;
    
52.                 int fileCount = 0;
    
53.                 try {
    
54.                         propIn = new BufferedInputStream(new FileInputStream(filesProp[0]));
    
55.                         prop.load(propIn);
    
56.                         Set<String > propSet = prop.stringPropertyNames();
    
57.                         for (String string : propSet) {
    
58.                                 fileName = string;
    
59.                                 fileCount = Integer.parseInt(prop.getProperty(fileName));
    
60.                         }
    
61.                 } catch (IOException e) {
    
62.                         System.out.println("异常啦..");
    
63.                 } finally {
    
64.                         if(propIn!=null)
    
65.                         try {
    
66.                                 propIn.close();
    
67.                         } catch (IOException e) {
    
68.                                 e.printStackTrace();
    
69.                         }
    
70.                 }
    
71.                 //判断碎片文件是否缺失或不连续
    
72.                 File[] filesPart = targfFile.listFiles(new FilenameFilter() {
    
73.                         @Override
    
74.                         public boolean accept(File dir, String name) {
    
75.                                 return name.endsWith(".part");
    
76.                         }
    
77.                 });
    
78.                 //判断碎片数异常
    
79.                 if(fileCount!=filesPart.length)
    
80.                        throw new RuntimeException("碎片数异常...");
    
81.                 //判断是否有碎片缺失
    
82.                 for (int i = 1; i <= fileCount; i++) {
    
83.                         File partFile = new File(targfFile, i+".part");
    
84.                         if(!partFile.exists())
    
85.                                 throw new RuntimeException(partFile.getName()+"碎片缺失..");
    
86.                 }
    
87.                 //合并文件
    
88.                 mergerFile(targfFile,filesPart,fileName);
    
89.         }
    
90.        
    
91.         private static void mergerFile(File targfFile, File[] filesPart,
    
92.                         String fileName) {
    
93.                 //创建存储流的集合
    
94.                 ArrayList<FileInputStream> list = new ArrayList<FileInputStream>();
    
95.                 //存入关联每一个碎片文件的流对象
    
96.                 for (File file : filesPart) {
    
97.                         try {
    
98.                                 list.add(new FileInputStream(file));
    
99.                         } catch (FileNotFoundException e) {
    
100.                                 e.printStackTrace();
     
101.                         }
     
102.                 }
     
103.                 //获取输入流的枚举
     
104.                 Enumeration<FileInputStream> en = Collections.enumeration(list);
     
105.                 //创建序列读取流
     
106.                 SequenceInputStream in = new SequenceInputStream(en);
     
107.                 //创建输出流
     
108.                 BufferedOutputStream out = null;
     
109.                
     
110.                 try {
     
111.                         out = new BufferedOutputStream(new FileOutputStream(new File(targfFile, fileName)));
     
112.                         byte[] buf = new byte[1024];
     
113.                         int len = 0;
     
114.                         while ((len=in.read(buf))!=-1) {
     
115.                                 out.write(buf, 0, len);
     
116.                                 out.flush();
     
117.                         }
     
118.                 } catch (IOException e) {
     
119.                         System.out.println("异常啦..");
     
120.                 } finally {
     
121.                         //关闭资源
     
122.                         if(in!=null)
     
123.                         try {
     
124.                                 in.close();
     
125.                         } catch (IOException e) {
     
126.                                 e.printStackTrace();
     
127.                         }
     
128.                         if(out!=null)
     
129.                                 try {
     
130.                                         out.close();
     
131.                                 } catch (IOException e) {
     
132.                                         e.printStackTrace();
     
133.                                 }
     
134.                 }
     
135.         }
     
136.         //切割文件方法
     
137.         public static void split(File file, File targfFile){
     
138.                 //判断被切割的文件是否是是文件并存在
     
139.                 if(!(file.isFile()&&file.exists()))
     
140.                         throw new RuntimeException("被切割的文件不存在或不是文件...");
     
141.                 //判断目标目录是否存在，不存在创建
     
142.                 if(!targfFile.exists())
     
143.                         targfFile.mkdir();
     
144.                 //创建属性集，持久化存储配置文件
     
145.                 Properties prop = new Properties();
     
146.                 //创建以该大小为单位的切割文件的缓冲数组
     
147.                 byte[] buf = new byte[1024*1024];
     
148.                 //创建读写流
     
149.                 BufferedInputStream bfi = null;
     
150.                 BufferedOutputStream bfo = null;
     
151.                 //记录生成文件编号
     
152.                 int fileNum = 0;
     
153.                 //完成切割
     
154.                 try {
     
155.                         bfi = new BufferedInputStream(new FileInputStream(file));
     
156.                        
     
157.                         int len = 0;
     
158.                         while ((len=bfi.read(buf))!=-1) {
     
159.                                 bfo = new BufferedOutputStream(new FileOutputStream(new File(targfFile, (++fileNum)+".part")));
     
160.                                 bfo.write(buf, 0, len);
     
161.                                 bfo.flush();
     
162.                         }
     
163.                         //记录配置数据
     
164.                         prop.setProperty(file.getName(), String.valueOf(fileNum));
     
165.                        
     
166.                         bfo = new BufferedOutputStream(new FileOutputStream(new File(targfFile, (++fileNum)+".properties")));
     
167.                         //写出数据到配置文件
     
168.                         prop.store(bfo, "wfq");
     
169.                        
     
170.                 } catch (IOException e) {
     
171.                         System.out.println("出错啦...");
     
172.                 } finally {
     
173.                         //关闭资源
     
174.                         if(bfi!=null)
     
175.                         try {
     
176.                                 bfi.close();
     
177.                         } catch (IOException e) {
     
178.                                 e.printStackTrace();
     
179.                         }
     
180.                         if(bfo!=null)
     
181.                                 try {
     
182.                                         bfo.close();
     
183.                                 } catch (IOException e) {
     
184.                                         e.printStackTrace();
     
185.                                 }
     
186.                 }
     
187.                
     
188.         }
     
189. 
     
190. }
     

复制代码