分割流

朱雀 2022-08-09 05:15 92阅读 0赞

package other;
    
    import java.io.FileInputStream;
    import java.io.FileOutputStream;
    import java.io.IOException;
    import java.io.SequenceInputStream;
    import java.util.ArrayList;
    import java.util.Enumeration;
    import java.util.Iterator;
    
    public class SplitFile { 
    
        public static void main(String[] args) throws IOException {
            merge();
        }
    
        public static void splitFile() throws IOException {
    
            FileInputStream fis = new FileInputStream("test.mp3");
            FileOutputStream fos = null;
            byte[] buf = new byte[1024 * 1024];
    
            int len = 0;
            int count = 1;
            while ((len = fis.read(buf)) != -1) {
                fos = new FileOutputStream("splitFiles\\" + (count++) + ".part");
                fos.write(buf, 0, len);
                fos.close(); // 及时关掉流
            }
    
            fis.close();
        }
    
        public static void merge() throws IOException {
            ArrayList<FileInputStream> al = new ArrayList<FileInputStream>();
            for (int i = 1; i <= 4; i++) {
                al.add(new FileInputStream("splitFiles\\" + i + ".part"));
            }
    
            Iterator<FileInputStream> it = al.iterator();
            Enumeration<FileInputStream> en = new Enumeration<FileInputStream>() {
    
                @Override
                public boolean hasMoreElements() {
                    return it.hasNext();
                }
    
                @Override
                public FileInputStream nextElement() {
                    return it.next();
                }
            };
            SequenceInputStream sis = new SequenceInputStream(en);
    
            FileOutputStream fos = new FileOutputStream("merge.mp3");
            byte[] buf = new byte[1024];
            int len = 0;
            while ((len = sis.read(buf)) != -1) {
                fos.write(buf, 0, len);
            }
    
            fos.close();
            sis.close();
        }
    
    }