Ошибка файловой операции с ObjectOutputStream / ObjectInputStream - PullRequest
0 голосов
/ 13 января 2019

Я пытаюсь записать пару объектов, используя ObjectOutputStream в файл. После этого я читаю файл с ObjectInputStream. Проблема в том, что я могу прочитать только первый объект в файле. Когда я открыл файл с помощью notepad ++, я вижу записи для других объектов.

Здесь писатель часть

public class FileProcess {
    private ObjectOutputStream output;
    private Accounts account;
    public FileProcess() {}

    public void WriteObject(Accounts account) {
        this.account = account;
        openFile();
        addRecords();
        closeFile();

    }

    private void openFile() {
        try {
            output = new ObjectOutputStream(Files.newOutputStream(Paths.get("record_files.txt"),CREATE,APPEND));
        }catch (Exception e) {
            System.out.println("\nError opening file");
        }
    }
    private void addRecords() {
        try {
            output.writeObject(account);
        }
        catch (Exception e) {
            System.out.printf("Error writing file %s",e);
        }
    }

    private void closeFile() {
        try {
            if(output != null)
                output.close();
        } catch (Exception e) {
            System.out.println("\nError closing file");
        }
    }
}

и считыватель часть

abstract class User {
    private String userID;
    private int password;
    private String position;
    private ObjectInputStream input;

    public User(String userID, int password, String position) {
        this.userID = userID;
        this.password = password;
        this.position = position;
    }


     boolean signIn() {

        boolean found_check = false;
        openFile();
        found_check = checkRecords();
        closeFile();
        return found_check;
    }

    private void closeFile() {
        try {

            if(input != null)
                input.close();

        } catch (Exception e) {
            System.out.println("Error closing file");
        }

    }


    private boolean checkRecords() {
        try {
            while(true) {
                Accounts account = (Accounts) input.readObject();
                System.out.printf("%s %d %s",account.getUserID(),account.getPassword(),account.getPosition());
            }
        }
        catch (Exception e) {
            System.out.println("\nError reading file");
            return false;
        }
        return false;
    }


    private void openFile() {
        try {
            input = new ObjectInputStream(Files.newInputStream(Paths.get("record_files.txt")));

        }catch (Exception e) {
            System.out.println("Error opening file");
        }
    }
}

Класс учетных записей реализует Сериализуемый

public class Accounts implements Serializable {

    private String userID;
    private int password;
    private String position;

    public Accounts(String userID, int password, String position) {
        try {

            this.userID = userID;
            this.password = password;
            this.position = position;
        }
        catch (Exception e) {
            System.out.printf(e.toString());
        }
    }
}

1 Ответ

0 голосов
/ 13 января 2019

Ваш код выдает следующее исключение: java.io.StreamCorruptedException: invalid type code: AC.
Хороший вопрос и ответ здесь

Это было обнаружено добавлением e.printStackTrace(); к обработчику исключений в User.checkRecords.

...