我试图写一个外部合并排序,但似乎我不能为一个文件创建第二个DataInputStream,如果我已经关闭了第一个。例如:
public class test {
private static DataInputStream createInputStream(RandomAccessFile f)
throws FileNotFoundException, IOException {
return new DataInputStream(new BufferedInputStream(new FileInputStream(
f.getFD())));
}
private static int readInt(RandomAccessFile file) throws IOException{
DataInputStream istream = createInputStream(file);
int i = istream.readInt();
istream.close();
return i;
}
public static void main(String[] args) throws IOException{
RandomAccessFile file = new RandomAccessFile(args[0], "rw");
for(int j = 0; j < 10; j++){
System.out.println(readInt(file));
}
}
}
当我运行这个,我得到一个数字,但然后得到以下错误:
java.io.IOException: Stream Closed
at java.io.FileInputStream.readBytes(Native Method)
at java.io.FileInputStream.read(FileInputStream.java:255)
at java.io.BufferedInputStream.fill(BufferedInputStream.java:246)
at java.io.BufferedInputStream.read(BufferedInputStream.java:265)
at java.io.DataInputStream.readInt(DataInputStream.java:387)
at uk.ac.cam.av429.fjava.tick0.test.readInt(test.java:19)
at uk.ac.cam.av429.fjava.tick0.test.main(test.java:26)
我如何为一个文件创建多个独立的流,或者我必须使用一个?
异常消息有点误导。在所有可能的情况下,问题是当您关闭第一个流时,它会导致底层RandomAccessFile
被关闭——或者至少是它的底层本地资源被关闭。
或者,也有可能第一个流消耗从RAF当前位置到其结束的所有数据,因此没有什么可读的。它会这样做,因为您将BufferedInputStream
插入到流的巢中—BIS应该预期提前读取以填充其缓冲区,当您关闭它时,缓冲的数据将丢失。
无论如何,你不应该这样做。每次创建一个流并重用它,而不是创建一个新的流。只需读取来自同一流的每个后续数据块。