Добавление к ObjectOutputStream

Вот в чем хитрость: подкласс ObjectOutputStream и переопределение метода writeStreamHeader:

public class AppendingObjectOutputStream extends ObjectOutputStream {

  public AppendingObjectOutputStream(OutputStream out) throws IOException {
    super(out);
  }

  @Override
  protected void writeStreamHeader() throws IOException {
    // do not write a header, but reset:
    // this line added after another question
    // showed a problem with the original
    reset();
  }

}

Чтобы использовать его, просто проверьте, существует ли файл истории, и создайте экземпляр либо этого присоединяемого потока (если файл существует = мы добавляем = нам не нужен заголовок), либо исходный поток (если файл не существует = нам нужен заголовок).

Изменить

Меня не устраивало первое название класса. Этот лучше: он описывает «для чего это нужно», а не «как это делается».

Изменить

Еще раз изменил имя, чтобы уточнить, что этот поток предназначен только для добавления к существующему файлу. Его нельзя использовать для создания нового файла с данными объекта.

Изменить

Добавлен вызов reset() после этот вопрос показал, что исходная версия, просто переопределил writeStreamHeader как неактивный, при некоторых условиях может создать поток, который невозможно прочитать.

Как API сообщает, что конструктор ObjectOutputStream записывает заголовок потока сериализации в базовый поток. И ожидается, что этот заголовок будет только один раз, в начале файла. Так зовет

new ObjectOutputStream(fos);

несколько раз в FileOutputStream, который ссылается на один и тот же файл, несколько раз запишет заголовок и повредит файл.

Из-за точного формата сериализованного файла добавление действительно испортит его. Вы должны записывать все объекты в файл как часть одного и того же потока, иначе произойдет сбой при чтении метаданных потока, когда он ожидает объект.

Дополнительные сведения см. в спецификации сериализации. или (проще) прочитать эту тему, где Роуди Грин говорит в основном то, что я только что сказал.

Самый простой способ избежать этой проблемы — держать OutputStream открытым при записи данных, а не закрывать его после каждого объекта. Вызов reset() может быть целесообразным, чтобы избежать утечки памяти.

Альтернативой может быть чтение файла как серии последовательных потоков ObjectInputStream. Но для этого требуется, чтобы вы подсчитывали, сколько байтов вы читаете (это можно реализовать с помощью FilterInputStream), затем закрываете InputStream, открываете его снова, пропускаете это количество байтов и только затем заключаете его в ObjectInputStream().

Я расширил принятое решение, чтобы создать класс, который можно использовать как для добавления, так и для создания нового файла.

import java.io.DataOutputStream;
import java.io.IOException;
import java.io.ObjectOutputStream;
import java.io.OutputStream;

public class AppendableObjectOutputStream extends ObjectOutputStream {

    private boolean append;
    private boolean initialized;
    private DataOutputStream dout;

    protected AppendableObjectOutputStream(boolean append) throws IOException, SecurityException {
        super();
        this.append = append;
        this.initialized = true;
    }

    public AppendableObjectOutputStream(OutputStream out, boolean append) throws IOException {
        super(out);
        this.append = append;
        this.initialized = true;
        this.dout = new DataOutputStream(out);
        this.writeStreamHeader();
    }

    @Override
    protected void writeStreamHeader() throws IOException {
        if (!this.initialized || this.append) return;
        if (dout != null) {
            dout.writeShort(STREAM_MAGIC);
            dout.writeShort(STREAM_VERSION);
        }
    }

}

Этот класс можно использовать как прямую расширенную замену ObjectOutputStream. Мы можем использовать класс следующим образом:

import java.io.File;
import java.io.FileNotFoundException;
import java.io.FileOutputStream;
import java.io.IOException;

public class ObjectWriter {

    public static void main(String[] args) {

        File file = new File("file.dat");
        boolean append = file.exists(); // if file exists then append, otherwise create new

        try (
            FileOutputStream fout = new FileOutputStream(file, append);
            AppendableObjectOutputStream oout = new AppendableObjectOutputStream(fout, append);
        ) {
            oout.writeObject(...); // replace "..." with serializable object to be written
        } catch (FileNotFoundException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        }

    }

}

Как насчет того, чтобы каждый раз, когда вы добавляете объект, читать и копировать все текущие данные в файл, а затем перезаписывать все вместе в файл.