scala – Kryo：反序列化旧版本的类

这个问题的解决方案是几个月前发现的.所以我想尽快发布这个问题的答案.
问题在于,由于代码中的错误,该类被使用标准的Kryo FieldSerializer序列化,该标准不是向前兼容的.
我们必须执行以下操作来反序列化旧类并将其转换为新的序列化类.

情况是：

case class ClassA(field1 : Long,field2 : String)

它像这样序列化：

object ClassASerializer extends Serializer[ClassA] with Serializable{
  override def write(kryo: Kryo,output: Output,t: ClassA) = {
      output.writeLong    { t.field1 }
      output.writeString  { t.field2 }
 }
  override def read(kryo: Kryo,input: Input,aClass: Class[ClassA]) = 
       classA( 
           field1 = input.readLong(),field2 = input.readLong()
       )

并且循环包含要使用序列化程序序列化的类的Seq,以便为所有类注册所有序列化程序.

protected def registry: Seq[aClass: Class[A],serializer: Serializer[A]] = ...
    final def register(kryo: Kryo) = {
         registry.foreach { registrable => kryo.register(registrable.aClass,registrable.serializer) }
    }

需要通过添加新字段来修改该类,该字段是另一个案例类的实例.

为了执行此类更改,我们必须使用与Kryo库“可选”相关的注释,

...
import com.esotericsoftware.kryo.serializers.FieldSerializer.Optional
import scala.annotation.meta.field
...

case class ClassA(field1 : Long,field2 : String,@(Optional @field)("field3") field3 : ClassB)

序列化程序被修改,例如在读取旧的序列化类时,它可以使用默认值实例化field3,并且在写入时,写入这样的默认值：

object ClassASerializer extends Serializer[ClassA] with Serializable{
  override def write(kryo: Kryo,t: ClassA) = {
      output.writeLong    { t.field1 }
      output.writeString  { t.field2 }
      kryo.writeObject(output,Option { t.field3 } getOrElse ClassB.default,ClassBSerializer)

 }
  override def read(kryo: Kryo,aClass: Class[ClassA]) = 
       ClassA( 
           field1 = input.readLong(),field2 = input.readLong(),field3 = ClassB.default
       )

还修改了kryo序列化程序注册以注册可选字段：

protected def registry: Seq[aClass: Class[A],serializer: Serializer[A]] = ...
    def optionals = Seq("field3")

    final def register(kryo: Kryo) = {
        optionals.foreach { optional =>
        kryo.getContext.asInstanceOf[ObjectMap[Any,Any]].put(optional,true) }
        registry.foreach { registrable => kryo.register(registrable.aClass,registrable.serializer) }
    }

结果我们能够编写序列化类的新版本.
之后,我们必须删除可选的注释,修改序列化程序以便从新的序列化类中读取实际字段,并删除可选的序列化程序注册并将其添加到注册表Seq.

与此同时,我们纠正了通过FieldSerializer强制序列化的代码中的错误,但这不在问题的范围内.