zoukankan      html  css  js  c++  java
  • 输入流InputStream的reset()和mark()方法注意事项

           今天写一个读写程序,运用到InputStream的reset方法是发现竟然失败了,然后查了一下JDK源码,发现BufferInputStream重写了父类FilterInputStream的mark和resetf方法,其有支持 mark 和 reset 方法的能力。而FileInputStream则没有重写父类InputStream的这两个方法,其不具有mark和reset方法的能力。

    在JDK源码中,写到

             public synchronized void mark(int readlimit)

                在该输入流中标记当前位置。 后续调用 reset 方法重新将流定位于最后标记位置,以便后续读取能重新读取相同字节。 

               readlimit 参数给出当前输入流在标记位置变为非法前允许读取的字节数。 

              这句话的意思是说:mark就像书签一样,用于标记,以后再调用reset时就可以再回到这个mark过的地方。mark方法有个参数,通过这个整型参数,你告诉系统,希望在读出这么多个字符之前,这个mark保持有效。比如说mark(10),那么在read()10个以内的字符时,reset()操作后可以重新读取已经读出的数据,如果已经读取的数据超过10个,那reset()操作后,就不能正确读取以前的数据了,因为此时mark标记已经失效。     

      下面是BufferInputStream以及父类FilterInputStream 中这两个方法的默认实现

                      

    //FilterInputStream.java   
     public synchronized void mark(int readlimit) {
    	in.mark(readlimit);
        }
    
     public synchronized void reset() throws IOException {
    	in.reset();
        }
    
    public boolean markSupported() {
    return in.markSupported()
    } //BufferedInputStream.java public synchronized void mark(int readlimit) { marklimit = readlimit; markpos = pos; } public synchronized void reset() throws IOException { getBufIfOpen(); // Cause exception if closed if (markpos < 0) throw new IOException("Resetting to invalid mark"); pos = markpos; }

     public boolean markSupported() {
        return true;
        } //支持mark操作

      而FileInputStream没有重写父类InputStream的默认实现,其默认实现如下:

    //InputStream.java
      public synchronized void mark(int readlimit) {}//空实现什么都没有实现
    
    public synchronized void reset() throws IOException {
        throw new IOException("mark/reset not supported");
        }//不支持reset操作
    
     public boolean markSupported() {
        return false;
        } //不支持mark操作

        下面是一个简单的程序,用于设置reset和mark.

    import java.io.BufferedInputStream;
    import java.io.File;
    import java.io.FileInputStream;
    import java.io.IOException;
    import java.io.InputStream;


    public class TestInputStream {

    public void read(InputStream in) throws IOException {
    if(in == null) {
    return;
    }
    int len=0;
    in.mark(1);
    in.read() //第一次读取
    in.reset();//又可以重新读取

    in.read()//第二次读取跟第一次读取结果一样。因为只读了一个,没有超过mark设置的整数。所以mark有效

    }


    public static void main(String[] args) throws IOException {
    TestInputStream test = new TestInputStream();
    String fileName = "F:/Google.txt";
    InputStream in1 = new FileInputStream(new File(fileName));
    if(!in1.markSupported()) {
    in1 = new BufferedInputStream(in1);
    }
    test.read(in1);
    byte[] buf = new byte[100];
    while(in1.read(buf, 0, buf.length)!=-1) {
    System.out.println(buf);
    }

    System.out.println("Success!");
    }
    }

     总结:

     mark

            public void mark(int readlimit)

            mark 的常规协定是:如果方法 markSupported 返回 true,那么输入流总是在调用 mark 之后记录所有读取的字节,并时刻准备在调用方法 reset 时(无论何时),再次提供这些相同的字节。但是,如果在调用 reset 之前可以从流中读取多于 readlimit 的字节,则不需要该流记录任何数据。 

            参数:

            readlimit - 在标记位置失效前可以读取字节的最大限制。

    4 reset

    public void reset() throws IOException

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

             reset 的常规协定是: 

             1、如果方法 markSupported 返回 true,那么: 

             如果创建流以后未调用方法 mark,或最后调用 mark 以后从该流读取的字节数大于最后调用 mark 时的参数,则可能抛出 IOException。 

             如果未抛出这样的 IOException,则将该流重新设置为这种状态:最近一次调用 mark 以后(如果未调用过 mark,则从文件开头开始)读取的所有字节将重新提供给 read 方法的后续调用者,后跟任何从调用 reset 时起将作为下一输入数据的字节。 

            2、如果方法 markSupported 返回 false,那么: 

             对 reset 的调用可能抛出 IOException。 

             如果未抛出 IOException,则将该流重新设置为一种固定状态,该状态取决于输入流的特定类型及其创建方式。提供给 read 方法后续调用者的字节取决于特定类型的输入流。 

             除了抛出 IOException 之外,类 InputStream 的方法 reset 不执行任何操作。 

             抛出: 

               IOException - 如果未标记此流或该标记失效。

            

            

  • 相关阅读:
    51nod-1462: 树据结构
    51nod-1363: 最小公倍数之和
    jar包反编译
    js表格某列多行值相同进行行合并
    JS对象转URL参数
    json数组转字符串 前端与后端交互
    element-ui 表格数据根据某一列值相同进行行合并(包括序号列)并同列相同值进行合计
    ssh框架中联合查询所取结果不在单一实体,sql写法
    ajax异步获取数据后动态向构建表格并添加数据
    关于ajax中async: false的作用
  • 原文地址:https://www.cnblogs.com/chenfei0801/p/2994513.html
Copyright © 2011-2022 走看看