java对IO流 进行分流

01    package org.richin.io.Stream.util;
02    import java.io.BufferedInputStream;
03    import java.io.BufferedOutputStream;
04    import java.io.FileInputStream;
05    import java.io.FileOutputStream;
06    import java.io.IOException;
07    import java.io.InputStream;
08    import java.io.OutputStream;
09    /**
10    * 对流进行分流,同时将一个输入流写入多个输出流
11    * @author Administrator
12    *
13    */
14    public class TeeOutputStream extends OutputStream {
15    private OutputStream out1;
16    private OutputStream out2;
17    public TeeOutputStream(OutputStream stream1, OutputStream stream2)
18    {
19    //调用父类的构造方法，传入需要过滤的流
20    //super(stream1);
21    out1 = stream1;
22    out2 = stream2;
23    }
24    //重写write方法
25    public void write(int b) throws IOException
26    {
27    out1.write(b);
28    out2.write(b);
29    }
30    //重写write方法
31    public void write(byte[] data, int offset, int length) throws IOException
32    {
33    out1.write(data, offset, length);
34    out2.write(data, offset, length);
35    }
36    //重写flush方法
37    public void flush() throws IOException
38    {
39    out1.flush();
40    out2.flush();
41    }
42    //重写close方法
43    public void close() throws IOException
44    {
45    out1.close();
46    out2.close();
47    }
48    public static void copy(InputStream in, OutputStream out)
49    throws IOException {
50    // 缓冲流
51    BufferedInputStream bin = new BufferedInputStream(in);
52    BufferedOutputStream bout = new BufferedOutputStream(out);
53    while (true) {
54    int datum = bin.read();
55    if (datum == -1)
56    break;
57    bout.write(datum);
58    }
59    // 刷新缓冲区
60    bout.flush();
61    }
62    //main方法
63    public static void main(String[] args) throws IOException {
64    FileInputStream fin = new FileInputStream("E:\\gzml\\gongzhens\\yaxi\\设计稿\\快递.rar");
65    FileOutputStream fout1 = new FileOutputStream("D:/快递.rar");
66    FileOutputStream fout2 = new FileOutputStream("e:/快递.rar");
67    TeeOutputStream tout = new TeeOutputStream(fout1, fout2);
68    TeeOutputStream.copy(fin, tout);
69    fin.close();
70    tout.close();
71    }
72    }