如何通过序列化实现邮件对象的文件追加存储？

问题描述 #

我查阅了大量关于序列化的资料，但始终未能找到问题的解决方案。我正在开发一款邮件客户端程序，希望将每一封发送的邮件以对象形式存储到文件中，并且后续能够读取这些对象。我遇到的问题是：每次使用ObjectOutputStream的writeObject()方法时，文件会被截断而非追加内容。于是我尝试将邮件对象存入ArrayList，再将整个ArrayList写入文件——每次存储时先通过readObject()读取文件中的ArrayList，添加新邮件后重新写入文件，但这种方法抛出了诸多异常（如InvalidClassException）。请问是否有办法实现序列化对象的追加存储，或者其他可行的解决办法？

提供的EmailMessage类代码 #

public class EmailMessage implements Serializable{//implement serializables
    private String recipient;
    private String subject;
    private String content;
    private String date;

    public void setRecipient(String recipient)
    {
        this.recipient=recipient;
    }
    
    public String getRecipient()
    {
        return this.recipient;
    }
    
    public void setSubject(String subject){
        this.subject=subject;
    }

    public void setContent(String content){
        this.content=content;
    }

    public String getSubject(){
        return this.subject;
    }
    
    public String getContent(){
        return this.content;
    }

    public void setDate(String date)
    {
        this.date=date;
    }

    public String getDate()
    {
        return this.date;
    }

    public String printDetails()
    {
        String details="Recipient: "+getRecipient()+
                        "\nSubject: "+getSubject()+
                        "\nEmail content: "+getContent()+
                        "\nDate Sent: "+getDate(); 
        return details;
    }
}

一、正确实现序列化对象的追加写入 #

直接用FileOutputStream的追加模式打开文件，但要避免重复写入序列化流头部（这是导致读取失败的核心原因）。具体实现：

• 首次写入时正常创建ObjectOutputStream，写入头部
• 后续追加时，重写writeStreamHeader()方法跳过头部写入

// 追加单个邮件对象到文件
public static void appendEmail(EmailMessage email) throws IOException {
    File file = new File("emails.ser");
    boolean isExistingFile = file.exists() && file.length() > 0;

    try (FileOutputStream fos = new FileOutputStream(file, true);
         ObjectOutputStream oos = isExistingFile ? new ObjectOutputStream(fos) {
             @Override
             protected void writeStreamHeader() throws IOException {
                 reset(); // 跳过流头部写入
             }
         } : new ObjectOutputStream(fos)) {
        oos.writeObject(email);
    }
}

// 读取文件中所有邮件对象
public static List<EmailMessage> readAllEmails() throws IOException, ClassNotFoundException {
    List<EmailMessage> emails = new ArrayList<>();
    try (FileInputStream fis = new FileInputStream("emails.ser");
         ObjectInputStream ois = new ObjectInputStream(fis)) {
        while (true) {
            try {
                emails.add((EmailMessage) ois.readObject());
            } catch (EOFException e) {
                break; // 读取到文件末尾，终止循环
            }
        }
    }
    return emails;
}

二、修复ArrayList存储方案的异常 #

你遇到的InvalidClassException大多是因为类的序列化UID不一致，或是文件中存储的对象与当前类结构不兼容。解决步骤：

1. 给EmailMessage显式声明序列化UID，避免类结构微调导致异常：

public class EmailMessage implements Serializable{
    private static final long serialVersionUID = 1L; // 显式添加序列化UID
    
    // 原有属性和方法不变...
}

2. 修正读写逻辑，确保文件状态正常时才读取：

// 读取现有邮件列表并添加新邮件后重写
public static void saveEmailToList(EmailMessage newEmail) throws IOException, ClassNotFoundException {
    List<EmailMessage> emails = new ArrayList<>();
    File file = new File("emails_list.ser");

    if (file.exists() && file.length() > 0) {
        try (ObjectInputStream ois = new ObjectInputStream(new FileInputStream(file))) {
            emails = (List<EmailMessage>) ois.readObject();
        }
    }

    emails.add(newEmail);
    try (ObjectOutputStream oos = new ObjectOutputStream(new FileOutputStream(file))) {
        oos.writeObject(emails);
    }
}

三、更易用的替代方案 #

如果序列化的兼容性问题难以调试，可以考虑以下更灵活的存储方式：

1. JSON序列化（推荐） #

用Gson或Jackson将对象转为JSON字符串，每行存储一个邮件，追加和读取都更直观：

// 用Gson追加写入JSON格式邮件
public static void appendEmailJson(EmailMessage email) throws IOException {
    Gson gson = new Gson();
    try (FileWriter writer = new FileWriter("emails.json", true)) {
        writer.write(gson.toJson(email) + "\n");
    }
}

// 读取所有JSON格式邮件
public static List<EmailMessage> readAllEmailsJson() throws IOException {
    List<EmailMessage> emails = new ArrayList<>();
    Gson gson = new Gson();
    try (BufferedReader reader = new BufferedReader(new FileReader("emails.json"))) {
        String line;
        while ((line = reader.readLine()) != null) {
            emails.add(gson.fromJson(line, EmailMessage.class));
        }
    }
    return emails;
}

2. 小型数据库 #

使用SQLite等轻量数据库存储邮件数据，支持查询、修改等操作，比文件存储更稳定可靠。

内容的提问来源于stack exchange，提问作者scout