[转]java 输出流转输入流

ByteArrayOutputStream.toByteArray

ByteArrayInputStream

StringWriter.toString

StringReader

字符流和二进制流是javaIO的两类流,

输入流和输出流是javaIO的两类流

　　如果你曾经使用过Java IO 编程，很可能会遇到这样一个状况，在一个类中向OutputStream里面写数据，而另一个类则从InputStream中读取这些数据。这时问题就出 现了,“如何才能把OutputStream里的数据转换为InputStream里的数据呢？”。

　　在Java里，并没有一个OutpStreamToInputStreamConverter 的类。 但庆幸的是还是有几个方法可以办到。

方法1：使用byte数组作为缓存

　　最简单的方法就是使用byte 数组作为缓存。代码示例如下：

  ByteArrayOutputStream out = new ByteArrayOutputStream();
  class1.putDataOnOutputStream(out);
  class2.processDataFromInputStream(
    new ByteArrayInputStream(out.toByteArray())
  );

  这样就行了，OutputStream已经转换为InputStream。

方法2：使用管道

　　方法1的问题是你必须有足够大的缓存来保存所有的数据。很可能就需要使用文件系统而不是内存，但是不论哪种方法都对能处理的数据存规模存在严格的限制。解 决的方法是在一个线程中往PipedOutputStream里面写数据，而当前线程则继续读另一个线程输入的数据。

  PipedInputStream in = new PipedInputStream();
  PipedOUtputStream out = new PipedOutputStream(in);
  new Thread(
    new Runnable(){
      public void run(){
        class1.putDataOnOutputStream(out);
      }
    }
  ).start();
  class2.processDataFromInputStream(in);

方法3：使用循环缓存

  方法2里面的两个管道实际上是维护了一个隐藏的循环缓存。所以明确的使用一个循环缓存可以更加简便。循环缓存提供了如下几种好处：

  （译者注：JDK中并没有提供这种解决方案，感兴趣的话可以去http://ostermiller.org/utils/ 下载）

• 一个循环缓存类替代两个管道类
• 可以很容易的在“缓存所有数据”和“多线程”方法间切换
• 你可以改变缓存的大小，而不是依赖于管道内硬编码的1k的缓存

  多线程使用循环缓存的示例如下：

CircularByteBuffer cbb = new CircularByteBuffer();
  new Thread(
    new Runnable(){
      public void run(){
        class1.putDataOnOutputStream(cbb.getOutputStream());
      }
    }
  ).start();
  class2.processDataFromInputStream(cbb.getInputStream());

单线程循环缓存示例如下：

// buffer all data in a circular buffer of infinite size
  CircularByteBuffer cbb = new CircularByteBuffer(CircularByteBuffer.INFINITE_SIZE);
  class1.putDataOnOutputStream(cbb.getOutputStream());
  class2.processDataFromInputStream(cbb.getInputStream());

Writer到Reader 的转换方法与上述方法类似，下面仅举例，不做详细说明了。

  方法4：使用缓存数组

StringWriter out = new StringWriter();
  class1.putDataOnWriter(out);
  class2.processDataFromReader(
    new StringReader(out.toString())
  );

方法5：使用管道

PipedReader in = new PipedReader();
  PipedWriter out = new PipedWriter(in);
  new Thread(
    new Runnable(){
      public void run(){
        class1.putDataOnWriter(out);
      }
    }
  ).start();
  class2.processDataFromReader(in);

方法6：使用循环缓存

多线程示例

CircularCharBuffer ccb = new CircularCharBuffer();
  new Thread(
    new Runnable(){
      public void run(){
        class1.putDataOnWriter(ccb.getWriter());
      }
    }
  ).start();
  class2.processDataFromReader(ccb.getReader());

单线程示例

// buffer all data in a circular buffer of infinite size
  CircularCharBuffer ccb = new CircularCharBuffer(CircularCharBuffer.INFINITE_SIZE);
  class1.putDataOnWriter(ccb.getWriter());
  class2.processDataFromReader(ccb.getReader());