java - 如何避免java.io.StreamCorruptedException？

我有一种将数据从列表写入文件的方法，一种将数据从文件读取到列表的方法，以及一种将文件中的列表数据写入指定次数的方法。我尝试使用第一种方法writeFile ()从文件中提取数据后，一切正常。我通过readFile ()方法将文件中的数据读取到列表中。之后，我使用我的方法将所需次数写入文件，一切都很好，它写入multyWrite ()。但是在那之后，我无法从readFile ()方法的文件中读取数据，因为我得到了`

异常堆栈跟踪:

 Exception in thread "main" java.io.StreamCorruptedException: invalid type code: AC
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1599)
at java.io.ObjectInputStream.readObject(ObjectInputStream.java:431)
at ProductService.readFile(ProductService.java:47)
at Main.main(Main.java:21)

我知道我应该使用objectOutputStream.reset ()，但是在哪里使用会更好呢？

private String fileName;
    private ProductInterface<FlyingMachine> productService = new ProductInterfaceImpl();
    private ObjectOutputStream objectOutputStream;
    private FileOutputStream fileOutputStream;


    public ProductService(String fileName) throws IOException {
        this.fileName = fileName;
        fileOutputStream = new FileOutputStream(fileName);
        this.objectOutputStream = new ObjectOutputStream(fileOutputStream);
    }

public void writeFile() throws IOException {
        try {
            for (FlyingMachine f : productService.getProductContainer()) {
                objectOutputStream.writeObject(f);
            }
        } catch (IOException e) {
            e.printStackTrace();
        } finally {
            if (objectOutputStream != null) {
                objectOutputStream.flush();
                objectOutputStream.close();
                fileOutputStream.close();
            }
        }
    }`

public void readFile() throws IOException {
        ObjectInputStream objectInputStream = null;
        FileInputStream fileInputStream = null;
        try {
            fileInputStream = new FileInputStream(fileName);
            objectInputStream = new ObjectInputStream(fileInputStream);
            while (fileInputStream.available() > 0) {
                FlyingMachine flyingMachine = (FlyingMachine) objectInputStream.readObject();
                productService.getProductContainer().add(flyingMachine);
            }
        } catch (ClassNotFoundException | EOFException e) {
            e.printStackTrace();
        } finally {
            if (objectInputStream != null) {
                objectInputStream.close();
                fileInputStream.close();
            }
        }
    }

public void multyWrite(int number) throws IOException {
        for (int i = 0; i < number; i++) {
            try {
                fileOutputStream = new FileOutputStream(fileName, true);
                objectOutputStream = new ObjectOutputStream(fileOutputStream);
                for (FlyingMachine f : productService.getProductContainer()) {
                    objectOutputStream.writeObject(f);
                }
            } catch (IOException e) {
                e.printStackTrace();
            } finally {
                if (objectOutputStream != null) {
                    objectOutputStream.flush();
                    objectOutputStream.close();
                }
            }
        }
    }

最佳答案

您在构造函数中创建一个新的ObjectOutputStream。在writeFile中，您使用该OOS实例并将其关闭。但是在multyWrite中，您不用它，而是创建新实例。

现在，当您在没有先调用multyWrite的情况下调用writeFile时，第一个OOS仍将处于打开状态，但是您在OOS中创建的multyWrite却不知道-从而使文件具有两个OOS标头。

然后，当您尝试读取这样的文件时，ObjectInputStream将找到第一个标头(一切都很好)，然后意外地找到第二个标头，而它期望输入一个类型代码。该标头以0xAC开头，因此引发异常消息“无效的类型代码:AC”。

要解决此问题，请让multyWrite使用构造函数中构造的OOS，与writeFile一样，或者在创建新的OOS之前将其关闭。

在构造函数中打开(任何类型的)流，然后依靠外部代码调用特定方法来关闭它通常不是一个好主意。更好地在需要时创建流并直接将其关闭。