Java如何从LevelDB读取数据存入Map并转回自定义对象

错误根因 #

该类型转换报错的核心原因是LevelDB中对应键存储的值并非你序列化后的MyObject字节数组，而是String类型的序列化结果，因此反序列化得到的对象是String实例，自然无法强转为MyObject。

排查方向 #

• 检查写入逻辑执行路径：确认执行myLevelDb().put(bytes((publicKey)), Serializer.serialize(myObject));前，没有其他代码误将同一个publicKey对应的值写入为字符串类型的序列化结果。LevelDB支持键覆盖写入，如果先写入了字符串值、后续MyObject写入逻辑未正常执行，读取时就会拿到String类型的反序列化结果。
• 校验序列化入参类型：写入前打印myObject的实际类型，确认传入序列化方法的是MyObject实例而非字符串。
• 检查键转换逻辑：确认bytes(publicKey)方法返回的字节数组符合预期，如果键转换逻辑异常，可能会读取到其他写入逻辑存入的字符串值。
• 验证序列化方法执行结果：你当前的serialize方法抛出异常时仅打印堆栈并返回null，如果序列化过程触发IO异常，实际存入LevelDB的可能是空值或其他默认写入的字符串值。

修复方案 #

临时排查代码

在反序列化前增加类型打印，确认值的来源：

Object obj = Serializer.deserialize(next.getValue());
System.out.println("反序列化结果类型：" + obj.getClass().getName());
System.out.println("反序列化结果内容：" + obj);

根据打印出的字符串内容，可以反向追溯是哪段逻辑写入了脏数据。

代码优化

1. 给反序列化方法增加类型校验，避免隐式转换问题：

public static <T> T deserialize(byte[] bytes, Class<T> clazz) throws ClassCastException {
    Object obj = deserialize(bytes);
    if (obj == null) {
        return null;
    }
    if (!clazz.isInstance(obj)) {
        throw new ClassCastException("反序列化结果类型为" + obj.getClass().getName() + "，无法转换为" + clazz.getName());
    }
    return clazz.cast(obj);
}

调用方式修改为：

MyObject myObject = Serializer.deserialize(next.getValue(), MyObject.class);

2. 写入前增加非空校验，避免写入脏数据：

byte[] value = Serializer.serialize(myObject);
if (value != null) {
    myLevelDb().put(bytes(publicKey), value);
} else {
    // 自定义序列化失败的处理逻辑
    throw new RuntimeException("MyObject序列化失败");
}

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