2

我的文件的写入过程如下(在我称之为非集群的模式下)

  1. 将对象写入文件的当前位置。注意在另一个文件(称为索引文件)中写入的位置,以便我知道我将对象放在哪里。
  2. 通过写入零字节留出一些空间(随机 1/2/3/4 KB 的空间)
  3. 重复步骤 1 和 2

现在我决定从文件中读取对象。但我想用BufferedInputStream. 但是,当我将 a 封装BufferedInputStream在 ObjectInputStream 中时,在读取一些对象后会出现错误。我猜这发生一次缓冲读取之后(即,缓冲区中可以容纳的尽可能多的对象被读取一次,下次我收到错误时)。

另一方面,将 aFileInputStream直接封装在ObjectInputStream作品中没有任何问题。

如果需要,我也会提供文件编写代码。随意询问有关以下代码的任何内容。

public class RecordsFileReader {
    RecordsFile rFile;
    Iterator itr;
    FileInputStream fis;
    ObjectInputStream ois;

// The constructor
public RecordsFileReader(RecordsFile rFile) throws IOException, ClassNotFoundException {
    this.rFile = rFile;
    fis = new FileInputStream(rFile.getFileName());


    ObjectInputStream ois2 = new ObjectInputStream(new FileInputStream(rFile.getFileName() + ".index"));



    rFile.recordsLocationList =  (ArrayList <Long>) ois2.readObject();
    itr = rFile.recordsLocationList.iterator();
   /**********************************************************/
   /*          HERE IS THE PROBLEM.                          */
   /* Doesnt work when I additionally use BufferedInputStream*/
   /**********************************************************/

    ois = new ObjectInputStream(fis);

   /**********************************************************/     
}

public Tuple readNext() throws IOException, ClassNotFoundException {
    if(!itr.hasNext())
        return null;
    Long nextRecordPosition = itr.next();
    fis.getChannel().position(nextRecordPosition);
    //System.out.println((Tuple) ois.readObject());
    return ((Tuple) ois.readObject());
}

public void close() throws IOException {
    ois.close();
    fis.close();



}

public boolean hasNext() {
    return itr.hasNext();

}

}

public class RecordsFile {

boolean clustered;
private String fileName;

public RecordsFile(String fileName, boolean clustered) throws IOException {
    this.fileName = fileName;
    this.clustered = clustered;
}

/*
The byte positions at which the records are located in the file.
*/
ArrayList<Long> recordsLocationList= new ArrayList<Long>();

public String getFileName() {
    return fileName;
}

}

这是导致错误的更改: ois = new ObjectInputStream(new BufferedInputStream(fis, 4096));而不是ois = new ObjectInputStream(fis);

错误是java.io.StreamCorruptionException: invalid type code : 00

编辑 :

我现在已经弄清楚了问题所在。当我的 fis 被定位到一个新位置时,我的 bis 没有被跳到那个新位置。相反,bis 试图仅从旧位置读取,因此例外

4

1 回答 1

2

这表明从流(和从文件)读回的字节被解释为对象(由 OIS)但实际上这些字节是其他东西(不是实际对象的字节表示)。这可能是因为明确指定了缓冲区大小(结合您手动设置位置的事实)。

我建议尝试不明确指定缓冲区大小。

ois = new ObjectInputStream(new BufferedInputStream(fis))

于 2011-09-14T21:33:23.487 回答