我正在尝试编写外部合并排序,但是,如果我已经关闭了第一个DataInputStream,似乎无法为其创建第二个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提前读取以填充其缓冲区,并且当您关闭它时,缓冲的数据将丢失。

无论如何,您都不应该这样处理。不必每次都创建一个新的流,而是创建一个流并重新使用它。只需从同一流中读取每个后续​​数据即可。

关于java - Java DataInputStream范围,我们在Stack Overflow上找到一个类似的问题:https://stackoverflow.com/questions/32851791/

10-11 05:02