修复数据库反序列化 StreamCorruptedException 问题指南

java

2024-03-16 13:58:59

从数据库表反序列化对象时 StreamCorruptedException 问题的解决指南

当从数据库表中读取序列化对象时，您可能会遇到带有消息“无效流头：EFBFBDEF”的 StreamCorruptedException。本指南将深入探讨此问题的原因及其有效的解决方案，帮助您顺利反序列化数据。

问题

StreamCorruptedException 通常是由于流中包含损坏或格式错误的数据造成的。在反序列化从数据库中检索到的数据时，您可能会遇到此问题。

解决方案

解决 StreamCorruptedException 问题需要多管齐下：

检查写入流的数据： 确保写入流的数据正确序列化，不包含任何无效或损坏的数据。
检查读取流的数据： 验证读取流的数据是否完整且未损坏。
检查流的打开和关闭： 流应在使用前正确打开，使用后正确关闭。

深入剖析

除了这些基本步骤，以下内容还将提供更深入的指导：

确保使用的 ObjectInputStream 版本与序列化数据相匹配。
考虑使用 ObjectOutputStream.writeObject() 方法的重载版本，它接受 OutputStream 参数而不是 ByteArrayOutputStream。
尝试使用其他反序列化库，例如 Jackson 或 Gson。

示例代码

下面是更新的 ClientDetailsMapper 和 addClient 方法示例：

// ClientDetailsMapper
@SneakyThrows
@Override
public ClientDetails mapRow(ResultSet rs, int rowNum) {
    byte[] temp = rs.getBytes("SERIALIZATION");
    return (ClientDetails) new ObjectInputStream(new ByteArrayInputStream(temp)).readObject();
}

// addClient
public boolean addClient(ClientDetails details) throws DataAccessException {
    ByteArrayOutputStream outBytes = new ByteArrayOutputStream();
    try (ObjectOutputStream outObject = new ObjectOutputStream(outBytes)) {
        outObject.writeObject(details);
        outObject.flush();
    }
    byte[] szDetails = outBytes.toByteArray();
    dataTemplate.update("INSERT INTO OAUTH_CLIENTS (CLIENTID, PROTOCOL, SERIALIZATION) VALUES(?,1,?)",
            new Object[]{details.getClientId(), szDetails});
    return false;
}