InputStream复用，mark和reset

markSupported

InputStream是否支持mark，默认不支持。

public boolean markSupported() {  
   return false;  
}

InputStream默认是不支持mark的，子类须要支持mark必须重写这三个方法。

在此输入流中标记当前的位置。对 reset 方法的后续调用会在最后标记的位置从新定位此流，以便后续读取从新读取相同的字节。

readlimit 参数告知此输入流在标记位置失效以前容许读取许多字节。

mark

mark接口。该接口在InputStream中默认实现不作任何事情。

public synchronized void mark(int readlimit) {}

reset

reset接口。该接口在InputStream中实现，调用就会抛异常。

public synchronized void reset() throws IOException {  
   throw new IOException("mark/reset not supported");  
}

将此流从新定位到对此输入流最后调用 mark 方法时的位置。

reset 的常规协定是：

若是方法 markSupported 返回 true，则：若是建立流以来未调用方法 mark，或最后调用 mark 以来从该流读取的字节数大于最后调用 mark 时的参数，则可能抛出 IOException。若是未抛出这样的 IOException，则将该流从新设置为这种状态：最近调用 mark 以来（或若是未调用 mark，则从文件开始以来）读取的全部字节将从新提供给 read 方法的后续调用方，后接多是调用 reset 时的下一输入数据的全部字节。

若是方法 markSupported 返回 false，则：对 reset 的调用可能抛出 IOException。若是未抛出IOException，则将该流从新设置为一种固定状态，该状态取决于输入流的特定类型和其建立方式的固定状态。提供给 read 方法的后续调用方的字节取决于特定类型的输入流。

简而言之就是：*调用mark方法会记下当前调用mark方法的时刻，InputStream被读到的位置。

调用reset方法就会回到该位置。*

Code

String content = "yydcdut!";  
InputStream inputStream = new ByteArrayInputStream(content.getBytes());  

// 判断该输入流是否支持mark操做  
if (!inputStream.markSupported()) {  
    System.out.println("mark/reset not supported!");  
}  
int ch;    
boolean marked = false;    
while ((ch = inputStream.read()) != -1) {  

    //读取一个字符输出一个字符    
    System.out.print((char)ch);    
    //读到 'c'的时候标记一下  
     if (((char)ch == 'c')& !marked) {    
        inputStream.mark(content.length());  //先不要理会mark的参数  
         marked = true;    
     }    

     //读到'!'的时候从新回到标记位置开始读  
      if ((char)ch == '!' && marked) {    
          inputStream.reset();    
          marked = false;  
      }    
}  
//程序最终输出：yydcdut!dut!

咱们知道InputStream是不支持mark的。要想支持mark子类必须重写这三个方法，我想说的是不一样的实现子类，mark的参数readlimit做用不尽相同。 经常使用的FileInputStream不支持mark。

• 对于BufferedInputStream，readlimit表示：InputStream调用mark方法的时刻起，在读取readlimit个字节以前，标记的该位置是有效的。若是读取的字节数大于readlimit，可能标记的位置会失效。

  在BufferedInputStream的read方法源码中有这么一段：

} else if (buffer.length >= marklimit) {  
     markpos = -1;   /* buffer got too big, invalidate mark */  
     pos = 0;        /* drop buffer contents */  
     } else {

为何是可能会失效呢？

由于BufferedInputStream读取不是一个字节一个字节读取的，是一个字节数组一个字节数组读取的。

例如，readlimit=35，第一次比较的时候buffer.length=0（没开始读）<readlimit.

而后buffer数组一次读取48个字节。这时的read方法只会简单的挨个返回buffer数组中的字节，不会作此次比较。直到读到buffer数组最后一个字节（第48个）后，才从新再次比较。这时若是咱们读到buffer中第47个字节就reset。mark仍然是有效的。虽然47>35。

• 对于InputStream的另一个实现类：ByteArrayInputStream，咱们发现readlimit参数根本就没有用，调用mark方法的时候写多少都无所谓。 

public void mark(int readAheadLimit) {  
   mark = pos;  
}  
  
public synchronized void reset() {  
   pos = mark;  
}

由于对于ByteArrayInputStream来讲，都是经过字节数组建立的，内部自己就保存了整个字节数组，mark只是标记一下数组下标位置，根本不用担忧mark会建立太大的buffer字节数组缓存。 

• 其余的InputStream子类没有去总结。原理都是同样的。 

因此因为mark和reset方法配合能够记录并回到咱们标记的流的位置从新读流，很大一部分就能够解决咱们的某些重复读的须要。 

这种方式的优势很明显：不用缓存整个InputStream数据。对于ByteArrayInputStream甚至没有任何的内存开销。 

固然这种方式也有缺点：就是须要经过干扰InputStream的读取细节，也相对比较复杂。

我是天王盖地虎的分割线

参考：http://zhangbo-peipei-163-com.iteye.com/blog/2022460