java - 使用 readClassDescriptor() 和 resolveClass() 允许序列化版本控制

Question

我正在研究 Java 序列化机制中的不同选项，以便在我们的类结构中实现版本容错存储的灵 active (并提倡不同的机制，你不需要告诉我)。

例如，如果只需要向后兼容，默认的序列化机制可以处理添加和删除字段。

不过，事实证明，重命名类或将其移动到不同的包要困难得多。我在 this question 中找到我能够通过子类化 ObjectInputStream 并覆盖 readClassDescriptor() 来做一个简单的类重命名和/或移动包:

    if (resultClassDescriptor.getName().equals("package.OldClass"))
        resultClassDescriptor = ObjectStreamClass.lookup(newpackage.NewClass.class);

这对于简单的重命名来说很好。但是，如果您随后尝试添加或删除一个字段，则会出现 java.io.StreamCorruptedException。更糟糕的是，即使添加或删除了一个字段，也会发生这种情况，然后您重命名了该类，这可能会导致多个开发人员或多个 checkin 出现问题。

根据我所做的一些阅读，我尝试了一些重写 resolveClass() 的想法，我们正确地将名称重新指向新类，但不加载旧类本身并轰炸字段更改.但这是对序列化机制的一些细节的非常模糊的理解，我什至不确定我是否在咆哮正确的树。

所以 2 个精确的问题:

1. 为什么使用 readClassDescriptor() 重新指向类名导致 反序列化在正常的、兼容的类更改时失败？
2. 有没有办法使用 resolveClass() 或其他机制绕过 这并允许类进化(添加和删除字段)并成为 重命名/重新包装？

我四处寻找，找不到关于 SO 的等效问题。无论如何，如果存在这样的问题，请指出我，但请仔细阅读该问题，除非另一个问题确实回答了我的确切问题，否则您不要关闭我。

Answer 1

我和你一样在灵 active 方面遇到了同样的问题，但我找到了解决之道。 所以这里是我的 readClassDescriptor() 版本

    static class HackedObjectInputStream extends ObjectInputStream
{

    /**
     * Migration table. Holds old to new classes representation.
     */
    private static final Map<String, Class<?>> MIGRATION_MAP = new HashMap<String, Class<?>>();

    static
    {
        MIGRATION_MAP.put("DBOBHandler", com.foo.valueobjects.BoardHandler.class);
        MIGRATION_MAP.put("DBEndHandler", com.foo.valueobjects.EndHandler.class);
        MIGRATION_MAP.put("DBStartHandler", com.foo.valueobjects.StartHandler.class);
    }

    /**
     * Constructor.
     * @param stream input stream
     * @throws IOException if io error
     */
    public HackedObjectInputStream(final InputStream stream) throws IOException
    {
        super(stream);
    }

    @Override
    protected ObjectStreamClass readClassDescriptor() throws IOException, ClassNotFoundException
    {
        ObjectStreamClass resultClassDescriptor = super.readClassDescriptor();

        for (final String oldName : MIGRATION_MAP.keySet())
        {
            if (resultClassDescriptor.getName().equals(oldName))
            {
                String replacement = MIGRATION_MAP.get(oldName).getName();

                try
                {
                    Field f = resultClassDescriptor.getClass().getDeclaredField("name");
                    f.setAccessible(true);
                    f.set(resultClassDescriptor, replacement);
                }
                catch (Exception e)
                {
                    LOGGER.severe("Error while replacing class name." + e.getMessage());
                }

            }
        }

        return resultClassDescriptor;
    }