[转]java 输出流转输入流

2022-12-23 07:37:53

ByteArrayOutputStream.toByteArray

ByteArrayInputStream

StringWriter.toString

StringReader

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

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

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

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

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

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

  1. ByteArrayOutputStream out = new ByteArrayOutputStream();
  2. class1.putDataOnOutputStream(out);
  3. class2.processDataFromInputStream(
  4. new ByteArrayInputStream(out.toByteArray())
  5. );

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

方法2：使用管道

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

  1. PipedInputStream in = new PipedInputStream();
  2. PipedOUtputStream out = new PipedOutputStream(in);
  3. new Thread(
  4. new Runnable(){
  5. public void run(){
  6. class1.putDataOnOutputStream(out);
  7. }
  8. }
  9. ).start();
  10. class2.processDataFromInputStream(in);

方法3：使用循环缓存

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

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

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

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

  1. CircularByteBuffer cbb = new CircularByteBuffer();
  2. new Thread(
  3. new Runnable(){
  4. public void run(){
  5. class1.putDataOnOutputStream(cbb.getOutputStream());
  6. }
  7. }
  8. ).start();
  9. class2.processDataFromInputStream(cbb.getInputStream());

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

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

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

方法4：使用缓存数组

  1. StringWriter out = new StringWriter();  
  2.   class1.putDataOnWriter(out);  
  3.   class2.processDataFromReader(  
  4.     new StringReader(out.toString())  
  5.   );  

方法5：使用管道

  1. PipedReader in = new PipedReader();  
  2.   PipedWriter out = new PipedWriter(in);  
  3.   new Thread(  
  4.     new Runnable(){  
  5.       public void run(){  
  6.         class1.putDataOnWriter(out);  
  7.       }  
  8.     }  
  9.   ).start();  
  10.   class2.processDataFromReader(in);  

方法6：使用循环缓存

多线程示例

  1. CircularCharBuffer ccb = new CircularCharBuffer();
  2. new Thread(
  3. new Runnable(){
  4. public void run(){
  5. class1.putDataOnWriter(ccb.getWriter());
  6. }
  7. }
  8. ).start();
  9. class2.processDataFromReader(ccb.getReader());

单线程示例

  1. // buffer all data in a circular buffer of infinite size  
  2.   CircularCharBuffer ccb = new CircularCharBuffer(CircularCharBuffer.INFINITE_SIZE);  
  3.   class1.putDataOnWriter(ccb.getWriter());  
  4.   class2.processDataFromReader(ccb.getReader());  
上一篇：【Java每日一题】20161207


下一篇：CSS3新增文本属性实现图片点击切换效果