我试图从文档中了解以下声明:

如果该对象的具体类未知,则该对象可以为null:


  kryo.writeClassAndObject(输出,对象);
  
  对象object = kryo.readClassAndObject(input);


如果具体类不清楚,该怎么办。

我有以下代码:

case class RawData(modelName: String,
                   sourceType: String,
                   deNormalizedVal: String,
                   normalVal: Map[String, String])

object KryoSpike extends App {


  val kryo = new Kryo()
  kryo.setRegistrationRequired(false)
  kryo.addDefaultSerializer(classOf[scala.collection.Map[_,_]], classOf[ScalaImmutableAbstractMapSerializer])
  kryo.addDefaultSerializer(classOf[scala.collection.generic.MapFactory[scala.collection.Map]], classOf[ScalaImmutableAbstractMapSerializer])
  kryo.addDefaultSerializer(classOf[RawData], classOf[ScalaProductSerializer])

  //val testin = Map("id" -> "objID", "field1" -> "field1Value")
  val testin = RawData("model1", "Json", "", Map("field1" -> "value1", "field2" -> "value2") )

  val outStream = new ByteArrayOutputStream()
  val output = new Output(outStream, 20480)
  kryo.writeClassAndObject(output, testin)
  output.close()


  val input = new Input(new ByteArrayInputStream(outStream.toByteArray), 4096)
  val testout = kryo.readClassAndObject(input)
  input.close()
  println(testout.toString)

}


当我使用readClassAndObject和writeClassAndObject是可行的。但是,如果我使用writeObject和readObject,则不会。


  线程“主要” com.esotericsoftware.kryo.KryoException中的异常:
  无法创建类(缺少no-arg构造函数):
  com.romix.scala.serialization.kryo.ScalaProductSerializer


我只是不明白为什么。

之前使用相同的代码,而不是使用我的类RawData,而是使用Map,它与writeObject和ReadObject一样具有吸引力。因此,我感到困惑。

有人可以帮助理解吗?

最佳答案

区别如下:


使用序列化程序时使用writeClassAndObjectreadClassAndObject


序列化基本类型:接口,具有子类的类,或者-如果是Scala,则使用Product之类的特征,
并且需要反序列化对象的类型(即Class对象)来构造该对象(如果没有此类型,则不知道要构造什么),
例如:ScalaProductSerializer

使用序列化程序时使用writeObjectreadObject


完全序列化一种类型(即可以实例化的类;例如:EnumSetSerializer),
或序列化不止一种类型,但是可以从序列化数据中以某种方式推断出特定类型(例如:ScalaImmutableAbstractMapSerializer





总结一下您的具体情况:


反序列化RawData时:


ScalaProductSerializer需要找出Product的确切类型来创建实例,
因此它使用typ: Class[Product]参数来执行此操作,
结果,只有readClassAndObject起作用。

当您反序列化Scala不可变映射(作为scala.collection.immutable.Map导入的IMap)时:


ScalaImmutableAbstractMapSerializer不需要找出确切的类型-它使用IMap.empty创建实例,
结果,它不使用typ: Class[IMap[_, _]]参数,
结果,readObjectreadClassAndObject均起作用。

10-06 05:57