Ответ 1

Я бы использовал подход с несколькими классами.

(Переименование пакетов также будет работать.Это кажется уродливым, но это одноразовый взломать, поэтому красота и правильность могут занять место. Промежуточная сериализация кажется рискованной - есть причина, по которой вы используете Kryo, и эта причина будет отрицаться с помощью другой промежуточной формы).

Общая конструкция:

child classloaders:      Old Kryo     New Kryo   <-- both with simple wrappers
                                \       /
                                 \     /
                                  \   /
                                   \ /
                                    |
default classloader:    domain model; controller for the re-serialization

• Загрузите классы объектов домена в загрузчик классов по умолчанию

• Загрузите Jar с модифицированной версией Kryo и кодом оболочки. Оболочка имеет статический "основной" метод с одним аргументом: имя файла для десериализации. Вызовите основной метод с помощью отражения от загрузчика классов по умолчанию:

      Class deserializer = deserializerClassLoader.loadClass("com.example.deserializer.Main");
      Method mainIn = deserializer.getMethod("main", String.class);
      Object graph = mainIn.invoke(null, "/path/to/input/file");
  

  • Этот метод:
    • десериализует файл как один граф объектов
    • Помещает объект в разделяемое пространство. ThreadLocal является простым способом или возвращает его в оболочку script.

• Когда вызов возвращается, загрузите второй Jar с новой структурой сериализации с помощью простой оболочки. Обертка имеет статический "основной" метод и аргумент для передачи имени файла для сериализации. Вызовите основной метод с помощью отражения от загрузчика классов по умолчанию:

      Class serializer = deserializerClassLoader.loadClass("com.example.serializer.Main");
      Method mainOut = deserializer.getMethod("main", Object.class, String.class);
      mainOut.invoke(null, graph, "/path/to/output/file");
  

  • Этот метод
    • Извлекает объект из ThreadLocal
    • Сериализует объект и записывает его в файл

Вопросы

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

for (String file: files) {
    Object graph = mainIn.invoke(null, file + ".in");
    mainOut.invoke(null, graph, file + ".out");
}

Имеют ли объекты домена какие-либо ссылки на любой класс Kryo? Если это так, у вас есть трудности:

• Если ссылка является просто ссылкой на класс, например, для вызова метода, то первое использование класса будет загружать одну из двух версий Kryo в загрузчик классов по умолчанию. Вероятно, это вызовет проблемы, поскольку часть сериализации или десериализации может быть выполнена неверной версией Kryo
• Если эта ссылка используется для создания экземпляров любых объектов Kryo и хранения ссылки в модели домена (члены класса или экземпляра), тогда Kryo фактически будет сериализовать часть себя в модели. Это может быть срабатывание для этого подхода.

В любом случае ваш первый подход должен состоять в том, чтобы изучить эти ссылки и устранить их. Один из подходов к обеспечению того, что вы сделали это, - обеспечить, чтобы загрузчик по умолчанию не имел доступа к какой-либо версии Kryo. Если объекты домена ссылаются на Kryo каким-либо образом, ссылка не сработает (с ClassNotFoundError, если класс ссылается напрямую или ClassNotFoundException, если используется отражение).

Ответ 2

Для 2 вы можете создать два файла jar, которые содержат сериализатор и все зависимости для новых и старых версий вашего сериализатора, как показано здесь. Затем создайте задачу уменьшения карты, которая загружает каждую версию вашего кода в отдельный загрузчик классов, и добавьте некоторый код клея в середине, который десериализуется со старым кодом, а затем сериализуется с новым кодом.

Вам нужно быть осторожным, чтобы ваш объект домена загружался в тот же загрузчик классов, что и ваш код, и код для сериализации/десериализации зависит от того же загрузчика классов, что и ваш код, так что они оба видят один и тот же домен класс объекта.

Ответ 3

Самый простой способ, с помощью которого я мог бы придумать, - это использовать дополнительное приложение Java для преобразования. Таким образом, вы отправляете двоичные данные во вторичное Java-приложение (простые локальные сокеты будут делать трюк красиво), поэтому вам не придется возиться с загрузчиками классов или пакетами.

Единственное, о чем нужно подумать, - это промежуточное представление. Возможно, вы захотите использовать другой механизм сериализации или если время не является проблемой, вы можете использовать внутреннюю сериализацию Java.

Использование второго приложения Java избавляет вас от работы с временным хранилищем и делает все в памяти.

И как только у вас есть эти сокеты + второй код приложения, вы найдете множество ситуаций, когда это удобно.

Также можно построить локальный кластер с помощью jGroups и сохранить все проблемы с сокетами. jGroups - это самый простой коммуникационный API, который я знаю. Просто сформируйте логический канал и проверьте, кто присоединяется. И лучше всего это работает даже в одном JVM, что упрощает тестирование, и если удалено, можно связать другой физический сервер вместе так же, как и для локальных приложений.

Другой альтернативной альтернативой является использование ZeroMQ с протоколом ipc (inter process communication).