输出流转输入流

当有输入流inputstream的数据想要写到数据流outputstream中时，这种情况比较简单，直接read inputstream然后write到outputstream中即可；

当有输出流数据需要转换成输入流使用时，就不那么直观了，我最初的想法是输出流数据写到文件中，然后读文件就转成输入流啦，但是这种利用到硬盘的方法非常不可取的，后来上网查了一下，可以通过管道流PipedStream来实现转换。

首先声明一个维护管道流的类

public class PipedManager {

    private PipedInputStream in = new PipedInputStream();
    private PipedOutputStream out = new PipedOutputStream();

    public PipedManager() {
        try {
            this.in.connect(this.out);
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

    public PipedInputStream getIn() {
        return in;
    }

    public void setIn(PipedInputStream in) {
        this.in = in;
    }

    public PipedOutputStream getOut() {
        return out;
    }

    public void setOut(PipedOutputStream out) {
        this.out = out;
    }
}

在构造器中通过inputstream.connect方法将输入流和输出流联系到一起

测试类

public class PipedTest {

    public static void main(String[] args) throws IOException {
        String readPath = "e:\test.txt";
        String writePath = "e:\write.txt";

        FileInputStream inputStream = new FileInputStream(readPath);
        PipedManager manager = new PipedManager();
        new Thread(){
            @Override
            public void run() {
                PipedOutputStream out = manager.getOut();
                int i = 0;
                byte[]buffer = new byte[1024];
                try {
                    while ((i = inputStream.read(buffer,0,buffer.length)) != -1){
                        out.write(buffer,0,i);
                        out.flush();
                    }
                    out.close();
                    inputStream.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }.start();


        FileOutputStream outputStream = new FileOutputStream(writePath);
        new Thread(){
            @Override
            public void run() {
                PipedInputStream in = manager.getIn();
                int i = 0;
                byte[]buffer = new byte[1024];
                try {
                    while ((i=in.read(buffer,0,buffer.length))!= -1){
                        outputStream.write(buffer,0,i);
                    }
                    in.close();
                    outputStream.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }.start();
    }
}

第一个线程是读取一个文件，将其写入到维护的管道输出流中，

第二个线程是直接从管道输入流中获取数据然后写到另外一个文件中，

最终可以看到数据从一个文件写到了另外一个文件，证明输出流的数据可以直接从输入流中获取到。

需要注意的是：我在使用的时候发现数据写到管道输出流这一步必须要起一个线程，也就是第一个线程，不然会一直阻塞