重复读取InputStream的方法

重复读取InputStream的方法在上篇博客中我们已经知道了Java的InputStream是不能重复被读取的。 但是在有的场合中,我们需要重复利用InputStream的数据。 比如: 1.一个officeword文件流,我需要首先读取InputStream中的前一些字节来判断word文件的实际内容(word文件可以保存html,mht的内容)。然后再根据实际内容决定我要解析InputStream的方式。 

上篇博客中
我们已经知道了Java的InputStream是不能重复被读取的。 


但是在有的场合中,我们需要重复利用InputStream的数据。 


比如: 


1. 一个office word文件流,我需要首先读取InputStream中的前一些字节来判断word文件的实际内容(word文件可以保存html,mht的内容)。然后再根据实际内容决定我要解析InputStream的方式。 




2. 一个Html文件流,我需要首先读取InputStream中的一些字节来判断Html文件编码方式。然后再根据html文件编码方式读取Html内容。 




3. 从socket收到的一个InputStream,我首先需要读取InputStream判断是什么类型的字符串。然后再将InputStream读取写到文件里。 




总之,在实际的工作当中,我们常常会需要多次读取一个InputStream的需求。 


如果该
InputStream是我们通过某种方式“主动”获取的
,那我们可以不必重复读取一个InputStream,而是再次获取一样数据的InputStream来处理。 


例如: 

Java代码  
收藏代码

  1. InputStream inputStream = new FileInputStream(path);  
  2. //利用inputStream  
  3. inputStream = new FileInputStream(path);  
  4. //再次利用inputStream  



再例如: 

Java代码  
收藏代码

  1. InputStream inputStream = httpconn.getInputStream();   
  2. //利用inputStream  
  3. inputStream = httpconn.getInputStream();  
  4. //再次利用inputStream  



但是,对于
“被动”利用InputStream
的接口,在接口内部需要重复利用InputStream,对于InputStream的来源,可能是文件,可能是网络,也可能是内存里的一个String,对于InputStream的方式接口内部不得而知,因此更谈不上在接口内部重复获取了。 


例如有这样一个接口: 

Java代码  
收藏代码

  1. //将InputStream转换成一个文本字符串  
  2. public String convert(InputStream inputStream);  



在接口内部我们可能需要首先读取InputStream前n个字节来判断InputStream流的数据流型,然后转化InputStream为一个字符串。 




最简单的方式就是缓存,首先将InputStream缓存到内存,然后重复使用内存里的数据。 


例如: 

Java代码  
收藏代码

  1. package com.gs.cvoud.attachment.converter;  
  2.   
  3. import java.io.ByteArrayInputStream;  
  4. import java.io.ByteArrayOutputStream;  
  5. import java.io.IOException;  
  6. import java.io.InputStream;  
  7.   
  8. import com.gs.cvoud.util.ObjectUtils;  
  9.   
  10. /** 
  11.  * 缓存InputStream,以便InputStream的重复利用 
  12.  * @author boyce 
  13.  * @version 2014-2-24 
  14.  */  
  15. public class InputStreamCacher {  
  16.       
  17.     private static final org.slf4j.Logger logger = org.slf4j.LoggerFactory.getLogger(InputStreamCacher.class);  
  18.       
  19.     /** 
  20.      * 将InputStream中的字节保存到ByteArrayOutputStream中。 
  21.      */  
  22.     private ByteArrayOutputStream byteArrayOutputStream = null;  
  23.       
  24.     public InputStreamCacher(InputStream inputStream) {  
  25.         if (ObjectUtils.isNull(inputStream))  
  26.             return;  
  27.           
  28.         byteArrayOutputStream = new ByteArrayOutputStream();  
  29.         byte[] buffer = new byte[1024];    
  30.         int len;    
  31.         try {  
  32.             while ((len = inputStream.read(buffer)) > –1 ) {    
  33.                 byteArrayOutputStream.write(buffer, 0, len);    
  34.             }  
  35.             byteArrayOutputStream.flush();  
  36.         } catch (IOException e) {  
  37.             logger.error(e.getMessage(), e);  
  38.         }    
  39.     }  
  40.       
  41.     public InputStream getInputStream() {  
  42.         if (ObjectUtils.isNull(byteArrayOutputStream))  
  43.             return null;  
  44.           
  45.         return new ByteArrayInputStream(byteArrayOutputStream.toByteArray());  
  46.     }  
  47. }  



接口内部使用情景: 

Java代码  
收藏代码

  1. InputStreamCacher  cacher = new InputStreamCacher(inputStream);  
  2. InputStream stream = cacher.getInputStream();  
  3. //读取stream  
  4. stream = cacher.getInputStream();  



上述的方式是将InputStream缓存到一个ByteArrayOutputStream中,当然缓存的数据类型和方式都是任意的,这只是一种解决思路。 


这种方式有一个最大的缺点,就是内存压力。 


外部传给接口的InputStream有可能很大。每调用一次接口就将InputStream缓存到内存中,内存要承受的压力是可想而知的。 




编程永远都是在时间和空间之间找到一个平衡点,前面说的“主动获取方式”的重复获取也有它的缺点,就是需要重新读取文件,获取重新建立网络连接等,这就是需要消耗更多的时间。 




万事万物都是这样,天下没有完美的事,有舍才有得,选择什么就意味着放弃什么,开了一扇窗可能就要关一扇门。所以不管是生活还是编程,我们都需要在舍与得,选择的与放弃的,窗和门之间做出相对合理的抉择,或者说不得不做的抉择。 



闲话扯远了,其实重复利用InputStream还有另一种方式: 

通过mark和reset方法重复利用InputStream


版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。
如需转载请保留出处:https://bianchenghao.cn/35656.html

(0)
编程小号编程小号

相关推荐

发表回复

您的电子邮箱地址不会被公开。 必填项已用*标注